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

DBZ-2994 Fix ClassCastException & compilation error

Browse Source
This commit is contained in:
Chris Cranford 2021-03-18 22:23:41 -04:00
parent 41b571fb37
commit 31ffa5e816
2 changed files with 3 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -244,7 +244,7 @@ protected void readTableStructure(ChangeEventSourceContext sourceContext, Relati
@Override
protected String enhanceOverriddenSelect(RelationalSnapshotContext snapshotContext, String overriddenSelect, TableId tableId) {
long snapshotOffset = (Long) snapshotContext.offset.getOffset().get("scn");
String snapshotOffset = (String) snapshotContext.offset.getOffset().get(SourceInfo.SCN_KEY);
String token = connectorConfig.getTokenToReplaceInSnapshotPredicate();
if (token != null) {
return overriddenSelect.replaceAll(token, " AS OF SCN " + snapshotOffset);

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

@ -14,7 +14,6 @@
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
@ -114,16 +113,8 @@ public void shouldAddRightRedoFiles() throws Exception {
assertThat(redoLogFilesCount + archivedLogFilesForMining.size()).isEqualTo(getNumberOfAddedLogFiles(conn));
}
private Scn getOldestArchivedScn(List<Scn> oneDayArchivedNextScn) throws Exception {
Scn oldestArchivedScn;
Optional<Scn> archivedScn = oneDayArchivedNextScn.stream().min(Scn::compareTo);
if (archivedScn.isPresent()) {
oldestArchivedScn = archivedScn.get();
}
else {
oldestArchivedScn = Scn.ZERO;
}
return oldestArchivedScn;
private Scn getOldestArchivedScn(List<Scn> oneDayArchivedNextScn) {
return oneDayArchivedNextScn.stream().min(Scn::compareTo).orElse(Scn.NULL);
}
private static int getNumberOfAddedLogFiles(OracleConnection conn) throws SQLException {