From f0d67143bdc0a87de94a2b8a416df9a1cfee7840 Mon Sep 17 00:00:00 2001 From: Randall Hauch Date: Mon, 27 Jun 2016 09:23:12 -0500 Subject: [PATCH] DBZ-82 Changed snapshot query to support pre-5.6.5 versions of MySQL --- .../java/io/debezium/connector/mysql/SnapshotReader.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/SnapshotReader.java b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/SnapshotReader.java index b34c64583..4df1b33fa 100644 --- a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/SnapshotReader.java +++ b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/SnapshotReader.java @@ -189,9 +189,12 @@ protected void execute() { if (rs.next()) { String binlogFilename = rs.getString(1); long binlogPosition = rs.getLong(2); - String gtidSet = rs.getString(5);// GTID set, may be null, blank, or contain a GTID set source.setBinlogStartPoint(binlogFilename, binlogPosition); - source.setGtidSet(gtidSet); + if ( rs.getMetaData().getColumnCount() > 4 ) { + // This column exists only in MySQL 5.6.5 or later ... + String gtidSet = rs.getString(5);// GTID set, may be null, blank, or contain a GTID set + source.setGtidSet(gtidSet); + } source.startSnapshot(); } });