Package io.debezium.pipeline.source.snapshot.incremental

Class AbstractChunkQueryBuilder<T extends io.debezium.spi.schema.DataCollectionId>

java.lang.Object

io.debezium.pipeline.source.snapshot.incremental.AbstractChunkQueryBuilder<T>

All Implemented Interfaces:

ChunkQueryBuilder<T>

Direct Known Subclasses:

DefaultChunkQueryBuilder, PhysicalRowIdentifierChunkQueryBuilder, RowValueConstructorChunkQueryBuilder

public abstract class AbstractChunkQueryBuilder<T extends io.debezium.spi.schema.DataCollectionId>
extends Object
implements ChunkQueryBuilder<T>

Base class for building queries for reading incremental snapshot chunks from a table.

Field Summary

Fields

Modifier and Type	Field	Description
protected Tables.ColumnNameFilter	columnFilter
protected final RelationalDatabaseConnectorConfig	connectorConfig
protected final JdbcConnection	jdbcConnection
private static final org.slf4j.Logger	LOGGER

Constructor Summary

Constructors

Constructor	Description
AbstractChunkQueryBuilder(RelationalDatabaseConnectorConfig config, JdbcConnection jdbcConnection)

Method Summary

Modifier and Type	Method	Description
protected void	addLowerBound(IncrementalSnapshotContext<T> context, Table table, Object[] boundaryKey, StringBuilder sql)
protected void	addUpperBound(IncrementalSnapshotContext<T> context, Table table, Object[] boundaryKey, StringBuilder sql)
String	buildChunkQuery(IncrementalSnapshotContext<T> context, Table table, int limit, Optional<String> additionalCondition)	Builds a query for reading the next incremental snapshot chunk from a table using the specified limit.
String	buildChunkQuery(IncrementalSnapshotContext<T> context, Table table, Optional<String> additionalCondition)	Builds a query for reading the next incremental snapshot chunk from a table using the chunk size configured by the connector.
String	buildMaxPrimaryKeyQuery(IncrementalSnapshotContext<T> context, Table table, Optional<String> additionalCondition)	Builds a query for reading the maximum primary key value from a table.
protected String	buildProjection(Table table)
private Key.KeyMapper	getKeyMapper()
List<Column>	getQueryColumns(IncrementalSnapshotContext<T> context, Table table)	Returns the columns that are used for paginating the incremental snapshot chunks.
protected Optional<String>	getTableAlias(Table table)
PreparedStatement	readTableChunkStatement(IncrementalSnapshotContext<T> context, Table table, String sql)	Prepares a statement for reading the next incremental snapshot chunk from a table using the SQL statement returned by buildChunkQuery.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.debezium.pipeline.source.snapshot.incremental.ChunkQueryBuilder

prepareTable

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

connectorConfig

protected final RelationalDatabaseConnectorConfig connectorConfig

jdbcConnection

protected final JdbcConnection jdbcConnection

columnFilter

protected Tables.ColumnNameFilter columnFilter

Constructor Details

AbstractChunkQueryBuilder

public AbstractChunkQueryBuilder(RelationalDatabaseConnectorConfig config,
 JdbcConnection jdbcConnection)

Method Details

buildChunkQuery

public String buildChunkQuery(IncrementalSnapshotContext<T> context,
 Table table,
 Optional<String> additionalCondition)

Description copied from interface: ChunkQueryBuilder

Builds a query for reading the next incremental snapshot chunk from a table using the chunk size configured by the connector.

Specified by:

buildChunkQuery in interface ChunkQueryBuilder<T extends io.debezium.spi.schema.DataCollectionId>

buildChunkQuery

public String buildChunkQuery(IncrementalSnapshotContext<T> context,
 Table table,
 int limit,
 Optional<String> additionalCondition)

Description copied from interface: ChunkQueryBuilder

Builds a query for reading the next incremental snapshot chunk from a table using the specified limit.

Specified by:

buildChunkQuery in interface ChunkQueryBuilder<T extends io.debezium.spi.schema.DataCollectionId>

buildProjection

protected String buildProjection(Table table)

addLowerBound

protected void addLowerBound(IncrementalSnapshotContext<T> context,
 Table table,
 Object[] boundaryKey,
 StringBuilder sql)

addUpperBound

protected void addUpperBound(IncrementalSnapshotContext<T> context,
 Table table,
 Object[] boundaryKey,
 StringBuilder sql)

readTableChunkStatement

public PreparedStatement readTableChunkStatement(IncrementalSnapshotContext<T> context,
 Table table,
 String sql)
                                          throws SQLException

Description copied from interface: ChunkQueryBuilder

Prepares a statement for reading the next incremental snapshot chunk from a table using the SQL statement returned by buildChunkQuery.

Specified by:

readTableChunkStatement in interface ChunkQueryBuilder<T extends io.debezium.spi.schema.DataCollectionId>

Throws:

SQLException

buildMaxPrimaryKeyQuery

public String buildMaxPrimaryKeyQuery(IncrementalSnapshotContext<T> context,
 Table table,
 Optional<String> additionalCondition)

Description copied from interface: ChunkQueryBuilder

Builds a query for reading the maximum primary key value from a table.

Specified by:

buildMaxPrimaryKeyQuery in interface ChunkQueryBuilder<T extends io.debezium.spi.schema.DataCollectionId>

getTableAlias

protected Optional<String> getTableAlias(Table table)

getKeyMapper

private Key.KeyMapper getKeyMapper()

getQueryColumns

public List<Column> getQueryColumns(IncrementalSnapshotContext<T> context,
 Table table)

Description copied from interface: ChunkQueryBuilder

Returns the columns that are used for paginating the incremental snapshot chunks.

Specified by:

getQueryColumns in interface ChunkQueryBuilder<T extends io.debezium.spi.schema.DataCollectionId>