Support binary type (bakwc#35)

Author: bakwc

mysql_ch_replicator/converter.py

@@ -194,6 +194,8 @@ def convert_type(self, mysql_type, parameters):
             return 'String'
         if 'varbinary' in mysql_type:
             return 'String'
+        if 'binary' in mysql_type:
+            return 'String'
         raise Exception(f'unknown mysql type "{mysql_type}"')
 
     def convert_field_type(self, mysql_type, mysql_parameters):

test_mysql_ch_replicator.py

@@ -717,13 +717,14 @@ def test_different_types_2():
     `id` int unsigned NOT NULL AUTO_INCREMENT,
     test1 bit(1),
     test2 point,
+    test3 binary(16),
     PRIMARY KEY (id)
 ); 
     ''')
 
     mysql.execute(
-        f"INSERT INTO {TEST_TABLE_NAME} (test1, test2) VALUES "
-        f"(0, POINT(10.0, 20.0));",
+        f"INSERT INTO {TEST_TABLE_NAME} (test1, test2, test3) VALUES "
+        f"(0, POINT(10.0, 20.0), 'azaza');",
         commit=True,
     )
 
@@ -749,6 +750,7 @@ def test_different_types_2():
 
     assert ch.select(TEST_TABLE_NAME, 'test1=True')[0]['test2']['x'] == 15.0
     assert ch.select(TEST_TABLE_NAME, 'test1=False')[0]['test2']['y'] == 20.0
+    assert ch.select(TEST_TABLE_NAME, 'test1=False')[0]['test3'] == 'azaza\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00'
 
     mysql.execute(
         f"INSERT INTO {TEST_TABLE_NAME} (test1, test2) VALUES "