Uses of Class
io.debezium.jdbc.JdbcConnection

Packages that use JdbcConnection

Package	Description
io.debezium.heartbeat
io.debezium.jdbc
io.debezium.pipeline.source.snapshot
io.debezium.pipeline.source.snapshot.chunked
io.debezium.pipeline.source.snapshot.incremental
io.debezium.processors.reselect
io.debezium.relational

Uses of JdbcConnection in io.debezium.heartbeat

Fields in io.debezium.heartbeat declared as JdbcConnection

Modifier and Type	Field	Description
private final JdbcConnection	DatabaseHeartbeatImpl.jdbcConnection

Methods in io.debezium.heartbeat that return JdbcConnection

Modifier and Type	Method	Description
JdbcConnection	HeartbeatConnectionProvider.get()

Constructors in io.debezium.heartbeat with parameters of type JdbcConnection

Modifier	Constructor	Description
	DatabaseHeartbeatImpl(JdbcConnection jdbcConnection, String heartBeatActionQuery, HeartbeatErrorHandler errorHandler)

Uses of JdbcConnection in io.debezium.jdbc

Classes in io.debezium.jdbc with type parameters of type JdbcConnection

Modifier and Type	Interface	Description
interface	ConnectionFactory<T extends JdbcConnection>	An on-demand provider of a JDBC connection.
class	DefaultMainConnectionProvidingConnectionFactory<T extends JdbcConnection>
interface	MainConnectionProvidingConnectionFactory<T extends JdbcConnection>	An on-demand provider of a JDBC connection.

Fields in io.debezium.jdbc declared as JdbcConnection

Modifier and Type	Field	Description
private final T	DefaultMainConnectionProvidingConnectionFactory.mainConnection

Methods in io.debezium.jdbc that return JdbcConnection

Modifier and Type	Method	Description
JdbcConnection	JdbcConnection.call(String sql, JdbcConnection.CallPreparer callPreparer, JdbcConnection.ResultSetConsumer resultSetConsumer)	Execute a stored procedure.
JdbcConnection	JdbcConnection.commit()
JdbcConnection	JdbcConnection.connect()	Ensure a connection to the database is established.
JdbcConnection	JdbcConnection.execute(JdbcConnection.Operations operations)	Execute a series of operations as a single transaction.
JdbcConnection	JdbcConnection.execute(String... sqlStatements)	Execute a series of SQL statements as a single transaction.
JdbcConnection	JdbcConnection.executeWithoutCommitting(String... statements)	Executes a series of statements without explicitly committing the connection.
JdbcConnection	JdbcConnection.prepareQuery(String preparedQueryString)	Executes a SQL query, preparing it if encountering it for the first time.
JdbcConnection	JdbcConnection.prepareQuery(String[] multiQuery, JdbcConnection.StatementPreparer[] preparers, JdbcConnection.BlockingMultiResultSetConsumer resultConsumer)	Execute multiple SQL prepared queries where each query is executed with the same set of parameters.
JdbcConnection	JdbcConnection.prepareQuery(String[] multiQuery, JdbcConnection.StatementPreparer preparer, JdbcConnection.BlockingMultiResultSetConsumer resultConsumer)	Execute multiple SQL prepared queries where each query is executed with the same set of parameters.
JdbcConnection	JdbcConnection.prepareQuery(String preparedQueryString, JdbcConnection.StatementPreparer preparer, JdbcConnection.ResultSetConsumer resultConsumer)	Execute a SQL prepared query.
JdbcConnection	JdbcConnection.prepareQuery(String preparedQueryString, List<?> parameters, JdbcConnection.ParameterResultSetConsumer resultConsumer)	Execute a SQL prepared query.
JdbcConnection	JdbcConnection.prepareQueryWithBlockingConsumer(String preparedQueryString, JdbcConnection.StatementPreparer preparer, JdbcConnection.BlockingResultSetConsumer resultConsumer)	Execute a SQL prepared query.
JdbcConnection	JdbcConnection.prepareUpdate(String stmt, JdbcConnection.StatementPreparer preparer)	Execute a SQL update via a prepared statement.
JdbcConnection	JdbcConnection.query(String query, JdbcConnection.ResultSetConsumer resultConsumer)	Execute a SQL query.
JdbcConnection	JdbcConnection.query(String query, JdbcConnection.StatementFactory statementFactory, JdbcConnection.ResultSetConsumer resultConsumer)	Execute a SQL query.
JdbcConnection	JdbcConnection.queryWithBlockingConsumer(String query, JdbcConnection.StatementFactory statementFactory, JdbcConnection.BlockingResultSetConsumer resultConsumer)
JdbcConnection	JdbcConnection.rollback()
JdbcConnection	JdbcConnection.setAutoCommit(boolean autoCommit)

Uses of JdbcConnection in io.debezium.pipeline.source.snapshot

Methods in io.debezium.pipeline.source.snapshot with parameters of type JdbcConnection

