Version checking

Author: Paultagoras

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

@@ -4,6 +4,7 @@
 
 import com.clickhouse.client.BaseIntegrationTest;
 import com.clickhouse.client.ClickHouseProtocol;
+import com.clickhouse.client.api.query.GenericRecord;
 import com.clickhouse.logging.Logger;
 import com.clickhouse.logging.LoggerFactory;
 
@@ -47,4 +48,35 @@ protected boolean runQuery(String query) {
             return false;
         }
     }
+
+
+    protected boolean earlierThan(int major, int minor) {
+        String serverVersion = getServerVersion();
+        if (serverVersion == null) {
+            return false;
+        }
+
+        String[] parts = serverVersion.split("\\.");
+        if (parts.length < 2) {
+            return false;
+        }
+
+        try {
+            int serverMajor = Integer.parseInt(parts[0]);
+            int serverMinor = Integer.parseInt(parts[1]);
+            return serverMajor < major || (serverMajor == major && serverMinor < minor);
+        } catch (NumberFormatException e) {
+            return false;
+        }
+    }
+
+    protected String getServerVersion() {
+        try (ConnectionImpl connection = (ConnectionImpl) getJdbcConnection()) {
+            GenericRecord result = connection.client.queryAll("SELECT version() as server_version").stream()
+                    .findFirst().orElseThrow(() -> new SQLException("Failed to retrieve server version."));
+            return result.getString("server_version");
+        } catch (SQLException e) {
+            return null;
+        }
+    }
 }

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

@@ -333,6 +333,10 @@ public void testExecuteQueryTimeout() throws Exception {
 
     @Test(groups = { "integration" })
     private void testSettingRole() throws SQLException {
+        if (earlierThan(24, 4)) {//Min version is 24.4
+            return;
+        }
+
         List<String> roles = Arrays.asList("role1", "role2");
 
         try (ConnectionImpl conn = (ConnectionImpl) getJdbcConnection()) {