@@ -215,7 +215,7 @@ private CompletableFuture<HttpResponse<InputStream>> postRequest(HttpRequest req
215215 private ClickHouseHttpResponse postStream (ClickHouseConfig config , HttpRequest .Builder reqBuilder , byte [] boundary ,
216216 String sql , ClickHouseInputStream data , List <ClickHouseExternalTable > tables , ClickHouseOutputStream output ,
217217 Runnable postAction ) throws IOException {
218- try {
218+
219219 ClickHousePipedOutputStream stream = ClickHouseDataStreamFactory .getInstance ()
220220 .createPipedOutputStream (config );
221221 reqBuilder .POST (HttpRequest .BodyPublishers .ofInputStream (stream ::getInputStream ));
@@ -240,12 +240,11 @@ private ClickHouseHttpResponse postStream(ClickHouseConfig config, HttpRequest.B
240240 }
241241
242242 return buildResponse (config , r , output , postAction );
243- }
244243 }
245244
246245 private ClickHouseHttpResponse postString (ClickHouseConfig config , HttpRequest .Builder reqBuilder , String sql ,
247246 ClickHouseOutputStream output , Runnable postAction ) throws IOException {
248- try {
247+
249248 reqBuilder .POST (HttpRequest .BodyPublishers .ofString (sql ));
250249 HttpResponse <InputStream > r ;
251250 try {
@@ -262,7 +261,6 @@ private ClickHouseHttpResponse postString(ClickHouseConfig config, HttpRequest.B
262261 }
263262 }
264263 return buildResponse (config , r , output , postAction );
265- }
266264 }
267265
268266 @ Override
0 commit comments