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

DBZ-7138 Provide separate method for stripping parenthesis

Browse Source
This commit is contained in:
ani-sha 2024-04-22 16:23:54 +05:30 committed by Jiri Pechanec
parent fbe31a77cd
commit a26281d837
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/snapshot/MongoDbIncrementalSnapshotChangeEventSource.java
View File

@ -636,7 +636,11 @@ private Document constructQueryPredicate(Object[] startKey, Object[] endKey, Str
private String getAdditionalConditions() {
// Strip additional parenthesis to make sure additional conditions are parsed correctly
return context.currentDataCollectionId().getAdditionalCondition().map(s -> s.substring(1, s.length() - 1)).orElse("");
return context.currentDataCollectionId().getAdditionalCondition().map(this::getStripedAdditionalConditions).orElse("");
}
private String getStripedAdditionalConditions(String additionalConditions) {
return additionalConditions.substring(1, additionalConditions.length() - 1);
}
private void incrementTableRowsScanned(long rows) {