mysql-source:fix tinyint unsigned handling (airbytehq#18619)

* mysql-source:fix tinyint unsigned handling

* update doc

* format

* upgrade version

* auto-bump connector version

Co-authored-by: Octavia Squidington III <[email protected]>

Author: 2 people

airbyte-config/init/src/main/resources/seed/source_definitions.yaml

@@ -792,7 +792,7 @@
 - name: MySQL
   sourceDefinitionId: 435bb9a5-7887-4809-aa58-28c27df0d7ad
   dockerRepository: airbyte/source-mysql
-  dockerImageTag: 1.0.9
+  dockerImageTag: 1.0.10
   documentationUrl: https://docs.airbyte.com/integrations/sources/mysql
   icon: mysql.svg
   sourceType: database

airbyte-config/init/src/main/resources/seed/source_specs.yaml

@@ -7587,7 +7587,7 @@
     supportsNormalization: false
     supportsDBT: false
     supported_destination_sync_modes: []
-- dockerImage: "airbyte/source-mysql:1.0.9"
+- dockerImage: "airbyte/source-mysql:1.0.10"
   spec:
     documentationUrl: "https://docs.airbyte.com/integrations/sources/mysql"
     connectionSpecification:

airbyte-integrations/bases/debezium-v1-9-6/src/main/java/io/airbyte/integrations/debezium/internals/CustomMySQLTinyIntOneToBooleanConverter.java

@@ -0,0 +1,21 @@
+/*
+ * Copyright (c) 2022 Airbyte, Inc., all rights reserved.
+ */
+
+package io.airbyte.integrations.debezium.internals;
+
+import io.debezium.connector.mysql.converters.TinyIntOneToBooleanConverter;
+import io.debezium.spi.converter.RelationalColumn;
+import org.apache.kafka.connect.data.SchemaBuilder;
+
+public class CustomMySQLTinyIntOneToBooleanConverter extends TinyIntOneToBooleanConverter {
+
+  @Override
+  public void converterFor(final RelationalColumn field, final ConverterRegistration<SchemaBuilder> registration) {
+    if (!"TINYINT".equalsIgnoreCase(field.typeName())) {
+      return;
+    }
+    super.converterFor(field, registration);
+  }
+
+}

airbyte-integrations/connectors/source-mysql-strict-encrypt/Dockerfile

@@ -16,6 +16,6 @@ ENV APPLICATION source-mysql-strict-encrypt
 
 COPY --from=build /airbyte /airbyte
 
-LABEL io.airbyte.version=1.0.9
+LABEL io.airbyte.version=1.0.10
 
 LABEL io.airbyte.name=airbyte/source-mysql-strict-encrypt

airbyte-integrations/connectors/source-mysql/Dockerfile

@@ -16,6 +16,6 @@ ENV APPLICATION source-mysql
 
 COPY --from=build /airbyte /airbyte
 
-LABEL io.airbyte.version=1.0.9
+LABEL io.airbyte.version=1.0.10
 
 LABEL io.airbyte.name=airbyte/source-mysql

airbyte-integrations/connectors/source-mysql/src/main/java/io/airbyte/integrations/source/mysql/MySqlCdcProperties.java

@@ -50,7 +50,7 @@ private static Properties commonProperties(final JdbcDatabase database) {
      * {@link MySQLConverter}
      */
     props.setProperty("converters", "boolean, datetime");
-    props.setProperty("boolean.type", "io.debezium.connector.mysql.converters.TinyIntOneToBooleanConverter");
+    props.setProperty("boolean.type", "io.airbyte.integrations.debezium.internals.CustomMySQLTinyIntOneToBooleanConverter");
     props.setProperty("datetime.type", "io.airbyte.integrations.debezium.internals.MySQLDateTimeConverter");
 
     // For CDC mode, the user cannot provide timezone arguments as JDBC parameters - they are

airbyte-integrations/connectors/source-mysql/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/AbstractMySqlSourceDatatypeTest.java

@@ -100,6 +100,15 @@ protected void initTests() {
             .addExpectedValues(null, "true", "false")
             .build());
 
+    addDataTypeTestData(
+        TestDataHolder.builder()
+            .sourceType("tinyint")
+            .fullSourceDataType("tinyint(1) unsigned")
+            .airbyteType(JsonSchemaType.INTEGER)
+            .addInsertValues("null", "0", "1", "2", "3")
+            .addExpectedValues(null, "0", "1", "2", "3")
+            .build());
+
     addDataTypeTestData(
         TestDataHolder.builder()
             .sourceType("tinyint")