com.facebook.presto.plugin.jdbc

Class BaseJdbcClient

java.lang.Object

com.facebook.presto.plugin.jdbc.BaseJdbcClient

All Implemented Interfaces:

JdbcClient

public class BaseJdbcClient
extends Object
implements JdbcClient

Field Summary

Fields

Modifier and Type	Field and Description
protected ConnectionFactory	connectionFactory
protected String	connectorId
protected String	identifierQuote

Constructor Summary

Constructors

Constructor and Description
BaseJdbcClient(JdbcConnectorId connectorId, BaseJdbcConfig config, String identifierQuote, ConnectionFactory connectionFactory)

Method Summary

Modifier and Type	Method and Description
void	addColumn(JdbcTableHandle handle, ColumnMetadata column)
JdbcOutputTableHandle	beginCreateTable(ConnectorTableMetadata tableMetadata)
JdbcOutputTableHandle	beginInsertTable(ConnectorTableMetadata tableMetadata)
String	buildInsertSql(JdbcOutputTableHandle handle)
PreparedStatement	buildSql(Connection connection, JdbcSplit split, List<JdbcColumnHandle> columnHandles)
void	commitCreateTable(JdbcOutputTableHandle handle)
void	createTable(ConnectorTableMetadata tableMetadata)
protected JdbcOutputTableHandle	createTable(ConnectorTableMetadata tableMetadata, String tableName)
void	destroy()
void	dropColumn(JdbcTableHandle handle, JdbcColumnHandle column)
void	dropTable(JdbcTableHandle handle)
protected static String	escapeNamePattern(String name, String escape)
protected void	execute(Connection connection, String query)
void	finishInsertTable(JdbcOutputTableHandle handle)
protected String	generateTemporaryTableName()
List<JdbcColumnHandle>	getColumns(ConnectorSession session, JdbcTableHandle tableHandle)
Connection	getConnection(JdbcOutputTableHandle handle)
Connection	getConnection(JdbcSplit split)
PreparedStatement	getPreparedStatement(Connection connection, String sql)
Set<String>	getSchemaNames()
protected SchemaTableName	getSchemaTableName(ResultSet resultSet)
ConnectorSplitSource	getSplits(JdbcTableLayoutHandle layoutHandle)
JdbcTableHandle	getTableHandle(SchemaTableName schemaTableName)
List<SchemaTableName>	getTableNames(String schema)
protected ResultSet	getTables(Connection connection, String schemaName, String tableName)
TableStatistics	getTableStatistics(ConnectorSession session, JdbcTableHandle handle, TupleDomain<ColumnHandle> tupleDomain)
protected String	quoted(String name)
protected String	quoted(String catalog, String schema, String table)
void	renameColumn(JdbcTableHandle handle, JdbcColumnHandle jdbcColumn, String newColumnName)
void	renameTable(JdbcTableHandle handle, SchemaTableName newTable)
protected void	renameTable(String catalogName, SchemaTableName oldTable, SchemaTableName newTable)
void	rollbackCreateTable(JdbcOutputTableHandle handle)
Optional<ReadMapping>	toPrestoType(ConnectorSession session, JdbcTypeHandle typeHandle)
protected String	toSqlType(Type type)

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.plugin.jdbc.JdbcClient

abortReadConnection, schemaExists

Field Detail

connectorId

protected final String connectorId

connectionFactory

protected final ConnectionFactory connectionFactory

identifierQuote

protected final String identifierQuote

Constructor Detail

BaseJdbcClient

public BaseJdbcClient(JdbcConnectorId connectorId,
                      BaseJdbcConfig config,
                      String identifierQuote,
                      ConnectionFactory connectionFactory)

Method Detail

destroy

@PreDestroy
public void destroy()
                         throws Exception

Throws:

Exception

getSchemaNames

public Set<String> getSchemaNames()

Specified by:

getSchemaNames in interface JdbcClient

getTableNames

public List<SchemaTableName> getTableNames(@Nullable
                                           String schema)

Specified by:

getTableNames in interface JdbcClient

getTableHandle

@Nullable
public JdbcTableHandle getTableHandle(SchemaTableName schemaTableName)

Specified by:

getTableHandle in interface JdbcClient

getColumns

public List<JdbcColumnHandle> getColumns(ConnectorSession session,
                                         JdbcTableHandle tableHandle)

