remove SET statement support

Author: gfunc

client-v2/src/main/java/com/clickhouse/client/api/Client.java

@@ -2213,10 +2213,6 @@ public void setDBRoles(Collection<String> dbRoles) {
                         this.configuration.get(ClientConfigProperties.SESSION_DB_ROLES.getKey())));
     }
 
-    public void setProfile(String name) {
-        this.configuration.put(ClientConfigProperties.PROFILE.getKey(), name);
-    }
-
     public void updateClientName(String name) {
         this.configuration.put(ClientConfigProperties.CLIENT_NAME.getKey(), name);
     }

client-v2/src/main/java/com/clickhouse/client/api/ClientConfigProperties.java

@@ -22,8 +22,6 @@ public enum ClientConfigProperties {
 
     PASSWORD("password", ""),
 
-    PROFILE("profile"),
-
     /**
      * Maximum number of active connection in internal connection pool.
      */

client-v2/src/main/java/com/clickhouse/client/api/internal/HttpAPIClientHelper.java

@@ -559,12 +559,6 @@ private void addQueryParams(URIBuilder req, Map<String, String> chConfig, Map<St
             sessionRoles.forEach(r -> req.addParameter(ClickHouseHttpProto.QPARAM_ROLE, r));
         }
 
-        String profile = (String) requestConfig.getOrDefault(ClientConfigProperties.PROFILE.getKey(),
-                chConfiguration.getOrDefault(ClientConfigProperties.PROFILE.getKey(), ""));
-        if (!profile.isEmpty()) {
-            req.addParameter(ClientConfigProperties.PROFILE.getKey(), profile);
-        }
-
         for (String key : requestConfig.keySet()) {
             if (key.startsWith(ClientConfigProperties.SERVER_SETTING_PREFIX)) {
                 Object val = requestConfig.get(key);

jdbc-v2/src/main/java/com/clickhouse/jdbc/StatementImpl.java

@@ -373,19 +373,6 @@ public boolean executeImpl(String sql, StatementType type, QuerySettings setting
                         connection.client.setDBRoles(roles);
                     }
                 }
-
-            } else if (JdbcUtils.containsIgnoresCase(tokens, "=")){
-                String key = tokens.get(1);
-                String value = tokens.get(3).replace("'", "");
-                //SET profile
-                if (key.equals("profile")) {
-                    connection.client.setProfile(value);
-                    LOG.debug("Set profile to {}", value);
-                } else {
-                    //SET session settings
-                    connection.getDefaultQuerySettings().serverSetting(key, value);
-                    LOG.debug("Set session server setting {} to {}", key, value);
-                }
             }
             return false;
         } else if (type == StatementType.USE) {

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

@@ -955,12 +955,15 @@ public void testNestedTypeSimpleStatement() throws SQLException {
 
     @Test(groups = { "integration" })
     public void testNestedTypeNonFlatten() throws SQLException {
+        if (earlierThan(25,1)){
+            return;
+        }
         try (Connection conn = getConnection()) {
             try (Statement stmt = conn.createStatement()) {
                 stmt.execute("SET flatten_nested = 0");
                 stmt.execute("CREATE TABLE test_nested_not_flatten (order Int8, "
                         + "nested Nested (int8 Int8, int16 Int16, int32 Int32, int64 Int64, int128 Int128, int256 Int256)"
-                        + ") ENGINE = MergeTree ORDER BY ()");
+                        + ") ENGINE = MergeTree ORDER BY () SETTINGS flatten_nested = 0");
                 // Insert random (valid) values
                 long seed = System.currentTimeMillis();
                 Random rand = new Random(seed);

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

@@ -412,33 +412,6 @@ record = conn.client.queryAll("SELECT currentRoles()").get(0);
         }
     }
 
-    @Test(groups = { "integration" })
-    public void testSetStatement() throws SQLException {
-        try (ConnectionImpl conn = (ConnectionImpl) getJdbcConnection()) {
-            try (Statement stmt = conn.createStatement()) {
-
-                stmt.execute("SET session_timezone = 'Europe/Berlin'");
-                try (ResultSet rs = stmt.executeQuery("SELECT timezone()")){
-                    assertTrue(rs.next());
-                    assertEquals(rs.getString(1),"Europe/Berlin");
-                    assertFalse(rs.next());
-                }
-                stmt.execute("SET network_compression_method = 'GZIP'");
-                try (ResultSet rs = stmt.executeQuery("SELECT getSetting('network_compression_method')")){
-                    assertTrue(rs.next());
-                    assertEquals(rs.getString(1),"GZIP");
-                    assertFalse(rs.next());
-                }
-                stmt.execute("SET profile = 'readonly'");
-                try (ResultSet rs = stmt.executeQuery("SELECT currentProfiles()")){
-                    assertTrue(rs.next());
-                    assertEquals(((Object[]) rs.getArray(1).getArray())[0],"readonly");
-                    assertFalse(rs.next());
-                }
-            }
-        }
-    }
-
     @Test
     public void testGettingArrays() throws Exception {
         try (ConnectionImpl conn = (ConnectionImpl) getJdbcConnection();