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

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

java.lang.Object

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

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

All Implemented Interfaces:

ChunkQueryBuilder<T>

public class PhysicalRowIdentifierChunkQueryBuilder<T extends io.debezium.spi.schema.DataCollectionId>
extends AbstractChunkQueryBuilder<T>

Chunk query builder that injects a hidden physical row identifier (e.g. Oracle ROWID, PostgreSQL ctid) so it can be used as the surrogate key for incremental snapshots.

This builder is vendor-agnostic at the core level; connector-specific implementations provide the appropriate physical column metadata for their database.

Field Summary

Fields

Modifier and Type	Field	Description
private final boolean	aliasWildcardProjection
private static final String	DEFAULT_TABLE_ALIAS
private final String	physicalColumnName
private final String	physicalIdentifierExpression
private final int	physicalJdbcType
private final Integer	physicalLength
private final int	physicalNativeType
private final Integer	physicalScale
private final String	physicalTypeName
private final String	tableAlias

Fields inherited from class io.debezium.pipeline.source.snapshot.incremental.AbstractChunkQueryBuilder

columnFilter, connectorConfig, jdbcConnection

Constructor Summary

Constructors

Constructor	Description
PhysicalRowIdentifierChunkQueryBuilder(RelationalDatabaseConnectorConfig config, JdbcConnection jdbcConnection, String physicalColumnName, String physicalIdentifierExpression, int physicalJdbcType, int physicalNativeType, String physicalTypeName, Integer physicalLength, Integer physicalScale, boolean aliasWildcardProjection, String tableAlias)

Method Summary

Modifier and Type	Method	Description
private Column	buildPhysicalColumn(Table table)
private String	buildPhysicalProjection()
protected String	buildProjection(Table table)
protected Optional<String>	getTableAlias(Table table)
private boolean	hasPhysicalColumn(Table table)
Table	prepareTable(IncrementalSnapshotContext<T> context, Table table)	Allows builders to adjust the Table metadata before it is used for chunking.
private boolean	usesPhysicalIdentifier(IncrementalSnapshotContext<T> context)

Methods inherited from class io.debezium.pipeline.source.snapshot.incremental.AbstractChunkQueryBuilder

addLowerBound, addUpperBound, buildChunkQuery, buildChunkQuery, buildMaxPrimaryKeyQuery, getQueryColumns, readTableChunkStatement

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_TABLE_ALIAS

private static final String DEFAULT_TABLE_ALIAS

See Also:

• Constant Field Values

physicalColumnName

private final String physicalColumnName

physicalIdentifierExpression

private final String physicalIdentifierExpression

physicalJdbcType

private final int physicalJdbcType

physicalNativeType

private final int physicalNativeType

physicalTypeName

private final String physicalTypeName

physicalLength

private final Integer physicalLength

physicalScale

private final Integer physicalScale

aliasWildcardProjection

private final boolean aliasWildcardProjection

tableAlias

private final String tableAlias

Constructor Details

PhysicalRowIdentifierChunkQueryBuilder

public PhysicalRowIdentifierChunkQueryBuilder(RelationalDatabaseConnectorConfig config,
 JdbcConnection jdbcConnection,
 String physicalColumnName,
 String physicalIdentifierExpression,
 int physicalJdbcType,
 int physicalNativeType,
 String physicalTypeName,
 Integer physicalLength,
 Integer physicalScale,
 boolean aliasWildcardProjection,
 String tableAlias)

Method Details

prepareTable

public Table prepareTable(IncrementalSnapshotContext<T> context,
 Table table)

Description copied from interface: ChunkQueryBuilder

Allows builders to adjust the Table metadata before it is used for chunking.

Default implementation is a no-op, returning the provided table instance.

buildPhysicalColumn

private Column buildPhysicalColumn(Table table)

usesPhysicalIdentifier

private boolean usesPhysicalIdentifier(IncrementalSnapshotContext<T> context)

hasPhysicalColumn

private boolean hasPhysicalColumn(Table table)

buildProjection

protected String buildProjection(Table table)

Overrides:

buildProjection in class AbstractChunkQueryBuilder<T extends io.debezium.spi.schema.DataCollectionId>

buildPhysicalProjection

private String buildPhysicalProjection()

getTableAlias

protected Optional<String> getTableAlias(Table table)

Overrides:

getTableAlias in class AbstractChunkQueryBuilder<T extends io.debezium.spi.schema.DataCollectionId>