test older server

Author: youngsofun

.github/workflows/test_cluster.yml

@@ -11,6 +11,12 @@ on:
 jobs:
   test:
     runs-on: ubuntu-latest
+    strategy:
+      fail-fast: false
+      matrix:
+        version:
+          - "nightly"
+          - "v1.2.790-nightly"
     steps:
       - uses: actions/checkout@v4
 
@@ -26,9 +32,12 @@ jobs:
       - name: Start Cluster With Nginx and Minio
         working-directory: tests
         run: make up
+        env:
+          DATABEND_QUERY_VERSION: ${{ matrix.version }}
 
       - name: Test with conn to nginx
         run: mvn test -DexcludedGroups=FLAKY
         env:
           MAVEN_GPG_PASSPHRASE: ${{ secrets.GPG_PASSPHRASE }}
           DATABEND_TEST_CONN_PORT: 8000
+          DATABEND_QUERY_VERSION: ${{ matrix.version }}

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

@@ -2,11 +2,6 @@
 
 import com.vdurmont.semver4j.Semver;
 
-import java.sql.Connection;
-import java.sql.DriverManager;
-import java.sql.SQLException;
-import java.util.Properties;
-
 public class Compatibility {
     public static class Capability {
         boolean streamingLoad;
@@ -19,35 +14,34 @@ public Capability(boolean streamingLoad) {
         }
 
         public static Capability fromServerVersion(Semver ver) {
-            boolean streamingLoad =  ver.isGreaterThan(new Semver("1.2.781"));
+            boolean streamingLoad =  ver.isGreaterThanOrEqualTo(new Semver("1.2.792"));
             return new Capability(streamingLoad);
         }
 
         public static Capability fromDriverVersion(Semver ver) {
-            boolean streamingLoad =  ver.isGreaterThan(new Semver("0.4.1"));
+            boolean streamingLoad =  ver.isGreaterThanOrEqualTo(new Semver("0.4.1"));
             return new Capability(streamingLoad);
         }
     }
 
-    static String port = System.getenv("DATABEND_TEST_CONN_PORT") != null ? System.getenv("DATABEND_TEST_CONN_PORT").trim() : "8000";
     public static Semver driverVersion = getDriverVersion();
     public static Semver serverVersion = getServerVersion();
     public static Capability driverCapability = driverVersion==null? new Capability(): Capability.fromDriverVersion(driverVersion);
     public static Capability serverCapability = serverVersion==null? new Capability(): Capability.fromServerVersion(serverVersion);
 
     private static Semver getDriverVersion() {
-        String env = System.getenv("DATABEND_TEST_DRIVER_VERSION");
+        String env = System.getenv("DRIVER_VERSION");
         if (env == null) {
             return null;
         }
         return new Semver(env);
     }
     private static Semver getServerVersion() {
-        String env = System.getenv("DATABEND_TEST_SERVER_VERSION");
-        if (env == null) {
+        String env = System.getenv("DATABEND_QUERY_VERSION");
+        if (env == null || "nightly".equals(env)) {
             return null;
         }
-        return new Semver(env);
+        return new Semver(env).withClearedSuffixAndBuild();
     }
 
      public static boolean skipDriverBug(String version) {