Skip the tests for non-http implementation

Author: zhicwu

clickhouse-client/src/test/java/com/clickhouse/client/ClientIntegrationTest.java

@@ -45,6 +45,7 @@
 import com.clickhouse.client.data.ClickHouseStringValue;
 
 import org.testng.Assert;
+import org.testng.SkipException;
 import org.testng.annotations.DataProvider;
 import org.testng.annotations.Test;
 
@@ -1262,7 +1263,7 @@ public void testTempTable() throws Exception {
     public void testErrorDuringInsert() throws Exception {
         ClickHouseNode server = getServer();
         if (server.getProtocol() != ClickHouseProtocol.HTTP) {
-            return;
+            throw new SkipException("Skip as only http implementation works well");
         }
         ClickHouseClient.send(server, "drop table if exists error_during_insert",
                 "create table error_during_insert(n UInt64, flag UInt8)engine=Null").get();
@@ -1288,7 +1289,7 @@ public void testErrorDuringInsert() throws Exception {
     public void testErrorDuringQuery() throws Exception {
         ClickHouseNode server = getServer();
         if (server.getProtocol() != ClickHouseProtocol.HTTP) {
-            return;
+            throw new SkipException("Skip as only http implementation works well");
         }
         String query = "select number, throwIf(number>=100000000) from numbers(500000000)";
         long count = 0L;

clickhouse-jdbc/src/test/java/com/clickhouse/jdbc/ClickHouseStatementTest.java

@@ -33,12 +33,14 @@
 import com.clickhouse.client.ClickHouseDataType;
 import com.clickhouse.client.ClickHouseParameterizedQuery;
 import com.clickhouse.client.ClickHouseProtocol;
+import com.clickhouse.client.ClickHouseRequest;
 import com.clickhouse.client.ClickHouseValues;
 import com.clickhouse.client.config.ClickHouseClientOption;
 import com.clickhouse.client.data.ClickHouseDateTimeValue;
 import com.clickhouse.client.http.config.ClickHouseHttpOption;
 
 import org.testng.Assert;
+import org.testng.SkipException;
 import org.testng.annotations.DataProvider;
 import org.testng.annotations.Test;
 
@@ -73,6 +75,9 @@ public void testSocketTimeout() throws SQLException {
         props.setProperty("database", "system");
         try (ClickHouseConnection conn = newConnection(props);
                 ClickHouseStatement stmt = conn.createStatement()) {
+            if (stmt.unwrap(ClickHouseRequest.class).getServer().getProtocol() != ClickHouseProtocol.HTTP) {
+                throw new SkipException("Skip as only http implementation works well");
+            }
             stmt.executeQuery("select sleep(3)");
             Assert.fail("Should throw timeout exception");
         } catch (SQLException e) {