in java/clickhouse-connector/src/integration-test/java/com/epam/deltix/timebase/connector/clickhouse/ConcurrentStreamReplicatorTests.java [134:148]
protected static Object getValue(final DataTypes type, final ResultSet rs, final String columnLabel) throws SQLException {
switch (type) {
case UINT8:
return rs.getObject(columnLabel) != null ? rs.getBoolean(columnLabel) : null;
case INT8:
return rs.getObject(columnLabel) != null ? rs.getByte(columnLabel) : null;
case INT16:
return rs.getObject(columnLabel) != null ? rs.getShort(columnLabel) : null;
case DATE_TIME64:
return rs.getString(columnLabel);
default:
return rs.getObject(columnLabel);
}
}