added tests for that settings are not mutated while operation

Author: chernser

client-v2/pom.xml

@@ -135,6 +135,12 @@
             <version>2.0.16</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.mockito</groupId>
+            <artifactId>mockito-core</artifactId>
+            <version>5.19.0</version>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 
     <build>

client-v2/src/test/java/com/clickhouse/client/insert/InsertTests.java

@@ -26,6 +26,7 @@
 import org.apache.commons.compress.compressors.lz4.FramedLZ4CompressorOutputStream;
 import org.apache.commons.compress.compressors.snappy.SnappyCompressorOutputStream;
 import org.apache.commons.lang3.StringEscapeUtils;
+import org.mockito.Mockito;
 import org.testcontainers.shaded.org.apache.commons.lang3.RandomStringUtils;
 import org.testng.Assert;
 import org.testng.annotations.AfterMethod;
@@ -822,4 +823,28 @@ private boolean isVersionMatch(String versionExpression) {
         List<GenericRecord> serverVersion = client.queryAll("SELECT version()");
         return ClickHouseVersion.of(serverVersion.get(0).getString(1)).check(versionExpression);
     }
+
+    @Test(groups = { "integration" }, enabled = true)
+    public void testInsertSettingsNotChanged() throws Exception {
+        String tableName = "test_settings_not_changed";
+        String createSQL = SamplePOJO.generateTableCreateSQL(tableName);
+        String uuid = UUID.randomUUID().toString();
+
+        initTable(tableName, createSQL);
+
+        client.register(SamplePOJO.class, client.getTableSchema(tableName));
+        List<Object> simplePOJOs = new ArrayList<>();
+
+        for (int i = 0; i < 1000; i++) {
+            simplePOJOs.add(new SamplePOJO());
+        }
+        InsertSettings settings = Mockito.spy(new InsertSettings());
+        settings.setQueryId(uuid);
+
+        try (InsertResponse response = client.insert(tableName, simplePOJOs, settings).get(EXECUTE_CMD_TIMEOUT, TimeUnit.SECONDS)) {
+            Mockito.verify(settings, Mockito.times(1)).getAllSettings();
+            Mockito.verify(settings, Mockito.times(1)).setQueryId(Mockito.eq(uuid));
+            Mockito.verifyNoMoreInteractions(settings);
+        }
+    }
 }

client-v2/src/test/java/com/clickhouse/client/query/QueryTests.java

@@ -38,6 +38,7 @@
 import com.google.common.io.BaseEncoding;
 import org.apache.commons.lang3.RandomStringUtils;
 import org.apache.commons.lang3.StringEscapeUtils;
+import org.mockito.Mockito;
 import org.testng.Assert;
 import org.testng.annotations.AfterMethod;
 import org.testng.annotations.BeforeMethod;
@@ -2190,4 +2191,15 @@ public void testEmptyResponse() throws Exception {
             System.out.println(response.getResultRows());
         }
     }
+
+    @Test(groups = {"integration"})
+    public void testSettingsNotChanged() throws Exception{
+        final QuerySettings settings = Mockito.spy(new QuerySettings());
+        try (QueryResponse response = client.query("select 1 FORMAT JSONEachRow", settings).get()) {
+            Mockito.verify(settings, Mockito.times(1)).getAllSettings();
+            Mockito.verifyNoMoreInteractions(settings);
+            Assert.assertNull(settings.getFormat());
+            Assert.assertEquals(response.getFormat(), ClickHouseFormat.JSONEachRow);
+        }
+    }
 }