Modifier and Type	Method	Description
static int	CascadingOrBoundaryConditions.bindTriangularParams(PreparedStatement statement, List<Column> columns, Object[] values, int startIndex, JdbcConnection connection)	Binds values in the triangular parameter pattern for a cascading-OR boundary condition.
static int	CascadingOrBoundaryConditions.bindTriangularParamsSkipNulls(PreparedStatement statement, List<Column> columns, Object[] values, int startIndex, JdbcConnection connection)	Binds values in the triangular parameter pattern, skipping null entries.

Uses of JdbcConnection in io.debezium.pipeline.source.snapshot.chunked

Fields in io.debezium.pipeline.source.snapshot.chunked declared as JdbcConnection

Modifier and Type	Field	Description
private final JdbcConnection	ChunkBoundaryCalculator.jdbcConnection
private final JdbcConnection	SnapshotChunkQueryBuilder.jdbcConnection

Constructors in io.debezium.pipeline.source.snapshot.chunked with parameters of type JdbcConnection

Modifier	Constructor	Description
	ChunkBoundaryCalculator(JdbcConnection jdbcConnection)
	SnapshotChunkQueryBuilder(JdbcConnection jdbcConnection)

Uses of JdbcConnection in io.debezium.pipeline.source.snapshot.incremental

Fields in io.debezium.pipeline.source.snapshot.incremental declared as JdbcConnection

Modifier and Type	Field	Description
protected final JdbcConnection	AbstractChunkQueryBuilder.jdbcConnection
protected JdbcConnection	AbstractIncrementalSnapshotChangeEventSource.jdbcConnection
private final JdbcConnection	DeleteWindowCloser.jdbcConnection
private final JdbcConnection	InsertWindowCloser.jdbcConnection

Methods in io.debezium.pipeline.source.snapshot.incremental with parameters of type JdbcConnection

Modifier and Type	Method	Description
private WatermarkWindowCloser	SignalBasedIncrementalSnapshotChangeEventSource.getWatermarkWindowCloser(CommonConnectorConfig connectorConfig, JdbcConnection jdbcConnection, String signalTable)

Constructors in io.debezium.pipeline.source.snapshot.incremental with parameters of type JdbcConnection

Modifier	Constructor	Description
	AbstractChunkQueryBuilder(RelationalDatabaseConnectorConfig config, JdbcConnection jdbcConnection)
	AbstractIncrementalSnapshotChangeEventSource(RelationalDatabaseConnectorConfig config, JdbcConnection jdbcConnection, EventDispatcher<P,T> dispatcher, DatabaseSchema<?> databaseSchema, io.debezium.util.Clock clock, SnapshotProgressListener<P> progressListener, DataChangeEventListener<P> dataChangeEventListener, NotificationService<P,? extends OffsetContext> notificationService)
	DefaultChunkQueryBuilder(RelationalDatabaseConnectorConfig config, JdbcConnection jdbcConnection)
	DeleteWindowCloser(JdbcConnection jdbcConnection, String signalTable, SignalBasedIncrementalSnapshotChangeEventSource<P,T> incrementalSnapshotChangeEventSource)
	InsertWindowCloser(JdbcConnection jdbcConnection, String signalTable, SignalMetadata signalMetadata)
	PhysicalRowIdentifierChunkQueryBuilder(RelationalDatabaseConnectorConfig config, JdbcConnection jdbcConnection, String physicalColumnName, String physicalIdentifierExpression, int physicalJdbcType, int physicalNativeType, String physicalTypeName, Integer physicalLength, Integer physicalScale, boolean aliasWildcardProjection, String tableAlias)
	RowValueConstructorChunkQueryBuilder(RelationalDatabaseConnectorConfig config, JdbcConnection jdbcConnection)
	SignalBasedIncrementalSnapshotChangeEventSource(RelationalDatabaseConnectorConfig config, JdbcConnection jdbcConnection, EventDispatcher<P,T> dispatcher, DatabaseSchema<?> databaseSchema, io.debezium.util.Clock clock, SnapshotProgressListener<P> progressListener, DataChangeEventListener<P> dataChangeEventListener, NotificationService<P,? extends OffsetContext> notificationService)

Uses of JdbcConnection in io.debezium.processors.reselect

Fields in io.debezium.processors.reselect declared as JdbcConnection

Modifier and Type	Field	Description
private JdbcConnection	ReselectColumnsPostProcessor.jdbcConnection

Uses of JdbcConnection in io.debezium.relational

Fields in io.debezium.relational declared as JdbcConnection

Modifier and Type	Field	Description
private final JdbcConnection	RelationalSnapshotChangeEventSource.jdbcConnection

Fields in io.debezium.relational with type parameters of type JdbcConnection

Modifier and Type	Field	Description
protected Queue<JdbcConnection>	RelationalSnapshotChangeEventSource.connectionPool
private final MainConnectionProvidingConnectionFactory<? extends JdbcConnection>	RelationalSnapshotChangeEventSource.jdbcConnectionFactory

Methods in io.debezium.relational that return types with arguments of type JdbcConnection

