com.facebook.presto.plugin.jdbc

Class JdbcConnector

java.lang.Object

com.facebook.presto.plugin.jdbc.JdbcConnector

All Implemented Interfaces:

Connector

public class JdbcConnector
extends Object
implements Connector

Constructor Summary

Constructors

Constructor and Description
JdbcConnector(io.airlift.bootstrap.LifeCycleManager lifeCycleManager, JdbcMetadataFactory jdbcMetadataFactory, JdbcSplitManager jdbcSplitManager, JdbcRecordSetProvider jdbcRecordSetProvider, JdbcPageSinkProvider jdbcPageSinkProvider, Optional<ConnectorAccessControl> accessControl, Set<Procedure> procedures)

Method Summary

Modifier and Type	Method and Description
ConnectorTransactionHandle	beginTransaction(IsolationLevel isolationLevel, boolean readOnly)
void	commit(ConnectorTransactionHandle transaction)
ConnectorAccessControl	getAccessControl()
Set<ConnectorCapabilities>	getCapabilities()
ConnectorMetadata	getMetadata(ConnectorTransactionHandle transaction)
ConnectorPageSinkProvider	getPageSinkProvider()
Set<Procedure>	getProcedures()
ConnectorRecordSetProvider	getRecordSetProvider()
ConnectorSplitManager	getSplitManager()
boolean	isSingleStatementWritesOnly()
void	rollback(ConnectorTransactionHandle transaction)
void	shutdown()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.facebook.presto.spi.connector.Connector

getAnalyzeProperties, getColumnProperties, getIndexProvider, getNodePartitioningProvider, getPageSourceProvider, getSchemaProperties, getSessionProperties, getSystemTables, getTableProperties

Constructor Detail

JdbcConnector

@Inject
public JdbcConnector(io.airlift.bootstrap.LifeCycleManager lifeCycleManager,
                             JdbcMetadataFactory jdbcMetadataFactory,
                             JdbcSplitManager jdbcSplitManager,
                             JdbcRecordSetProvider jdbcRecordSetProvider,
                             JdbcPageSinkProvider jdbcPageSinkProvider,
                             Optional<ConnectorAccessControl> accessControl,
                             Set<Procedure> procedures)

Method Detail

isSingleStatementWritesOnly

public boolean isSingleStatementWritesOnly()

Specified by:

isSingleStatementWritesOnly in interface Connector

beginTransaction

public ConnectorTransactionHandle beginTransaction(IsolationLevel isolationLevel,
                                                   boolean readOnly)

Specified by:

beginTransaction in interface Connector

getMetadata

public ConnectorMetadata getMetadata(ConnectorTransactionHandle transaction)

Specified by:

getMetadata in interface Connector

commit

public void commit(ConnectorTransactionHandle transaction)

Specified by:

commit in interface Connector

rollback

public void rollback(ConnectorTransactionHandle transaction)

Specified by:

rollback in interface Connector

getSplitManager

public ConnectorSplitManager getSplitManager()

Specified by:

getSplitManager in interface Connector

getRecordSetProvider

public ConnectorRecordSetProvider getRecordSetProvider()

Specified by:

getRecordSetProvider in interface Connector

getPageSinkProvider

public ConnectorPageSinkProvider getPageSinkProvider()

Specified by:

getPageSinkProvider in interface Connector

getAccessControl

public ConnectorAccessControl getAccessControl()

Specified by:

getAccessControl in interface Connector

getProcedures

public Set<Procedure> getProcedures()

Specified by:

getProcedures in interface Connector

shutdown

public final void shutdown()

Specified by:

shutdown in interface Connector

getCapabilities

public Set<ConnectorCapabilities> getCapabilities()

Specified by:

getCapabilities in interface Connector