Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-2811 JdbcCommon doesn't convert bigint(20) column. 

Signed-off-by: Matt Burgess <mattyb149@apache.org>

This closes #1053
This commit is contained in:
Byunghwa Yun 2016-09-23 15:34:49 +09:00 committed by Matt Burgess
parent 30f008d676
commit 28acb07433
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util/JdbcCommon.java
View File

@ -177,8 +177,8 @@ public class JdbcCommon {
// long (and the schema says it will be), so try to get its value as a long.
// Otherwise, Avro can't handle BigInteger as a number - it will throw an AvroRuntimeException
// such as: "Unknown datum type: java.math.BigInteger: 38". In this case the schema is expecting a string.
int precision = meta.getPrecision(i);
if (javaSqlType == BIGINT) {
int precision = meta.getPrecision(i);
if (precision < 0 || precision > MAX_DIGITS_IN_BIGINT) {
rec.put(i - 1, value.toString());
} else {
@ -194,7 +194,16 @@ public class JdbcCommon {
}
} else if (value instanceof Number || value instanceof Boolean) {
rec.put(i - 1, value);
if (javaSqlType == BIGINT) {
int precision = meta.getPrecision(i);
if (precision < 0 || precision > MAX_DIGITS_IN_BIGINT) {
rec.put(i - 1, value.toString());
} else {
rec.put(i - 1, value);
}
} else {
rec.put(i - 1, value);
}
} else {
// The different types that we support are numbers (int, long, double, float),