Support for mysql fresher then 8.4 LTS

closes #109
doublecloud · Nov 20, 2024 · af2e8db · af2e8db
1 parent 1382bb9
commit af2e8db
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/providers/mysql/storage.go b/pkg/providers/mysql/storage.go
@@ -333,7 +333,7 @@ func (s *Storage) LoadTable(ctx context.Context, table abstract.TableDescription
 func (s *Storage) getBinlogPosition(ctx context.Context, tx Queryable) (string, uint32, error) {
 	masterStatusQuery := "show master status;"
 	_, version := CheckMySQLVersion(s)
-	if strings.HasPrefix(version, "8.4") {
+	if strings.HasPrefix(version, "8.4") || strings.HasPrefix(version, "9") {
 		masterStatusQuery = " SHOW BINARY LOG STATUS;"
 	}