diff --git a/pipelinewise/fastsync/commons/tap_mysql.py b/pipelinewise/fastsync/commons/tap_mysql.py index 220ea9572..89b8c4389 100644 --- a/pipelinewise/fastsync/commons/tap_mysql.py +++ b/pipelinewise/fastsync/commons/tap_mysql.py @@ -357,7 +357,7 @@ def get_table_columns(self, table_name, max_num=None, date_type='date'): WHEN data_type IN ('blob', 'tinyblob', 'mediumblob', 'longblob') THEN CONCAT('REPLACE(hex(`', column_name, '`)', ", '\n', ' ')") WHEN data_type IN ('binary', 'varbinary') - THEN concat('REPLACE(REPLACE(hex(trim(trailing CHAR(0x00) from `',COLUMN_NAME,'`))', ", '\n', ' '), '\r', '')") + THEN concat('REPLACE(REPLACE(hex(`',COLUMN_NAME,'`)', ", '\n', ' '), '\r', '')") WHEN data_type IN ('bit') THEN concat('cast(`', column_name, '` AS unsigned)') WHEN data_type IN ('date') diff --git a/singer-connectors/tap-mysql/requirements.txt b/singer-connectors/tap-mysql/requirements.txt index 9e9397c77..f09a912c2 100644 --- a/singer-connectors/tap-mysql/requirements.txt +++ b/singer-connectors/tap-mysql/requirements.txt @@ -1 +1 @@ -pipelinewise-tap-mysql==1.5.5 +pipelinewise-tap-mysql==1.5.6 \ No newline at end of file diff --git a/tests/db/tap_mysql_data.sql b/tests/db/tap_mysql_data.sql index deec5c03a..008547193 100644 --- a/tests/db/tap_mysql_data.sql +++ b/tests/db/tap_mysql_data.sql @@ -1608,7 +1608,7 @@ DROP TABLE IF EXISTS `all_datatypes`; CREATE TABLE `all_datatypes` ( c_char CHAR PRIMARY KEY, c_varchar VARCHAR(100), - c_binary BINARY, + c_binary BINARY(6), c_varbinary VARBINARY(100), c_blob BLOB, c_tinyblob TINYBLOB,