Merge branch 'main' into clientv2_pojo_deserializers

Author: chernser

.github/workflows/analysis.yml

@@ -54,9 +54,7 @@ jobs:
         uses: actions/setup-java@v4
         with:
           distribution: "temurin"
-          java-version: |
-            8
-            17
+          java-version: 17
           cache: "maven"
       - name: Setup Toolchain
         shell: bash
@@ -90,13 +88,13 @@ jobs:
       - name: Build and install
         run: |
           find . -type f -name "simplelogger.*" -exec rm -fv '{}' \;
-          mvn -q --batch-mode --projects '!clickhouse-benchmark' -DclickhouseVersion=$PREFERRED_LTS_VERSION \
+          mvn -q --batch-mode -DclickhouseVersion=$PREFERRED_LTS_VERSION \
             -DskipTests install
       - name: Analyze
         env:
           GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }} # Needed to get PR information, if any
           SONAR_TOKEN: ${{ secrets.SONAR_TOKEN }}
         run: |
-          mvn --batch-mode --projects '!clickhouse-benchmark' -DclickhouseVersion=$PREFERRED_LTS_VERSION \
+          mvn --batch-mode -DclickhouseVersion=$PREFERRED_LTS_VERSION \
             -Panalysis verify org.sonarsource.scanner.maven:sonar-maven-plugin:sonar
         continue-on-error: true

README.md

@@ -1984,6 +1984,7 @@ public void testInsertWithCustomFormat() throws ClickHouseException {
 
     @Test(groups = { "integration" })
     public void testInsertRawDataSimple() throws Exception {
+        if (isCloud()) return; // TODO: This test is really just for performance purposes
         testInsertRawDataSimple(1000);
     }
     public void testInsertRawDataSimple(int numberOfRecords) throws Exception {

clickhouse-client/src/test/java/com/clickhouse/client/ClientIntegrationTest.java

@@ -95,7 +95,7 @@ private CloseableHttpClient newConnection(ClickHouseConfig c) throws IOException
         }
 
         long connectionTTL = config.getLongOption(ClickHouseClientOption.CONNECTION_TTL);
-        log.info("Connection TTL: %d ms", connectionTTL);
+        log.debug("Connection TTL: %d ms", connectionTTL);
         String poolReuseStrategy = c.getStrOption(ClickHouseHttpOption.CONNECTION_REUSE_STRATEGY);
         PoolReusePolicy poolReusePolicy = PoolReusePolicy.LIFO;
         if (poolReuseStrategy != null && !poolReuseStrategy.isEmpty()) {
@@ -105,7 +105,7 @@ private CloseableHttpClient newConnection(ClickHouseConfig c) throws IOException
                 throw new IllegalArgumentException("Invalid connection reuse strategy: " + poolReuseStrategy);
             }
         }
-        log.info("Connection reuse strategy: %s", poolReusePolicy.name());
+        log.debug("Connection reuse strategy: %s", poolReusePolicy.name());
         HttpConnectionManager connManager = new HttpConnectionManager(r.build(), c, PoolConcurrencyPolicy.LAX,
                 poolReusePolicy, TimeValue.ofMilliseconds(connectionTTL));
         int maxConnection = config.getIntOption(ClickHouseHttpOption.MAX_OPEN_CONNECTIONS);

clickhouse-http-client/src/main/java/com/clickhouse/client/http/ApacheHttpConnectionImpl.java

@@ -140,6 +140,7 @@ public void testAuthentication() throws ClickHouseException {
 
     @Test(groups = "integration")
     public void testUserAgent() throws Exception {
+        if (isCloud()) return; //TODO: testUserAgent - Revisit after the issue is resolved, see: https://github.com/ClickHouse/ClickHouse/issues/68748
         testUserAgent(ClickHouseClientOption.PRODUCT_NAME, "MyCustomProduct");
         testUserAgent(ClickHouseClientOption.CLIENT_NAME, "MyCustomClient");
     }

clickhouse-http-client/src/test/java/com/clickhouse/client/http/ClickHouseHttpClientTest.java

@@ -18,7 +18,7 @@ public class ClickHouseConnectionFactory implements ConnectionFactory {
 
     @Override
     public Mono<? extends Connection> create() {
-        return Mono.just(new ClickHouseConnection(nodes));
+        return Mono.defer(() -> Mono.just(new ClickHouseConnection(nodes)));
     }
 
     @Override