Modifier and Type	Method	Description
private Queue<JdbcConnection>	RelationalSnapshotChangeEventSource.createConnectionPool(RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> ctx)

Methods in io.debezium.relational with parameters of type JdbcConnection

Modifier and Type	Method	Description
protected void	RelationalSnapshotChangeEventSource.connectionPoolConnectionCreated(RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, JdbcConnection connection)	Executes steps which have to be taken just after a connection pool connection is created.
protected void	RelationalSnapshotChangeEventSource.doCreateDataEventsForChunk(ChangeEventSource.ChangeEventSourceContext sourceContext, RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, O offset, EventDispatcher.SnapshotReceiver<P> snapshotReceiver, SnapshotChunk chunk, Map<TableId,TableChunkProgress> progressMap, SnapshotProgress snapshotProgress, JdbcConnection jdbcConnection)
protected void	RelationalSnapshotChangeEventSource.doCreateDataEventsForTable(ChangeEventSource.ChangeEventSourceContext sourceContext, RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, O offset, EventDispatcher.SnapshotReceiver<P> snapshotReceiver, Table table, boolean firstTable, boolean lastTable, int tableOrder, int tableCount, String selectStatement, OptionalLong rowCount, Set<TableId> rowCountTablesKeySet, JdbcConnection jdbcConnection)
void	RelationalSnapshotChangeEventSource.PooledWork.execute(JdbcConnection connection, T offset)	Execute the work with the provided pooled resources.
protected Instant	RelationalSnapshotChangeEventSource.getSnapshotSourceTimestamp(JdbcConnection jdbcConnection, O offset, TableId tableId)	For the given table gets source.ts_ms value from the database for snapshot data!
private void	RelationalSnapshotChangeEventSource.initializePooledConnection(JdbcConnection connection)
protected Statement	RelationalSnapshotChangeEventSource.readTableStatement(JdbcConnection jdbcConnection, OptionalLong tableSize)	Allow per-connector query creation to override for best database performance depending on the table size.

Method parameters in io.debezium.relational with type arguments of type JdbcConnection

Modifier and Type	Method	Description
private void	RelationalSnapshotChangeEventSource.createChunkedDataEvents(ChangeEventSource.ChangeEventSourceContext sourceContext, RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, Queue<JdbcConnection> connectionPool, Map<io.debezium.spi.schema.DataCollectionId,String> snapshotSelectOverridesByTable, Queue<O> offsets, EventDispatcher.SnapshotReceiver<P> snapshotReceiver)
private void	RelationalSnapshotChangeEventSource.createDataEvents(ChangeEventSource.ChangeEventSourceContext sourceContext, RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, Queue<JdbcConnection> connectionPool, Map<io.debezium.spi.schema.DataCollectionId,String> snapshotSelectOverridesByTable)
protected Callable<Void>	RelationalSnapshotChangeEventSource.createDataEventsForChunkedTableCallable(ChangeEventSource.ChangeEventSourceContext sourceContext, RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, EventDispatcher.SnapshotReceiver<P> snapshotReceiver, SnapshotChunk chunk, Map<TableId,TableChunkProgress> progressMap, SnapshotProgress snapshotProgress, Queue<JdbcConnection> connectionPool, Queue<O> offsets)
protected Callable<Void>	RelationalSnapshotChangeEventSource.createDataEventsForTableCallable(ChangeEventSource.ChangeEventSourceContext sourceContext, RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, EventDispatcher.SnapshotReceiver<P> snapshotReceiver, Table table, boolean firstTable, boolean lastTable, int tableOrder, int tableCount, String selectStatement, OptionalLong rowCount, Set<TableId> rowCountTablesKeySet, Queue<JdbcConnection> connectionPool, Queue<O> offsets)
private void	RelationalSnapshotChangeEventSource.createLegacyDataEvents(ChangeEventSource.ChangeEventSourceContext sourceContext, RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, Queue<JdbcConnection> connectionPool, Map<io.debezium.spi.schema.DataCollectionId,String> snapshotSelectOverridesByTable, Queue<O> offsets, EventDispatcher.SnapshotReceiver<P> snapshotReceiver)
private Callable<Void>	RelationalSnapshotChangeEventSource.createPooledResourceCallable(Queue<JdbcConnection> connectionPool, Queue<O> offsetPool, RelationalSnapshotChangeEventSource.PooledWork<O> work, Runnable errorHandler)	Creates a Callable that borrows resources from pools, executes work, and returns resources.

Constructor parameters in io.debezium.relational with type arguments of type JdbcConnection

Modifier	Constructor	Description
	RelationalSnapshotChangeEventSource(RelationalDatabaseConnectorConfig connectorConfig, MainConnectionProvidingConnectionFactory<? extends JdbcConnection> jdbcConnectionFactory, RelationalDatabaseSchema schema, EventDispatcher<P,TableId> dispatcher, io.debezium.util.Clock clock, SnapshotProgressListener<P> snapshotProgressListener, NotificationService<P,O> notificationService, SnapshotterService snapshotterService)