alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-149 Corrected type of BINARY column

Browse Source 
The MySQL connector (or rather the DDL parser used in the connector) improperly assumed a `CHAR` JDBC type (and Avro schema `STRING` type) for MySQL columns of type `BINARY`. This corrects the error.
This commit is contained in:
Randall Hauch 2016-11-08 17:38:27 -06:00
parent c66037f52a
commit 0d2acfd0a6
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlDdlParser.java
View File

@ -108,9 +108,9 @@ protected void initializeDataTypes(DataTypeParser dataTypes) {
dataTypes.register(Types.INTEGER, "YEAR[(2|4)]");
dataTypes.register(Types.BLOB, "CHAR[(L)] BINARY");
dataTypes.register(Types.BLOB, "VARCHAR(L) BINARY");
dataTypes.register(Types.CHAR, "CHAR[(L)]");
dataTypes.register(Types.BLOB, "BINARY[(L)]");
dataTypes.register(Types.VARCHAR, "VARCHAR(L)");
dataTypes.register(Types.CHAR, "BINARY[(L)]");
dataTypes.register(Types.CHAR, "CHAR[(L)]");
dataTypes.register(Types.VARBINARY, "VARBINARY(L)");
dataTypes.register(Types.BLOB, "TINYBLOB");
dataTypes.register(Types.BLOB, "BLOB");