Fix build break caused by server compatibility issue

ClickHouse · Apr 4, 2022 · 35fad2d · 35fad2d
1 parent e86bd13
commit 35fad2d
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/clickhouse-jdbc/src/test/java/com/clickhouse/jdbc/ClickHousePreparedStatementTest.java b/clickhouse-jdbc/src/test/java/com/clickhouse/jdbc/ClickHousePreparedStatementTest.java
@@ -910,8 +910,10 @@ public void testInsertWithFunction() throws Exception {
         try (ClickHouseConnection conn = newConnection(new Properties());
                 Statement s = conn.createStatement();
                 PreparedStatement stmt = conn.prepareStatement(
-                        "insert into test_issue_315(id, src, dst) values (?,IPv4ToIPv6(toIPv4(?)),IPv4ToIPv6(toIPv4(?)))")) {
-            s.execute("drop table if exists test_issue_315;"
+                        conn.getServerVersion().check("[22.3,)")
+                                ? "insert into test_issue_315(id, src, dst) values (?+0,?,?)"
+                                : "insert into test_issue_315(id, src, dst) values (?,IPv4ToIPv6(toIPv4(?)),IPv4ToIPv6(toIPv4(?)))")) {
+            s.execute("drop table if exists test_issue_315; "
                     + "create table test_issue_315(id Int32, src IPv6, dst IPv6)engine=Memory");
 
             stmt.setObject(1, 1);
@@ -935,7 +937,8 @@ public void testInsertWithFunction() throws Exception {
             Assert.assertTrue(rs.next());
             Assert.assertEquals(rs.getInt(1), 2);
             Assert.assertEquals(rs.getString(2), "0:0:0:0:0:ffff:7f00:2");
-            Assert.assertEquals(rs.getString(3), "0:0:0:0:0:ffff:0:0");
+            Assert.assertEquals(rs.getString(3),
+                    conn.getServerVersion().check("[22.3,)") ? "0:0:0:0:0:0:0:1" : "0:0:0:0:0:ffff:0:0");
             Assert.assertFalse(rs.next());
         }
     }