added tuple support

Author: chernser

client-v2/src/main/java/com/clickhouse/client/api/internal/SerializerUtils.java

@@ -81,9 +81,18 @@ private static void serializeArrayData(OutputStream stream, Object value, ClickH
     private static void serializeTupleData(OutputStream stream, Object value, ClickHouseColumn column) throws IOException {
         //Serialize the tuple to the stream
         //The tuple is a list of values
-        List<?> values = (List<?>) value;
-        for (int i = 0; i < values.size(); i++) {
-            serializeData(stream, values.get(i), column.getNestedColumns().get(i));
+        if (value instanceof List) {
+            List<?> values = (List<?>) value;
+            for (int i = 0; i < values.size(); i++) {
+                serializeData(stream, values.get(i), column.getNestedColumns().get(i));
+            }
+        } else if (value instanceof Object[]) {
+            Object[] values = (Object[]) value;
+            for (int i = 0; i < values.length; i++) {
+                serializeData(stream, values[i], column.getNestedColumns().get(i));
+            }
+        } else {
+            throw new IllegalArgumentException("Cannot serialize " + value + " as a tuple");
         }
     }
 

client-v2/src/test/java/com/clickhouse/client/query/QuerySamplePOJO.java

@@ -68,6 +68,9 @@ public class QuerySamplePOJO {
 
     private List<String> array;
     private List<?> tuple;
+
+    private Object[] tupleArray;
+
     private Map<String, Integer> map;
     private List<Integer> nestedInnerInt;
     private List<String> nestedInnerString;
@@ -143,6 +146,7 @@ public QuerySamplePOJO() {
 
         array = Arrays.asList("a", "b", "c", "d", "e", "f", "g", "h", "i", "j", "k", "l", "m", "n", "o", "p", "q", "r", "s", "t", "u", "v", "w", "x", "y", "z");
         tuple = Arrays.asList(random.nextInt(), random.nextDouble(), "a", "b");
+        tupleArray = new Object[] {random.nextInt(), random.nextDouble(), "c", "d" };
         map = new HashMap<>();
         for (int i = 0; i < 10; i++) {
             map.put(String.valueOf((char) ('a' + i)), i + 1);
@@ -437,6 +441,14 @@ public void setTuple(List<?> tuple) {
         this.tuple = tuple;
     }
 
+    public Object[] getTupleArray() {
+        return tupleArray;
+    }
+
+    public void setTupleArray(Object[] tupleArray) {
+        this.tupleArray = tupleArray;
+    }
+
     public Map<String, Integer> getMap() {
         return map;
     }
@@ -560,6 +572,7 @@ public static String generateTableCreateSQL(String tableName) {
                 "ipv6 IPv6, " +
                 "array Array(String), " +
                 "tuple Tuple(Int32, Float64, String, String), " +
+                "tupleArray Tuple(Int32, Float64, String, String), " +
                 "map Map(String, Int32), " +
                 "nested Nested (innerInt Int32, innerString String)" +
                 ") ENGINE = Memory";