Merge remote-tracking branch 'origin/v0.10.0' into sync/release_0.10.0

Author: chernser

CHANGELOG.md

@@ -108,6 +108,17 @@
   previously set in milliseconds but mistakenly retrieved and used in seconds in some places. Now it correctly uses
   milliseconds consistently. (https://github.com/ClickHouse/clickhouse-java/issues/2358)
 
+- **[client-v2]** HTTP `503 Service Unavailable` responses are now surfaced as a connection-style failure (
+  `java.net.ConnectException`) and are retried by default. Previously a `503` was treated as a server error (
+  `ServerException`) and fell under the `ServerRetryable` fault cause. It has been moved to the `ConnectTimeout` fault
+  cause category so that connectivity/availability failures are handled uniformly with other connection errors. Callers
+  that specifically excluded `ServerRetryable` to avoid retrying `503` should now adjust their
+  `client_retry_on_failures` configuration to exclude `ConnectTimeout` instead.
+
+- **[client-v2]** Unexpected/unknown HTTP status codes (those the client cannot interpret as a ClickHouse response) now
+  throw a `ClientException` instead of a `ServerException`. Since the client cannot meaningfully handle these responses,
+  they are reported as a client-side error rather than being attributed to the server.
+
 ### New Features
 
 - **[client-v2, jdbc-v2]** Added support for an application-supplied `javax.net.ssl.SSLContext`. In client-v2,
@@ -174,6 +185,12 @@
   supported but will be removed. Please migrate to the new property. 
   (https://github.com/ClickHouse/clickhouse-java/issues/2858)
 
+- **[client-v2]** Added `Client#cancelTransportRequest(String queryId)` to cancel an in-flight request that has not yet
+  received a response from the server, identified by the query id supplied in the operation settings. This aborts the
+  request on the client side (cancels the underlying IO operation) but does **not** issue a `KILL QUERY` on the server,
+  so a query that already started executing may continue to run server-side. It is recommended to use operation timeout
+  settings where possible; this API is intended for explicitly aborting a request from the client.
+
 ### Improvements 
 
 - **[jdbc-v2, client-v2]** Added support of hostnames with underscore (`_`) in them. Now it is possible to specify endpoint 

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

@@ -84,6 +84,12 @@ public class ClickHouseHttpProto {
      */
     public static final String QPARAM_QUERY_STMT = "query";
 
+    public static final String QPARAM_ENABLE_HTTP_COMPRESSION = "enable_http_compression";
+
+    public static final String QPARAM_COMPRESS = "compress";
+
+    public static final String QPARAM_DECOMPRESS = "decompress";
+
     public static final int DEFAULT_HTTP_PORT = 8123;
 
     public static final int DEFAULT_HTTPS_PORT = 8443;

client-v2/src/main/java/com/clickhouse/client/api/http/ClickHouseHttpProto.java

@@ -3,21 +3,17 @@
 import com.clickhouse.client.api.http.ClickHouseHttpProto;
 import com.clickhouse.client.api.metrics.OperationMetrics;
 import com.clickhouse.client.api.metrics.ServerMetrics;
+import com.clickhouse.client.api.transport.internal.TransportResponse;
 
-import java.util.Collections;
 import java.util.Map;
 
 public class InsertResponse implements AutoCloseable {
     private OperationMetrics operationMetrics;
     private final Map<String, String> responseHeaders;
 
-    public InsertResponse(OperationMetrics metrics) {
-        this(metrics, Collections.emptyMap());
-    }
-
-    public InsertResponse(OperationMetrics metrics, Map<String, String> responseHeaders) {
+    public InsertResponse(TransportResponse transportResponse, OperationMetrics metrics) {
         this.operationMetrics = metrics;
-        this.responseHeaders = responseHeaders;
+        this.responseHeaders = transportResponse.getHeaders();
     }
 
     @Override

client-v2/src/main/java/com/clickhouse/client/api/insert/InsertResponse.java

@@ -1,5 +1,9 @@
 package com.clickhouse.client.api.internal;
 
+import org.slf4j.Logger;
+
+import java.io.Closeable;
+
 /**
  * Class containing utility methods used across the client.
  */
@@ -14,4 +18,14 @@ public static boolean isNotBlank(String str) {
     public static boolean isBlank(String str) {
         return str == null || str.trim().isEmpty();
     }
+
+    public static void quietClose(Closeable closeable, Logger log) {
+        if (closeable != null) {
+            try {
+                closeable.close();
+            } catch (Exception e) {
+                log.warn("Failed to close object " + closeable, e);
+            }
+        }
+    }
 }