diff --git a/src/main/java/org/duckdb/DuckDBConnection.java b/src/main/java/org/duckdb/DuckDBConnection.java
index 617f2321..58dd2b84 100644
--- a/src/main/java/org/duckdb/DuckDBConnection.java
+++ b/src/main/java/org/duckdb/DuckDBConnection.java
@@ -96,13 +96,13 @@ public Statement createStatement() throws SQLException {
         return createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
     }
 
-    public Connection duplicate() throws SQLException {
+    public DuckDBConnection duplicate() throws SQLException {
         checkOpen();
         connRefLock.lock();
         try {
             checkOpen();
-            return new DuckDBConnection(DuckDBNative.duckdb_jdbc_connect(connRef), url, readOnly, sessionInitSQL,
-                                        autoCommit);
+            ByteBuffer dupRef = DuckDBNative.duckdb_jdbc_connect(connRef);
+            return new DuckDBConnection(dupRef, url, readOnly, sessionInitSQL, autoCommit);
         } finally {
             connRefLock.unlock();
         }
diff --git a/src/test/java/org/duckdb/TestResults.java b/src/test/java/org/duckdb/TestResults.java
index a0798fe3..8174b97d 100644
--- a/src/test/java/org/duckdb/TestResults.java
+++ b/src/test/java/org/duckdb/TestResults.java
@@ -57,7 +57,7 @@ public static void test_result() throws Exception {
                 assertFalse(rs.next());
             }
             // test duplication
-            try (Connection conn2 = conn.unwrap(DuckDBConnection.class).duplicate();
+            try (DuckDBConnection conn2 = conn.unwrap(DuckDBConnection.class).duplicate();
                  Statement stmt2 = conn2.createStatement(); ResultSet rs_conn2 = stmt2.executeQuery("SELECT 42")) {
                 rs_conn2.next();
                 assertEquals(42, rs_conn2.getInt(1));