Package org.apache.flink.cdc.connectors.base.dialect

Interface JdbcDataSourceDialect

All Superinterfaces:

AutoCloseable, Closeable, DataSourceDialect<JdbcSourceConfig>, Serializable

All Known Implementing Classes:

Db2Dialect, OracleDialect, PostgresDialect, SqlServerDialect

@Experimental
public interface JdbcDataSourceDialect
extends DataSourceDialect<JdbcSourceConfig>

The dialect of JDBC data source.

Method Summary

Modifier and Type	Method	Description
default void	close()
FetchTask<SourceSplitBase>	createFetchTask(SourceSplitBase sourceSplitBase)	The fetch task used to fetch data of a snapshot split or stream split.
List<io.debezium.relational.TableId>	discoverDataCollections(JdbcSourceConfig sourceConfig)	Discovers the list of table to capture.
Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	discoverDataCollectionSchemas(JdbcSourceConfig sourceConfig)	Discovers the captured tables' schema by SourceConfig.
JdbcConnectionPoolFactory	getPooledDataSourceFactory()	Get a connection pool factory to create connection pool.
io.debezium.jdbc.JdbcConnection	openJdbcConnection(JdbcSourceConfig sourceConfig)	Creates and opens a new JdbcConnection backing connection pool.
io.debezium.relational.history.TableChanges.TableChange	queryTableSchema(io.debezium.jdbc.JdbcConnection jdbc, io.debezium.relational.TableId tableId)	Query and build the schema of table.

Methods inherited from interface org.apache.flink.cdc.connectors.base.dialect.DataSourceDialect

createChunkSplitter, createChunkSplitter, createFetchTaskContext, displayCommittedOffset, displayCurrentOffset, getName, isDataCollectionIdCaseSensitive, isIncludeDataCollection, notifyCheckpointComplete

Method Detail

discoverDataCollections

List<io.debezium.relational.TableId> discoverDataCollections(JdbcSourceConfig sourceConfig)

Discovers the list of table to capture.

Specified by:

discoverDataCollections in interface DataSourceDialect<JdbcSourceConfig>

discoverDataCollectionSchemas

Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> discoverDataCollectionSchemas(JdbcSourceConfig sourceConfig)

Discovers the captured tables' schema by SourceConfig.

Specified by:

discoverDataCollectionSchemas in interface DataSourceDialect<JdbcSourceConfig>

Parameters:

sourceConfig - a basic source configuration.

openJdbcConnection

io.debezium.jdbc.JdbcConnection openJdbcConnection(JdbcSourceConfig sourceConfig)

Creates and opens a new JdbcConnection backing connection pool.

Parameters:

sourceConfig - a basic source configuration.

Returns:

a utility that simplifies using a JDBC connection.

getPooledDataSourceFactory

JdbcConnectionPoolFactory getPooledDataSourceFactory()

Get a connection pool factory to create connection pool.

queryTableSchema

io.debezium.relational.history.TableChanges.TableChange queryTableSchema(io.debezium.jdbc.JdbcConnection jdbc,
                                                                         io.debezium.relational.TableId tableId)

Query and build the schema of table.

createFetchTask

FetchTask<SourceSplitBase> createFetchTask(SourceSplitBase sourceSplitBase)

Description copied from interface: DataSourceDialect

The fetch task used to fetch data of a snapshot split or stream split.

Specified by:

createFetchTask in interface DataSourceDialect<JdbcSourceConfig>

close

default void close()
            throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface DataSourceDialect<JdbcSourceConfig>

Throws:

IOException