Specified by:

getColumns in interface JdbcClient

toPrestoType

public Optional<ReadMapping> toPrestoType(ConnectorSession session,
                                          JdbcTypeHandle typeHandle)

Specified by:

toPrestoType in interface JdbcClient

getSplits

public ConnectorSplitSource getSplits(JdbcTableLayoutHandle layoutHandle)

Specified by:

getSplits in interface JdbcClient

getConnection

public Connection getConnection(JdbcSplit split)
                         throws SQLException

Specified by:

getConnection in interface JdbcClient

Throws:

SQLException

buildSql

public PreparedStatement buildSql(Connection connection,
                                  JdbcSplit split,
                                  List<JdbcColumnHandle> columnHandles)
                           throws SQLException

Specified by:

buildSql in interface JdbcClient

Throws:

SQLException

createTable

public void createTable(ConnectorTableMetadata tableMetadata)

Specified by:

createTable in interface JdbcClient

beginCreateTable

public JdbcOutputTableHandle beginCreateTable(ConnectorTableMetadata tableMetadata)

Specified by:

beginCreateTable in interface JdbcClient

beginInsertTable

public JdbcOutputTableHandle beginInsertTable(ConnectorTableMetadata tableMetadata)

Specified by:

beginInsertTable in interface JdbcClient

createTable

protected JdbcOutputTableHandle createTable(ConnectorTableMetadata tableMetadata,
                                            String tableName)
                                     throws SQLException

Throws:

SQLException

generateTemporaryTableName

protected String generateTemporaryTableName()

commitCreateTable

public void commitCreateTable(JdbcOutputTableHandle handle)

Specified by:

commitCreateTable in interface JdbcClient

renameTable

public void renameTable(JdbcTableHandle handle,
                        SchemaTableName newTable)

Specified by:

renameTable in interface JdbcClient

renameTable

protected void renameTable(String catalogName,
                           SchemaTableName oldTable,
                           SchemaTableName newTable)

finishInsertTable

public void finishInsertTable(JdbcOutputTableHandle handle)

Specified by:

finishInsertTable in interface JdbcClient

addColumn

public void addColumn(JdbcTableHandle handle,
                      ColumnMetadata column)

Specified by:

addColumn in interface JdbcClient

renameColumn

public void renameColumn(JdbcTableHandle handle,
                         JdbcColumnHandle jdbcColumn,
                         String newColumnName)

Specified by:

renameColumn in interface JdbcClient

dropColumn

public void dropColumn(JdbcTableHandle handle,
                       JdbcColumnHandle column)

Specified by:

dropColumn in interface JdbcClient

dropTable

public void dropTable(JdbcTableHandle handle)

Specified by:

dropTable in interface JdbcClient

rollbackCreateTable

public void rollbackCreateTable(JdbcOutputTableHandle handle)

Specified by:

rollbackCreateTable in interface JdbcClient

buildInsertSql

public String buildInsertSql(JdbcOutputTableHandle handle)

Specified by:

buildInsertSql in interface JdbcClient

getConnection

public Connection getConnection(JdbcOutputTableHandle handle)
                         throws SQLException

Specified by:

getConnection in interface JdbcClient

Throws:

SQLException

getPreparedStatement

public PreparedStatement getPreparedStatement(Connection connection,
                                              String sql)
                                       throws SQLException

Specified by:

getPreparedStatement in interface JdbcClient

Throws:

SQLException

getTables

protected ResultSet getTables(Connection connection,
                              String schemaName,
                              String tableName)
                       throws SQLException

Throws:

SQLException

getSchemaTableName

protected SchemaTableName getSchemaTableName(ResultSet resultSet)
                                      throws SQLException

Throws:

SQLException

getTableStatistics

public TableStatistics getTableStatistics(ConnectorSession session,
                                          JdbcTableHandle handle,
                                          TupleDomain<ColumnHandle> tupleDomain)

Specified by:

getTableStatistics in interface JdbcClient

execute

protected void execute(Connection connection,
                       String query)
                throws SQLException

Throws:

SQLException

toSqlType

protected String toSqlType(Type type)

quoted

protected String quoted(String name)

quoted

protected String quoted(String catalog,
                        String schema,
                        String table)

escapeNamePattern

protected static String escapeNamePattern(String name,
                                          String escape)