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

DBZ-8144 Fix bad test data

Browse Source
This commit is contained in:
Chris Cranford 2024-08-13 17:47:10 -04:00 committed by Chris Cranford
parent 8226c2a191
commit 2f537de14f
1 changed files with 41 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/LogFileCollectorTest.java
View File

@ -201,14 +201,21 @@ public void testOracleRacWithRealDataRedoThreadsWithIndependentSequenceRanges()
files.add(createRedoLog("group_303.8411.1106167689", 10403072997229L, 56770, 3));
files.add(createArchiveLog("thread_4_seq_62925.29497.1152789389", 10403069930249L, 10403071899909L, 62925, 4));
files.add(createRedoLog("group_401.8418.1106167699", 10403071899909L, 62926, 4));
files.add(createRedoLog("group_201.8400.1106167673", 10326919867728L, 10326919867733L, 78034, 2, false));
files.add(createRedoLog("group_202.8401.1106167675", 10326919867733L, 10326919910394L, 78035, 2, false));
files.add(createRedoLog("group_203.8402.1106167677", 10326919910394L, 10326919923665L, 78036, 2, false));
files.add(createRedoLog("group_101.8391.1106167659", 10326919867747L, 10326919867788L, 83112, 1, false));
files.add(createRedoLog("group_102.8392.1106167661", 10326919867788L, 10326919910390L, 83113, 1, false));
files.add(createRedoLog("group_103.8393.1106167663", 10326919910390L, 10326919923663L, 83114, 1, false));
// These logs would have not been pulled since they don't contain the read position or come after read position
// files.add(createRedoLog("group_201.8400.1106167673", 10326919867728L, 10326919867733L, 78034, 2, false));
// files.add(createRedoLog("group_202.8401.1106167675", 10326919867733L, 10326919910394L, 78035, 2, false));
// files.add(createRedoLog("group_203.8402.1106167677", 10326919910394L, 10326919923665L, 78036, 2, false));
// files.add(createRedoLog("group_101.8391.1106167659", 10326919867747L, 10326919867788L, 83112, 1, false));
// files.add(createRedoLog("group_102.8392.1106167661", 10326919867788L, 10326919910390L, 83113, 1, false));
// files.add(createRedoLog("group_103.8393.1106167663", 10326919910390L, 10326919923663L, 83114, 1, false));
final RedoThreadState state = getFourThreadOpenState(Scn.valueOf(10326919867700L), Scn.valueOf(10326919867700L));
RedoThreadState.Builder builder = RedoThreadState.builder();
builder = makeClosedRedoThreadState(builder.thread(), 1, Scn.valueOf(10326919860000L), Scn.valueOf(10326919923663L)).build();
builder = makeClosedRedoThreadState(builder.thread(), 2, Scn.valueOf(10326919860000L), Scn.valueOf(10326919923665L)).build();
builder = makeOpenRedoThreadState(builder.thread(), 3, Scn.valueOf(10326919867700L), Scn.valueOf(10326919867700L)).build();
builder = makeOpenRedoThreadState(builder.thread(), 4, Scn.valueOf(10326919867700L), Scn.valueOf(10326919867700L)).build();
final RedoThreadState state = builder.build();
assertThat(getLogFileCollector(state).isLogFileListConsistent(Scn.valueOf("10403071210665"), files, state)).isTrue();
}
@ -1462,7 +1469,7 @@ public void testLogsWithRegularScns() throws Exception {
final OracleConnection connection = getOracleConnectionMock(redoThreadState, files);
final LogFileCollector collector = getLogFileCollector(config, connection);
final List<LogFile> result = collector.getLogs(Scn.valueOf(10));
final List<LogFile> result = collector.getLogs(Scn.valueOf(103401));
assertThat(result).hasSize(2);
assertThat(getLogFileWithName(result, "logfile1").getNextScn()).isEqualTo(Scn.valueOf(103700));
assertThat(getLogFileWithName(result, "logfile2").getNextScn()).isEqualTo(Scn.MAX);
@ -1501,7 +1508,7 @@ public void testNullsHandledAsMaxScn() throws Exception {
final OracleConnection connection = getOracleConnectionMock(redoThreadState, files);
final LogFileCollector collector = getLogFileCollector(config, connection);
final List<LogFile> result = collector.getLogs(Scn.valueOf(600));
final List<LogFile> result = collector.getLogs(Scn.valueOf(103301));
assertThat(result).hasSize(3);
assertThat(getLogFileWithName(result, "logfile2").getNextScn()).isEqualTo(Scn.MAX);
}
@ -1520,7 +1527,7 @@ public void testCanHandleMaxScn() throws Exception {
final OracleConnection connection = getOracleConnectionMock(redoThreadState, files);
final LogFileCollector collector = getLogFileCollector(config, connection);
final List<LogFile> result = collector.getLogs(Scn.valueOf(600));
final List<LogFile> result = collector.getLogs(Scn.valueOf(103301));
assertThat(result).hasSize(3);
assertThat(getLogFileWithName(result, "logfile2").getNextScn()).isEqualTo(Scn.MAX);
}
@ -1541,7 +1548,7 @@ public void testCanHandleVeryLargeScnValuesInNonCurrentRedoLog() throws Exceptio
final OracleConnection connection = getOracleConnectionMock(redoThreadState, files);
final LogFileCollector collector = getLogFileCollector(config, connection);
final List<LogFile> result = collector.getLogs(Scn.valueOf(600));
final List<LogFile> result = collector.getLogs(Scn.valueOf(103301));
assertThat(result).hasSize(3);
assertThat(getLogFileWithName(result, "logfile2").getNextScn()).isEqualTo(Scn.valueOf(largeScnValue));
}
@ -1956,6 +1963,29 @@ private RedoThread.Builder makeOpenRedoThreadState(RedoThread.Builder builder,
.conId(0L);
}
private RedoThread.Builder makeClosedRedoThreadState(RedoThread.Builder builder,
int threadId, Scn enabledScn, Scn lastFlushedScn) {
return builder.threadId(threadId)
.status("CLOSED")
.enabled("PUBLIC")
.instanceName("ORCLCDB")
.logGroups(2L)
.openTime(Instant.now().minus(10, ChronoUnit.MINUTES))
.checkpointTime(Instant.now().minus(5, ChronoUnit.MINUTES))
.checkpointScn(lastFlushedScn.add(Scn.ONE))
.currentGroupNumber(1L)
.currentSequenceNumber(1L)
.enabledScn(enabledScn)
.enabledTime(Instant.now().minus(10, ChronoUnit.MINUTES))
.disabledScn(Scn.valueOf(0))
.disabledTime(null)
.lastRedoScn(lastFlushedScn)
.lastRedoBlock(1234L)
.lastRedoSequenceNumber(2L)
.lastRedoTime(Instant.now().minus(3, ChronoUnit.SECONDS))
.conId(0L);
}
// Node 1 - OPEN Sequence 1, started at SCN 500, last SCN 1100, recent checkpoint SCN 1000
// Node 2 - OPEN Sequence 1, started at SCN 500, last SCN 1100, recent checkpoint SCN 1000
private RedoThreadState initialMultiNodeRedoThreadState() {