Skip to content

Commit 6c309d5

Browse files
committed
Fixed varbinary
1 parent b7c341b commit 6c309d5

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

mysql_ch_replicator/converter.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -112,6 +112,8 @@ def convert_type(self, mysql_type):
112112
return 'Float64'
113113
if mysql_type.startswith('time'):
114114
return 'String'
115+
if 'varbinary' in mysql_type:
116+
return 'String'
115117
raise Exception(f'unknown mysql type "{mysql_type}"')
116118

117119
def convert_field_type(self, mysql_type, mysql_parameters):

0 commit comments

Comments
 (0)