add Compatibility

Author: youngsofun

databend-jdbc/src/test/java/com/databend/jdbc/Compatibility.java

@@ -44,7 +44,7 @@ private static Semver getServerVersion() {
         return new Semver(env, Semver.SemverType.NPM).withClearedSuffixAndBuild();
     }
 
-     public static boolean skipDriverBug(String version) {
+     public static boolean skipDriverBugLowerThen(String version) {
         if (driverVersion != null && driverVersion.isLowerThan(new Semver(version))) {
            StackTraceElement[] stackTrace = Thread.currentThread().getStackTrace();
            String callerName = stackTrace[2].getMethodName();
@@ -53,4 +53,16 @@ public static boolean skipDriverBug(String version) {
         }
         return false;
     }
+    public static boolean skipBugLowerThenOrEqualTo(String serverVersionBug, String driverVersionBug) {
+        if (driverVersion != null && driverVersion.isLowerThanOrEqualTo(new Semver(serverVersionBug))
+                && serverVersion != null && serverVersion.isLowerThanOrEqualTo(serverVersionBug)
+        ) {
+            StackTraceElement[] stackTrace = Thread.currentThread().getStackTrace();
+            String callerName = stackTrace[2].getMethodName();
+            System.out.printf("SkipDriverBug (server <= %s && driver <=%s), method = %s",
+                    serverVersionBug, driverVersionBug, callerName);
+            return true;
+        }
+        return false;
+    }
 }

databend-jdbc/src/test/java/com/databend/jdbc/TestBasicDriver.java

@@ -201,7 +201,7 @@ public void testDefaultSelectNullValue() throws SQLException {
             Assert.assertEquals(r.getInt(1), 1);
             Assert.assertNull(r.getObject(2));
             Assert.assertEquals(r.getObject(3), "null");
-            if (Compatibility.skipDriverBug("0.3.9")) {
+            if (Compatibility.skipDriverBugLowerThen("0.3.9")) {
                 Assert.assertNull(r.getObject(4));
             } else {
                 Assert.assertEquals(r.getObject(4), "NULL");

databend-jdbc/src/test/java/com/databend/jdbc/TestPrepareStatement.java

@@ -609,7 +609,7 @@ public void testExecuteUpdate() throws SQLException {
 
     @Test(groups = "IT")
     public void testInsertWithSelect() throws SQLException {
-        if (Compatibility.skipDriverBug("0.3.9")) {
+        if (Compatibility.skipDriverBugLowerThen("0.3.9")) {
             return;
         }
         Connection conn = Utils.createConnection();

databend-jdbc/src/test/java/com/databend/jdbc/TestTransaction.java

@@ -110,9 +110,12 @@ public void testConflict() throws SQLException {
                     java.sql.SQLException.class,
                     () ->  statement1.execute("commit")
             );
-            // e.g. Unresolvable conflict detected for table 2249
-            Assert.assertTrue(exception.getMessage().toLowerCase().contains("conflict"), exception.getMessage());
 
+            // Bug: Transaction timeout: last_query_id 9b619dc70fd64d6b8de7490aaf486f5c not found on this server
+            if (!Compatibility.skipBugLowerThenOrEqualTo("1.2.790", "0.3.9")) {
+                // e.g. Unresolvable conflict detected for table 2249
+                Assert.assertTrue(exception.getMessage().toLowerCase().contains("conflict"), exception.getMessage());
+            }
 
             statement2.execute("select j from test_txn.table3 where i = 1");
             ResultSet rs = statement2.getResultSet();