Package io.debezium.connector.oracle.logminer

Class LogMinerAdapter

java.lang.Object

io.debezium.connector.oracle.AbstractStreamingAdapter

io.debezium.connector.oracle.logminer.LogMinerAdapter

All Implemented Interfaces:

io.debezium.connector.oracle.StreamingAdapter

public class LogMinerAdapter
extends io.debezium.connector.oracle.AbstractStreamingAdapter

Copied from Debezium 1.9.8.Final.

Line 356: Replace < condition with <= to be able to catch ongoing transactions during snapshot if current SCN points to START/INSERT/DELETE/UPDATE event.

Nested Class Summary

Nested classes/interfaces inherited from interface io.debezium.connector.oracle.StreamingAdapter

io.debezium.connector.oracle.StreamingAdapter.TableNameCaseSensitivity

Field Summary

Fields

Modifier and Type	Field	Description
static String	TYPE

Fields inherited from class io.debezium.connector.oracle.AbstractStreamingAdapter

connectorConfig

Constructor Summary

Constructors

Constructor	Description
LogMinerAdapter(io.debezium.connector.oracle.OracleConnectorConfig connectorConfig)

Method Summary

Modifier and Type	Method	Description
io.debezium.connector.oracle.OracleOffsetContext	determineSnapshotOffset(io.debezium.relational.RelationalSnapshotChangeEventSource.RelationalSnapshotContext<io.debezium.connector.oracle.OraclePartition,io.debezium.connector.oracle.OracleOffsetContext> ctx, io.debezium.connector.oracle.OracleConnectorConfig connectorConfig, io.debezium.connector.oracle.OracleConnection connection)
io.debezium.relational.history.HistoryRecordComparator	getHistoryRecordComparator()
io.debezium.pipeline.spi.OffsetContext.Loader<io.debezium.connector.oracle.OracleOffsetContext>	getOffsetContextLoader()
io.debezium.pipeline.source.spi.StreamingChangeEventSource<io.debezium.connector.oracle.OraclePartition,io.debezium.connector.oracle.OracleOffsetContext>	getSource(io.debezium.connector.oracle.OracleConnection connection, io.debezium.pipeline.EventDispatcher<io.debezium.connector.oracle.OraclePartition,io.debezium.relational.TableId> dispatcher, io.debezium.pipeline.ErrorHandler errorHandler, io.debezium.util.Clock clock, io.debezium.connector.oracle.OracleDatabaseSchema schema, io.debezium.connector.oracle.OracleTaskContext taskContext, io.debezium.config.Configuration jdbcConfig, io.debezium.connector.oracle.OracleStreamingChangeEventSourceMetrics streamingMetrics)
String	getType()
boolean	isPendingTransactionViewOnly(io.debezium.connector.oracle.OracleConnectorConfig config)

Methods inherited from class io.debezium.connector.oracle.AbstractStreamingAdapter

areSameTimestamp, getLatestTableDdlScn, resolveScn

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.debezium.connector.oracle.StreamingAdapter

getTableNameCaseSensitivity

Field Detail

TYPE

public static final String TYPE

See Also:

Constant Field Values

Constructor Detail

LogMinerAdapter

public LogMinerAdapter(io.debezium.connector.oracle.OracleConnectorConfig connectorConfig)

Method Detail

getType

public String getType()

getHistoryRecordComparator

public io.debezium.relational.history.HistoryRecordComparator getHistoryRecordComparator()

getOffsetContextLoader

public io.debezium.pipeline.spi.OffsetContext.Loader<io.debezium.connector.oracle.OracleOffsetContext> getOffsetContextLoader()

getSource

public io.debezium.pipeline.source.spi.StreamingChangeEventSource<io.debezium.connector.oracle.OraclePartition,io.debezium.connector.oracle.OracleOffsetContext> getSource(io.debezium.connector.oracle.OracleConnection connection,
                                                                                                                                                                                 io.debezium.pipeline.EventDispatcher<io.debezium.connector.oracle.OraclePartition,io.debezium.relational.TableId> dispatcher,
                                                                                                                                                                                 io.debezium.pipeline.ErrorHandler errorHandler,
                                                                                                                                                                                 io.debezium.util.Clock clock,
                                                                                                                                                                                 io.debezium.connector.oracle.OracleDatabaseSchema schema,
                                                                                                                                                                                 io.debezium.connector.oracle.OracleTaskContext taskContext,
                                                                                                                                                                                 io.debezium.config.Configuration jdbcConfig,
                                                                                                                                                                                 io.debezium.connector.oracle.OracleStreamingChangeEventSourceMetrics streamingMetrics)

determineSnapshotOffset

public io.debezium.connector.oracle.OracleOffsetContext determineSnapshotOffset(io.debezium.relational.RelationalSnapshotChangeEventSource.RelationalSnapshotContext<io.debezium.connector.oracle.OraclePartition,io.debezium.connector.oracle.OracleOffsetContext> ctx,
                                                                                io.debezium.connector.oracle.OracleConnectorConfig connectorConfig,
                                                                                io.debezium.connector.oracle.OracleConnection connection)
                                                                         throws SQLException

Throws:

SQLException

isPendingTransactionViewOnly

public boolean isPendingTransactionViewOnly(io.debezium.connector.oracle.OracleConnectorConfig config)