Skip to content

Commit 2d2491e

Browse files
committed
fixed issue reading missing paths in 25.3 version.
1 parent eeee5cf commit 2d2491e

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

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

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -56,6 +56,8 @@ public class BinaryStreamReader {
5656

5757
private static final int SB_INIT_SIZE = 100;
5858

59+
private ClickHouseColumn lastDataColumn = null;
60+
5961
/**
6062
* Createa a BinaryStreamReader instance that will use the provided buffer allocator.
6163
*
@@ -108,6 +110,7 @@ public <T> T readValue(ClickHouseColumn column, Class<?> typeHint) throws IOExce
108110
}
109111

110112
ClickHouseColumn actualColumn = column.getDataType() == ClickHouseDataType.Dynamic ? readDynamicData() : column;
113+
lastDataColumn = actualColumn;
111114
ClickHouseDataType dataType = actualColumn.getDataType();
112115
int precision = actualColumn.getPrecision();
113116
int scale = actualColumn.getScale();
@@ -1336,6 +1339,9 @@ private Map<String, Object> readJsonData(InputStream input, ClickHouseColumn col
13361339
ClickHouseColumn dataColumn = predefinedColumns == null? JSON_PLACEHOLDER_COL :
13371340
predefinedColumns.getOrDefault(path, JSON_PLACEHOLDER_COL);
13381341
Object value = readValue(dataColumn);
1342+
if (value == null && (lastDataColumn != null && lastDataColumn.getDataType() == ClickHouseDataType.Nothing) ) {
1343+
continue;
1344+
}
13391345
obj.put(path, value);
13401346
}
13411347
return obj;

0 commit comments

Comments
 (0)