Merge branch 'main' into jdbc_v2_row_binary_writer

Author: chernser

jdbc-v2/src/main/java/com/clickhouse/jdbc/PreparedStatementImpl.java

@@ -44,13 +44,7 @@
 import java.time.format.DateTimeFormatter;
 import java.time.format.DateTimeFormatterBuilder;
 import java.time.temporal.ChronoField;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Calendar;
-import java.util.Collection;
-import java.util.Collections;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.regex.Pattern;
 
 public class PreparedStatementImpl extends StatementImpl implements PreparedStatement, JdbcV2Wrapper {
@@ -681,6 +675,8 @@ private static String encodeObject(Object x) throws SQLException {
                 }
                 tupleString.append(")");
                 return tupleString.toString();
+            } else if (x instanceof UUID) {
+                return "'" + escapeString(((UUID) x).toString()) + "'";
             }
 
             return escapeString(x.toString());//Escape single quotes

jdbc-v2/src/test/java/com/clickhouse/jdbc/PreparedStatementTest.java

@@ -21,6 +21,7 @@
 import java.util.Properties;
 import java.util.Random;
 import java.util.TimeZone;
+import java.util.UUID;
 
 import static org.testng.Assert.assertEquals;
 import static org.testng.Assert.assertFalse;
@@ -648,4 +649,27 @@ void testBatchInsert() throws Exception {
             }
         }
     }
+
+    @Test(groups = {"integration"})
+    void testWriteCollection() throws Exception {
+        String sql = "insert into `test_issue_2327` (`id`, `uuid`) values (?, ?)";
+        try (Connection conn = getJdbcConnection();
+             PreparedStatementImpl ps = (PreparedStatementImpl) conn.prepareStatement(sql)) {
+
+            try (Statement stmt = conn.createStatement()) {
+                stmt.execute("CREATE TABLE IF NOT EXISTS `test_issue_2327` (`id` Nullable(String), `uuid` UUID) ENGINE Memory;");
+            }
+            UUID uuid = UUID.randomUUID();
+            ps.setString(1, "testId01");
+            ps.setObject(2, uuid);
+            ps.execute();
+
+            try (Statement stmt = conn.createStatement()) {
+                ResultSet rs = stmt.executeQuery("SELECT count(*) FROM `test_issue_2327`");
+                Assert.assertTrue(rs.next());
+                Assert.assertEquals(rs.getInt(1), 1);
+            }
+        }
+
+    }
 }

performance/pom.xml

@@ -15,7 +15,7 @@
     <properties>
         <apache.httpclient.version>5.3.1</apache.httpclient.version>
         <slf4j.version>2.0.17</slf4j.version>
-        <ch.jdbc.revision>0.8.3-SNAPSHOT</ch.jdbc.revision>
+        <ch.jdbc.revision>0.8.4-SNAPSHOT</ch.jdbc.revision>
         <jmh.version>1.37</jmh.version>
         <testcontainers.version>1.20.6</testcontainers.version>