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

DBZ-5301 FIx LogMinerHelperIT to work on Oracle RAC with multiple nodes

Browse Source
This commit is contained in:
Chris Cranford 2022-06-23 18:23:50 -04:00 committed by Chris Cranford
parent 28a618bef0
commit cab3c664a1
1 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/LogMinerHelperIT.java
View File

@ -72,19 +72,21 @@ public void before() throws SQLException {
@Test
@FixFor("DBZ-3256")
public void shouldAddCorrectLogFiles() throws Exception {
final int instances = getNumberOfInstances(conn);
// case 1 : oldest scn = current scn
Scn currentScn = conn.getCurrentScn();
List<LogFile> files = LogMinerHelper.getLogFilesForOffsetScn(conn, currentScn, Duration.ofHours(0L), false, null);
assertThat(files).hasSize(1); // just the current redo log
assertThat(files).hasSize(instances); // just the current redo log
// case 2 : oldest scn = oldest in not cleared archive
List<Scn> oneDayArchivedNextScn = getOneDayArchivedLogNextScn(conn);
Scn oldestArchivedScn = getOldestArchivedScn(oneDayArchivedNextScn);
files = LogMinerHelper.getLogFilesForOffsetScn(conn, oldestArchivedScn, Duration.ofHours(0L), false, null);
assertThat(files.size()).isEqualTo(oneDayArchivedNextScn.size());
assertThat(files.size()).isEqualTo(oneDayArchivedNextScn.size() + instances - 1);
files = LogMinerHelper.getLogFilesForOffsetScn(conn, oldestArchivedScn.subtract(Scn.valueOf(1L)), Duration.ofHours(0L), false, null);
assertThat(files.size()).isEqualTo(oneDayArchivedNextScn.size() + 1);
assertThat(files.size()).isEqualTo(oneDayArchivedNextScn.size() + instances);
}
@Test
@ -151,4 +153,15 @@ private List<Scn> getOneDayArchivedLogNextScn(OracleConnection conn) throws SQLE
return allArchivedNextScn;
}
private static int getNumberOfInstances(OracleConnection connection) throws SQLException {
// In an Oracle RAC environment, there will be multiple instances connected to the database.
// This information can be queried from GV$INSTANCE.
// For non-RAC environments, there will always just be one record here, the standalone instance.
return connection.queryAndMap("SELECT COUNT(1) FROM GV$INSTANCE", rs -> {
if (rs.next()) {
return rs.getInt(1);
}
return 0;
});
}
}