com.facebook.presto.plugin.jdbc

Interface JdbcClient

All Known Implementing Classes:

BaseJdbcClient

public interface JdbcClient

Method Summary

Modifier and Type	Method and Description
default void	abortReadConnection(Connection connection)
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)
void	dropColumn(JdbcTableHandle handle, JdbcColumnHandle column)
void	dropTable(JdbcTableHandle jdbcTableHandle)
void	finishInsertTable(JdbcOutputTableHandle handle)
List<JdbcColumnHandle>	getColumns(ConnectorSession session, JdbcTableHandle tableHandle)
Connection	getConnection(JdbcOutputTableHandle handle)
Connection	getConnection(JdbcSplit split)
PreparedStatement	getPreparedStatement(Connection connection, String sql)
Set<String>	getSchemaNames()
ConnectorSplitSource	getSplits(JdbcTableLayoutHandle layoutHandle)
JdbcTableHandle	getTableHandle(SchemaTableName schemaTableName)
List<SchemaTableName>	getTableNames(String schema)
TableStatistics	getTableStatistics(ConnectorSession session, JdbcTableHandle handle, TupleDomain<ColumnHandle> tupleDomain)
void	renameColumn(JdbcTableHandle handle, JdbcColumnHandle jdbcColumn, String newColumnName)
void	renameTable(JdbcTableHandle handle, SchemaTableName newTableName)
void	rollbackCreateTable(JdbcOutputTableHandle handle)
default boolean	schemaExists(String schema)
Optional<ReadMapping>	toPrestoType(ConnectorSession session, JdbcTypeHandle typeHandle)

Method Detail

schemaExists

default boolean schemaExists(String schema)

getSchemaNames

Set<String> getSchemaNames()

getTableNames

List<SchemaTableName> getTableNames(@Nullable
                                    String schema)

getTableHandle

@Nullable
JdbcTableHandle getTableHandle(SchemaTableName schemaTableName)

getColumns

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

toPrestoType

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

getSplits

ConnectorSplitSource getSplits(JdbcTableLayoutHandle layoutHandle)

getConnection

Connection getConnection(JdbcSplit split)
                  throws SQLException

Throws:

SQLException

abortReadConnection

default void abortReadConnection(Connection connection)
                          throws SQLException

Throws:

SQLException

buildSql

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

Throws:

SQLException

addColumn

void addColumn(JdbcTableHandle handle,
               ColumnMetadata column)

dropColumn

void dropColumn(JdbcTableHandle handle,
                JdbcColumnHandle column)

renameColumn

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

renameTable

void renameTable(JdbcTableHandle handle,
                 SchemaTableName newTableName)

createTable

void createTable(ConnectorTableMetadata tableMetadata)

beginCreateTable

JdbcOutputTableHandle beginCreateTable(ConnectorTableMetadata tableMetadata)

commitCreateTable

void commitCreateTable(JdbcOutputTableHandle handle)

beginInsertTable

JdbcOutputTableHandle beginInsertTable(ConnectorTableMetadata tableMetadata)

finishInsertTable

void finishInsertTable(JdbcOutputTableHandle handle)

dropTable

void dropTable(JdbcTableHandle jdbcTableHandle)

rollbackCreateTable

void rollbackCreateTable(JdbcOutputTableHandle handle)

buildInsertSql

String buildInsertSql(JdbcOutputTableHandle handle)

getConnection

Connection getConnection(JdbcOutputTableHandle handle)
                  throws SQLException

Throws:

SQLException

getPreparedStatement

PreparedStatement getPreparedStatement(Connection connection,
                                       String sql)
                                throws SQLException

Throws:

SQLException

getTableStatistics

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