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

DBZ-947 Revert default isolation level after initial load

Browse Source
This commit is contained in:
Grzegorz Kołakowski 2019-01-24 20:44:10 +01:00 committed by Gunnar Morling
parent 430d828e86
commit c5578c055b
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerSnapshotChangeEventSource.java
View File

@ -181,6 +181,12 @@ protected SchemaChangeEvent getCreateTableEvent(SnapshotContext snapshotContext,
@Override
protected void complete() {
try {
// Revert to default transaction isolation level (read committed).
jdbcConnection.connection().setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
} catch (SQLException e) {
throw new RuntimeException("Failed to set transaction isolation level.", e);
}
}
@Override