Skip to content

Commit 3eaf4c0

Browse files
committed
reimplemented without converter methods
1 parent abcdfcc commit 3eaf4c0

File tree

6 files changed

+196
-230
lines changed

6 files changed

+196
-230
lines changed

client-v2/src/main/java/com/clickhouse/client/api/Client.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -977,7 +977,7 @@ public synchronized void register(Class<?> clazz, TableSchema schema) {
977977
Method setterMethod = classSetters.get(propertyName);
978978
String columnName = column.getColumnName();
979979
if (setterMethod != null) {
980-
classDeserializers.put(columnName, SerializerUtils.compilePOJOSetter(setterMethod));
980+
classDeserializers.put(columnName, SerializerUtils.compilePOJOSetter(setterMethod, column));
981981
} else {
982982
LOG.warn("No setter method found for column: {}", propertyName);
983983
}

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@
1818
import java.io.EOFException;
1919
import java.io.IOException;
2020
import java.io.InputStream;
21-
import java.lang.reflect.InvocationTargetException;
2221
import java.math.BigDecimal;
2322
import java.math.BigInteger;
2423
import java.net.Inet4Address;
@@ -93,7 +92,7 @@ public boolean readToPOJO(Map<String, POJOSetter> deserializers, Object obj ) th
9392
}
9493
throw e;
9594
} catch (Exception e) {
96-
throw new ClientException("Failed to put value into POJO", e);
95+
throw new ClientException("Failed to put value of '" + column.getColumnName() + "' into POJO", e);
9796
}
9897
}
9998
return true;

0 commit comments

Comments
 (0)