|
20 | 20 | import com.clickhouse.client.api.insert.InsertResponse; |
21 | 21 | import com.clickhouse.client.api.insert.InsertSettings; |
22 | 22 | import com.clickhouse.client.api.insert.POJOSerializer; |
23 | | -import com.clickhouse.client.api.insert.SerializerNotFoundException; |
24 | | -import com.clickhouse.client.api.internal.BasicObjectsPool; |
25 | 23 | import com.clickhouse.client.api.internal.ClickHouseLZ4OutputStream; |
26 | 24 | import com.clickhouse.client.api.internal.ClientStatisticsHolder; |
27 | 25 | import com.clickhouse.client.api.internal.ClientV1AdaptorHelper; |
|
64 | 62 | import java.net.URL; |
65 | 63 | import java.nio.charset.StandardCharsets; |
66 | 64 | import java.time.Duration; |
67 | | -import java.time.LocalDate; |
68 | | -import java.time.LocalDateTime; |
69 | 65 | import java.time.ZoneId; |
70 | 66 | import java.time.temporal.ChronoUnit; |
71 | 67 | import java.util.ArrayList; |
72 | 68 | import java.util.Collections; |
73 | 69 | import java.util.HashMap; |
74 | 70 | import java.util.HashSet; |
75 | 71 | import java.util.LinkedHashMap; |
76 | | -import java.util.LinkedList; |
77 | 72 | import java.util.List; |
78 | 73 | import java.util.Map; |
79 | 74 | import java.util.Set; |
@@ -1560,12 +1555,12 @@ public <T> List<T> queryAll(String sqlQuery, Class<T> clazz, Supplier<T> allocat |
1560 | 1555 |
|
1561 | 1556 | try { |
1562 | 1557 | int operationTimeout = getOperationTimeout(); |
1563 | | - QuerySettings settings = new QuerySettings(); |
| 1558 | + QuerySettings settings = new QuerySettings().setFormat(ClickHouseFormat.RowBinaryWithNamesAndTypes); |
1564 | 1559 | try (QueryResponse response = operationTimeout == 0 ? query(sqlQuery, settings).get() : |
1565 | 1560 | query(sqlQuery, settings).get(operationTimeout, TimeUnit.MILLISECONDS)) { |
1566 | 1561 | List<T> records = new ArrayList<>(); |
1567 | 1562 | RowBinaryWithNamesAndTypesFormatReader reader = |
1568 | | - new RowBinaryWithNamesAndTypesFormatReader(response.getInputStream(), response.getSettings()); |
| 1563 | + (RowBinaryWithNamesAndTypesFormatReader) newBinaryFormatReader(response); |
1569 | 1564 |
|
1570 | 1565 | while (true) { |
1571 | 1566 | Object record = allocator == null ? clazz.getDeclaredConstructor().newInstance() : allocator.get(); |
|
0 commit comments