Merge branch 'rickyhuo.clickhouse.array'

RickyHuo · May 8, 2018 · e8e7fce · e8e7fce
2 parents fea4ad7 + 25dd9c8
commit e8e7fce
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/src/main/java/com/sina/bip/hangout/outputs/TabSeparated.java b/src/main/java/com/sina/bip/hangout/outputs/TabSeparated.java
@@ -151,7 +151,7 @@ public void bulkInsert(List<Map> events) throws Exception {
 
         int size = fields.size();
         for (Map e: events) {
-            statement.setString(1, "sd");
+            //statement.setString(1, "sd");
 
             for (int i=0; i<size; i++) {
                 String field = fields.get(i);
@@ -169,7 +169,7 @@ public void bulkInsert(List<Map> events) throws Exception {
                                 statement.setInt(i + 1, v);
 
                             } catch (Exception exp) {
-                                String msg = String.format("Cannot Convert %s %s to integer, render default", fieldValue.getClass(), fieldValue);
+                                String msg = String.format("Cannot Convert %s %s to integer, render default. Field is %s", fieldValue.getClass(), fieldValue, field);
                                 log.warn(msg);
                                 log.error(exp);
                                 statement.setInt(i + 1, 0);
@@ -225,6 +225,15 @@ public void bulkInsert(List<Map> events) throws Exception {
                         }
 
                         break;
+                    case "Array(String)":
+                        if (fieldValue != null) {
+                            List<String> v = (List) fieldValue;
+                            String [] array = v.toArray(new String[v.size()]);
+                            statement.setArray(i + 1, this.conn.createArrayOf("string", array));
+                        } else {
+                            statement.setArray(i + 1, this.conn.createArrayOf("string", new String[1]));
+                        }
+
                 }
             }
             statement.addBatch();