refactor IDataType

pan3793 · pan3793 · commit 4bc86e62c718 · 2020-12-25T20:46:26.000+08:00
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/IDataType.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/IDataType.java
@@ -21,40 +21,63 @@
 import java.io.IOException;
 import java.sql.SQLException;
 
-// It would be nice if we introduce a Generic Type, `IDataType<T>`, then we can avoid using `Object` and type cast.
-// Unfortunately Java not support unsigned number, UInt8(u_byte) must be represented by Int16(short), which will
-// break the Generic Type constriction and cause compile failed.
-public interface IDataType {
+/**
+ * IDataType is responsible for:
+ * 1. represent data type attributions
+ * 2. serialize and deserialize
+ * 3. parse from sql text
+ * 4. cast between inner type and other types
+ * 5. format to string
+ * @param <T> inner data type, 1:1 map to ClickHouse data type
+ */
+public interface IDataType<T> {
 
+    // 1. represent data type attributions
     String name();
 
-    int sqlTypeId();
+    default String[] getAliases() {
+        return new String[0];
+    }
 
-    Object defaultValue();
+    int sqlTypeId();
 
-    Class javaTypeClass();
+    Class<T> javaTypeClass();
 
     boolean nullable();
 
     int getPrecision();
 
     int getScale();
 
-    Object deserializeTextQuoted(SQLLexer lexer) throws SQLException;
+    T defaultValue();
 
-    Object deserializeBinary(BinaryDeserializer deserializer) throws SQLException, IOException;
+    // 2. serialize and deserialize
+    void serializeBinary(T data, BinarySerializer serializer) throws SQLException, IOException;
 
-    void serializeBinary(Object data, BinarySerializer serializer) throws SQLException, IOException;
-
-    default void serializeBinaryBulk(Object[] data, BinarySerializer serializer) throws SQLException, IOException {
-        for (Object d : data) {
-            serializeBinary(d, serializer);
+    default void serializeBinaryBulk(T[] values, BinarySerializer serializer) throws SQLException, IOException {
+        for (T value : values) {
+            serializeBinary(value, serializer);
         }
     }
 
-    Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws SQLException, IOException;
+    T deserializeBinary(BinaryDeserializer deserializer) throws SQLException, IOException;
 
-    default String[] getAliases() {
-        return new String[0];
+    T[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws SQLException, IOException;
+
+    // 3. parse from sql text
+    T deserializeTextQuoted(SQLLexer lexer) throws SQLException;
+
+    // 4. cast between inner type and other types
+    default <O> T castFrom(O other) {
+        return javaTypeClass().cast(other);
+    }
+
+    default <O> O castTo(T inner, Class<O> castToClazz) {
+        return castToClazz.cast(inner);
+    }
+
+    // 5. format to string
+    default <O> String format(O value) {
+        return castTo(castFrom(value), String.class);
     }
 }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/DataTypeDate.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/DataTypeDate.java
@@ -82,9 +82,9 @@ public Object deserializeBinary(BinaryDeserializer deserializer) throws IOExcept
     }
 
     @Override
-    public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws IOException {
-        Date[] data = new Date[rows];
-        for (int row = 0; row < rows; row++) {
+    public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws IOException {
+        Date[] data = new Date[rowCnt];
+        for (int row = 0; row < rowCnt; row++) {
             short daysSinceEpoch = deserializer.readShort();
             data[row] = Date.valueOf(LocalDate.ofEpochDay(daysSinceEpoch));
         }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/DataTypeFloat32.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/DataTypeFloat32.java
@@ -73,10 +73,10 @@ public Object deserializeBinary(BinaryDeserializer deserializer) throws IOExcept
     }
 
     @Override
-    public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws IOException {
-        Float[] data = new Float[rows];
-        for (int row = 0; row < rows; row++) {
-            data[row] = deserializer.readFloat();
+    public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws IOException {
+        Float[] data = new Float[rowCnt];
+        for (int i = 0; i < rowCnt; i++) {
+            data[i] = deserializer.readFloat();
         }
         return data;
     }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/DataTypeFloat64.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/DataTypeFloat64.java
@@ -73,10 +73,10 @@ public Double deserializeBinary(BinaryDeserializer deserializer) throws SQLExcep
     }
 
     @Override
-    public Double[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws IOException {
-        Double[] data = new Double[rows];
-        for (int row = 0; row < rows; row++) {
-            data[row] = deserializer.readDouble();
+    public Double[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws IOException {
+        Double[] data = new Double[rowCnt];
+        for (int i = 0; i < rowCnt; i++) {
+            data[i] = deserializer.readDouble();
         }
         return data;
     }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/DataTypeIPv4.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/DataTypeIPv4.java
@@ -73,10 +73,10 @@ public Object deserializeBinary(BinaryDeserializer deserializer) throws SQLExcep
     }
 
     @Override
-    public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws SQLException, IOException {
-        Object[] data = new Object[rows];
-        for (int row = 0; row < rows; row++) {
-            data[row] = this.deserializeBinary(deserializer);
+    public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws SQLException, IOException {
+        Object[] data = new Object[rowCnt];
+        for (int i = 0; i < rowCnt; i++) {
+            data[i] = this.deserializeBinary(deserializer);
         }
         return data;
     }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/DataTypeInt16.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/DataTypeInt16.java
@@ -84,10 +84,10 @@ public Object deserializeBinary(BinaryDeserializer deserializer) throws SQLExcep
     }
 
     @Override
-    public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws SQLException, IOException {
-        Object[] data = new Object[rows];
-        for (int row = 0; row < rows; row++) {
-            data[row] = this.deserializeBinary(deserializer);
+    public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws SQLException, IOException {
+        Object[] data = new Object[rowCnt];
+        for (int i = 0; i < rowCnt; i++) {
+            data[i] = this.deserializeBinary(deserializer);
         }
         return data;
     }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/DataTypeInt32.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/DataTypeInt32.java
@@ -84,11 +84,11 @@ public Object deserializeBinary(BinaryDeserializer deserializer) throws SQLExcep
     }
 
     @Override
-    public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer)
+    public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer)
             throws SQLException, IOException {
-        Object[] data = new Object[rows];
-        for (int row = 0; row < rows; row++) {
-            data[row] = this.deserializeBinary(deserializer);
+        Object[] data = new Object[rowCnt];
+        for (int i = 0; i < rowCnt; i++) {
+            data[i] = this.deserializeBinary(deserializer);
         }
         return data;
     }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/DataTypeInt64.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/DataTypeInt64.java
@@ -96,11 +96,11 @@ public BigInteger parseBigIntegerPositive(String num, int bitlen) {
     }
 
     @Override
-    public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer)
+    public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer)
             throws SQLException, IOException {
-        Object[] data = new Object[rows];
-        for (int row = 0; row < rows; row++) {
-            data[row] = this.deserializeBinary(deserializer);
+        Object[] data = new Object[rowCnt];
+        for (int i = 0; i < rowCnt; i++) {
+            data[i] = this.deserializeBinary(deserializer);
         }
         return data;
     }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/DataTypeInt8.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/DataTypeInt8.java
@@ -84,10 +84,10 @@ public Number deserializeBinary(BinaryDeserializer deserializer) throws IOExcept
     }
 
     @Override
-    public Number[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws IOException {
-        Number[] data = new Number[rows];
-        for (int row = 0; row < rows; row++) {
-            data[row] = deserializeBinary(deserializer);
+    public Number[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws IOException {
+        Number[] data = new Number[rowCnt];
+        for (int i = 0; i < rowCnt; i++) {
+            data[i] = deserializeBinary(deserializer);
         }
         return data;
     }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/DataTypeUUID.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/DataTypeUUID.java
@@ -79,10 +79,10 @@ public Object deserializeBinary(BinaryDeserializer deserializer) throws SQLExcep
     }
 
     @Override
-    public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws SQLException, IOException {
-        String[] data = new String[rows];
-        for (int row = 0; row < rows; row++) {
-            data[row] = (String) deserializeBinary(deserializer);
+    public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws SQLException, IOException {
+        String[] data = new String[rowCnt];
+        for (int i = 0; i < rowCnt; i++) {
+            data[i] = (String) deserializeBinary(deserializer);
         }
         return data;
     }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeArray.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeArray.java
@@ -117,11 +117,10 @@ public void serializeBinary(Object data, BinarySerializer serializer) throws SQL
         }
     }
 
-
     @Override
-    public void serializeBinaryBulk(Object[] data, BinarySerializer serializer) throws SQLException, IOException {
-        offsetIDataType.serializeBinary(data.length, serializer);
-        getElemDataType().serializeBinaryBulk(data, serializer);
+    public void serializeBinaryBulk(Object[] values, BinarySerializer serializer) throws SQLException, IOException {
+        offsetIDataType.serializeBinary(values.length, serializer);
+        getElemDataType().serializeBinaryBulk(values, serializer);
     }
 
     @Override
@@ -131,17 +130,17 @@ public Object deserializeBinary(BinaryDeserializer deserializer) throws SQLExcep
     }
 
     @Override
-    public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws IOException, SQLException {
-        ClickHouseArray[] data = new ClickHouseArray[rows];
-        if (rows == 0) {
+    public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws IOException, SQLException {
+        ClickHouseArray[] data = new ClickHouseArray[rowCnt];
+        if (rowCnt == 0) {
             return data;
         }
 
-        Object[] offsets = offsetIDataType.deserializeBinaryBulk(rows, deserializer);
+        Object[] offsets = offsetIDataType.deserializeBinaryBulk(rowCnt, deserializer);
         ClickHouseArray res = new ClickHouseArray(elemDataType,
-                elemDataType.deserializeBinaryBulk(((BigInteger) offsets[rows - 1]).intValue(), deserializer));
+                elemDataType.deserializeBinaryBulk(((BigInteger) offsets[rowCnt - 1]).intValue(), deserializer));
 
-        for (int row = 0, lastOffset = 0; row < rows; row++) {
+        for (int row = 0, lastOffset = 0; row < rowCnt; row++) {
             BigInteger offset = (BigInteger) offsets[row];
             data[row] = res.slice(lastOffset, offset.intValue() - lastOffset);
             lastOffset = offset.intValue();
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeDateTime.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeDateTime.java
@@ -119,10 +119,10 @@ public Object deserializeBinary(BinaryDeserializer deserializer) throws SQLExcep
     }
 
     @Override
-    public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws SQLException, IOException {
-        Timestamp[] data = new Timestamp[rows];
-        for (int row = 0; row < rows; row++) {
-            data[row] = new Timestamp(deserializer.readInt() * 1000L);
+    public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws SQLException, IOException {
+        Timestamp[] data = new Timestamp[rowCnt];
+        for (int i = 0; i < rowCnt; i++) {
+            data[i] = new Timestamp(deserializer.readInt() * 1000L);
         }
         return data;
     }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeDateTime64.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeDateTime64.java
@@ -156,10 +156,10 @@ public void serializeBinary(Object data, BinarySerializer serializer) throws IOE
     }
 
     @Override
-    public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws IOException {
-        Timestamp[] data = new Timestamp[rows];
-        for (int row = 0; row < rows; row++) {
-            data[row] = (Timestamp) deserializeBinary(deserializer);
+    public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws IOException {
+        Timestamp[] data = new Timestamp[rowCnt];
+        for (int i = 0; i < rowCnt; i++) {
+            data[i] = (Timestamp) deserializeBinary(deserializer);
         }
         return data;
     }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeDecimal.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeDecimal.java
@@ -204,10 +204,10 @@ public Object deserializeBinary(BinaryDeserializer deserializer) throws SQLExcep
     }
 
     @Override
-    public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws SQLException, IOException {
-        BigDecimal[] data = new BigDecimal[rows];
-        for (int row = 0; row < rows; row++) {
-            data[row] = (BigDecimal) this.deserializeBinary(deserializer);
+    public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws SQLException, IOException {
+        BigDecimal[] data = new BigDecimal[rowCnt];
+        for (int i = 0; i < rowCnt; i++) {
+            data[i] = (BigDecimal) this.deserializeBinary(deserializer);
         }
         return data;
     }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeEnum16.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeEnum16.java
@@ -139,10 +139,10 @@ public Object deserializeBinary(BinaryDeserializer deserializer) throws SQLExcep
     }
 
     @Override
-    public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws SQLException, IOException {
-        String[] data = new String[rows];
-        for (int row = 0; row < rows; row++) {
-            data[row] = (String) deserializeBinary(deserializer);
+    public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws SQLException, IOException {
+        String[] data = new String[rowCnt];
+        for (int i = 0; i < rowCnt; i++) {
+            data[i] = (String) deserializeBinary(deserializer);
         }
         return data;
     }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeEnum8.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeEnum8.java
@@ -139,10 +139,10 @@ public Object deserializeBinary(BinaryDeserializer deserializer) throws SQLExcep
     }
 
     @Override
-    public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws SQLException, IOException {
-        String[] data = new String[rows];
-        for (int row = 0; row < rows; row++) {
-            data[row] = (String) deserializeBinary(deserializer);
+    public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws SQLException, IOException {
+        String[] data = new String[rowCnt];
+        for (int i = 0; i < rowCnt; i++) {
+            data[i] = (String) deserializeBinary(deserializer);
         }
         return data;
     }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeFixedString.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeFixedString.java
@@ -123,10 +123,10 @@ public Object deserializeBinary(BinaryDeserializer deserializer) throws SQLExcep
     }
 
     @Override
-    public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws SQLException, IOException {
-        String[] data = new String[rows];
-        for (int row = 0; row < rows; row++) {
-            data[row] = new String(deserializer.readBytes(n), charset);
+    public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws SQLException, IOException {
+        String[] data = new String[rowCnt];
+        for (int i = 0; i < rowCnt; i++) {
+            data[i] = new String(deserializer.readBytes(n), charset);
         }
         return data;
     }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeNullable.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeNullable.java
@@ -114,21 +114,21 @@ public Object deserializeBinary(BinaryDeserializer deserializer) throws SQLExcep
     }
 
     @Override
-    public void serializeBinaryBulk(Object[] data, BinarySerializer serializer) throws SQLException, IOException {
-        Short[] isNull = new Short[data.length];
-        for (int i = 0; i < data.length; i++) {
-            isNull[i] = (data[i] == null ? IS_NULL : NON_NULL);
-            data[i] = data[i] == null ? nestedDataType.defaultValue() : data[i];
+    public void serializeBinaryBulk(Object[] values, BinarySerializer serializer) throws SQLException, IOException {
+        Short[] isNull = new Short[values.length];
+        for (int i = 0; i < values.length; i++) {
+            isNull[i] = (values[i] == null ? IS_NULL : NON_NULL);
+            values[i] = values[i] == null ? nestedDataType.defaultValue() : values[i];
         }
         nullMapDataType.serializeBinaryBulk(isNull, serializer);
-        nestedDataType.serializeBinaryBulk(data, serializer);
+        nestedDataType.serializeBinaryBulk(values, serializer);
     }
 
     @Override
-    public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws SQLException, IOException {
-        Object[] nullMap = nullMapDataType.deserializeBinaryBulk(rows, deserializer);
+    public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws SQLException, IOException {
+        Object[] nullMap = nullMapDataType.deserializeBinaryBulk(rowCnt, deserializer);
 
-        Object[] data = nestedDataType.deserializeBinaryBulk(rows, deserializer);
+        Object[] data = nestedDataType.deserializeBinaryBulk(rowCnt, deserializer);
         for (int i = 0; i < nullMap.length; i++) {
             if (IS_NULL.equals(nullMap[i])) {
                 data[i] = null;
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeString.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeString.java
@@ -94,9 +94,9 @@ public String deserializeBinary(BinaryDeserializer deserializer) throws SQLExcep
     }
 
     @Override
-    public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws SQLException, IOException {
-        String[] data = new String[rows];
-        for (int row = 0; row < rows; row++) {
+    public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws SQLException, IOException {
+        String[] data = new String[rowCnt];
+        for (int row = 0; row < rowCnt; row++) {
             byte[] bs = deserializer.readBytesBinary();
             data[row] = new String(bs, charset);
         }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeTuple.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/jdbc/data/type/complex/DataTypeTuple.java

Original file line number	Diff line number	Diff line change
`@@ -82,9 +82,9 @@ public Object deserializeBinary(BinaryDeserializer deserializer) throws IOExcept`
`82`	`82`	`}`
`83`	`83`
`84`	`84`	`@Override`
`85`		`- public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws IOException {`
`86`		`- Date[] data = new Date[rows];`
`87`		`- for (int row = 0; row < rows; row++) {`
	`85`	`+ public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws IOException {`
	`86`	`+ Date[] data = new Date[rowCnt];`
	`87`	`+ for (int row = 0; row < rowCnt; row++) {`
`88`	`88`	`short daysSinceEpoch = deserializer.readShort();`
`89`	`89`	`data[row] = Date.valueOf(LocalDate.ofEpochDay(daysSinceEpoch));`
`90`	`90`	`}`
Original file line number	Diff line number	Diff line change
`@@ -73,10 +73,10 @@ public Object deserializeBinary(BinaryDeserializer deserializer) throws IOExcept`
`73`	`73`	`}`
`74`	`74`
`75`	`75`	`@Override`
`76`		`- public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws IOException {`
`77`		`- Float[] data = new Float[rows];`
`78`		`- for (int row = 0; row < rows; row++) {`
`79`		`- data[row] = deserializer.readFloat();`
	`76`	`+ public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws IOException {`
	`77`	`+ Float[] data = new Float[rowCnt];`
	`78`	`+ for (int i = 0; i < rowCnt; i++) {`
	`79`	`+ data[i] = deserializer.readFloat();`
`80`	`80`	`}`
`81`	`81`	`return data;`
`82`	`82`	`}`
Original file line number	Diff line number	Diff line change
`@@ -73,10 +73,10 @@ public Double deserializeBinary(BinaryDeserializer deserializer) throws SQLExcep`
`73`	`73`	`}`
`74`	`74`
`75`	`75`	`@Override`
`76`		`- public Double[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws IOException {`
`77`		`- Double[] data = new Double[rows];`
`78`		`- for (int row = 0; row < rows; row++) {`
`79`		`- data[row] = deserializer.readDouble();`
	`76`	`+ public Double[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws IOException {`
	`77`	`+ Double[] data = new Double[rowCnt];`
	`78`	`+ for (int i = 0; i < rowCnt; i++) {`
	`79`	`+ data[i] = deserializer.readDouble();`
`80`	`80`	`}`
`81`	`81`	`return data;`
`82`	`82`	`}`
Original file line number	Diff line number	Diff line change
`@@ -84,10 +84,10 @@ public Object deserializeBinary(BinaryDeserializer deserializer) throws SQLExcep`
`84`	`84`	`}`
`85`	`85`
`86`	`86`	`@Override`
`87`		`- public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws SQLException, IOException {`
`88`		`- Object[] data = new Object[rows];`
`89`		`- for (int row = 0; row < rows; row++) {`
`90`		`- data[row] = this.deserializeBinary(deserializer);`
	`87`	`+ public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws SQLException, IOException {`
	`88`	`+ Object[] data = new Object[rowCnt];`
	`89`	`+ for (int i = 0; i < rowCnt; i++) {`
	`90`	`+ data[i] = this.deserializeBinary(deserializer);`
`91`	`91`	`}`
`92`	`92`	`return data;`
`93`	`93`	`}`
Original file line number	Diff line number	Diff line change
`@@ -84,11 +84,11 @@ public Object deserializeBinary(BinaryDeserializer deserializer) throws SQLExcep`
`84`	`84`	`}`
`85`	`85`
`86`	`86`	`@Override`
`87`		`- public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer)`
	`87`	`+ public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer)`
`88`	`88`	`throws SQLException, IOException {`
`89`		`- Object[] data = new Object[rows];`
`90`		`- for (int row = 0; row < rows; row++) {`
`91`		`- data[row] = this.deserializeBinary(deserializer);`
	`89`	`+ Object[] data = new Object[rowCnt];`
	`90`	`+ for (int i = 0; i < rowCnt; i++) {`
	`91`	`+ data[i] = this.deserializeBinary(deserializer);`
`92`	`92`	`}`
`93`	`93`	`return data;`
`94`	`94`	`}`
Original file line number	Diff line number	Diff line change
`@@ -96,11 +96,11 @@ public BigInteger parseBigIntegerPositive(String num, int bitlen) {`
`96`	`96`	`}`
`97`	`97`
`98`	`98`	`@Override`
`99`		`- public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer)`
	`99`	`+ public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer)`
`100`	`100`	`throws SQLException, IOException {`
`101`		`- Object[] data = new Object[rows];`
`102`		`- for (int row = 0; row < rows; row++) {`
`103`		`- data[row] = this.deserializeBinary(deserializer);`
	`101`	`+ Object[] data = new Object[rowCnt];`
	`102`	`+ for (int i = 0; i < rowCnt; i++) {`
	`103`	`+ data[i] = this.deserializeBinary(deserializer);`
`104`	`104`	`}`
`105`	`105`	`return data;`
`106`	`106`	`}`
Original file line number	Diff line number	Diff line change
`@@ -84,10 +84,10 @@ public Number deserializeBinary(BinaryDeserializer deserializer) throws IOExcept`
`84`	`84`	`}`
`85`	`85`
`86`	`86`	`@Override`
`87`		`- public Number[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws IOException {`
`88`		`- Number[] data = new Number[rows];`
`89`		`- for (int row = 0; row < rows; row++) {`
`90`		`- data[row] = deserializeBinary(deserializer);`
	`87`	`+ public Number[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws IOException {`
	`88`	`+ Number[] data = new Number[rowCnt];`
	`89`	`+ for (int i = 0; i < rowCnt; i++) {`
	`90`	`+ data[i] = deserializeBinary(deserializer);`
`91`	`91`	`}`
`92`	`92`	`return data;`
`93`	`93`	`}`
Original file line number	Diff line number	Diff line change
`@@ -79,10 +79,10 @@ public Object deserializeBinary(BinaryDeserializer deserializer) throws SQLExcep`
`79`	`79`	`}`
`80`	`80`
`81`	`81`	`@Override`
`82`		`- public Object[] deserializeBinaryBulk(int rows, BinaryDeserializer deserializer) throws SQLException, IOException {`
`83`		`- String[] data = new String[rows];`
`84`		`- for (int row = 0; row < rows; row++) {`
`85`		`- data[row] = (String) deserializeBinary(deserializer);`
	`82`	`+ public Object[] deserializeBinaryBulk(int rowCnt, BinaryDeserializer deserializer) throws SQLException, IOException {`
	`83`	`+ String[] data = new String[rowCnt];`
	`84`	`+ for (int i = 0; i < rowCnt; i++) {`
	`85`	`+ data[i] = (String) deserializeBinary(deserializer);`
`86`	`86`	`}`
`87`	`87`	`return data;`
`88`	`88`	`}`