alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-3055 Use JdbcConnection#query instead

Browse Source
This commit is contained in:
Chris Cranford 2021-02-04 16:21:03 -05:00 committed by Jiri Pechanec
parent e973c11818
commit 933ca55b74
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerHelper.java
View File

@ -252,13 +252,13 @@ static Duration getTimeDifference(Connection connection) throws SQLException {
* @param isContinuousMining works < 19 version only
* @throws SQLException if anything unexpected happens
*/
static void startLogMining(Connection connection, Long startScn, Long endScn,
static void startLogMining(OracleConnection connection, Long startScn, Long endScn,
OracleConnectorConfig.LogMiningStrategy strategy, boolean isContinuousMining)
throws SQLException {
LOGGER.trace("Starting log mining startScn={}, endScn={}, strategy={}, continuous={}", startScn, endScn, strategy, isContinuousMining);
String statement = SqlUtils.startLogMinerStatement(startScn, endScn, strategy, isContinuousMining);
try {
executeCallableStatement(connection, statement);
executeCallableStatement(connection.connection(), statement);
}
catch (SQLException e) {
// Capture database state before throwing exception
@ -603,7 +603,7 @@ private static BigInteger resolveNextChangeFromScnRange(String nextChangeValue)
*
* @param connection the database connection
*/
private static void logDatabaseState(Connection connection) {
private static void logDatabaseState(OracleConnection connection) {
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("Configured redo logs are:");
try {
@ -650,8 +650,8 @@ private static void logDatabaseState(Connection connection) {
* @param query the query to execute
* @throws SQLException thrown if an exception occurs performing a SQL operation
*/
private static void logQueryResults(Connection connection, String query) throws SQLException {
try (PreparedStatement s = connection.prepareStatement(query); ResultSet rs = s.executeQuery()) {
private static void logQueryResults(OracleConnection connection, String query) throws SQLException {
connection.query(query, rs -> {
int columns = rs.getMetaData().getColumnCount();
List<String> columnNames = new ArrayList<>();
for (int index = 1; index <= columns; ++index) {
@ -665,7 +665,7 @@ private static void logQueryResults(Connection connection, String query) throws
}
LOGGER.debug("{}", columnValues);
}
}
});
}
/**

2
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java
View File

@ -180,7 +180,7 @@ public void execute(ChangeEventSourceContext context) {
currentRedoLogFiles = getCurrentRedoLogFiles(connection, logMinerMetrics);
}
startLogMining(connection, startScn, endScn, strategy, isContinuousMining);
startLogMining(jdbcConnection, startScn, endScn, strategy, isContinuousMining);
stopwatch.start();
miningView.setFetchSize(LOG_MINING_VIEW_FETCH_SIZE);