Merge branch 'main' into fix_duplicate_queryId

Author: chernser

.github/workflows/nightly.yml

@@ -12,7 +12,7 @@ on:
 
 env:
   CHC_BRANCH: "main"
-  CHC_VERSION: "0.6.0"
+  CHC_VERSION: "0.6.1"
 
 jobs:
   nightly:

.github/workflows/release.yml

@@ -6,7 +6,7 @@ on:
       version:
         description: "Release version"
         required: true
-        default: "0.6.0-SNAPSHOT"
+        default: "0.6.1-SNAPSHOT"
 
 jobs:
   release:
@@ -57,8 +57,8 @@ jobs:
           maven_args: -q --batch-mode
           gpg_private_key: ${{ secrets.GPG_PRIVATE_KEY }}
           gpg_passphrase: ${{ secrets.GPG_PASSPHRASE }}
-          nexus_username: ${{ secrets.SONATYPE_USER }}
-          nexus_password: ${{ secrets.SONATYPE_PASSWD }}
+          nexus_username: ${{ secrets.SONATYPE_TOKEN_USER }}
+          nexus_password: ${{ secrets.SONATYPE_TOKEN }}
       - name: Release R2DBC 0.9.1
         uses: samuelmeuli/action-maven-publish@v1
         with:
@@ -67,8 +67,8 @@ jobs:
           maven_args: -q --batch-mode -Dr2dbc-spi.version=0.9.1.RELEASE
           gpg_private_key: ${{ secrets.GPG_PRIVATE_KEY }}
           gpg_passphrase: ${{ secrets.GPG_PASSPHRASE }}
-          nexus_username: ${{ secrets.SONATYPE_USER }}
-          nexus_password: ${{ secrets.SONATYPE_PASSWD }}
+          nexus_username: ${{ secrets.SONATYPE_TOKEN_USER }}
+          nexus_password: ${{ secrets.SONATYPE_TOKEN }}
       - name: Create Pre-release on Github
         uses: "zhicwu/action-automatic-releases@latest"
         with:

clickhouse-client/src/main/java/com/clickhouse/client/ClickHouseNode.java

@@ -787,7 +787,10 @@ public static ClickHouseNode of(String uri, Map<?, ?> options) {
         String scheme = normalizedUri.getScheme();
         ClickHouseProtocol protocol = ClickHouseProtocol.fromUriScheme(scheme);
         int port = extract(scheme, normalizedUri.getPort(), protocol, params);
-
+        if ((options == null || options.get(ClickHouseClientOption.SSL.getKey()) == null)
+                && scheme.equalsIgnoreCase("https")) {
+            params.put(ClickHouseClientOption.SSL.getKey(), "true");
+        }
         ClickHouseCredentials credentials = extract(normalizedUri.getRawUserInfo(), params, null);
 
         return new ClickHouseNode(normalizedUri.getHost(), protocol, port, credentials, params, tags);

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

@@ -191,7 +191,11 @@ public Builder addEndpoint(Protocol protocol, String host, int port, boolean sec
             ValidationUtils.checkNonBlank(host, "host");
             ValidationUtils.checkNotNull(protocol, "protocol");
             ValidationUtils.checkRange(port, 1, ValidationUtils.TCP_PORT_NUMBER_MAX, "port");
-
+            if (secure) {
+                // For some reason com.clickhouse.client.http.ApacheHttpConnectionImpl.newConnection checks only client config
+                // for SSL, so we need to set it here. But it actually should be set for each node separately.
+                this.configuration.put(ClickHouseClientOption.SSL.getKey(), "true");
+            }
             String endpoint = String.format("%s%s://%s:%d", protocol.toString().toLowerCase(), secure ? "s": "", host, port);
             this.addEndpoint(endpoint);
             return this;

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

@@ -18,27 +18,29 @@
 
 public class ClientV1AdaptorHelper {
 
-    private static void copyProxySettings(Map<ClickHouseOption, Serializable> target, Map<String, String> config) {
-        ClickHouseClientOption opt = ClickHouseClientOption.PROXY_HOST;
-        String value = config.get(opt.getKey());
-        if (value != null) {
-            target.put(opt, value);
-        }
-        opt = ClickHouseClientOption.PROXY_PORT;
-        value = config.get(opt.getKey());
-        if (value != null) {
-            target.put(opt, Integer.parseInt(value));
-        }
-        opt = ClickHouseClientOption.PROXY_TYPE;
-        value = config.get(opt.getKey());
-        if (value != null) {
-            target.put(opt, ClickHouseProxyType.valueOf(value));
+    private static void copyClientOptions(Map<ClickHouseOption, Serializable> target, Map<String, String> config) {
+
+        for (ClickHouseClientOption opt : ClickHouseClientOption.values()) {
+            String value = config.get(opt.getKey());
+            if (value == null) {
+                continue;
+            }
+
+            if (opt.getValueType().isAssignableFrom(Integer.class)) {
+                target.put(opt, Integer.parseInt(value));
+            } else if (opt.getValueType().isAssignableFrom(Boolean.class)) {
+                target.put(opt, Boolean.parseBoolean(value));
+            } else if (opt.getValueType().isEnum()) {
+                target.put(opt, Enum.valueOf((Class<Enum>) opt.getValueType(), value));
+            } else if (opt.getValueType().isAssignableFrom(String.class)) {
+                target.put(opt, value);
+            }
         }
     }
 
     public static ClickHouseClient createClient(Map<String, String> configuration) {
         Map<ClickHouseOption, Serializable> config = new HashMap<>();
-        copyProxySettings(config, configuration);
+        copyClientOptions(config, configuration);
 
         ClickHouseConfig clientConfig = new ClickHouseConfig(config);
 

client-v2/src/test/java/com/clickhouse/client/ClientTests.java

@@ -0,0 +1,31 @@
+package com.clickhouse.client;
+
+import com.clickhouse.client.api.Client;
+import com.clickhouse.client.api.enums.Protocol;
+import com.clickhouse.client.api.query.GenericRecord;
+import org.junit.Assert;
+import org.testng.annotations.Test;
+
+import java.util.Optional;
+
+public class ClientTests extends BaseIntegrationTest {
+
+
+    @Test(enabled = false)
+    public void testWithSSL() {
+
+        ClickHouseNode secureNode = getSecureServer(ClickHouseProtocol.HTTP);
+        Client client = new Client.Builder()
+                .addEndpoint(Protocol.HTTP, "localhost", secureNode.getPort(), true)
+                .setUsername("default")
+                .setPassword("")
+                .build();
+
+
+        Optional<GenericRecord> genericRecord = client
+                .queryAll("SELECT hostname()").stream().findFirst();
+        Assert.assertTrue(genericRecord.isPresent());
+
+        System.out.println(genericRecord.get().getString(1));
+    }
+}

pom.xml

@@ -85,8 +85,8 @@
     </distributionManagement>
 
     <properties>
-        <revision>0.6.0-SNAPSHOT</revision>
-        <project.current.year>2023</project.current.year>
+        <revision>0.6.1-SNAPSHOT</revision>
+        <project.current.year>2024</project.current.year>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>