build correctly the cloud endpoint

ClickHouse · Mar 27, 2024 · c9d01fd · c9d01fd
1 parent a615878
commit c9d01fd
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/clickhouse-client/src/test/java/com/clickhouse/client/ClickHouseServerForTest.java b/clickhouse-client/src/test/java/com/clickhouse/client/ClickHouseServerForTest.java
@@ -217,6 +217,11 @@ public static ClickHouseNode getClickHouseNode(ClickHouseProtocol protocol, bool
         if (isCloud()) {
             port = 8443;
             host = System.getenv("CLICKHOUSE_CLOUD_HOST");
+            return ClickHouseNode.builder(template)
+                    .address(protocol, new InetSocketAddress(host, port))
+                    .addOption("password", getPassword())
+                    .addOption("user", "default")
+                    .build();
         } else if (container != null) {
             host = container.getHost();
             port = container.getMappedPort(port);

diff --git a/clickhouse-client/src/test/java/com/clickhouse/client/ClientIntegrationTest.java b/clickhouse-client/src/test/java/com/clickhouse/client/ClientIntegrationTest.java
@@ -195,6 +195,7 @@ protected ClickHouseNode getServer(ClickHouseNode base) {
     }
 
     protected ClickHouseNode getServer() {
+        if (isCloud()) return getSecureServer(getProtocol());
         return getServer(getProtocol());
     }