[source-mysql] More meaningful errors for variables used in extra checks for CDC (#55731)

Author: szemek

airbyte-integrations/connectors/source-mysql/metadata.yaml

@@ -9,7 +9,7 @@ data:
   connectorSubtype: database
   connectorType: source
   definitionId: 435bb9a5-7887-4809-aa58-28c27df0d7ad
-  dockerImageTag: 3.11.8
+  dockerImageTag: 3.11.9
   dockerRepository: airbyte/source-mysql
   documentationUrl: https://docs.airbyte.com/integrations/sources/mysql
   githubIssueLabel: source-mysql

airbyte-integrations/connectors/source-mysql/src/main/kotlin/io/airbyte/integrations/source/mysql/MySqlSourceMetadataQuerier.kt

@@ -32,14 +32,24 @@ class MySqlSourceMetadataQuerier(
         base.extraChecks()
         if (base.config.global) {
             // Extra checks for CDC
-            var cdcVariableCheckQueries: List<Pair<String, String>> =
+            var cdcVariableCheckQueries: List<Triple<String, String, String>> =
                 listOf(
-                    Pair("show variables where Variable_name = 'log_bin'", "ON"),
-                    Pair("show variables where Variable_name = 'binlog_format'", "ROW"),
-                    Pair("show variables where Variable_name = 'binlog_row_image'", "FULL"),
+                    Triple("log_bin", "show variables where Variable_name = 'log_bin'", "ON"),
+                    Triple(
+                        "binlog_format",
+                        "show variables where Variable_name = 'binlog_format'",
+                        "ROW"
+                    ),
+                    Triple(
+                        "binlog_row_image",
+                        "show variables where Variable_name = 'binlog_row_image'",
+                        "FULL"
+                    ),
                 )
 
-            cdcVariableCheckQueries.forEach { runVariableCheckSql(it.first, it.second, base.conn) }
+            cdcVariableCheckQueries.forEach {
+                runVariableCheckSql(it.first, it.second, it.third, base.conn)
+            }
 
             // Note: SHOW MASTER STATUS has been deprecated in latest mysql (8.4) and going forward
             // it should be SHOW BINARY LOG STATUS. We will run both - if both have been failed we
@@ -62,7 +72,12 @@ class MySqlSourceMetadataQuerier(
         }
     }
 
-    private fun runVariableCheckSql(sql: String, expectedValue: String, conn: Connection) {
+    private fun runVariableCheckSql(
+        variable: String,
+        sql: String,
+        expectedValue: String,
+        conn: Connection
+    ) {
         try {
             conn.createStatement().use { stmt: Statement ->
                 stmt.executeQuery(sql).use { rs: ResultSet ->
@@ -73,7 +88,8 @@ class MySqlSourceMetadataQuerier(
                     if (!resultValue.equals(expectedValue, ignoreCase = true)) {
                         throw ConfigErrorException(
                             String.format(
-                                "The variable should be set to \"%s\", but it is \"%s\"",
+                                "The variable \"%s\" should be set to \"%s\", but it is \"%s\"",
+                                variable,
                                 expectedValue,
                                 resultValue,
                             ),

docs/integrations/sources/mysql.md

@@ -226,6 +226,7 @@ Any database or table encoding combination of charset and collation is supported
 
 | Version     | Date       | Pull Request                                               | Subject                                                                                                                                         |
 |:------------|:-----------|:-----------------------------------------------------------|:------------------------------------------------------------------------------------------------------------------------------------------------|
+| 3.11.9 | 2025-03-14 | [55731](https://github.com/airbytehq/airbyte/pull/55731) | More meaningful errors for variables used in extra checks for CDC |
 | 3.11.8 | 2025-03-14 | [55761](https://github.com/airbytehq/airbyte/pull/55761) | Do not perform complex sampling for source-mysql |
 | 3.11.7 | 2025-03-12 | [55734](https://github.com/airbytehq/airbyte/pull/55734) | Expose additional stream context for debezium properties at startup |
 | 3.11.6 | 2025-03-06 | [55237](https://github.com/airbytehq/airbyte/pull/55237) | [Fix fetching binlog status for version >=8.4](https://github.com/airbytehq/airbyte/pull/55237#top) |