File tree Expand file tree Collapse file tree 7 files changed +134
-1178
lines changed
client-v2/src/main/java/com/clickhouse/client/api Expand file tree Collapse file tree 7 files changed +134
-1178
lines changed Load Diff Large diffs are not rendered by default.
Original file line number Diff line number Diff line change 11package com .clickhouse .client .api .insert ;
22
3- import com .clickhouse .client .ClickHouseResponse ;
4- import com .clickhouse .client .api .internal .ClientStatisticsHolder ;
5- import com .clickhouse .client .api .internal .ClientV1AdaptorHelper ;
63import com .clickhouse .client .api .metrics .OperationMetrics ;
74import com .clickhouse .client .api .metrics .ServerMetrics ;
85
96public class InsertResponse implements AutoCloseable {
10- private final ClickHouseResponse responseRef ;
117 private OperationMetrics operationMetrics ;
128
13- public InsertResponse (ClickHouseResponse responseRef ,
14- ClientStatisticsHolder clientStatisticsHolder ) {
15- this .responseRef = responseRef ;
16- this .operationMetrics = new OperationMetrics (clientStatisticsHolder );
17- this .operationMetrics .operationComplete ();
18- this .operationMetrics .setQueryId (responseRef .getSummary ().getQueryId ());
19- ClientV1AdaptorHelper .setServerStats (responseRef .getSummary ().getProgress (), this .operationMetrics );
20- }
21-
229 public InsertResponse (OperationMetrics metrics ) {
23- this .responseRef = null ;
2410 this .operationMetrics = metrics ;
2511 }
2612
2713 @ Override
2814 public void close () {
29- if (responseRef != null ) {
30- responseRef .close ();
31- }
3215 }
3316
3417 /**
Original file line number Diff line number Diff line change 11package com .clickhouse .client .api .insert ;
22
3+ import com .clickhouse .client .ClickHouseProtocol ;
34import com .clickhouse .client .api .Client ;
45import com .clickhouse .client .api .ClientConfigProperties ;
5- import com .clickhouse .client .api .internal . ServerSettings ;
6+ import com .clickhouse .client .api .enums . Protocol ;
67import com .clickhouse .client .api .internal .ValidationUtils ;
7- import com .clickhouse .client .config .ClickHouseClientOption ;
88import org .apache .hc .core5 .http .HttpHeaders ;
99
1010import java .util .Collection ;
@@ -79,14 +79,14 @@ public InsertSettings setDeduplicationToken(String token) {
7979 }
8080
8181 public String getQueryId () {
82- return (String ) rawSettings .get (ClickHouseClientOption .QUERY_ID .getKey ());
82+ return (String ) rawSettings .get (ClientConfigProperties .QUERY_ID .getKey ());
8383 }
8484
8585 /**
8686 * Sets the query id. This id will be sent to the server and can be used to identify the query.
8787 */
8888 public InsertSettings setQueryId (String queryId ) {
89- rawSettings .put (ClickHouseClientOption .QUERY_ID .getKey (), queryId );
89+ rawSettings .put (ClientConfigProperties .QUERY_ID .getKey (), queryId );
9090 return this ;
9191 }
9292
Load Diff This file was deleted.
Original file line number Diff line number Diff line change 33import com .clickhouse .client .ClickHouseNode ;
44import com .clickhouse .client .ClickHouseSslContextProvider ;
55import com .clickhouse .client .api .Client ;
6+ import com .clickhouse .client .api .ClientConfigProperties ;
67import com .clickhouse .client .api .ClientException ;
78import com .clickhouse .client .api .ClientFaultCause ;
89import com .clickhouse .client .api .ClientMisconfigurationException ;
9- import com .clickhouse .client .api .ClientConfigProperties ;
1010import com .clickhouse .client .api .ConnectionInitiationException ;
1111import com .clickhouse .client .api .ConnectionReuseStrategy ;
1212import com .clickhouse .client .api .ServerException ;
You can’t perform that action at this time.
0 commit comments