in java/clickhouse-connector/src/integration-test/java/com/epam/deltix/timebase/connector/clickhouse/BaseStreamReplicatorTests.java [273:288]
protected static Object getValue(final DataTypes type, final ResultSet rs, final String columnLabel, boolean isNested) throws SQLException {
if (isNested) return rs.getObject(columnLabel);
switch (type) {
case UINT8:
return isNotNullOrArray(rs, columnLabel) ? rs.getBoolean(columnLabel) : rs.getObject(columnLabel);
case INT8:
return isNotNullOrArray(rs, columnLabel) ? rs.getByte(columnLabel) : rs.getObject(columnLabel);
case INT16:
return isNotNullOrArray(rs, columnLabel) ? rs.getShort(columnLabel) : rs.getObject(columnLabel);
case DATE_TIME64:
return rs.getString(columnLabel);
default:
return rs.getObject(columnLabel);
}
}