Skip to content

Commit b7db65f

Browse files
committed
fix after merge
1 parent 8f400f4 commit b7db65f

File tree

6 files changed

+17
-12
lines changed

6 files changed

+17
-12
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1137,7 +1137,7 @@ public CompletableFuture<QueryResponse> query(String sqlQuery, Map<String, Objec
11371137
metrics.setQueryId(queryId);
11381138
metrics.operationComplete();
11391139

1140-
return new QueryResponse(httpResponse, finalSettings.getFormat(), metrics);
1140+
return new QueryResponse(httpResponse, finalSettings.getFormat(), finalSettings, metrics);
11411141
} catch (ClientException e) {
11421142
throw e;
11431143
} catch (Exception e) {
@@ -1169,7 +1169,7 @@ public CompletableFuture<QueryResponse> query(String sqlQuery, Map<String, Objec
11691169
clickHouseResponse = request.execute().get();
11701170
}
11711171

1172-
return new QueryResponse(clickHouseResponse, format, clientStats);
1172+
return new QueryResponse(clickHouseResponse, format, clientStats, finalSettings);
11731173
} catch (ClientException e) {
11741174
throw e;
11751175
} catch (Exception e) {

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
@@ -56,8 +56,7 @@ public abstract class AbstractBinaryFormatReader implements ClickHouseBinaryForm
5656
protected AbstractBinaryFormatReader(InputStream inputStream, QuerySettings querySettings, TableSchema schema) {
5757
this.input = inputStream;
5858
this.settings = querySettings == null ? Collections.emptyMap() : new HashMap<>(querySettings.getAllSettings());
59-
boolean useServerTimeZone = (boolean) this.settings.getOrDefault(ClickHouseClientOption.USE_SERVER_TIME_ZONE.getKey(),
60-
false);
59+
boolean useServerTimeZone = (boolean) this.settings.get(ClickHouseClientOption.USE_SERVER_TIME_ZONE.getKey());
6160
TimeZone timeZone = useServerTimeZone ? querySettings.getServerTimeZone() :
6261
(TimeZone) this.settings.get(ClickHouseClientOption.USE_TIME_ZONE.getKey());
6362
if (timeZone == null) {

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -153,6 +153,7 @@ public static Map<String, ClickHouseOption> createMapOfRequestOptions() {
153153
ClickHouseClientOption.USE_OBJECTS_IN_ARRAYS,
154154
ClickHouseClientOption.USE_SERVER_TIME_ZONE,
155155
ClickHouseClientOption.USE_SERVER_TIME_ZONE_FOR_DATES,
156+
ClickHouseClientOption.SERVER_TIME_ZONE,
156157
ClickHouseClientOption.USE_TIME_ZONE)
157158
.forEach(option -> map.put(option.getKey(), option));
158159

client-v2/src/main/java/com/clickhouse/client/api/query/QueryResponse.java

Lines changed: 11 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66
import com.clickhouse.client.api.internal.ClientV1AdaptorHelper;
77
import com.clickhouse.client.api.metrics.OperationMetrics;
88
import com.clickhouse.client.api.metrics.ServerMetrics;
9+
import com.clickhouse.client.config.ClickHouseClientOption;
910
import com.clickhouse.client.http.ClickHouseHttpProto;
1011
import com.clickhouse.data.ClickHouseFormat;
1112
import org.apache.hc.core5.http.ClassicHttpResponse;
@@ -40,27 +41,31 @@ public class QueryResponse implements AutoCloseable {
4041

4142
@Deprecated
4243
public QueryResponse(ClickHouseResponse clickHouseResponse, ClickHouseFormat format,
43-
ClientStatisticsHolder clientStatisticsHolder) {
44+
ClientStatisticsHolder clientStatisticsHolder, QuerySettings settings) {
4445
this.clickHouseResponse = clickHouseResponse;
4546
this.format = format;
4647
this.operationMetrics = new OperationMetrics(clientStatisticsHolder);
4748
this.operationMetrics.operationComplete();
4849
this.operationMetrics.setQueryId(clickHouseResponse.getSummary().getQueryId());
50+
this.settings = settings;
4951
ClientV1AdaptorHelper.setServerStats(clickHouseResponse.getSummary().getProgress(),
5052
this.operationMetrics);
51-
settings.setOption("server_timezone", clickHouseResponse.getTimeZone());
53+
this.settings.setOption(ClickHouseClientOption.SERVER_TIME_ZONE.getKey(), clickHouseResponse.getTimeZone());
5254
}
5355

54-
public QueryResponse(ClassicHttpResponse response, ClickHouseFormat format, OperationMetrics operationMetrics) {
56+
public QueryResponse(ClassicHttpResponse response, ClickHouseFormat format, QuerySettings settings,
57+
OperationMetrics operationMetrics) {
5558
this.clickHouseResponse = null;
5659
this.httpResponse = response;
5760
this.format = format;
5861
this.operationMetrics = operationMetrics;
62+
this.settings = settings;
5963

6064
Header tzHeader = response.getFirstHeader(ClickHouseHttpProto.HEADER_TIMEZONE);
6165
if (tzHeader != null) {
6266
try {
63-
settings.setOption("server_timezone", TimeZone.getTimeZone(tzHeader.getValue()));
67+
this.settings.setOption(ClickHouseClientOption.SERVER_TIME_ZONE.getKey(),
68+
TimeZone.getTimeZone(tzHeader.getValue()));
6469
} catch (Exception e) {
6570
throw new ClientException("Failed to parse server timezone", e);
6671
}
@@ -172,9 +177,9 @@ public String getQueryId() {
172177
}
173178

174179
public TimeZone getTimeZone() {
175-
return settings.getOption("server_timezone") == null
180+
return settings.getOption(ClickHouseClientOption.SERVER_TIME_ZONE.getKey()) == null
176181
? null
177-
: (TimeZone) settings.getOption("server_timezone");
182+
: (TimeZone) settings.getOption(ClickHouseClientOption.SERVER_TIME_ZONE.getKey());
178183
}
179184

180185
public QuerySettings getSettings() {

client-v2/src/main/java/com/clickhouse/client/api/query/QuerySettings.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -151,6 +151,6 @@ public QuerySettings setUseTimeZone(String timeZone) {
151151
}
152152

153153
public TimeZone getServerTimeZone() {
154-
return (TimeZone) rawSettings.get("server_timezone");
154+
return (TimeZone) rawSettings.get(ClickHouseClientOption.SERVER_TIME_ZONE.getKey());
155155
}
156156
}

client-v2/src/test/java/com/clickhouse/client/query/QueryTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ public void setUp() {
8989
.setPassword("")
9090
.compressClientRequest(false)
9191
.compressServerResponse(false)
92-
.useNewImplementation(System.getProperty("client.tests.useNewImplementation", "true").equals("true"))
92+
.useNewImplementation(System.getProperty("client.tests.useNewImplementation", "false").equals("true"))
9393
.build();
9494

9595
delayForProfiler(0);

0 commit comments

Comments
 (0)