Fix bugs if null value in cells

mvalleavila · mvalleavila · commit fd13bc84384f · 2015-05-27T18:34:04.000+02:00
diff --git a/src/main/java/org/keedio/flume/source/SQLSourceHelper.java b/src/main/java/org/keedio/flume/source/SQLSourceHelper.java
@@ -124,7 +124,10 @@ public List<String[]> getAllRows(List<List<Object>> queryResult){
 			List<Object> rawRow = queryResult.get(i);
 			row = new String[rawRow.size()];
 			for (int j=0; j< rawRow.size(); j++){
-				row[j] = rawRow.get(j).toString();
+				if (rawRow.get(j) != null)
+					row[j] = rawRow.get(j).toString();
+				else
+					row[j] = "";
 			}
 			allRows.add(row);
 		}

Original file line number	Diff line number	Diff line change
`@@ -124,7 +124,10 @@ public List<String[]> getAllRows(List<List<Object>> queryResult){`
`124`	`124`	`List<Object> rawRow = queryResult.get(i);`
`125`	`125`	`row = new String[rawRow.size()];`
`126`	`126`	`for (int j=0; j< rawRow.size(); j++){`
`127`		`- row[j] = rawRow.get(j).toString();`
	`127`	`+ if (rawRow.get(j) != null)`
	`128`	`+ row[j] = rawRow.get(j).toString();`
	`129`	`+ else`
	`130`	`+ row[j] = "";`
`128`	`131`	`}`
`129`	`132`	`allRows.add(row);`
`130`	`133`	`}`