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

DBZ-137 Fix rebase

Browse Source
This commit is contained in:
Chris Cranford 2020-08-25 11:04:20 -04:00 committed by Gunnar Morling
parent 77662a0dde
commit 72d59348ed
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
debezium-core/src/main/java/io/debezium/relational/RelationalSnapshotChangeEventSource.java
View File

@ -391,7 +391,7 @@ protected ChangeRecordEmitter getChangeRecordEmitter(SnapshotContext snapshotCon
* @param tableId the table to generate a query for
* @return a valid query string or empty if table will not be snapshotted
*/
private Optional<String> determineSnapshotSelect(SnapshotContext snapshotContext, TableId tableId) {
private Optional<String> determineSnapshotSelect(RelationalSnapshotContext snapshotContext, TableId tableId) {
String overriddenSelect = connectorConfig.getSnapshotSelectOverridesByTable().get(tableId);
// try without catalog id, as this might or might not be populated based on the given connector
@ -408,7 +408,7 @@ private Optional<String> determineSnapshotSelect(SnapshotContext snapshotContext
* @param overriddenSelect conditional snapshot select
* @return enhanced select statement. By default it just returns original select statements.
*/
protected String enhanceOverriddenSelect(SnapshotContext snapshotContext, String overriddenSelect, TableId tableId) {
protected String enhanceOverriddenSelect(RelationalSnapshotContext snapshotContext, String overriddenSelect, TableId tableId) {
return overriddenSelect;
}
@ -419,7 +419,7 @@ protected String enhanceOverriddenSelect(SnapshotContext snapshotContext, String
// TODO Should it be Statement or similar?
// TODO Handle override option generically; a problem will be how to handle the dynamic part (Oracle's "... as of
// scn xyz")
protected abstract Optional<String> getSnapshotSelect(SnapshotContext snapshotContext, TableId tableId);
protected abstract Optional<String> getSnapshotSelect(RelationalSnapshotContext snapshotContext, TableId tableId);
private Column[] getColumnsForResultSet(Table table, ResultSet rs) throws SQLException {
ResultSetMetaData metaData = rs.getMetaData();