Function queryGtid

binlogreplication/binlog_replication_test.go:623–642

(t *testing.T, database *sqlx.DB)

}

func queryGtid(t *testing.T, database *sqlx.DB) string {
	gtidEnabled := getGtidEnabled()
	isPrimary := database == primaryDatabase
	if gtidEnabled {
		rows, err := database.Queryx("SELECT @@global.gtid_executed as gtid_executed;")
		require.NoError(t, err)
		defer rows.Close()
		row := convertMapScanResultToStrings(readNextRow(t, rows))
		if row["gtid_executed"] == nil {
			t.Fatal("no value for @@GLOBAL.gtid_executed")
		}
		return row["gtid_executed"].(string)
	} else if isPrimary {
		sourceLogFile, sourceLogPos := getPrimaryLogPosition(t, gtidEnabled)
		return fmt.Sprintf("%s:%s", sourceLogFile, sourceLogPos)
	} else {
		sourceLogFile, sourceLogPos := getReplicaLogPosition(t)
		return fmt.Sprintf("%s:%s", sourceLogFile, sourceLogPos)
	}
}

func readNextRow(t *testing.T, rows *sqlx.Rows) map[string]interface{} {
	row := make(map[string]interface{})