mysql-source:fix tinyint unsigned handling

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/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")

docs/integrations/sources/mysql.md

@@ -183,6 +183,7 @@ MySQL data types are mapped to the following data types when synchronizing data.
 | `boolean`                                 | boolean                |                                                                                                                |
 | `tinyint(1)`                              | boolean                |                                                                                                                |
 | `tinyint(>1)`                             | number                 |                                                                                                                |
+| `tinyint(>=1) unsigned`                   | number                 |                                                                                                                |
 | `smallint`                                | number                 |                                                                                                                |
 | `mediumint`                               | number                 |                                                                                                                |
 | `int`                                     | number                 |                                                                                                                |