(t *testing.T, gtidEnabled bool)
| 721 | } |
| 722 | |
| 723 | func getPrimaryLogPosition(t *testing.T, gtidEnabled bool) (string, string) { |
| 724 | rows, err := primaryDatabase.Queryx("SHOW BINARY LOG STATUS;") |
| 725 | require.NoError(t, err) |
| 726 | primaryStatus := convertMapScanResultToStrings(readNextRow(t, rows)) |
| 727 | sourceLogFile := primaryStatus["File"].(string) |
| 728 | sourceLogPos := primaryStatus["Position"].(string) |
| 729 | require.NoError(t, rows.Close()) |
| 730 | |
| 731 | return sourceLogFile, sourceLogPos |
| 732 | } |
| 733 | |
| 734 | func getReplicaLogPosition(t *testing.T) (string, string) { |
| 735 | rows, err := replicaDatabase.Queryx("SHOW REPLICA STATUS;") |
no test coverage detected