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

DBZ-3615: Keep database connection closed during schema recovery

Browse Source
This commit is contained in:
Sergei Morozov 2021-05-28 13:26:03 -07:00 committed by Gunnar Morling
parent 331648dce0
commit b36e8247a3
1 changed files with 19 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlConnectorTask.java
View File

@ -79,12 +79,6 @@ public ChangeEventSourceCoordinator<MySqlOffsetContext> start(Configuration conf
connection = new MySqlConnection(new MySqlConnectionConfiguration(config),
connectorConfig.useCursorFetch() ? new MysqlBinaryProtocolFieldReader()
: new MysqlTextProtocolFieldReader());
try {
connection.setAutoCommit(false);
}
catch (SQLException e) {
throw new DebeziumException(e);
}
validateBinlogConfiguration(connectorConfig);
@ -97,7 +91,26 @@ public ChangeEventSourceCoordinator<MySqlOffsetContext> start(Configuration conf
this.schema = new MySqlDatabaseSchema(connectorConfig, valueConverters, topicSelector, schemaNameAdjuster, tableIdCaseInsensitive);
LOGGER.info("Closing connection before starting schema recovery");
try {
connection.close();
}
catch (SQLException e) {
throw new DebeziumException(e);
}
validateAndLoadDatabaseHistory(connectorConfig, previousOffset, schema);
LOGGER.info("Reconnecting after finishing schema recovery");
try {
connection.setAutoCommit(false);
}
catch (SQLException e) {
throw new DebeziumException(e);
}
// If the binlog position is not available it is necessary to reexecute snapshot
if (validateSnapshotFeasibility(connectorConfig, previousOffset)) {
previousOffset = null;