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

DBZ-1184 Support long purged GTID set

Browse Source
This commit is contained in:
Jiri Pechanec 2019-03-15 13:05:26 +01:00 committed by Gunnar Morling
parent 2f187fd1cb
commit 41734d322e
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlJdbcContext.java
View File

@ -205,7 +205,7 @@ public String knownGtidSet() {
public GtidSet purgedGtidSet() { public GtidSet purgedGtidSet() {
AtomicReference<String> gtidSetStr = new AtomicReference<String>(); AtomicReference<String> gtidSetStr = new AtomicReference<String>();
try { try {
jdbc.query("SHOW GLOBAL VARIABLES LIKE 'gtid_purged'", rs -> { jdbc.query("SELECT @@global.gtid_purged", rs -> {
if (rs.next() && rs.getMetaData().getColumnCount() > 1) { if (rs.next() && rs.getMetaData().getColumnCount() > 1) {
gtidSetStr.set(rs.getString(2));// GTID set, may be null, blank, or contain a GTID set gtidSetStr.set(rs.getString(2));// GTID set, may be null, blank, or contain a GTID set
} }