From 02153a47a6c08f317dbbc7242bca8ce4ef58b0e9 Mon Sep 17 00:00:00 2001 From: Farid UYAR Date: Tue, 12 Feb 2019 16:45:21 +0100 Subject: [PATCH] fix executed gtid set missing --- go/inst/instance_dao.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/go/inst/instance_dao.go b/go/inst/instance_dao.go index e224156a6..47d64e1e7 100644 --- a/go/inst/instance_dao.go +++ b/go/inst/instance_dao.go @@ -395,7 +395,6 @@ func ReadTopologyInstanceBufferable(instanceKey *InstanceKey, bufferWrites bool, var err error instance.SelfBinlogCoordinates.LogFile = m.GetString("File") instance.SelfBinlogCoordinates.LogPos = m.GetInt64("Position") - instance.ExecutedGtidSet = m.GetStringD("Executed_Gtid_Set", "") return err }) }() @@ -424,7 +423,7 @@ func ReadTopologyInstanceBufferable(instanceKey *InstanceKey, bufferWrites bool, // ... // @@gtid_mode only available in Orcale MySQL >= 5.6 // Previous version just issued this query brute-force, but I don't like errors being issued where they shouldn't. - _ = db.QueryRow("select @@global.gtid_mode, @@global.server_uuid, @@global.gtid_purged, @@global.master_info_repository = 'TABLE', @@global.binlog_row_image").Scan(&instance.GTIDMode, &instance.ServerUUID, &instance.GtidPurged, &masterInfoRepositoryOnTable, &instance.BinlogRowImage) + _ = db.QueryRow("select @@global.gtid_mode, @@global.server_uuid, @@global.gtid_executed, @@global.gtid_purged, @@global.master_info_repository = 'TABLE', @@global.binlog_row_image").Scan(&instance.GTIDMode, &instance.ServerUUID, &instance.ExecutedGtidSet, &instance.GtidPurged, &masterInfoRepositoryOnTable, &instance.BinlogRowImage) if instance.GTIDMode != "" && instance.GTIDMode != "OFF" { instance.SupportsOracleGTID = true }