fix use the database from InsertSettings if set

Author: Am-phi

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

@@ -391,8 +391,12 @@ private void addHeaders(HttpPost req, Map<String, String> chConfig, Map<String,
             if (requestConfig.containsKey(ClickHouseClientOption.QUERY_ID.getKey())) {
                 req.addHeader(ClickHouseHttpProto.HEADER_QUERY_ID, requestConfig.get(ClickHouseClientOption.QUERY_ID.getKey()).toString());
             }
+            if(requestConfig.containsKey(ClickHouseClientOption.DATABASE.getKey())) {
+                req.addHeader(ClickHouseHttpProto.HEADER_DATABASE, requestConfig.get(ClickHouseClientOption.DATABASE.getKey()));
+            }else {
+                req.addHeader(ClickHouseHttpProto.HEADER_DATABASE, chConfig.get(ClickHouseClientOption.DATABASE.getKey()));
+            }
         }
-        req.addHeader(ClickHouseHttpProto.HEADER_DATABASE, chConfig.get(ClickHouseClientOption.DATABASE.getKey()));
         req.addHeader(ClickHouseHttpProto.HEADER_DB_USER, chConfig.get(ClickHouseDefaults.USER.getKey()));
         req.addHeader(ClickHouseHttpProto.HEADER_DB_PASSWORD, chConfig.get(ClickHouseDefaults.PASSWORD.getKey()));
 

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

@@ -235,7 +235,7 @@ public void insertRawDataSimple(int numberOfRecords) throws Exception {
     public void testInsertMetricsOperationId() throws Exception {
         final String tableName = "insert_metrics_test";
         final String createSQL = "CREATE TABLE " + tableName +
-                " (Id UInt32, event_ts Timestamp, name String, p1 Int64, p2 String) ENGINE = MergeTree() ORDER BY ()";
+                                 " (Id UInt32, event_ts Timestamp, name String, p1 Int64, p2 String) ENGINE = MergeTree() ORDER BY ()";
         dropTable(tableName);
         createTable(createSQL);
 
@@ -248,13 +248,50 @@ public void testInsertMetricsOperationId() throws Exception {
         writer.flush();
 
         InsertSettings settings = new InsertSettings()
-                .setQueryId(String.valueOf(UUID.randomUUID()))
-                .setOperationId(UUID.randomUUID().toString());
+            .setQueryId(String.valueOf(UUID.randomUUID()))
+            .setOperationId(UUID.randomUUID().toString());
         InsertResponse response = client.insert(tableName, new ByteArrayInputStream(data.toByteArray()),
-                ClickHouseFormat.TSV, settings).get(30, TimeUnit.SECONDS);
+            ClickHouseFormat.TSV, settings).get(30, TimeUnit.SECONDS);
         OperationMetrics metrics = response.getMetrics();
         assertEquals((int)response.getWrittenRows(), numberOfRecords );
         assertEquals(metrics.getQueryId(), settings.getQueryId());
         assertTrue(metrics.getMetric(ClientMetrics.OP_DURATION).getLong() > 0);
     }
+
+    @Test(groups = { "integration" })
+    public void testInsertSettingsAddDatabase() throws Exception {
+        final String tableName = "insert_settings_database_test";
+        final String new_database = "new_database";
+        final String createDatabaseSQL = "CREATE DATABASE " + new_database;
+        final String createTableSQL = "CREATE TABLE " + new_database + "." + tableName +
+                                 " (Id UInt32, event_ts Timestamp, name String, p1 Int64, p2 String) ENGINE = MergeTree() ORDER BY ()";
+        final String dropDatabaseSQL = "DROP DATABASE IF EXISTS " + new_database;
+
+        try (ClickHouseClient client = ClickHouseClient.builder().config(new ClickHouseConfig())
+            .nodeSelector(ClickHouseNodeSelector.of(ClickHouseProtocol.HTTP))
+            .build()) {
+            client.read(getServer(ClickHouseProtocol.HTTP)).query(dropDatabaseSQL).executeAndWait().close();
+            client.read(getServer(ClickHouseProtocol.HTTP)).query(createDatabaseSQL).executeAndWait().close();
+            client.read(getServer(ClickHouseProtocol.HTTP)).query(createTableSQL).executeAndWait().close();
+        }
+
+
+        InsertSettings insertSettings = settings.setInputStreamCopyBufferSize(8198 * 2)
+            .setDeduplicationToken(RandomStringUtils.randomAlphabetic(36))
+            .setQueryId(String.valueOf(UUID.randomUUID()));
+        insertSettings.setDatabase(new_database);
+
+        ByteArrayOutputStream data = new ByteArrayOutputStream();
+        PrintWriter writer = new PrintWriter(data);
+        for (int i = 0; i < 1000; i++) {
+            writer.printf("%d\t%s\t%s\t%d\t%s\n", i, "2021-01-01 00:00:00", "name" + i, i, "p2");
+        }
+        writer.flush();
+        InsertResponse response = client.insert(tableName, new ByteArrayInputStream(data.toByteArray()),
+            ClickHouseFormat.TSV, insertSettings).get(30, TimeUnit.SECONDS);
+        assertEquals((int)response.getWrittenRows(), 1000 );
+
+        List<GenericRecord> records = client.queryAll("SELECT * FROM " + new_database + "." + tableName);
+        assertEquals(records.size(), 1000);
+    }
 }