Skip to content

Commit 09dfdba

Browse files
committed
merged main
1 parent f830df8 commit 09dfdba

File tree

1 file changed

+0
-25
lines changed
  • client-v2/src/main/java/com/clickhouse/client/api

1 file changed

+0
-25
lines changed

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

Lines changed: 0 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -884,31 +884,6 @@ public CompletableFuture<CommandResponse> execute(String sql) {
884884
});
885885
}
886886

887-
private ClickHouseClient createClient() {
888-
ClickHouseConfig clientConfig = new ClickHouseConfig();
889-
ClickHouseClientBuilder clientV1 = ClickHouseClient.builder()
890-
.config(clientConfig)
891-
.nodeSelector(ClickHouseNodeSelector.of(ClickHouseProtocol.HTTP));
892-
return clientV1.build();
893-
}
894-
895-
private ClickHouseRequest.Mutation createMutationRequest(ClickHouseRequest.Mutation request, String tableName, InsertSettings settings) {
896-
if (settings == null) return request.table(tableName);
897-
898-
if (settings.getQueryId() != null) {//This has to be handled separately
899-
request.table(tableName, settings.getQueryId());
900-
} else {
901-
request.table(tableName);
902-
}
903-
904-
//For each setting, set the value in the request
905-
for (Map.Entry<String, Object> entry : settings.getAllSettings().entrySet()) {
906-
request.set(entry.getKey(), String.valueOf(entry.getValue()));
907-
}
908-
909-
return request;
910-
}
911-
912887
private String startOperation() {
913888
String operationId = UUID.randomUUID().toString();
914889
globalClientStats.put(operationId, new ClientStatisticsHolder());

0 commit comments

Comments
 (0)