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

DBZ-3208 Fix regression with Oracle XStreams

Browse Source
This commit is contained in:
Chris Cranford 2021-03-04 10:54:26 -05:00 committed by Gunnar Morling
parent bb24f931d3
commit be80834838
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/converters/NumberOneToBooleanConverter.java
View File

@ -5,6 +5,7 @@
*/ */
package io.debezium.connector.oracle.converters; package io.debezium.connector.oracle.converters;
import java.sql.SQLException;
import java.util.Properties; import java.util.Properties;
import java.util.function.Predicate; import java.util.function.Predicate;
@ -16,6 +17,7 @@
import io.debezium.spi.converter.CustomConverter; import io.debezium.spi.converter.CustomConverter;
import io.debezium.spi.converter.RelationalColumn; import io.debezium.spi.converter.RelationalColumn;
import io.debezium.util.Strings; import io.debezium.util.Strings;
import oracle.sql.NUMBER;
/** /**
* Oracle reports {@code NUMBER(1)} as a numeric column type by default. There may be some cases * Oracle reports {@code NUMBER(1)} as a numeric column type by default. There may be some cases
@ -66,6 +68,14 @@ else if (field.hasDefaultValue()) {
else if (x instanceof Number) { else if (x instanceof Number) {
return ((Number) x).intValue() > 0; return ((Number) x).intValue() > 0;
} }
else if (x instanceof NUMBER) {
try {
return ((NUMBER) x).intValue() > 0;
}
catch (SQLException e) {
// ignored, use fallback below
}
}
else if (x instanceof String) { else if (x instanceof String) {
try { try {
return Integer.parseInt((String) x) > 0; return Integer.parseInt((String) x) > 0;
@ -74,7 +84,7 @@ else if (x instanceof String) {
return Boolean.parseBoolean((String) x); return Boolean.parseBoolean((String) x);
} }
} }
LOGGER.warn("Cannot converter '{}' to boolean", x.getClass()); LOGGER.warn("Cannot convert '{}' to boolean", x.getClass());
return FALLBACK; return FALLBACK;
}); });
} }