Package org.apache.flink.cdc.connectors.oracle.connection

Class OracleSourceConnection

  • All Implemented Interfaces:
    AutoCloseable
    public class OracleSourceConnection
extends io.debezium.connector.oracle.OracleConnection
    Used to create OracleConnection specified to Oracle.

    • Nested Class Summary

      • Nested classes/interfaces inherited from class io.debezium.connector.oracle.OracleConnection

        io.debezium.connector.oracle.OracleConnection.NonRelationalTableException

      • Nested classes/interfaces inherited from class io.debezium.jdbc.JdbcConnection

        io.debezium.jdbc.JdbcConnection.BlockingMultiResultSetConsumer, io.debezium.jdbc.JdbcConnection.BlockingResultSetConsumer, io.debezium.jdbc.JdbcConnection.CallPreparer, io.debezium.jdbc.JdbcConnection.ConnectionFactory, io.debezium.jdbc.JdbcConnection.MultiResultSetConsumer, io.debezium.jdbc.JdbcConnection.Operations, io.debezium.jdbc.JdbcConnection.ParameterResultSetConsumer, io.debezium.jdbc.JdbcConnection.ResultSetConsumer, io.debezium.jdbc.JdbcConnection.ResultSetExtractor<T extends Object>, io.debezium.jdbc.JdbcConnection.ResultSetMapper<T extends Object>, io.debezium.jdbc.JdbcConnection.StatementFactory, io.debezium.jdbc.JdbcConnection.StatementPreparer

    • Constructor Summary

      Constructors 
      Constructor Description
      OracleSourceConnection​(io.debezium.jdbc.JdbcConfiguration config, java.util.function.Supplier<ClassLoader> classLoaderSupplier)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <T extends io.debezium.schema.DatabaseSchema<io.debezium.relational.TableId>>
      Object      		 getColumnValue​(ResultSet rs, int columnIndex, io.debezium.relational.Column column, io.debezium.relational.Table table, T schema)  

      • Methods inherited from class io.debezium.connector.oracle.OracleConnection

        buildSelectWithRowLimits, connectionString, getAllTableIds, getColumnsDetails, getCurrentScn, getCurrentTimestamp, getOracleVersion, getRowCount, getScnToTimestamp, getSessionStatisticByName, getTableMetadataDdl, isArchiveLogMode, isTableEmpty, isTableExists, isTableExists, isTableUniqueIndexIncluded, overrideColumn, readSchemaForCapturedTables, readTableNames, readTableUniqueIndices, resetSessionToCdb, resolveCatalogName, setSessionToPdb, singleOptionalValue

      • Methods inherited from class io.debezium.jdbc.JdbcConnection

        call, close, commit, config, connect, connection, connection, connectionString, database, execute, execute, executeWithoutCommitting, isConnected, isNullable, isTableType, isValid, loadKeyStore, parseSqlStatementString, patternBasedFactory, patternBasedFactory, prepareQuery, prepareQuery, prepareQuery, prepareQuery, prepareQuery, prepareQueryAndMap, prepareQueryWithBlockingConsumer, prepareUpdate, print, print, query, query, queryAndMap, queryAndMap, querySingleValue, queryWithBlockingConsumer, quotedColumnIdString, quotedTableIdString, readAllCatalogNames, readAllSchemaNames, readAllTableNames, readPrimaryKeyNames, readPrimaryKeyOrUniqueIndexNames, readSchema, readTableColumn, readTablePreparedStatement, readTableStatement, resolveJdbcType, resolveNativeType, rollback, rowToArray, setAutoCommit, singleResultMapper, supportedTableTypes, tableTypes, username

    • Constructor Detail

      • OracleSourceConnection

        public OracleSourceConnection​(io.debezium.jdbc.JdbcConfiguration config,
                              java.util.function.Supplier<ClassLoader> classLoaderSupplier)

    • Method Detail

      • getColumnValue

        public <T extends io.debezium.schema.DatabaseSchema<io.debezium.relational.TableId>> Object getColumnValue​(ResultSet rs,
                                                                                                           int columnIndex,
                                                                                                           io.debezium.relational.Column column,
                                                                                                           io.debezium.relational.Table table,
                                                                                                           T schema)
                                                                                                    throws SQLException
        Overrides:
        getColumnValue in class io.debezium.jdbc.JdbcConnection
        Throws:
        SQLException