Merge pull request #176 from staticlibs/conn_duplicate

Retain client config on connection duplication

Author: Mytherin

src/jni/duckdb_java.cpp

@@ -108,7 +108,9 @@ jobject _duckdb_jdbc_startup(JNIEnv *env, jclass, jbyteArray database_j, jboolea
 
 jobject _duckdb_jdbc_connect(JNIEnv *env, jclass, jobject conn_ref_buf) {
 	auto conn_ref = (ConnectionHolder *)env->GetDirectBufferAddress(conn_ref_buf);
+	auto config = ClientConfig::GetConfig(*conn_ref->connection->context);
 	auto conn = new ConnectionHolder(conn_ref->db);
+	conn->connection->context->config = config;
 	return env->NewDirectByteBuffer(conn, 0);
 }
 

src/test/java/org/duckdb/TestDuckDBJDBC.java

@@ -4776,6 +4776,23 @@ public static void test_typed_connection_properties() throws Exception {
         }
     }
 
+    public static void test_client_config_retained_on_dup() throws Exception {
+        try (Connection conn = DriverManager.getConnection(JDBC_URL)) {
+            try (Statement stmt1 = conn.createStatement()) {
+                stmt1.execute("set home_directory='test1'");
+                try (ResultSet rs = stmt1.executeQuery("select current_setting('home_directory')")) {
+                    rs.next();
+                    assertEquals(rs.getString(1), "test1");
+                }
+            }
+            try (Connection dup = ((DuckDBConnection) conn).duplicate(); Statement stmt2 = dup.createStatement();
+                 ResultSet rs = stmt2.executeQuery("select current_setting('home_directory')")) {
+                rs.next();
+                assertEquals(rs.getString(1), "test1");
+            }
+        }
+    }
+
     public static void main(String[] args) throws Exception {
         String arg1 = args.length > 0 ? args[0] : "";
         final int statusCode;