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

Merge pull request #201 from rhauch/dbz-197

Browse Source 
DBZ-197 Corrected MySQL connector to handle invalid enum values
This commit is contained in:
Randall Hauch 2017-03-16 14:16:23 -05:00 committed by GitHub
commit a2d6d62fb0
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlValueConverters.java
View File

@ -306,8 +306,13 @@ protected Object convertEnumToString(List<String> options, Column column, Field
if (options != null) {
// The binlog will contain an int with the 1-based index of the option in the enum value ...
int index = ((Integer) data).intValue() - 1; // 'options' is 0-based
if (index < options.size()) {
int value = ((Integer)data).intValue();
if (value == 0) {
// an invalid value was specified, which corresponds to the empty string '' and an index of 0
return "";
}
int index = value - 1; // 'options' is 0-based
if (index < options.size() && index >= 0) {
return options.get(index);
}
}