You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by ja...@apache.org on 2013/05/20 15:13:09 UTC
git commit: SQOOP-1048: Sqoop2: NPE when importing NULL value
Updated Branches:
refs/heads/sqoop2 2941fa666 -> 61335e6e8
SQOOP-1048: Sqoop2: NPE when importing NULL value
(Vasanth kumar RJ via Jarek Jarcec Cecho)
Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/61335e6e
Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/61335e6e
Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/61335e6e
Branch: refs/heads/sqoop2
Commit: 61335e6e821c40dfa258c8000514c5d1040d1788
Parents: 2941fa6
Author: Jarek Jarcec Cecho <ja...@apache.org>
Authored: Mon May 20 06:12:28 2013 -0700
Committer: Jarek Jarcec Cecho <ja...@apache.org>
Committed: Mon May 20 06:12:28 2013 -0700
----------------------------------------------------------------------
.../jdbc/GenericJdbcConnectorConstants.java | 2 ++
.../connector/jdbc/GenericJdbcImportExtractor.java | 3 ++-
2 files changed, 4 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/sqoop/blob/61335e6e/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcConnectorConstants.java
----------------------------------------------------------------------
diff --git a/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcConnectorConstants.java b/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcConnectorConstants.java
index 23f19b5..abcc89d 100644
--- a/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcConnectorConstants.java
+++ b/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcConnectorConstants.java
@@ -51,6 +51,8 @@ public final class GenericJdbcConnectorConstants {
public static final String SUBQUERY_ALIAS = "SQOOP_SUBQUERY_ALIAS";
+ public static final String SQL_NULL_VALUE = "null";
+
private GenericJdbcConnectorConstants() {
// Disable explicit object creation
}
http://git-wip-us.apache.org/repos/asf/sqoop/blob/61335e6e/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportExtractor.java
----------------------------------------------------------------------
diff --git a/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportExtractor.java b/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportExtractor.java
index d54b430..3f9aa9b 100644
--- a/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportExtractor.java
+++ b/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportExtractor.java
@@ -55,7 +55,8 @@ public class GenericJdbcImportExtractor extends Extractor<ConnectionConfiguratio
while (resultSet.next()) {
Object[] array = new Object[column];
for (int i = 0; i< column; i++) {
- array[i] = resultSet.getObject(i+1);
+ array[i] = resultSet.getObject(i + 1) == null ? GenericJdbcConnectorConstants.SQL_NULL_VALUE
+ : resultSet.getObject(i + 1);
}
context.getDataWriter().writeArrayRecord(array);
rowsRead++;