From 3e6761e533198bce1b1e597021d32d05cf4e2a69 Mon Sep 17 00:00:00 2001
From: dmitrybugakov <bugakov.dima@gmail.com>
Date: Sat, 26 Aug 2023 23:27:33 +0200
Subject: [PATCH] [FEATURE]: Add clickhouse SSL\TLS connection

---
 .../housepower/client/NativeClient.java       |   38 +-
 .../client/ssl/PermissiveTrustManager.java    |   62 +
 .../client/ssl/SSLContextBuilder.java         |   83 ++
 .../housepower/settings/ClickHouseConfig.java |   50 +-
 .../housepower/settings/KeyStoreConfig.java   |   42 +
 .../housepower/settings/SettingKey.java       |   41 +-
 .../github/housepower/jdbc/AbstractITest.java |   54 +-
 .../jdbc/ClickHouseConnectionITest.java       |   44 +-
 .../jdbc/tool/LocalKeyStoreConfig.java        |   43 +
 .../resources/clickhouse/config/config.xml    | 1198 +++++++++++++++++
 .../resources/clickhouse/config/users.xml     |  123 ++
 .../src/test/resources/clickhouse/server.crt  |   19 +
 .../src/test/resources/clickhouse/server.jks  |  Bin 0 -> 2134 bytes
 .../src/test/resources/clickhouse/server.key  |   28 +
 .../src/test/resources/clickhouse/server.p12  |  Bin 0 -> 2594 bytes
 .../src/test/resources/grpc_config.xml        |   32 -
 .../resources/keymanagement/bin/generate.sh   |   42 +
 17 files changed, 1830 insertions(+), 69 deletions(-)
 create mode 100644 clickhouse-native-jdbc/src/main/java/com/github/housepower/client/ssl/PermissiveTrustManager.java
 create mode 100644 clickhouse-native-jdbc/src/main/java/com/github/housepower/client/ssl/SSLContextBuilder.java
 create mode 100644 clickhouse-native-jdbc/src/main/java/com/github/housepower/settings/KeyStoreConfig.java
 create mode 100644 clickhouse-native-jdbc/src/test/java/com/github/housepower/jdbc/tool/LocalKeyStoreConfig.java
 create mode 100644 clickhouse-native-jdbc/src/test/resources/clickhouse/config/config.xml
 create mode 100644 clickhouse-native-jdbc/src/test/resources/clickhouse/config/users.xml
 create mode 100644 clickhouse-native-jdbc/src/test/resources/clickhouse/server.crt
 create mode 100644 clickhouse-native-jdbc/src/test/resources/clickhouse/server.jks
 create mode 100644 clickhouse-native-jdbc/src/test/resources/clickhouse/server.key
 create mode 100644 clickhouse-native-jdbc/src/test/resources/clickhouse/server.p12
 delete mode 100644 clickhouse-native-jdbc/src/test/resources/grpc_config.xml
 create mode 100644 clickhouse-native-jdbc/src/test/resources/keymanagement/bin/generate.sh

diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/client/NativeClient.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/client/NativeClient.java
index 27da6776..986975e6 100644
--- a/clickhouse-native-jdbc/src/main/java/com/github/housepower/client/NativeClient.java
+++ b/clickhouse-native-jdbc/src/main/java/com/github/housepower/client/NativeClient.java
@@ -16,6 +16,7 @@
 
 import com.github.housepower.buffer.SocketBuffedReader;
 import com.github.housepower.buffer.SocketBuffedWriter;
+import com.github.housepower.client.ssl.SSLContextBuilder;
 import com.github.housepower.data.Block;
 import com.github.housepower.misc.Validate;
 import com.github.housepower.protocol.*;
@@ -29,11 +30,14 @@
 import com.github.housepower.stream.QueryResult;
 import com.github.housepower.stream.ClickHouseQueryResult;
 
+import javax.net.ssl.*;
 import java.io.IOException;
 import java.io.Serializable;
 import java.net.InetSocketAddress;
 import java.net.Socket;
 import java.net.SocketAddress;
+import java.security.*;
+import java.security.cert.CertificateException;
 import java.sql.SQLException;
 import java.time.Duration;
 import java.util.Map;
@@ -44,23 +48,41 @@ public class NativeClient {
 
     private static final Logger LOG = LoggerFactory.getLogger(NativeClient.class);
 
-    public static NativeClient connect(ClickHouseConfig configure) throws SQLException {
-        return connect(configure.host(), configure.port(), configure);
+    public static NativeClient connect(ClickHouseConfig config) throws SQLException {
+        return connect(config.host(), config.port(), config);
     }
 
-    public static NativeClient connect(String host, int port, ClickHouseConfig configure) throws SQLException {
+    // TODO: Support proxy
+    // TODO: Move socket initialisation to separate factory (default & ssl)
+    public static NativeClient connect(String host, int port, ClickHouseConfig config) throws SQLException {
         try {
             SocketAddress endpoint = new InetSocketAddress(host, port);
-            // TODO support proxy
-            Socket socket = new Socket();
+            Socket socket;
+
+            boolean useSSL = config.ssl();
+            if (useSSL) {
+                LOG.debug("Client works in SSL mode!");
+                SSLContext context = new SSLContextBuilder(config).getSSLContext();
+                SSLSocketFactory factory = context.getSocketFactory();
+                socket = (SSLSocket) factory.createSocket();
+            } else {
+                socket = new Socket();
+            }
             socket.setTcpNoDelay(true);
             socket.setSendBufferSize(ClickHouseDefines.SOCKET_SEND_BUFFER_BYTES);
             socket.setReceiveBufferSize(ClickHouseDefines.SOCKET_RECV_BUFFER_BYTES);
-            socket.setKeepAlive(configure.tcpKeepAlive());
-            socket.connect(endpoint, (int) configure.connectTimeout().toMillis());
+            socket.setKeepAlive(config.tcpKeepAlive());
+            socket.connect(endpoint, (int) config.connectTimeout().toMillis());
+
+            if (useSSL) ((SSLSocket) socket).startHandshake();
 
             return new NativeClient(socket);
-        } catch (IOException ex) {
+        } catch (IOException |
+                 NoSuchAlgorithmException |
+                 KeyStoreException |
+                 CertificateException |
+                 UnrecoverableKeyException |
+                 KeyManagementException ex) {
             throw new SQLException(ex.getMessage(), ex);
         }
     }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/client/ssl/PermissiveTrustManager.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/client/ssl/PermissiveTrustManager.java
new file mode 100644
index 00000000..0ca74bb8
--- /dev/null
+++ b/clickhouse-native-jdbc/src/main/java/com/github/housepower/client/ssl/PermissiveTrustManager.java
@@ -0,0 +1,62 @@
+/*
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.github.housepower.client.ssl;
+
+import javax.net.ssl.X509TrustManager;
+import java.security.cert.X509Certificate;
+
+/**
+ * An implementation of X509TrustManager that trusts all certificates.
+ * This class is not secure and should only be used for debugging or
+ * in a completely isolated environment.
+ */
+public class PermissiveTrustManager implements X509TrustManager {
+
+    /**
+     * Checks the client certificates but does nothing.
+     * It effectively trusts all client certificates.
+     *
+     * @param x509Certificates Array of client certificates to check
+     * @param s The auth type (e.g., "RSA", "DSS")
+     */
+    @Override
+    public void checkClientTrusted(X509Certificate[] x509Certificates, String s) {
+        // Do nothing to bypass client checks
+    }
+
+    /**
+     * Checks the server certificates but does nothing.
+     * It effectively trusts all server certificates.
+     *
+     * @param x509Certificates Array of server certificates to check
+     * @param s The auth type (e.g., "RSA", "DSS")
+     */
+    @Override
+    public void checkServerTrusted(X509Certificate[] x509Certificates, String s) {
+        // Do nothing to bypass server checks
+    }
+
+    /**
+     * Returns an empty array of certificate authorities, indicating
+     * that all certificates are trusted, subject to the
+     * verification done in the checkClientTrusted and checkServerTrusted methods.
+     *
+     * @return An empty X509Certificate array
+     */
+    @Override
+    public X509Certificate[] getAcceptedIssuers() {
+        return new X509Certificate[0];
+    }
+}
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/client/ssl/SSLContextBuilder.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/client/ssl/SSLContextBuilder.java
new file mode 100644
index 00000000..14848169
--- /dev/null
+++ b/clickhouse-native-jdbc/src/main/java/com/github/housepower/client/ssl/SSLContextBuilder.java
@@ -0,0 +1,83 @@
+/*
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.github.housepower.client.ssl;
+
+import com.github.housepower.client.NativeClient;
+import com.github.housepower.log.Logger;
+import com.github.housepower.log.LoggerFactory;
+import com.github.housepower.settings.ClickHouseConfig;
+import com.github.housepower.settings.KeyStoreConfig;
+import com.github.housepower.settings.SettingKey;
+
+
+import javax.net.ssl.*;
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Paths;
+import java.security.*;
+import java.security.cert.CertificateException;
+
+public class SSLContextBuilder {
+    private static final Logger LOG = LoggerFactory.getLogger(NativeClient.class);
+
+    private ClickHouseConfig config;
+
+    private KeyStoreConfig keyStoreConfig;
+
+    public SSLContextBuilder(ClickHouseConfig config) {
+        this.config = config;
+        this.keyStoreConfig = new KeyStoreConfig(
+                (String) config.settings().get(SettingKey.keyStoreType),
+                (String) config.settings().get(SettingKey.keyStorePath),
+                (String) config.settings().get(SettingKey.keyStorePassword)
+        );
+    }
+
+    public SSLContext getSSLContext() throws NoSuchAlgorithmException, KeyStoreException, IOException, CertificateException, UnrecoverableKeyException, KeyManagementException {
+        SSLContext sslContext = SSLContext.getInstance("TLS");
+        TrustManager[] trustManager = null;
+        KeyManager[] keyManager = null;
+        SecureRandom secureRandom = new SecureRandom();
+        String sslMode = config.sslMode();
+        LOG.debug("Client SSL mode: '" + sslMode + "'");
+
+        switch (sslMode) {
+            case "disabled":
+                trustManager = new TrustManager[]{new PermissiveTrustManager()};
+                keyManager = new KeyManager[]{};
+                break;
+            case "verify_ca":
+                KeyStore keyStore = KeyStore.getInstance(keyStoreConfig.getKeyStoreType());
+                keyStore.load(Files.newInputStream(Paths.get(keyStoreConfig.getKeyStorePath()).toFile().toPath()),
+                        keyStoreConfig.getKeyStorePassword().toCharArray());
+
+                KeyManagerFactory keyManagerFactory = KeyManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm());
+                keyManagerFactory.init(keyStore, keyStoreConfig.getKeyStorePassword().toCharArray());
+
+                TrustManagerFactory trustManagerFactory = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
+                trustManagerFactory.init(keyStore);
+
+                trustManager = trustManagerFactory.getTrustManagers();
+                keyManager = keyManagerFactory.getKeyManagers();
+                break;
+            default:
+                throw new IllegalArgumentException("Unknown SSL mode: '" + sslMode + "'");
+        }
+
+        sslContext.init(keyManager, trustManager, secureRandom);
+        return sslContext;
+    }
+
+}
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/settings/ClickHouseConfig.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/settings/ClickHouseConfig.java
index cece71ec..6bb20b63 100644
--- a/clickhouse-native-jdbc/src/main/java/com/github/housepower/settings/ClickHouseConfig.java
+++ b/clickhouse-native-jdbc/src/main/java/com/github/housepower/settings/ClickHouseConfig.java
@@ -34,7 +34,6 @@
 @Immutable
 public class ClickHouseConfig implements Serializable {
 
-
     private final String host;
     private final List<String> hosts;
     private final int port;
@@ -46,11 +45,14 @@ public class ClickHouseConfig implements Serializable {
     private final String charset; // use String because Charset is not serializable
     private final Map<SettingKey, Serializable> settings;
     private final boolean tcpKeepAlive;
+    private final boolean ssl;
+    private final String sslMode;
     private final String clientName;
 
     private ClickHouseConfig(String host, int port, String database, String user, String password,
                              Duration queryTimeout, Duration connectTimeout, boolean tcpKeepAlive,
-                             String charset, String clientName, Map<SettingKey, Serializable> settings) {
+                             boolean ssl, String sslMode, String charset, String clientName,
+                             Map<SettingKey, Serializable> settings) {
         this.host = host;
         this.hosts = Arrays.asList(host.split(HOST_DELIMITER));
         this.port = port;
@@ -60,6 +62,8 @@ private ClickHouseConfig(String host, int port, String database, String user, St
         this.queryTimeout = queryTimeout;
         this.connectTimeout = connectTimeout;
         this.tcpKeepAlive = tcpKeepAlive;
+        this.ssl = ssl;
+        this.sslMode = sslMode;
         this.charset = charset;
         this.clientName = clientName;
         this.settings = settings;
@@ -97,6 +101,14 @@ public Duration connectTimeout() {
         return this.connectTimeout;
     }
 
+    public boolean ssl() {
+        return this.ssl;
+    }
+
+    public String sslMode() {
+        return this.sslMode;
+    }
+
     public Charset charset() {
         return Charset.forName(charset);
     }
@@ -162,6 +174,18 @@ public ClickHouseConfig withTcpKeepAlive(boolean enable) {
                 .build();
     }
 
+    public ClickHouseConfig withSSL(boolean enable) {
+        return Builder.builder(this)
+                .ssl(enable)
+                .build();
+    }
+
+    public ClickHouseConfig withSSLMode(String mode) {
+        return Builder.builder(this)
+                .sslMode(mode)
+                .build();
+    }
+
     public ClickHouseConfig withCharset(Charset charset) {
         return Builder.builder(this)
                 .charset(charset)
@@ -212,6 +236,8 @@ public static final class Builder {
         private Duration connectTimeout;
         private Duration queryTimeout;
         private boolean tcpKeepAlive;
+        private boolean ssl;
+        private String sslMode;
         private Charset charset;
         private String clientName;
         private Map<SettingKey, Serializable> settings = new HashMap<>();
@@ -234,6 +260,8 @@ public static Builder builder(ClickHouseConfig cfg) {
                     .queryTimeout(cfg.queryTimeout())
                     .charset(cfg.charset())
                     .tcpKeepAlive(cfg.tcpKeepAlive())
+                    .ssl(cfg.ssl())
+                    .sslMode(cfg.sslMode())
                     .clientName(cfg.clientName())
                     .withSettings(cfg.settings());
         }
@@ -288,6 +316,16 @@ public Builder tcpKeepAlive(boolean tcpKeepAlive) {
             return this;
         }
 
+        public Builder ssl(boolean ssl) {
+            this.withSetting(SettingKey.ssl, ssl);
+            return this;
+        }
+
+        public Builder sslMode(String sslMode) {
+            this.withSetting(SettingKey.ssl, ssl);
+            return this;
+        }
+
         public Builder charset(String charset) {
             this.withSetting(SettingKey.charset, charset);
             return this;
@@ -330,6 +368,8 @@ public ClickHouseConfig build() {
             this.connectTimeout = (Duration) this.settings.getOrDefault(SettingKey.connect_timeout, Duration.ZERO);
             this.queryTimeout = (Duration) this.settings.getOrDefault(SettingKey.query_timeout, Duration.ZERO);
             this.tcpKeepAlive = (boolean) this.settings.getOrDefault(SettingKey.tcp_keep_alive, false);
+            this.ssl = (boolean) this.settings.getOrDefault(SettingKey.ssl, false);
+            this.sslMode = (String) this.settings.getOrDefault(SettingKey.sslMode, "disabled");
             this.charset = Charset.forName((String) this.settings.getOrDefault(SettingKey.charset, "UTF-8"));
             this.clientName = (String) this.settings.getOrDefault(SettingKey.client_name,
                     String.format(Locale.ROOT, "%s %s", ClickHouseDefines.NAME, "client"));
@@ -337,8 +377,8 @@ public ClickHouseConfig build() {
             revisit();
             purgeSettings();
 
-            return new ClickHouseConfig(
-                    host, port, database, user, password, queryTimeout, connectTimeout, tcpKeepAlive, charset.name(), clientName, settings);
+            return new ClickHouseConfig(host, port, database, user, password, queryTimeout, connectTimeout,
+                    tcpKeepAlive, ssl, sslMode, charset.name(), clientName, settings);
         }
 
         private void revisit() {
@@ -360,6 +400,8 @@ private void purgeSettings() {
             this.settings.remove(SettingKey.query_timeout);
             this.settings.remove(SettingKey.connect_timeout);
             this.settings.remove(SettingKey.tcp_keep_alive);
+            this.settings.remove(SettingKey.ssl);
+            this.settings.remove(SettingKey.sslMode);
             this.settings.remove(SettingKey.charset);
             this.settings.remove(SettingKey.client_name);
         }
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/settings/KeyStoreConfig.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/settings/KeyStoreConfig.java
new file mode 100644
index 00000000..3e3351c5
--- /dev/null
+++ b/clickhouse-native-jdbc/src/main/java/com/github/housepower/settings/KeyStoreConfig.java
@@ -0,0 +1,42 @@
+/*
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.github.housepower.settings;
+
+public class KeyStoreConfig {
+    private String keyStoreType;
+    private String keyStorePath;
+    private String keyStorePassword;
+
+    public KeyStoreConfig() {
+    }
+
+    public KeyStoreConfig(String keyStoreType, String keyStorePath, String keyStorePassword) {
+        this.keyStoreType = keyStoreType;
+        this.keyStorePath = keyStorePath;
+        this.keyStorePassword = keyStorePassword;
+    }
+
+    public String getKeyStorePath() {
+        return this.keyStorePath;
+    }
+
+    public String getKeyStorePassword() {
+        return this.keyStorePassword;
+    }
+
+    public String getKeyStoreType() {
+        return this.keyStoreType;
+    }
+}
diff --git a/clickhouse-native-jdbc/src/main/java/com/github/housepower/settings/SettingKey.java b/clickhouse-native-jdbc/src/main/java/com/github/housepower/settings/SettingKey.java
index 068fe3b6..47ed5720 100644
--- a/clickhouse-native-jdbc/src/main/java/com/github/housepower/settings/SettingKey.java
+++ b/clickhouse-native-jdbc/src/main/java/com/github/housepower/settings/SettingKey.java
@@ -803,7 +803,6 @@ public class SettingKey implements Serializable {
             .withDescription("identify who you are, it will record in system.query_log")
             .build();
 
-
     public static SettingKey port = SettingKey.builder()
             .withName("port")
             .withType(SettingType.Int32)
@@ -830,6 +829,36 @@ public class SettingKey implements Serializable {
             .isSecret()
             .build();
 
+    public static SettingKey ssl = SettingKey.builder()
+            .withName("ssl")
+            .withType(SettingType.Bool)
+            .withDescription("Establish secure connection: True or False")
+            .build();
+
+    public static SettingKey sslMode = SettingKey.builder()
+            .withName("ssl_mode")
+            .withType(SettingType.UTF8)
+            .withDescription("Verify or not certificate: disabled (don't verify), verify_ca (verify)")
+            .build();
+
+    public static SettingKey keyStoreType = SettingKey.builder()
+            .withName("key_store_type")
+            .withType(SettingType.UTF8)
+            .withDescription("Type of the KeyStore. Currently, only JKS is supported.")
+            .build();
+
+    public static SettingKey keyStorePath = SettingKey.builder()
+            .withName("key_store_path")
+            .withType(SettingType.UTF8)
+            .withDescription("Path to the KeyStore file.")
+            .build();
+
+    public static SettingKey keyStorePassword = SettingKey.builder()
+            .withName("key_store_password")
+            .withType(SettingType.UTF8)
+            .withDescription("Password for the KeyStore.")
+            .build();
+
     public static SettingKey query_timeout = SettingKey.builder()
             .withName("query_timeout")
             .withType(SettingType.Seconds)
@@ -847,17 +876,17 @@ public class SettingKey implements Serializable {
             .build();
 
     public static SettingKey allow_experimental_map_type = SettingKey.builder()
-          .withName("allow_experimental_map_type")
-          .withType(SettingType.Int32)
-          .withDescription("Allow Map field to be use")
-          .build();
+            .withName("allow_experimental_map_type")
+            .withType(SettingType.Int32)
+            .withDescription("Allow Map field to be use")
+            .build();
 
     public static SettingKey query_id = SettingKey.builder()
             .withName("query_id")
             .withType(SettingType.UTF8)
             .withDescription("set current session query")
             .build();
-    
+
     public static Builder builder() {
         return new Builder();
     }
diff --git a/clickhouse-native-jdbc/src/test/java/com/github/housepower/jdbc/AbstractITest.java b/clickhouse-native-jdbc/src/test/java/com/github/housepower/jdbc/AbstractITest.java
index 7175d06b..8438fd00 100644
--- a/clickhouse-native-jdbc/src/test/java/com/github/housepower/jdbc/AbstractITest.java
+++ b/clickhouse-native-jdbc/src/test/java/com/github/housepower/jdbc/AbstractITest.java
@@ -41,27 +41,36 @@ public abstract class AbstractITest implements Serializable {
     protected static final String CLICKHOUSE_PASSWORD = SystemUtil.loadProp("CLICKHOUSE_PASSWORD", "");
     protected static final String CLICKHOUSE_DB = SystemUtil.loadProp("CLICKHOUSE_DB", "");
 
-    protected static final int CLICKHOUSE_GRPC_PORT = 9100;
     protected static final int CLICKHOUSE_HTTP_PORT = 8123;
+    protected static final int CLICKHOUSE_HTTPS_PORT = 8443;
     protected static final int CLICKHOUSE_NATIVE_PORT = 9000;
+    protected static final int CLICKHOUSE_NATIVE_SECURE_PORT = 9440;
 
     @Container
     public static ClickHouseContainer container = new ClickHouseContainer(CLICKHOUSE_IMAGE)
             .withEnv("CLICKHOUSE_USER", CLICKHOUSE_USER)
             .withEnv("CLICKHOUSE_PASSWORD", CLICKHOUSE_PASSWORD)
             .withEnv("CLICKHOUSE_DB", CLICKHOUSE_DB)
-            .withExposedPorts(CLICKHOUSE_HTTP_PORT, CLICKHOUSE_NATIVE_PORT, CLICKHOUSE_GRPC_PORT)
-            .withCopyFileToContainer(MountableFile.forClasspathResource("grpc_config.xml"), "/etc/clickhouse-server/config.d/grpc_config.xml");
+            .withExposedPorts(CLICKHOUSE_HTTP_PORT,
+                    CLICKHOUSE_HTTPS_PORT,
+                    CLICKHOUSE_NATIVE_PORT,
+                    CLICKHOUSE_NATIVE_SECURE_PORT)
+            .withCopyFileToContainer(MountableFile.forClasspathResource("clickhouse/config/config.xml"),
+                    "/etc/clickhouse-server/config.xml")
+            .withCopyFileToContainer(MountableFile.forClasspathResource("clickhouse/config/users.xml"),
+                    "/etc/clickhouse-server/users.xml")
+            .withCopyFileToContainer(MountableFile.forClasspathResource("clickhouse/server.key"),
+                    "/etc/clickhouse-server/server.key")
+            .withCopyFileToContainer(MountableFile.forClasspathResource("clickhouse/server.crt"),
+                    "/etc/clickhouse-server/server.crt");
 
     protected static String CK_HOST;
     protected static int CK_PORT;
-    protected static int CK_GRPC_PORT;
 
     @BeforeAll
     public static void extractContainerInfo() {
         CK_HOST = container.getHost();
         CK_PORT = container.getMappedPort(CLICKHOUSE_NATIVE_PORT);
-        CK_GRPC_PORT = container.getMappedPort(CLICKHOUSE_GRPC_PORT);
     }
 
     /**
@@ -72,28 +81,39 @@ protected String getJdbcUrl() {
     }
 
     protected String getJdbcUrl(Object... params) {
-        StringBuilder sb = new StringBuilder();
-        int port = container.getMappedPort(CLICKHOUSE_NATIVE_PORT);
-        sb.append("jdbc:clickhouse://").append(container.getHost()).append(":").append(port);
-        if (StrUtil.isNotEmpty(CLICKHOUSE_DB)) {
-            sb.append("/").append(container.getDatabaseName());
-        }
+        StringBuilder settingsStringBuilder = new StringBuilder();
         for (int i = 0; i + 1 < params.length; i++) {
-            sb.append(i == 0 ? "?" : "&");
-            sb.append(params[i]).append("=").append(params[i + 1]);
+            settingsStringBuilder.append(i == 0 ? "?" : "&");
+            settingsStringBuilder.append(params[i]).append("=").append(params[i + 1]);
+        }
+
+        StringBuilder mainStringBuilder = new StringBuilder();
+        int port = 0;
+        if (settingsStringBuilder.indexOf("ssl=true") == -1) {
+            port = container.getMappedPort(CLICKHOUSE_NATIVE_PORT);
+        } else {
+            port = container.getMappedPort(CLICKHOUSE_NATIVE_SECURE_PORT);
         }
 
+        mainStringBuilder.append("jdbc:clickhouse://").append(container.getHost()).append(":").append(port);
+        if (StrUtil.isNotEmpty(CLICKHOUSE_DB)) {
+            mainStringBuilder.append("/").append(container.getDatabaseName());
+        }
+
+        // Add settings
+        mainStringBuilder.append(settingsStringBuilder);
+
         // Add user
-        sb.append(params.length < 2 ? "?" : "&");
-        sb.append("user=").append(container.getUsername());
+        mainStringBuilder.append(params.length < 2 ? "?" : "&");
+        mainStringBuilder.append("user=").append(container.getUsername());
 
         // Add password
         // ignore blank password
         if (!StrUtil.isBlank(CLICKHOUSE_PASSWORD)) {
-            sb.append("&password=").append(container.getPassword());
+            mainStringBuilder.append("&password=").append(container.getPassword());
         }
 
-        return sb.toString();
+        return mainStringBuilder.toString();
     }
 
     // this method should be synchronized
diff --git a/clickhouse-native-jdbc/src/test/java/com/github/housepower/jdbc/ClickHouseConnectionITest.java b/clickhouse-native-jdbc/src/test/java/com/github/housepower/jdbc/ClickHouseConnectionITest.java
index 20bd3639..4db3fc9e 100644
--- a/clickhouse-native-jdbc/src/test/java/com/github/housepower/jdbc/ClickHouseConnectionITest.java
+++ b/clickhouse-native-jdbc/src/test/java/com/github/housepower/jdbc/ClickHouseConnectionITest.java
@@ -14,13 +14,53 @@
 
 package com.github.housepower.jdbc;
 
+import com.github.housepower.jdbc.tool.LocalKeyStoreConfig;
+import com.github.housepower.settings.KeyStoreConfig;
 import org.junit.jupiter.api.Test;
 
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertNull;
+import java.sql.ResultSet;
+
+import static org.junit.jupiter.api.Assertions.*;
 
 public class ClickHouseConnectionITest extends AbstractITest {
 
+    @Test
+    void ping() throws Exception {
+        withNewConnection(connection -> {
+            withStatement(connection, stmt -> {
+                ResultSet resultSet = stmt.executeQuery("SELECT 1");
+                assertTrue(resultSet.next());
+            });
+        });
+    }
+
+    @Test
+    void pingWithSecureConnection() throws Exception {
+        withNewConnection(connection -> {
+                    withStatement(connection, stmt -> {
+                        ResultSet resultSet = stmt.executeQuery("SELECT 1");
+                        assertTrue(resultSet.next());
+                    });
+                }, "ssl", "true",
+                "ssl_mode", "disabled");
+    }
+
+    @Test
+    void pingWithSecureConnectionAndVerification() throws Exception {
+        KeyStoreConfig keyStoreConfig = new LocalKeyStoreConfig();
+
+        withNewConnection(connection -> {
+                    withStatement(connection, stmt -> {
+                        ResultSet resultSet = stmt.executeQuery("SELECT 1");
+                        assertTrue(resultSet.next());
+                    });
+                }, "ssl", "true",
+                "ssl_mode", "verify_ca",
+                "key_store_type", keyStoreConfig.getKeyStoreType(),
+                "key_store_path", keyStoreConfig.getKeyStorePath(),
+                "key_store_password", keyStoreConfig.getKeyStorePassword());
+    }
+
     @Test
     public void testCatalog() throws Exception {
         withNewConnection(connection -> {
diff --git a/clickhouse-native-jdbc/src/test/java/com/github/housepower/jdbc/tool/LocalKeyStoreConfig.java b/clickhouse-native-jdbc/src/test/java/com/github/housepower/jdbc/tool/LocalKeyStoreConfig.java
new file mode 100644
index 00000000..d0daead1
--- /dev/null
+++ b/clickhouse-native-jdbc/src/test/java/com/github/housepower/jdbc/tool/LocalKeyStoreConfig.java
@@ -0,0 +1,43 @@
+/*
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.github.housepower.jdbc.tool;
+
+import com.github.housepower.settings.KeyStoreConfig;
+
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.security.KeyStore;
+
+public class LocalKeyStoreConfig extends KeyStoreConfig {
+    @Override
+    public String getKeyStorePath() {
+        return getKeyStoreAbsolutePath();
+    }
+
+    @Override
+    public String getKeyStoreType() {
+        return KeyStore.getDefaultType();
+    }
+
+    @Override
+    public String getKeyStorePassword() {
+        return "mypassword";
+    }
+
+    private String getKeyStoreAbsolutePath() {
+        Path jksPath = Paths.get("src", "test", "resources", "clickhouse", "server.jks");
+        return jksPath.toFile().getAbsolutePath();
+    }
+}
diff --git a/clickhouse-native-jdbc/src/test/resources/clickhouse/config/config.xml b/clickhouse-native-jdbc/src/test/resources/clickhouse/config/config.xml
new file mode 100644
index 00000000..202070de
--- /dev/null
+++ b/clickhouse-native-jdbc/src/test/resources/clickhouse/config/config.xml
@@ -0,0 +1,1198 @@
+<?xml version="1.0"?>
+<!--
+  NOTE: User and query level settings are set up in "users.xml" file.
+  If you have accidentally specified user-level settings here, server won't start.
+  You can either move the settings to the right place inside "users.xml" file
+   or add <skip_check_for_incorrect_settings>1</skip_check_for_incorrect_settings> here.
+-->
+<yandex>
+    <logger>
+        <!-- Possible levels [1]:
+
+          - none (turns off logging)
+          - fatal
+          - critical
+          - error
+          - warning
+          - notice
+          - information
+          - debug
+          - trace
+
+            [1]: https://github.com/pocoproject/poco/blob/poco-1.9.4-release/Foundation/include/Poco/Logger.h#L105-L114
+        -->
+        <level>trace</level>
+        <log>/var/log/clickhouse-server/clickhouse-server.log</log>
+        <errorlog>/var/log/clickhouse-server/clickhouse-server.err.log</errorlog>
+        <!-- Rotation policy
+             See https://github.com/pocoproject/poco/blob/poco-1.9.4-release/Foundation/include/Poco/FileChannel.h#L54-L85
+          -->
+        <size>1000M</size>
+        <count>10</count>
+        <!-- <console>1</console> --> <!-- Default behavior is autodetection (log to console if not daemon mode and is tty) -->
+
+        <!-- Per level overrides (legacy):
+
+        For example to suppress logging of the ConfigReloader you can use:
+        NOTE: levels.logger is reserved, see below.
+        -->
+        <!--
+        <levels>
+          <ConfigReloader>none</ConfigReloader>
+        </levels>
+        -->
+
+        <!-- Per level overrides:
+
+        For example to suppress logging of the RBAC for default user you can use:
+        (But please note that the logger name maybe changed from version to version, even after minor upgrade)
+        -->
+        <!--
+        <levels>
+          <logger>
+            <name>ContextAccess (default)</name>
+            <level>none</level>
+          </logger>
+          <logger>
+            <name>DatabaseOrdinary (test)</name>
+            <level>none</level>
+          </logger>
+        </levels>
+        -->
+    </logger>
+
+    <!-- It is the name that will be shown in the clickhouse-client.
+         By default, anything with "production" will be highlighted in red in query prompt.
+    -->
+    <!--display_name>production</display_name-->
+
+    <!-- Port for HTTP API. See also 'https_port' for secure connections.
+         This interface is also used by ODBC and JDBC drivers (DataGrip, Dbeaver, ...)
+         and by most of web interfaces (embedded UI, Grafana, Redash, ...).
+      -->
+    <http_port>8123</http_port>
+
+    <!-- Port for interaction by native protocol with:
+         - clickhouse-client and other native ClickHouse tools (clickhouse-benchmark, clickhouse-copier);
+         - clickhouse-server with other clickhouse-servers for distributed query processing;
+         - ClickHouse drivers and applications supporting native protocol
+         (this protocol is also informally called as "the TCP protocol");
+         See also 'tcp_port_secure' for secure connections.
+    -->
+    <tcp_port>9000</tcp_port>
+
+    <!-- Compatibility with MySQL protocol.
+         ClickHouse will pretend to be MySQL for applications connecting to this port.
+    -->
+    <mysql_port>9004</mysql_port>
+
+    <!-- Compatibility with PostgreSQL protocol.
+         ClickHouse will pretend to be PostgreSQL for applications connecting to this port.
+    -->
+    <postgresql_port>9005</postgresql_port>
+
+    <!-- HTTP API with TLS (HTTPS).
+         You have to configure certificate to enable this interface.
+         See the openSSL section below.
+    -->
+     <https_port>8443</https_port>
+
+    <!-- Native interface with TLS.
+         You have to configure certificate to enable this interface.
+         See the openSSL section below.
+    -->
+     <tcp_port_secure>9440</tcp_port_secure>
+
+    <!-- Native interface wrapped with PROXYv1 protocol
+         PROXYv1 header sent for every connection.
+         ClickHouse will extract information about proxy-forwarded client address from the header.
+    -->
+    <!-- <tcp_with_proxy_port>9011</tcp_with_proxy_port> -->
+
+    <!-- Port for communication between replicas. Used for data exchange.
+         It provides low-level data access between servers.
+         This port should not be accessible from untrusted networks.
+         See also 'interserver_http_credentials'.
+         Data transferred over connections to this port should not go through untrusted networks.
+         See also 'interserver_https_port'.
+      -->
+    <interserver_http_port>9009</interserver_http_port>
+
+    <!-- Port for communication between replicas with TLS.
+         You have to configure certificate to enable this interface.
+         See the openSSL section below.
+         See also 'interserver_http_credentials'.
+      -->
+    <!-- <interserver_https_port>9010</interserver_https_port> -->
+
+    <!-- Hostname that is used by other replicas to request this server.
+         If not specified, than it is determined analogous to 'hostname -f' command.
+         This setting could be used to switch replication to another network interface
+         (the server may be connected to multiple networks via multiple addresses)
+      -->
+    <!--
+    <interserver_http_host>example.yandex.ru</interserver_http_host>
+    -->
+
+    <!-- You can specify credentials for authenthication between replicas.
+         This is required when interserver_https_port is accessible from untrusted networks,
+         and also recommended to avoid SSRF attacks from possibly compromised services in your network.
+      -->
+    <!--<interserver_http_credentials>
+        <user>interserver</user>
+        <password></password>
+    </interserver_http_credentials>-->
+
+    <!-- Listen specified address.
+         Use :: (wildcard IPv6 address), if you want to accept connections both with IPv4 and IPv6 from everywhere.
+         Notes:
+         If you open connections from wildcard address, make sure that at least one of the following measures applied:
+         - server is protected by firewall and not accessible from untrusted networks;
+         - all users are restricted to subset of network addresses (see users.xml);
+         - all users have strong passwords, only secure (TLS) interfaces are accessible, or connections are only made via TLS interfaces.
+         - users without password have readonly access.
+         See also: https://www.shodan.io/search?query=clickhouse
+      -->
+    <!-- <listen_host>::</listen_host> -->
+
+    <!-- Same for hosts without support for IPv6: -->
+    <!-- <listen_host>0.0.0.0</listen_host> -->
+
+    <!-- Default values - try listen localhost on IPv4 and IPv6. -->
+    <!--
+    <listen_host>::1</listen_host>
+    <listen_host>127.0.0.1</listen_host>
+    -->
+
+    <!-- Don't exit if IPv6 or IPv4 networks are unavailable while trying to listen. -->
+    <!-- <listen_try>0</listen_try> -->
+
+    <!-- Allow multiple servers to listen on the same address:port. This is not recommended.
+      -->
+    <!-- <listen_reuse_port>0</listen_reuse_port> -->
+
+    <!-- <listen_backlog>64</listen_backlog> -->
+
+    <max_connections>4096</max_connections>
+
+    <!-- For 'Connection: keep-alive' in HTTP 1.1 -->
+    <keep_alive_timeout>3</keep_alive_timeout>
+
+    <!-- gRPC protocol (see src/Server/grpc_protos/clickhouse_grpc.proto for the API) -->
+    <!-- <grpc_port>9100</grpc_port> -->
+    <grpc>
+        <enable_ssl>false</enable_ssl>
+
+        <!-- The following two files are used only if enable_ssl=1 -->
+        <ssl_cert_file>/path/to/ssl_cert_file</ssl_cert_file>
+        <ssl_key_file>/path/to/ssl_key_file</ssl_key_file>
+
+        <!-- Whether server will request client for a certificate -->
+        <ssl_require_client_auth>false</ssl_require_client_auth>
+
+        <!-- The following file is used only if ssl_require_client_auth=1 -->
+        <ssl_ca_cert_file>/path/to/ssl_ca_cert_file</ssl_ca_cert_file>
+
+        <!-- Default compression algorithm (applied if client doesn't specify another algorithm).
+             Supported algorithms: none, deflate, gzip, stream_gzip -->
+        <compression>deflate</compression>
+
+        <!-- Default compression level (applied if client doesn't specify another level).
+             Supported levels: none, low, medium, high -->
+        <compression_level>medium</compression_level>
+
+        <!-- Send/receive message size limits in bytes. -1 means unlimited -->
+        <max_send_message_size>-1</max_send_message_size>
+        <max_receive_message_size>-1</max_receive_message_size>
+
+        <!-- Enable if you want very detailed logs -->
+        <verbose_logs>false</verbose_logs>
+    </grpc>
+
+    <!-- Used with https_port and tcp_port_secure. Full ssl options list: https://github.com/ClickHouse-Extras/poco/blob/master/NetSSL_OpenSSL/include/Poco/Net/SSLManager.h#L71 -->
+    <openSSL>
+        <server> <!-- Used for https server AND secure tcp port -->
+            <!-- openssl req -subj "/CN=localhost" -new -newkey rsa:2048 -days 365 -nodes -x509 -keyout /etc/clickhouse-server/server.key -out /etc/clickhouse-server/server.crt -->
+            <certificateFile>/etc/clickhouse-server/server.crt</certificateFile>
+            <privateKeyFile>/etc/clickhouse-server/server.key</privateKeyFile>
+            <!-- dhparams are optional. You can delete the <dhParamsFile> element.
+                 To generate dhparams, use the following command:
+                  openssl dhparam -out /etc/clickhouse-server/dhparam.pem 4096
+                 Only file format with BEGIN DH PARAMETERS is supported.
+              -->
+            <!-- <dhParamsFile>/etc/clickhouse-server/dhparam.pem</dhParamsFile>-->
+            <verificationMode>none</verificationMode>
+            <loadDefaultCAFile>true</loadDefaultCAFile>
+            <cacheSessions>true</cacheSessions>
+            <disableProtocols>sslv2,sslv3</disableProtocols>
+            <preferServerCiphers>true</preferServerCiphers>
+        </server>
+
+        <client> <!-- Used for connecting to https dictionary source and secured Zookeeper communication -->
+            <loadDefaultCAFile>true</loadDefaultCAFile>
+            <cacheSessions>true</cacheSessions>
+            <disableProtocols>sslv2,sslv3</disableProtocols>
+            <preferServerCiphers>true</preferServerCiphers>
+            <!-- Use for self-signed: <verificationMode>none</verificationMode> -->
+            <invalidCertificateHandler>
+                <!-- Use for self-signed: <name>AcceptCertificateHandler</name> -->
+                <name>RejectCertificateHandler</name>
+            </invalidCertificateHandler>
+        </client>
+    </openSSL>
+
+    <!-- Default root page on http[s] server. For example load UI from https://tabix.io/ when opening http://localhost:8123 -->
+    <!--
+    <http_server_default_response><![CDATA[<html ng-app="SMI2"><head><base href="http://ui.tabix.io/"></head><body><div ui-view="" class="content-ui"></div><script src="http://loader.tabix.io/master.js"></script></body></html>]]></http_server_default_response>
+    -->
+
+    <!-- Maximum number of concurrent queries. -->
+    <max_concurrent_queries>100</max_concurrent_queries>
+
+    <!-- Maximum memory usage (resident set size) for server process.
+         Zero value or unset means default. Default is "max_server_memory_usage_to_ram_ratio" of available physical RAM.         If the value is larger than "max_server_memory_usage_to_ram_ratio" of available physical RAM, it will be cut down.
+
+         The constraint is checked on query execution time.
+         If a query tries to allocate memory and the current memory usage plus allocation is greater
+          than specified threshold, exception will be thrown.
+
+         It is not practical to set this constraint to small values like just a few gigabytes,
+          because memory allocator will keep this amount of memory in caches and the server will deny service of queries.
+      -->
+    <max_server_memory_usage>0</max_server_memory_usage>
+
+    <!-- Maximum number of threads in the Global thread pool.
+    This will default to a maximum of 10000 threads if not specified.
+    This setting will be useful in scenarios where there are a large number
+    of distributed queries that are running concurrently but are idling most
+    of the time, in which case a higher number of threads might be required.
+    -->
+
+    <max_thread_pool_size>10000</max_thread_pool_size>
+
+    <!-- On memory constrained environments you may have to set this to value larger than 1.
+      -->
+    <max_server_memory_usage_to_ram_ratio>0.9</max_server_memory_usage_to_ram_ratio>
+
+    <!-- Simple server-wide memory profiler. Collect a stack trace at every peak allocation step (in bytes).
+         Data will be stored in system.trace_log table with query_id = empty string.
+         Zero means disabled.
+      -->
+    <total_memory_profiler_step>4194304</total_memory_profiler_step>
+
+    <!-- Collect random allocations and deallocations and write them into system.trace_log with 'MemorySample' trace_type.
+         The probability is for every alloc/free regardless to the size of the allocation.
+         Note that sampling happens only when the amount of untracked memory exceeds the untracked memory limit,
+          which is 4 MiB by default but can be lowered if 'total_memory_profiler_step' is lowered.
+         You may want to set 'total_memory_profiler_step' to 1 for extra fine grained sampling.
+      -->
+    <total_memory_tracker_sample_probability>0</total_memory_tracker_sample_probability>
+
+    <!-- Set limit on number of open files (default: maximum). This setting makes sense on Mac OS X because getrlimit() fails to retrieve
+         correct maximum value. -->
+    <!-- <max_open_files>262144</max_open_files> -->
+
+    <!-- Size of cache of uncompressed blocks of data, used in tables of MergeTree family.
+         In bytes. Cache is single for server. Memory is allocated only on demand.
+         Cache is used when 'use_uncompressed_cache' user setting turned on (off by default).
+         Uncompressed cache is advantageous only for very short queries and in rare cases.
+
+         Note: uncompressed cache can be pointless for lz4, because memory bandwidth
+         is slower than multi-core decompression on some server configurations.
+         Enabling it can sometimes paradoxically make queries slower.
+      -->
+    <uncompressed_cache_size>8589934592</uncompressed_cache_size>
+
+    <!-- Approximate size of mark cache, used in tables of MergeTree family.
+         In bytes. Cache is single for server. Memory is allocated only on demand.
+         You should not lower this value.
+      -->
+    <mark_cache_size>5368709120</mark_cache_size>
+
+
+    <!-- If you enable the `min_bytes_to_use_mmap_io` setting,
+         the data in MergeTree tables can be read with mmap to avoid copying from kernel to userspace.
+         It makes sense only for large files and helps only if data reside in page cache.
+         To avoid frequent open/mmap/munmap/close calls (which are very expensive due to consequent page faults)
+         and to reuse mappings from several threads and queries,
+         the cache of mapped files is maintained. Its size is the number of mapped regions (usually equal to the number of mapped files).
+         The amount of data in mapped files can be monitored
+         in system.metrics, system.metric_log by the MMappedFiles, MMappedFileBytes metrics
+         and in system.asynchronous_metrics, system.asynchronous_metrics_log by the MMapCacheCells metric,
+         and also in system.events, system.processes, system.query_log, system.query_thread_log, system.query_views_log by the
+         CreatedReadBufferMMap, CreatedReadBufferMMapFailed, MMappedFileCacheHits, MMappedFileCacheMisses events.
+         Note that the amount of data in mapped files does not consume memory directly and is not accounted
+         in query or server memory usage - because this memory can be discarded similar to OS page cache.
+         The cache is dropped (the files are closed) automatically on removal of old parts in MergeTree,
+         also it can be dropped manually by the SYSTEM DROP MMAP CACHE query.
+      -->
+    <mmap_cache_size>1000</mmap_cache_size>
+
+    <!-- Cache size for compiled expressions.-->
+    <compiled_expression_cache_size>134217728</compiled_expression_cache_size>
+
+    <!-- Path to data directory, with trailing slash. -->
+    <path>/var/lib/clickhouse/</path>
+
+    <!-- Path to temporary data for processing hard queries. -->
+    <tmp_path>/var/lib/clickhouse/tmp/</tmp_path>
+
+    <!-- Policy from the <storage_configuration> for the temporary files.
+         If not set <tmp_path> is used, otherwise <tmp_path> is ignored.
+
+         Notes:
+         - move_factor              is ignored
+         - keep_free_space_bytes    is ignored
+         - max_data_part_size_bytes is ignored
+         - you must have exactly one volume in that policy
+    -->
+    <!-- <tmp_policy>tmp</tmp_policy> -->
+
+    <!-- Directory with user provided files that are accessible by 'file' table function. -->
+    <user_files_path>/var/lib/clickhouse/user_files/</user_files_path>
+
+    <!-- LDAP server definitions. -->
+    <ldap_servers>
+        <!-- List LDAP servers with their connection parameters here to later 1) use them as authenticators for dedicated local users,
+              who have 'ldap' authentication mechanism specified instead of 'password', or to 2) use them as remote user directories.
+             Parameters:
+                host - LDAP server hostname or IP, this parameter is mandatory and cannot be empty.
+                port - LDAP server port, default is 636 if enable_tls is set to true, 389 otherwise.
+                bind_dn - template used to construct the DN to bind to.
+                        The resulting DN will be constructed by replacing all '{user_name}' substrings of the template with the actual
+                         user name during each authentication attempt.
+                user_dn_detection - section with LDAP search parameters for detecting the actual user DN of the bound user.
+                        This is mainly used in search filters for further role mapping when the server is Active Directory. The
+                         resulting user DN will be used when replacing '{user_dn}' substrings wherever they are allowed. By default,
+                         user DN is set equal to bind DN, but once search is performed, it will be updated with to the actual detected
+                         user DN value.
+                    base_dn - template used to construct the base DN for the LDAP search.
+                            The resulting DN will be constructed by replacing all '{user_name}' and '{bind_dn}' substrings
+                             of the template with the actual user name and bind DN during the LDAP search.
+                    scope - scope of the LDAP search.
+                            Accepted values are: 'base', 'one_level', 'children', 'subtree' (the default).
+                    search_filter - template used to construct the search filter for the LDAP search.
+                            The resulting filter will be constructed by replacing all '{user_name}', '{bind_dn}', and '{base_dn}'
+                             substrings of the template with the actual user name, bind DN, and base DN during the LDAP search.
+                            Note, that the special characters must be escaped properly in XML.
+                verification_cooldown - a period of time, in seconds, after a successful bind attempt, during which a user will be assumed
+                         to be successfully authenticated for all consecutive requests without contacting the LDAP server.
+                        Specify 0 (the default) to disable caching and force contacting the LDAP server for each authentication request.
+                enable_tls - flag to trigger use of secure connection to the LDAP server.
+                        Specify 'no' for plain text (ldap://) protocol (not recommended).
+                        Specify 'yes' for LDAP over SSL/TLS (ldaps://) protocol (recommended, the default).
+                        Specify 'starttls' for legacy StartTLS protocol (plain text (ldap://) protocol, upgraded to TLS).
+                tls_minimum_protocol_version - the minimum protocol version of SSL/TLS.
+                        Accepted values are: 'ssl2', 'ssl3', 'tls1.0', 'tls1.1', 'tls1.2' (the default).
+                tls_require_cert - SSL/TLS peer certificate verification behavior.
+                        Accepted values are: 'never', 'allow', 'try', 'demand' (the default).
+                tls_cert_file - path to certificate file.
+                tls_key_file - path to certificate key file.
+                tls_ca_cert_file - path to CA certificate file.
+                tls_ca_cert_dir - path to the directory containing CA certificates.
+                tls_cipher_suite - allowed cipher suite (in OpenSSL notation).
+             Example:
+                <my_ldap_server>
+                    <host>localhost</host>
+                    <port>636</port>
+                    <bind_dn>uid={user_name},ou=users,dc=example,dc=com</bind_dn>
+                    <verification_cooldown>300</verification_cooldown>
+                    <enable_tls>yes</enable_tls>
+                    <tls_minimum_protocol_version>tls1.2</tls_minimum_protocol_version>
+                    <tls_require_cert>demand</tls_require_cert>
+                    <tls_cert_file>/path/to/tls_cert_file</tls_cert_file>
+                    <tls_key_file>/path/to/tls_key_file</tls_key_file>
+                    <tls_ca_cert_file>/path/to/tls_ca_cert_file</tls_ca_cert_file>
+                    <tls_ca_cert_dir>/path/to/tls_ca_cert_dir</tls_ca_cert_dir>
+                    <tls_cipher_suite>ECDHE-ECDSA-AES256-GCM-SHA384:ECDHE-RSA-AES256-GCM-SHA384:AES256-GCM-SHA384</tls_cipher_suite>
+                </my_ldap_server>
+             Example (typical Active Directory with configured user DN detection for further role mapping):
+                <my_ad_server>
+                    <host>localhost</host>
+                    <port>389</port>
+                    <bind_dn>EXAMPLE\{user_name}</bind_dn>
+                    <user_dn_detection>
+                        <base_dn>CN=Users,DC=example,DC=com</base_dn>
+                        <search_filter>(&amp;(objectClass=user)(sAMAccountName={user_name}))</search_filter>
+                    </user_dn_detection>
+                    <enable_tls>no</enable_tls>
+                </my_ad_server>
+        -->
+    </ldap_servers>
+
+    <!-- To enable Kerberos authentication support for HTTP requests (GSS-SPNEGO), for those users who are explicitly configured
+          to authenticate via Kerberos, define a single 'kerberos' section here.
+         Parameters:
+            principal - canonical service principal name, that will be acquired and used when accepting security contexts.
+                    This parameter is optional, if omitted, the default principal will be used.
+                    This parameter cannot be specified together with 'realm' parameter.
+            realm - a realm, that will be used to restrict authentication to only those requests whose initiator's realm matches it.
+                    This parameter is optional, if omitted, no additional filtering by realm will be applied.
+                    This parameter cannot be specified together with 'principal' parameter.
+         Example:
+            <kerberos />
+         Example:
+            <kerberos>
+                <principal>HTTP/clickhouse.example.com@EXAMPLE.COM</principal>
+            </kerberos>
+         Example:
+            <kerberos>
+                <realm>EXAMPLE.COM</realm>
+            </kerberos>
+    -->
+
+    <!-- Sources to read users, roles, access rights, profiles of settings, quotas. -->
+    <user_directories>
+        <users_xml>
+            <!-- Path to configuration file with predefined users. -->
+            <path>users.xml</path>
+        </users_xml>
+        <local_directory>
+            <!-- Path to folder where users created by SQL commands are stored. -->
+            <path>/var/lib/clickhouse/access/</path>
+        </local_directory>
+
+        <!-- To add an LDAP server as a remote user directory of users that are not defined locally, define a single 'ldap' section
+              with the following parameters:
+                server - one of LDAP server names defined in 'ldap_servers' config section above.
+                        This parameter is mandatory and cannot be empty.
+                roles - section with a list of locally defined roles that will be assigned to each user retrieved from the LDAP server.
+                        If no roles are specified here or assigned during role mapping (below), user will not be able to perform any
+                         actions after authentication.
+                role_mapping - section with LDAP search parameters and mapping rules.
+                        When a user authenticates, while still bound to LDAP, an LDAP search is performed using search_filter and the
+                         name of the logged in user. For each entry found during that search, the value of the specified attribute is
+                         extracted. For each attribute value that has the specified prefix, the prefix is removed, and the rest of the
+                         value becomes the name of a local role defined in ClickHouse, which is expected to be created beforehand by
+                         CREATE ROLE command.
+                        There can be multiple 'role_mapping' sections defined inside the same 'ldap' section. All of them will be
+                         applied.
+                    base_dn - template used to construct the base DN for the LDAP search.
+                            The resulting DN will be constructed by replacing all '{user_name}', '{bind_dn}', and '{user_dn}'
+                             substrings of the template with the actual user name, bind DN, and user DN during each LDAP search.
+                    scope - scope of the LDAP search.
+                            Accepted values are: 'base', 'one_level', 'children', 'subtree' (the default).
+                    search_filter - template used to construct the search filter for the LDAP search.
+                            The resulting filter will be constructed by replacing all '{user_name}', '{bind_dn}', '{user_dn}', and
+                             '{base_dn}' substrings of the template with the actual user name, bind DN, user DN, and base DN during
+                             each LDAP search.
+                            Note, that the special characters must be escaped properly in XML.
+                    attribute - attribute name whose values will be returned by the LDAP search. 'cn', by default.
+                    prefix - prefix, that will be expected to be in front of each string in the original list of strings returned by
+                             the LDAP search. Prefix will be removed from the original strings and resulting strings will be treated
+                             as local role names. Empty, by default.
+             Example:
+                <ldap>
+                    <server>my_ldap_server</server>
+                    <roles>
+                        <my_local_role1 />
+                        <my_local_role2 />
+                    </roles>
+                    <role_mapping>
+                        <base_dn>ou=groups,dc=example,dc=com</base_dn>
+                        <scope>subtree</scope>
+                        <search_filter>(&amp;(objectClass=groupOfNames)(member={bind_dn}))</search_filter>
+                        <attribute>cn</attribute>
+                        <prefix>clickhouse_</prefix>
+                    </role_mapping>
+                </ldap>
+             Example (typical Active Directory with role mapping that relies on the detected user DN):
+                <ldap>
+                    <server>my_ad_server</server>
+                    <role_mapping>
+                        <base_dn>CN=Users,DC=example,DC=com</base_dn>
+                        <attribute>CN</attribute>
+                        <scope>subtree</scope>
+                        <search_filter>(&amp;(objectClass=group)(member={user_dn}))</search_filter>
+                        <prefix>clickhouse_</prefix>
+                    </role_mapping>
+                </ldap>
+        -->
+    </user_directories>
+
+    <!-- Default profile of settings. -->
+    <default_profile>default</default_profile>
+
+    <!-- Comma-separated list of prefixes for user-defined settings. -->
+    <custom_settings_prefixes></custom_settings_prefixes>
+
+    <!-- System profile of settings. This settings are used by internal processes (Distributed DDL worker and so on). -->
+    <!-- <system_profile>default</system_profile> -->
+
+    <!-- Buffer profile of settings.
+         This settings are used by Buffer storage to flush data to the underlying table.
+         Default: used from system_profile directive.
+    -->
+    <!-- <buffer_profile>default</buffer_profile> -->
+
+    <!-- Default database. -->
+    <default_database>default</default_database>
+
+    <!-- Server time zone could be set here.
+
+         Time zone is used when converting between String and DateTime types,
+          when printing DateTime in text formats and parsing DateTime from text,
+          it is used in date and time related functions, if specific time zone was not passed as an argument.
+
+         Time zone is specified as identifier from IANA time zone database, like UTC or Africa/Abidjan.
+         If not specified, system time zone at server startup is used.
+
+         Please note, that server could display time zone alias instead of specified name.
+         Example: W-SU is an alias for Europe/Moscow and Zulu is an alias for UTC.
+    -->
+    <!-- <timezone>Europe/Moscow</timezone> -->
+
+    <!-- You can specify umask here (see "man umask"). Server will apply it on startup.
+         Number is always parsed as octal. Default umask is 027 (other users cannot read logs, data files, etc; group can only read).
+    -->
+    <!-- <umask>022</umask> -->
+
+    <!-- Perform mlockall after startup to lower first queries latency
+          and to prevent clickhouse executable from being paged out under high IO load.
+         Enabling this option is recommended but will lead to increased startup time for up to a few seconds.
+    -->
+    <mlock_executable>true</mlock_executable>
+
+    <!-- Reallocate memory for machine code ("text") using huge pages. Highly experimental. -->
+    <remap_executable>false</remap_executable>
+
+    <![CDATA[
+         Uncomment below in order to use JDBC table engine and function.
+
+         To install and run JDBC bridge in background:
+         * [Debian/Ubuntu]
+           export MVN_URL=https://repo1.maven.org/maven2/ru/yandex/clickhouse/clickhouse-jdbc-bridge
+           export PKG_VER=$(curl -sL $MVN_URL/maven-metadata.xml | grep '<release>' | sed -e 's|.*>\(.*\)<.*|\1|')
+           wget https://github.com/ClickHouse/clickhouse-jdbc-bridge/releases/download/v$PKG_VER/clickhouse-jdbc-bridge_$PKG_VER-1_all.deb
+           apt install --no-install-recommends -f ./clickhouse-jdbc-bridge_$PKG_VER-1_all.deb
+           clickhouse-jdbc-bridge &
+
+         * [CentOS/RHEL]
+           export MVN_URL=https://repo1.maven.org/maven2/ru/yandex/clickhouse/clickhouse-jdbc-bridge
+           export PKG_VER=$(curl -sL $MVN_URL/maven-metadata.xml | grep '<release>' | sed -e 's|.*>\(.*\)<.*|\1|')
+           wget https://github.com/ClickHouse/clickhouse-jdbc-bridge/releases/download/v$PKG_VER/clickhouse-jdbc-bridge-$PKG_VER-1.noarch.rpm
+           yum localinstall -y clickhouse-jdbc-bridge-$PKG_VER-1.noarch.rpm
+           clickhouse-jdbc-bridge &
+
+         Please refer to https://github.com/ClickHouse/clickhouse-jdbc-bridge#usage for more information.
+    ]]>
+    <!--
+    <jdbc_bridge>
+        <host>127.0.0.1</host>
+        <port>9019</port>
+    </jdbc_bridge>
+    -->
+
+    <!-- Configuration of clusters that could be used in Distributed tables.
+         https://clickhouse.tech/docs/en/operations/table_engines/distributed/
+      -->
+    <remote_servers>
+        <!-- Test only shard config for testing distributed storage -->
+        <test_shard_localhost>
+            <!-- Inter-server per-cluster secret for Distributed queries
+                 default: no secret (no authentication will be performed)
+
+                 If set, then Distributed queries will be validated on shards, so at least:
+                 - such cluster should exist on the shard,
+                 - such cluster should have the same secret.
+
+                 And also (and which is more important), the initial_user will
+                 be used as current user for the query.
+
+                 Right now the protocol is pretty simple and it only takes into account:
+                 - cluster name
+                 - query
+
+                 Also it will be nice if the following will be implemented:
+                 - source hostname (see interserver_http_host), but then it will depends from DNS,
+                   it can use IP address instead, but then the you need to get correct on the initiator node.
+                 - target hostname / ip address (same notes as for source hostname)
+                 - time-based security tokens
+            -->
+            <!-- <secret></secret> -->
+
+            <shard>
+                <!-- Optional. Whether to write data to just one of the replicas. Default: false (write data to all replicas). -->
+                <!-- <internal_replication>false</internal_replication> -->
+                <!-- Optional. Shard weight when writing data. Default: 1. -->
+                <!-- <weight>1</weight> -->
+                <replica>
+                    <host>localhost</host>
+                    <port>9000</port>
+                    <!-- Optional. Priority of the replica for load_balancing. Default: 1 (less value has more priority). -->
+                    <!-- <priority>1</priority> -->
+                </replica>
+            </shard>
+        </test_shard_localhost>
+        <test_cluster_two_shards_localhost>
+            <shard>
+                <replica>
+                    <host>localhost</host>
+                    <port>9000</port>
+                </replica>
+            </shard>
+            <shard>
+                <replica>
+                    <host>localhost</host>
+                    <port>9000</port>
+                </replica>
+            </shard>
+        </test_cluster_two_shards_localhost>
+        <test_cluster_two_shards>
+            <shard>
+                <replica>
+                    <host>127.0.0.1</host>
+                    <port>9000</port>
+                </replica>
+            </shard>
+            <shard>
+                <replica>
+                    <host>127.0.0.2</host>
+                    <port>9000</port>
+                </replica>
+            </shard>
+        </test_cluster_two_shards>
+        <test_cluster_two_shards_internal_replication>
+            <shard>
+                <internal_replication>true</internal_replication>
+                <replica>
+                    <host>127.0.0.1</host>
+                    <port>9000</port>
+                </replica>
+            </shard>
+            <shard>
+                <internal_replication>true</internal_replication>
+                <replica>
+                    <host>127.0.0.2</host>
+                    <port>9000</port>
+                </replica>
+            </shard>
+        </test_cluster_two_shards_internal_replication>
+        <test_shard_localhost_secure>
+            <shard>
+                <replica>
+                    <host>localhost</host>
+                    <port>9440</port>
+                    <secure>1</secure>
+                </replica>
+            </shard>
+        </test_shard_localhost_secure>
+        <test_unavailable_shard>
+            <shard>
+                <replica>
+                    <host>localhost</host>
+                    <port>9000</port>
+                </replica>
+            </shard>
+            <shard>
+                <replica>
+                    <host>localhost</host>
+                    <port>1</port>
+                </replica>
+            </shard>
+        </test_unavailable_shard>
+    </remote_servers>
+
+    <!-- The list of hosts allowed to use in URL-related storage engines and table functions.
+        If this section is not present in configuration, all hosts are allowed.
+    -->
+    <!--<remote_url_allow_hosts>-->
+    <!-- Host should be specified exactly as in URL. The name is checked before DNS resolution.
+        Example: "yandex.ru", "yandex.ru." and "www.yandex.ru" are different hosts.
+                If port is explicitly specified in URL, the host:port is checked as a whole.
+                If host specified here without port, any port with this host allowed.
+                "yandex.ru" -> "yandex.ru:443", "yandex.ru:80" etc. is allowed, but "yandex.ru:80" -> only "yandex.ru:80" is allowed.
+        If the host is specified as IP address, it is checked as specified in URL. Example: "[2a02:6b8:a::a]".
+        If there are redirects and support for redirects is enabled, every redirect (the Location field) is checked.            Host should be specified using the host xml tag:
+                <host>yandex.ru</host>
+    -->
+
+    <!-- Regular expression can be specified. RE2 engine is used for regexps.
+        Regexps are not aligned: don't forget to add ^ and $. Also don't forget to escape dot (.) metacharacter
+        (forgetting to do so is a common source of error).
+    -->
+    <!--</remote_url_allow_hosts>-->
+
+    <!-- If element has 'incl' attribute, then for it's value will be used corresponding substitution from another file.         By default, path to file with substitutions is /etc/metrika.xml. It could be changed in config in 'include_from' element.
+         Values for substitutions are specified in /yandex/name_of_substitution elements in that file.
+      -->
+
+    <!-- ZooKeeper is used to store metadata about replicas, when using Replicated tables.
+         Optional. If you don't use replicated tables, you could omit that.
+
+         See https://clickhouse.tech/docs/en/engines/table-engines/mergetree-family/replication/
+      -->
+
+    <!--
+    <zookeeper>
+        <node>
+            <host>example1</host>
+            <port>2181</port>
+        </node>
+        <node>
+            <host>example2</host>
+            <port>2181</port>
+        </node>
+        <node>
+            <host>example3</host>
+            <port>2181</port>
+        </node>
+    </zookeeper>
+    -->
+
+    <!-- Substitutions for parameters of replicated tables.
+          Optional. If you don't use replicated tables, you could omit that.
+
+         See https://clickhouse.tech/docs/en/engines/table-engines/mergetree-family/replication/#creating-replicated-tables
+      -->
+    <!--
+    <macros>
+        <shard>01</shard>
+        <replica>example01-01-1</replica>
+    </macros>
+    -->
+
+
+    <!-- Reloading interval for embedded dictionaries, in seconds. Default: 3600. -->
+    <builtin_dictionaries_reload_interval>3600</builtin_dictionaries_reload_interval>
+
+
+    <!-- Maximum session timeout, in seconds. Default: 3600. -->
+    <max_session_timeout>3600</max_session_timeout>
+
+    <!-- Default session timeout, in seconds. Default: 60. -->
+    <default_session_timeout>60</default_session_timeout>
+
+    <!-- Sending data to Graphite for monitoring. Several sections can be defined. -->
+    <!--
+        interval - send every X second
+        root_path - prefix for keys
+        hostname_in_path - append hostname to root_path (default = true)
+        metrics - send data from table system.metrics
+        events - send data from table system.events
+        asynchronous_metrics - send data from table system.asynchronous_metrics
+    -->
+    <!--
+    <graphite>
+        <host>localhost</host>
+        <port>42000</port>
+        <timeout>0.1</timeout>
+        <interval>60</interval>
+        <root_path>one_min</root_path>
+        <hostname_in_path>true</hostname_in_path>
+
+        <metrics>true</metrics>
+        <events>true</events>
+        <events_cumulative>false</events_cumulative>
+        <asynchronous_metrics>true</asynchronous_metrics>
+    </graphite>
+    <graphite>
+        <host>localhost</host>
+        <port>42000</port>
+        <timeout>0.1</timeout>
+        <interval>1</interval>
+        <root_path>one_sec</root_path>
+
+        <metrics>true</metrics>
+        <events>true</events>
+        <events_cumulative>false</events_cumulative>
+        <asynchronous_metrics>false</asynchronous_metrics>
+    </graphite>
+    -->
+
+    <!-- Serve endpoint for Prometheus monitoring. -->
+    <!--
+        endpoint - mertics path (relative to root, statring with "/")
+        port - port to setup server. If not defined or 0 than http_port used
+        metrics - send data from table system.metrics
+        events - send data from table system.events
+        asynchronous_metrics - send data from table system.asynchronous_metrics
+        status_info - send data from different component from CH, ex: Dictionaries status
+    -->
+    <!--
+    <prometheus>
+        <endpoint>/metrics</endpoint>
+        <port>9363</port>
+
+        <metrics>true</metrics>
+        <events>true</events>
+        <asynchronous_metrics>true</asynchronous_metrics>
+        <status_info>true</status_info>
+    </prometheus>
+    -->
+
+    <!-- Query log. Used only for queries with setting log_queries = 1. -->
+    <query_log>
+        <!-- What table to insert data. If table is not exist, it will be created.
+             When query log structure is changed after system update,
+              then old table will be renamed and new table will be created automatically.
+        -->
+        <database>system</database>
+        <table>query_log</table>
+        <!--
+            PARTITION BY expr: https://clickhouse.yandex/docs/en/table_engines/mergetree-family/custom_partitioning_key/            Example:
+                event_date
+                toMonday(event_date)
+                toYYYYMM(event_date)
+                toStartOfHour(event_time)
+        -->
+        <partition_by>toYYYYMM(event_date)</partition_by>
+        <!--
+            Table TTL specification: https://clickhouse.tech/docs/en/engines/table-engines/mergetree-family/mergetree/#mergetree-table-ttl
+            Example:
+                event_date + INTERVAL 1 WEEK
+                event_date + INTERVAL 7 DAY DELETE
+                event_date + INTERVAL 2 WEEK TO DISK 'bbb'
+
+        <ttl>event_date + INTERVAL 30 DAY DELETE</ttl>
+        -->
+
+        <!-- Instead of partition_by, you can provide full engine expression (starting with ENGINE = ) with parameters,
+             Example: <engine>ENGINE = MergeTree PARTITION BY toYYYYMM(event_date) ORDER BY (event_date, event_time) SETTINGS index_granularity = 1024</engine>
+          -->
+
+        <!-- Interval of flushing data. -->
+        <flush_interval_milliseconds>7500</flush_interval_milliseconds>
+    </query_log>
+
+    <!-- Trace log. Stores stack traces collected by query profilers.
+         See query_profiler_real_time_period_ns and query_profiler_cpu_time_period_ns settings. -->
+    <trace_log>
+        <database>system</database>
+        <table>trace_log</table>
+
+        <partition_by>toYYYYMM(event_date)</partition_by>
+        <flush_interval_milliseconds>7500</flush_interval_milliseconds>
+    </trace_log>
+
+    <!-- Query thread log. Has information about all threads participated in query execution.
+         Used only for queries with setting log_query_threads = 1. -->
+    <query_thread_log>
+        <database>system</database>
+        <table>query_thread_log</table>
+        <partition_by>toYYYYMM(event_date)</partition_by>
+        <flush_interval_milliseconds>7500</flush_interval_milliseconds>
+    </query_thread_log>
+
+    <!-- Query views log. Has information about all dependent views associated with a query.
+         Used only for queries with setting log_query_views = 1. -->
+    <query_views_log>
+        <database>system</database>
+        <table>query_views_log</table>
+        <partition_by>toYYYYMM(event_date)</partition_by>
+        <flush_interval_milliseconds>7500</flush_interval_milliseconds>
+    </query_views_log>
+
+    <!-- Uncomment if use part log.
+         Part log contains information about all actions with parts in MergeTree tables (creation, deletion, merges, downloads).-->
+    <part_log>
+        <database>system</database>
+        <table>part_log</table>
+        <partition_by>toYYYYMM(event_date)</partition_by>
+        <flush_interval_milliseconds>7500</flush_interval_milliseconds>
+    </part_log>
+
+    <!-- Uncomment to write text log into table.
+         Text log contains all information from usual server log but stores it in structured and efficient way.
+         The level of the messages that goes to the table can be limited (<level>), if not specified all messages will go to the table.
+    <text_log>
+        <database>system</database>
+        <table>text_log</table>
+        <flush_interval_milliseconds>7500</flush_interval_milliseconds>
+        <level></level>
+    </text_log>
+    -->
+
+    <!-- Metric log contains rows with current values of ProfileEvents, CurrentMetrics collected with "collect_interval_milliseconds" interval. -->
+    <metric_log>
+        <database>system</database>
+        <table>metric_log</table>
+        <flush_interval_milliseconds>7500</flush_interval_milliseconds>
+        <collect_interval_milliseconds>1000</collect_interval_milliseconds>
+    </metric_log>
+
+    <!--
+        Asynchronous metric log contains values of metrics from
+        system.asynchronous_metrics.
+    -->
+    <asynchronous_metric_log>
+        <database>system</database>
+        <table>asynchronous_metric_log</table>
+        <!--
+            Asynchronous metrics are updated once a minute, so there is
+            no need to flush more often.
+        -->
+        <flush_interval_milliseconds>7000</flush_interval_milliseconds>
+    </asynchronous_metric_log>
+
+    <!--
+        OpenTelemetry log contains OpenTelemetry trace spans.
+    -->
+    <opentelemetry_span_log>
+        <!--
+            The default table creation code is insufficient, this <engine> spec
+            is a workaround. There is no 'event_time' for this log, but two times,
+            start and finish. It is sorted by finish time, to avoid inserting
+            data too far away in the past (probably we can sometimes insert a span
+            that is seconds earlier than the last span in the table, due to a race
+            between several spans inserted in parallel). This gives the spans a
+            global order that we can use to e.g. retry insertion into some external
+            system.
+        -->
+        <engine>
+            engine MergeTree
+            partition by toYYYYMM(finish_date)
+            order by (finish_date, finish_time_us, trace_id)
+        </engine>
+        <database>system</database>
+        <table>opentelemetry_span_log</table>
+        <flush_interval_milliseconds>7500</flush_interval_milliseconds>
+    </opentelemetry_span_log>
+
+
+    <!-- Crash log. Stores stack traces for fatal errors.
+         This table is normally empty. -->
+    <crash_log>
+        <database>system</database>
+        <table>crash_log</table>
+
+        <partition_by />
+        <flush_interval_milliseconds>1000</flush_interval_milliseconds>
+    </crash_log>
+
+
+    <!-- Parameters for embedded dictionaries, used in Yandex.Metrica.
+         See https://clickhouse.yandex/docs/en/dicts/internal_dicts/
+    -->
+
+    <!-- Path to file with region hierarchy. -->
+    <!-- <path_to_regions_hierarchy_file>/opt/geo/regions_hierarchy.txt</path_to_regions_hierarchy_file> -->
+
+    <!-- Path to directory with files containing names of regions -->
+    <!-- <path_to_regions_names_files>/opt/geo/</path_to_regions_names_files> -->
+
+
+    <!-- <top_level_domains_path>/var/lib/clickhouse/top_level_domains/</top_level_domains_path> -->
+    <!-- Custom TLD lists.
+         Format: <name>/path/to/file</name>
+
+         Changes will not be applied w/o server restart.
+         Path to the list is under top_level_domains_path (see above).
+    -->
+    <top_level_domains_lists>
+        <!--
+        <public_suffix_list>/path/to/public_suffix_list.dat</public_suffix_list>
+        -->
+    </top_level_domains_lists>
+
+    <!-- Configuration of external dictionaries. See:
+         https://clickhouse.tech/docs/en/sql-reference/dictionaries/external-dictionaries/external-dicts
+    -->
+    <dictionaries_config>*_dictionary.xml</dictionaries_config>
+
+    <!-- Uncomment if you want data to be compressed 30-100% better.
+         Don't do that if you just started using ClickHouse.
+      -->
+    <!--
+    <compression>
+        <!- - Set of variants. Checked in order. Last matching case wins. If nothing matches, lz4 will be used. - ->
+        <case>
+
+            <!- - Conditions. All must be satisfied. Some conditions may be omitted. - ->
+            <min_part_size>10000000000</min_part_size>        <!- - Min part size in bytes. - ->
+            <min_part_size_ratio>0.01</min_part_size_ratio>   <!- - Min size of part relative to whole table size. - ->
+
+            <!- - What compression method to use. - ->
+            <method>zstd</method>
+        </case>
+    </compression>
+    -->
+
+    <!-- Configuration of encryption. The server executes a command to
+         obtain an encryption key at startup if such a command is
+         defined, or encryption codecs will be disabled otherwise. The
+         command is executed through /bin/sh and is expected to write
+         a Base64-encoded key to the stdout. -->
+    <encryption>
+        <!-- <key_command>/usr/bin/systemd-ask-password &#45;&#45;id="clickhouse-server" &#45;&#45;timeout=0 "Enter the ClickHouse encryption passphrase:" | base64</key_command> -->
+        <!-- <key_command><![CDATA[IFS=; echo -n >/dev/tty "Enter the ClickHouse encryption passphrase: "; stty=`stty -F /dev/tty -g`; stty -F /dev/tty -echo; read k </dev/tty; stty -F /dev/tty "$stty"; echo -n $k | base64]]></key_command> -->
+    </encryption>
+
+    <!-- Allow to execute distributed DDL queries (CREATE, DROP, ALTER, RENAME) on cluster.
+         Works only if ZooKeeper is enabled. Comment it if such functionality isn't required. -->
+    <distributed_ddl>
+        <!-- Path in ZooKeeper to queue with DDL queries -->
+        <path>/clickhouse/task_queue/ddl</path>
+
+        <!-- Settings from this profile will be used to execute DDL queries -->
+        <!-- <profile>default</profile> -->
+
+        <!-- Controls how much ON CLUSTER queries can be run simultaneously. -->
+        <!-- <pool_size>1</pool_size> -->
+
+        <!--
+             Cleanup settings (active tasks will not be removed)
+        -->
+
+        <!-- Controls task TTL (default 1 week) -->
+        <!-- <task_max_lifetime>604800</task_max_lifetime> -->
+
+        <!-- Controls how often cleanup should be performed (in seconds) -->
+        <!-- <cleanup_delay_period>60</cleanup_delay_period> -->
+
+        <!-- Controls how many tasks could be in the queue -->
+        <!-- <max_tasks_in_queue>1000</max_tasks_in_queue> -->
+    </distributed_ddl>
+
+    <!-- Settings to fine tune MergeTree tables. See documentation in source code, in MergeTreeSettings.h -->
+    <!--
+    <merge_tree>
+        <max_suspicious_broken_parts>5</max_suspicious_broken_parts>
+    </merge_tree>
+    -->
+
+    <!-- Protection from accidental DROP.
+         If size of a MergeTree table is greater than max_table_size_to_drop (in bytes) than table could not be dropped with any DROP query.
+         If you want do delete one table and don't want to change clickhouse-server config, you could create special file <clickhouse-path>/flags/force_drop_table and make DROP once.
+         By default max_table_size_to_drop is 50GB; max_table_size_to_drop=0 allows to DROP any tables.
+         The same for max_partition_size_to_drop.
+         Uncomment to disable protection.
+    -->
+    <!-- <max_table_size_to_drop>0</max_table_size_to_drop> -->
+    <!-- <max_partition_size_to_drop>0</max_partition_size_to_drop> -->
+
+    <!-- Example of parameters for GraphiteMergeTree table engine -->
+    <graphite_rollup_example>
+        <pattern>
+            <regexp>click_cost</regexp>
+            <function>any</function>
+            <retention>
+                <age>0</age>
+                <precision>3600</precision>
+            </retention>
+            <retention>
+                <age>86400</age>
+                <precision>60</precision>
+            </retention>
+        </pattern>
+        <default>
+            <function>max</function>
+            <retention>
+                <age>0</age>
+                <precision>60</precision>
+            </retention>
+            <retention>
+                <age>3600</age>
+                <precision>300</precision>
+            </retention>
+            <retention>
+                <age>86400</age>
+                <precision>3600</precision>
+            </retention>
+        </default>
+    </graphite_rollup_example>
+
+    <!-- Directory in <clickhouse-path> containing schema files for various input formats.
+         The directory will be created if it doesn't exist.
+      -->
+    <format_schema_path>/var/lib/clickhouse/format_schemas/</format_schema_path>
+
+    <!-- Default query masking rules, matching lines would be replaced with something else in the logs
+        (both text logs and system.query_log).
+        name - name for the rule (optional)
+        regexp - RE2 compatible regular expression (mandatory)
+        replace - substitution string for sensitive data (optional, by default - six asterisks)
+    -->
+    <query_masking_rules>
+        <rule>
+            <name>hide encrypt/decrypt arguments</name>
+            <regexp>((?:aes_)?(?:encrypt|decrypt)(?:_mysql)?)\s*\(\s*(?:'(?:\\'|.)+'|.*?)\s*\)</regexp>
+            <!-- or more secure, but also more invasive:
+                (aes_\w+)\s*\(.*\)
+            -->
+            <replace>\1(???)</replace>
+        </rule>
+    </query_masking_rules>
+
+    <!-- Uncomment to use custom http handlers.
+        rules are checked from top to bottom, first match runs the handler
+            url - to match request URL, you can use 'regex:' prefix to use regex match(optional)
+            methods - to match request method, you can use commas to separate multiple method matches(optional)
+            headers - to match request headers, match each child element(child element name is header name), you can use 'regex:' prefix to use regex match(optional)
+        handler is request handler
+            type - supported types: static, dynamic_query_handler, predefined_query_handler
+            query - use with predefined_query_handler type, executes query when the handler is called
+            query_param_name - use with dynamic_query_handler type, extracts and executes the value corresponding to the <query_param_name> value in HTTP request params
+            status - use with static type, response status code
+            content_type - use with static type, response content-type
+            response_content - use with static type, Response content sent to client, when using the prefix 'file://' or 'config://', find the content from the file or configuration send to client.
+
+    <http_handlers>
+        <rule>
+            <url>/</url>
+            <methods>POST,GET</methods>
+            <headers><pragma>no-cache</pragma></headers>
+            <handler>
+                <type>dynamic_query_handler</type>
+                <query_param_name>query</query_param_name>
+            </handler>
+        </rule>
+
+        <rule>
+            <url>/predefined_query</url>
+            <methods>POST,GET</methods>
+            <handler>
+                <type>predefined_query_handler</type>
+                <query>SELECT * FROM system.settings</query>
+            </handler>
+        </rule>
+
+        <rule>
+            <handler>
+                <type>static</type>
+                <status>200</status>
+                <content_type>text/plain; charset=UTF-8</content_type>
+                <response_content>config://http_server_default_response</response_content>
+            </handler>
+        </rule>
+    </http_handlers>
+    -->
+
+    <send_crash_reports>
+        <!-- Changing <enabled> to true allows sending crash reports to -->
+        <!-- the ClickHouse core developers team via Sentry https://sentry.io -->
+        <!-- Doing so at least in pre-production environments is highly appreciated -->
+        <enabled>false</enabled>
+        <!-- Change <anonymize> to true if you don't feel comfortable attaching the server hostname to the crash report -->
+        <anonymize>false</anonymize>
+        <!-- Default endpoint should be changed to different Sentry DSN only if you have -->
+        <!-- some in-house engineers or hired consultants who're going to debug ClickHouse issues for you -->
+        <endpoint>https://6f33034cfe684dd7a3ab9875e57b1c8d@o388870.ingest.sentry.io/5226277</endpoint>
+    </send_crash_reports>
+
+    <!-- Uncomment to disable ClickHouse internal DNS caching. -->
+    <!-- <disable_internal_dns_cache>1</disable_internal_dns_cache> -->
+
+    <!-- You can also configure rocksdb like this: -->
+    <!--
+    <rocksdb>
+        <options>
+            <max_background_jobs>8</max_background_jobs>
+        </options>
+        <column_family_options>
+            <num_levels>2</num_levels>
+        </column_family_options>
+        <tables>
+            <table>
+                <name>TABLE</name>
+                <options>
+                    <max_background_jobs>8</max_background_jobs>
+                </options>
+                <column_family_options>
+                    <num_levels>2</num_levels>
+                </column_family_options>
+            </table>
+        </tables>
+    </rocksdb>
+    -->
+</yandex>
\ No newline at end of file
diff --git a/clickhouse-native-jdbc/src/test/resources/clickhouse/config/users.xml b/clickhouse-native-jdbc/src/test/resources/clickhouse/config/users.xml
new file mode 100644
index 00000000..c7cf0f5b
--- /dev/null
+++ b/clickhouse-native-jdbc/src/test/resources/clickhouse/config/users.xml
@@ -0,0 +1,123 @@
+<?xml version="1.0"?>
+<yandex>
+    <!-- See also the files in users.d directory where the settings can be overridden. -->
+
+    <!-- Profiles of settings. -->
+    <profiles>
+        <!-- Default settings. -->
+        <default>
+            <!-- Maximum memory usage for processing single query, in bytes. -->
+            <max_memory_usage>10000000000</max_memory_usage>
+
+            <!-- How to choose between replicas during distributed query processing.
+                 random - choose random replica from set of replicas with minimum number of errors
+                 nearest_hostname - from set of replicas with minimum number of errors, choose replica
+                  with minimum number of different symbols between replica's hostname and local hostname
+                  (Hamming distance).
+                 in_order - first live replica is chosen in specified order.
+                 first_or_random - if first replica one has higher number of errors, pick a random one from replicas with minimum number of errors.
+            -->
+            <load_balancing>random</load_balancing>
+        </default>
+
+        <!-- Profile that allows only read queries. -->
+        <readonly>
+            <readonly>1</readonly>
+        </readonly>
+    </profiles>
+
+    <!-- Users and ACL. -->
+    <users>
+        <!-- If user name was not specified, 'default' user is used. -->
+        <default>
+            <!-- See also the files in users.d directory where the password can be overridden.
+
+                 Password could be specified in plaintext or in SHA256 (in hex format).
+
+                 If you want to specify password in plaintext (not recommended), place it in 'password' element.
+                 Example: <password>qwerty</password>.
+                 Password could be empty.
+
+                 If you want to specify SHA256, place it in 'password_sha256_hex' element.
+                 Example: <password_sha256_hex>65e84be33532fb784c48129675f9eff3a682b27168c0ea744b2cf58ee02337c5</password_sha256_hex>
+                 Restrictions of SHA256: impossibility to connect to ClickHouse using MySQL JS client (as of July 2019).
+
+                 If you want to specify double SHA1, place it in 'password_double_sha1_hex' element.
+                 Example: <password_double_sha1_hex>e395796d6546b1b65db9d665cd43f0e858dd4303</password_double_sha1_hex>
+
+                 If you want to specify a previously defined LDAP server (see 'ldap_servers' in the main config) for authentication,
+                  place its name in 'server' element inside 'ldap' element.
+                 Example: <ldap><server>my_ldap_server</server></ldap>
+
+                 If you want to authenticate the user via Kerberos (assuming Kerberos is enabled, see 'kerberos' in the main config),
+                  place 'kerberos' element instead of 'password' (and similar) elements.
+                 The name part of the canonical principal name of the initiator must match the user name for authentication to succeed.
+                 You can also place 'realm' element inside 'kerberos' element to further restrict authentication to only those requests
+                  whose initiator's realm matches it.
+                 Example: <kerberos />
+                 Example: <kerberos><realm>EXAMPLE.COM</realm></kerberos>
+
+                 How to generate decent password:
+                 Execute: PASSWORD=$(base64 < /dev/urandom | head -c8); echo "$PASSWORD"; echo -n "$PASSWORD" | sha256sum | tr -d '-'
+                 In first line will be password and in second - corresponding SHA256.
+
+                 How to generate double SHA1:
+                 Execute: PASSWORD=$(base64 < /dev/urandom | head -c8); echo "$PASSWORD"; echo -n "$PASSWORD" | sha1sum | tr -d '-' | xxd -r -p | sha1sum | tr -d '-'
+                 In first line will be password and in second - corresponding double SHA1.
+            -->
+            <password></password>
+
+            <!-- List of networks with open access.
+
+                 To open access from everywhere, specify:
+                    <ip>::/0</ip>
+
+                 To open access only from localhost, specify:
+                    <ip>::1</ip>
+                    <ip>127.0.0.1</ip>
+
+                 Each element of list has one of the following forms:
+                 <ip> IP-address or network mask. Examples: 213.180.204.3 or 10.0.0.1/8 or 10.0.0.1/255.255.255.0
+                     2a02:6b8::3 or 2a02:6b8::3/64 or 2a02:6b8::3/ffff:ffff:ffff:ffff::.
+                 <host> Hostname. Example: server01.yandex.ru.
+                     To check access, DNS query is performed, and all received addresses compared to peer address.
+                 <host_regexp> Regular expression for host names. Example, ^server\d\d-\d\d-\d\.yandex\.ru$
+                     To check access, DNS PTR query is performed for peer address and then regexp is applied.
+                     Then, for result of PTR query, another DNS query is performed and all received addresses compared to peer address.
+                     Strongly recommended that regexp is ends with $
+                 All results of DNS requests are cached till server restart.
+            -->
+            <networks>
+                <ip>::/0</ip>
+            </networks>
+
+            <!-- Settings profile for user. -->
+            <profile>default</profile>
+
+            <!-- Quota for user. -->
+            <quota>default</quota>
+
+            <!-- User can create other users and grant rights to them. -->
+            <!-- <access_management>1</access_management> -->
+        </default>
+    </users>
+
+    <!-- Quotas. -->
+    <quotas>
+        <!-- Name of quota. -->
+        <default>
+            <!-- Limits for time interval. You could specify many intervals with different limits. -->
+            <interval>
+                <!-- Length of interval. -->
+                <duration>3600</duration>
+
+                <!-- No limits. Just calculate resource usage for time interval. -->
+                <queries>0</queries>
+                <errors>0</errors>
+                <result_rows>0</result_rows>
+                <read_rows>0</read_rows>
+                <execution_time>0</execution_time>
+            </interval>
+        </default>
+    </quotas>
+</yandex>
\ No newline at end of file
diff --git a/clickhouse-native-jdbc/src/test/resources/clickhouse/server.crt b/clickhouse-native-jdbc/src/test/resources/clickhouse/server.crt
new file mode 100644
index 00000000..ed279bd9
--- /dev/null
+++ b/clickhouse-native-jdbc/src/test/resources/clickhouse/server.crt
@@ -0,0 +1,19 @@
+-----BEGIN CERTIFICATE-----
+MIIDCTCCAfGgAwIBAgIUGiof/tcvWR9ITSWwONatZC68ys0wDQYJKoZIhvcNAQEL
+BQAwFDESMBAGA1UEAwwJbG9jYWxob3N0MB4XDTIzMDgyNjIxMTczN1oXDTI0MDgy
+NTIxMTczN1owFDESMBAGA1UEAwwJbG9jYWxob3N0MIIBIjANBgkqhkiG9w0BAQEF
+AAOCAQ8AMIIBCgKCAQEAmC1y+HO3QzDIk5DnK6ouUoxCIH6c/zeT/uYSCmvUQU1l
+rEWQ5+U/iEAQkmIyK/7yvyHromp+ZfzoVlDANF/5d3OaRcXxLKjVBf1xxELlEzXR
+Jw2Vx3KnrxO0P9RXwmuc+n8alYZwxIbt1IPlqGJzgUHd3cFcjXe7Z8dnhAO3zekr
+UDRP028LdIrLPGpBanHNKiJv73o3QrNJKLw9l5kDPMlmrXb/9uot4xxYj6L3Kz84
+lACApL04tkH3+W6vadwdzWjPEvFwlLIoRBV1YXnzKUlgNwey6PLDo5jE+2AXR433
+6UPHZJ5XNTtJ1zSe+wiC8xqA5zgv2f/S6KNrGAZ4JQIDAQABo1MwUTAdBgNVHQ4E
+FgQUucBNLF7S0DEqgJYTpD0Y6rKZx6kwHwYDVR0jBBgwFoAUucBNLF7S0DEqgJYT
+pD0Y6rKZx6kwDwYDVR0TAQH/BAUwAwEB/zANBgkqhkiG9w0BAQsFAAOCAQEAN9i6
+xLrh4DyJOV1KsIM1nrWq1P5wZjQny9i4TmU6doGXIiTIAipXyL8liX5/3qVGZkBb
+WYWgQTdfjjZJENSawxUiIQnsvqO83dyzRaMg+yKRUPf6MZTQDxjgmK3BZ6qmMLbj
+BhMYAA5r6b6oTW5pmqo+wQxP7doZOiX/Xcjw2iHBtL1jy4rEwsEoOYpH7u0ywWiQ
+9WsaYNcm+b452MJBYWeRqxJx4gtvcBFAii2Win5AT/SUTtHQcQKrDxv+osGS5vZj
+v+2LxCCNfTmJfIsGPSsyiqulvzzn4xcNE6ETzAcvudx+to9YfUogJYmhsQpc/CBa
+7DYS2q7Uf7a7d7xZDw==
+-----END CERTIFICATE-----
diff --git a/clickhouse-native-jdbc/src/test/resources/clickhouse/server.jks b/clickhouse-native-jdbc/src/test/resources/clickhouse/server.jks
new file mode 100644
index 0000000000000000000000000000000000000000..a83d56c291eb3b46ccbc7fcf4efcc7076930f015
GIT binary patch
literal 2134
zcmZ`(c{J1u8=jwGFj;48Sz>6Ab*wYC7?Pzs8HBiYAw$NHC4JUJMq<cTDoY_tma(PL
zG(&N@LdKFJQl$8-ne3l?&-cgu<NN-2&U>EoKJR<p^StLg2g?V`AP|V-2*BUqzH-ec
zB*-V?h?8|%syaX*E&!FxxsMWnKvf|CC!oS13;<jp&ScI-hccWAI!mmF5uld53J3d=
zW!Ln5TK1zMc#;#9tTVK<$xXGC9<W}6dO-c77Dk)HOX<@Q@R?Mdu}CUn%I(p6!erO7
z`|uCc_aGZ(mJ(!5AKoUBV@99S@G8b=9OrtV{GEcCtpsr!sM~~4rO1~|S}#6&MpK4U
zQrlfd1vWjbvYB-gOakrc1B+*9;|lg@oc0B8(}JC%(hfw{dsDC8F1oYoN)7L|7-inr
z^t-t*n_D9&xpo>+bD&9zihGv4oYUk!rmG{iL{u8S5+_>At4QtbJQn<EWJK=tYYQdX
z&E0k$2c><IrCPklB4Qh)yV>i)E)<N7*0YlB`!F2Q^tr+fM?pH8@HnL6Y&|W`1sSZq
zpYe1b&Hm=(G+n_^ncW$zM#raE?bq}u*ZE7Fw7V|D|J1YvXHVV{{07ZzBUJEH#WZt0
zEu%KIqzsckQ0&zjUUrbTlt1g*FqrijWcIdovuS_yhuz%|G6i{iAqzRVUncCuhP;^G
zPTmEblQE8dmF1`tAKB&1n*v&rAxm0&>q}=7U4OpWPWiI&8n=sYmZ><s?-&ujB+oYc
zL~zCm$WRMs2}&N=1Plw)xR8=!_J&mKM-R{4%{1D|*QevgM~Cp8Q3xWynC$CTT@mTo
z;f^^dTPq=6aBeD^!&qO3LU=EHCfRZchulwS!&D|m`q#B8GZtsWeHO0>O{Ymd{f(=k
z#XdGJ!rM!{qHrWOdo{GAjt}8Fa8=`_1u)cQex_PeSF(b&T8=J@?z6%yzAkBID!fab
zabqGK#csk@O46c`X70zQAD@)@cwe-+OV;(gMFsPk22Qz$-IzG|qrp>nb>K1KL)uuS
z`Va8J&W%&{igI_>yQ626OF6JyCNhGLxKB_a<1GiU8~6;!&NCwSf~P-zYtL)&N3^Em
z1`Q@LHXairh{elS63E$#n$)T6vM`Yg(6EH8fZqgB2X80&7~db@QqL91bY{btcaDcz
zcLq3i6E)XpwbYGQzt7D&4O?ua(XMAUzDU}Wa)>@5V!KyAuOFyydB#*~wL#rz@Z=xR
zSlj-jTJhKh``SF`q(2okFQ`&UYbh1Y3U(CY8<BG<de+DyV`85_KdIhZbeX1gDvKh`
zpCvT6cW>_8?F=n>cnhEZ$i9bK93`gF7x7kL(uIh?CU8J`w)q0zkYca!$XlZ=5`SJg
zZFqKbAZXvZJrTqu7dY)k4@=vZ#rqC9AnVJe@sSG(*}T5NohvXk$Jh9Z?NOx_$lKy7
zvT&E05rOjrY`KVx%*;1_Xp(i>w#~I<vsXAQtkcZ1vGjA3XF<H<n{ZvgAgDolFpKqR
z{%vi+^q4evMx7v;`yS;JgO3+sRJ1$m6Lcv8AV#9EIL}*8b%-0`Y2`!JTL<&kzpU4?
zfzbQ6GK{JU^2}!z&6C_}<2!HVm)UfTIoEAZD4ycn9JlEkrh~yX^4)=FTv&YX;<cZ%
zL`!+h6&~QyY7MMK2K=FJ>K%q=4Y~QnSJheK3L^c*!4O#<Sl`f)*+EqAEsC0iu#kW)
z;_BIp<wV7>3~WuqDE*l4_@|$FO%xIdJg?Wk$0bmp4b}U#<r!-D<&Fsv2Vc6qR(<Dw
zjd{YBW`F{>^m^vGrfPyL{i|EE6Jpl{$*rg~Ibf6iB=@arZq?t($aPUe4`l!Xf%#F%
zU|v)*uvP-*05~{ABvoV&#x-4Kt#QZ(%vjwe4O-s-iXXzOl4_mG<_CadTp*N)77Qf>
z0XuPm`FKN!em)_Wi4j*(C&c-+bx;^>eQhl*v<}+si0U3uz5mkxGnEX;|8xCO7=x1m
zLD11fP>y5(02Qi-|B7g{K=tNkFQ`^)INUaui!VMz=N`<%pusFG&cD_&d*Q3;Ei<7U
zUv1Tcbvoil86n<(@0&CJm9E!zbi_T&*K2B3qg?x>Zu75jy<sK(yq@sNdU&%b%Y_+S
zyptfAmm1ccy3D%qwaPal2|G2#aL<f>5!e%$0&W{vRK@GsjS!DrCHET>umsY8iac>8
z7Hv+oQKp#`6oHNZ2&juX-1@FQCw(!ijIC;lxeH2s+=*$$vbRI)gFea(Tpon2h23pZ
zJ|i0Gb8X|4jW?RR>Dzi&d13dix42a%d(ooj(nA+LBb#yEhr2w<8<L3&7|r*G@4l4>
zOF&|f9AE$hlslsAQ8Gu4%Ls6aaf&>Dg;Vo<H>9PKm=Aw!BJsVcsOKq4_OG@ArvyqY
z@qY^h{}R9f;E<CG1wJbOwEgI-N45hX^h8H@$Lx%8x`Bsn!wtQME!C`pumD}9{)zVU
z{)SOW1@b3*IaFMF>B#i>gy|<|1I&JRy;*`qd)?8u5n|oz5|u~rF1;+LO?{+VmdowR
zQ}FB^t-C{l5;KK$jKJy&RO=iBE&&n<UVK@F3k|wgeVV~%w>){=5P9g)yE=(rG<W*-
zle?J=WdpL+zn8Tcm$QEcOL~thZof2`U}Aj&DK#+C=VQb$VKcINJ~`gZZu9Q>;UN-7
zjiA&)86#(Y%a6XC(Jhx5XORA{42X%UHo4{r-FRV6oF85a|C3wu`N#Oytc!8Ba>(@3
sMyUIqoZFH<Z1Nc^q4h;H%~i1Bu-DJR?+iQAE>huIPPb)yoXD^L0LEp+w*UYD

literal 0
HcmV?d00001

diff --git a/clickhouse-native-jdbc/src/test/resources/clickhouse/server.key b/clickhouse-native-jdbc/src/test/resources/clickhouse/server.key
new file mode 100644
index 00000000..357188fc
--- /dev/null
+++ b/clickhouse-native-jdbc/src/test/resources/clickhouse/server.key
@@ -0,0 +1,28 @@
+-----BEGIN PRIVATE KEY-----
+MIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQCYLXL4c7dDMMiT
+kOcrqi5SjEIgfpz/N5P+5hIKa9RBTWWsRZDn5T+IQBCSYjIr/vK/Ieuian5l/OhW
+UMA0X/l3c5pFxfEsqNUF/XHEQuUTNdEnDZXHcqevE7Q/1FfCa5z6fxqVhnDEhu3U
+g+WoYnOBQd3dwVyNd7tnx2eEA7fN6StQNE/Tbwt0iss8akFqcc0qIm/vejdCs0ko
+vD2XmQM8yWatdv/26i3jHFiPovcrPziUAICkvTi2Qff5bq9p3B3NaM8S8XCUsihE
+FXVhefMpSWA3B7Lo8sOjmMT7YBdHjffpQ8dknlc1O0nXNJ77CILzGoDnOC/Z/9Lo
+o2sYBnglAgMBAAECggEAFJKXB48+jWb+brNOX+D5XdqCpA70iCzfepG9ivV0iUF+
+hxwT0MMgDs+OY05tdvTX+fk1eExfpcew3IkSeuImARKP9B0kPhky90TXSPo8KsKB
+8dQh1V1NiFsoaTVP30OaF2Pwgu9dC7csAX4KoZ7G+7NHsbokGic/dB0JLwKA/4/v
+vSAEpyZpoCEK9AjfqkFNYHTtuAmuIfBvHGcDdcDHsCh+c1MevqTlL5wBElr8RKJ7
+Vxb4eApwwWLB2aQnmcyCOpJQtb/XpuMNZ5/IsBNVmUDCRNYbKCFx4Ts/mwVbL1jz
+e4YD1DKiEtZ9Wzy7saZFIM2L7k8JuUomGucuqUHaLwKBgQDWnFLtwB7Lcbmv3QWz
+CDrNqFOTTrlLEbLgawXeCFyuL/QKSiI7VLGYo3FfCBMKE9bQf11AYKlP6dhW7f/G
+z0iHuy4wKhPHPKDmsJT3lnJlshayxjyr5RfT29bfz0vw/UJ+U4bEs46rTkEi6ZyW
+pCopD+az0BvyidkjQAMjbBW1HwKBgQC1hrOJ8eZkX5tCflRNVqmuX6QkINOLhErw
+4I41i0oaJVD0KU3hLHtTD57bn36q8tWuaFrubUir9OSz9r1nLCc4uu2OUUn0t9sy
+IvoG4JHWHkFdaOxGheWFdoCkTRnyU8mb4196h7C2MIQ6a6SwuaF9y9/p7l1/JjWu
+PI6vq1kGOwKBgQCGWwWb7Iwa587NJ7z6sWtG91ujPETKl4D5+GaK84c6UbEhg/nc
+VRB+M8y1JvPsejEhBKuXsywsaITVH1ji2UBaITgwVRdewzkkU2ZffmOOASkusOao
+4trA+r+SDFBJxfQL7DTSDmuCGZKzzbcHpCz02gyfg+kLNXuoEtokIfWRFwKBgGFR
+YOmgfTLsqrEgRxPbVUa90aLo0mDmwMKYsMT18vlHbjon9q+0iD1Ej5cQz/jYDUTe
+f3l5r085EG+G5Y3tdu2MEZWN8Qc4llQvujl7pdPUDpkEij9Yw28k09zB1Ro8X0aq
+xGJNYqiaJBmp4fY43uIxLc8dUpS7KGZL4vc89pJHAoGAET1i4vxlD6BMgwJCyCmc
+afJ5Eh4WrrBYM+E4emGS0/pgeRkjRk5cCaKJ/IEO8x2uxr/EGmlZa+ki8ETc8/9m
+LG9sX9za2lg9tiZW8A676hheVHe4IOIjkldey9ovxm8ar12PECwgkkJ6WXeG4uzJ
+lqaPsbBiOzZvBiBBJLpydYY=
+-----END PRIVATE KEY-----
diff --git a/clickhouse-native-jdbc/src/test/resources/clickhouse/server.p12 b/clickhouse-native-jdbc/src/test/resources/clickhouse/server.p12
new file mode 100644
index 0000000000000000000000000000000000000000..eb7c886c044c856787dbdd0362b5f671e68d1ad9
GIT binary patch
literal 2594
zcmai$S5Om*5{459LVyseLg*k!v4nD>^w5hKkS+*F7bQxs(jrw6Lkm6hjua_M6O<N;
zQbmf9CM_odA_xWo7w4WiKAwl&o&Eov*{A(x;TT2%8Xzqk1D-qsmWt7f*@pn>f%zD4
zF9-vEdn$LpF(CFo)|q?^=yaO)ga!yWEeC%bAl&lbh7JNZfJ^>qnc;jOhSj?J#ljq)
zt!QW%0C46r4FBIo1EvGO`Okpw#OMKCXhA?J5G%r0$gc3DbG=@=rdsR8jC%xz7F!I5
zDLOSa%2usfVR>C%^Aa1L;P@B|qZu5Kio(tS9jnoV;|Ut`7>~;?ftHu8P{3sFlSV&%
z)S&<wynnVl5s`n??L$4`RLc-*yvkeNuS#EbyNj!|iQJ9X#6Wspxnq<K545vCLlqsC
zJ`uQMa1eYGb*r9X{%CL|DD(b^hKtsVUk8=%`n~78#@D^}ehS&<`;$cyQQo$R;x&^N
z^wxfW!2=kc<E8AOR^}_yi0XznGAzxRK*lyP=B^PA?GfRo{{5l^TgtXv*mx|fa*Wa6
z#)#Ab+?2&hUcfVlJjKPuFZYUrkFcAXdG*<@wUcY1+4X}%B6&InF?B080o15z=E6sg
z%<;IAPa!~STj?)Qg#CnU(FGq1{D<^T8#H6cnC7L_ODUCvZ1Zhm*-z+sGkU5S?gx{$
zlV(I^kKBL)dgIDi$M=XI@C0|R`yB(--q%`l4U>g9Sf4k>N*>bOaNWim+KCMA3p%6d
zFC<TB)2Xye1=uFJNmUEJN+Q-m$N5PMkjn#ADxpvg>D?f$uBgi|Aw>OqSkY&bb!kz^
zV=;64w<NjM*xroMm`@u4+nYtfwJ#zK@M8DH$vlH<BS4+A&hE7?v=NmAdQs7?a`HIZ
zcNX3(dx1vZG_Hw8yeJwcu$wF*hRh0w`W9?lMG=JL<->h}TJ3KI(&dcirxzOI&*kLq
zw6uKKAXO0^eCIftNbZVpQ!hXAm(X!lv&v5%H#!OUWetXCCv?v=?sHMM%9X_$h&zs)
z;OTbh`Ly$1VS=g|_y;3w7k~BHs{;ypP3R1F^z1YCPqJ@dKkKes(JO2#;YIC<5g#r(
z#rsFvp(4!}w0s~EL{cHWslJi~Aq;jD@-3&@o_*ds_1q8alEKtd*3YPNQXov}XVL}o
zvE_8q!+K1@5-^wdyTlb{67=&4v+V{oFws@Cgx{uWVglv}C=U~#Qy%#awKG~AYh|AQ
zOMy*6h0l#UM(b=x2udBa!sgeRar3c&a+yB!+Y8rS<=Ki=qgy8C<9X)1hF^i#@>(7V
z7_Shzy$FFR-WHm>aATYME79vRp6NZhv0GHUYo%r6DCBFRTjljGZA|n%kD3<)ba}p6
z*=Cacpxm%*i%uwsZat|QT7JDne!E>PT<Ok!$1V5a_I8UJyAL*jmat(=)_GZsr|^WT
zite(v95VP~{NN5YFR&4GEN)FtYc&AJ&=viA-@k!DmkPqrVNd0R(}+96^bbpz8G$sX
zrp&2$>AwI`lhUdgW`eo>pMbF9?rmG4)IzGY!phACH(Eg$(5T`)(lIY)K1IYU@>yp3
z!rfW1*Uvg&M#rgBp=~Er-)Nq?<(MIw@L-|Nu?!czNPB!w9@HJz&gsE%?~`Qbb#g1{
zQCn#8_ddh{MTNupYQ{`TzJi+JUfib>-j=7%N#=kbJ$qVT*UN@ohCE#tFZxA4`{@#D
z-||KiH=e^3T5lqF#OL(@cAo7O8q<r&gE3yJR{}-txRdG~GL-Va>PVMK_#eK@cf*hF
zl}a0Gi5=}sjfGfRK9-XjQepC13vpX*8t+MMxg-B1wvWZXVeO#?rJ&k@nemhGZk1%C
z0IOxm>~o7J+D}mgyCxH4)N$K5lFONdI-uQDOB-*slj_&yC?ig0ZYq9LHUm4eejAfC
z8k=Lo>gOkv`pUA0T<ru2bs|ko)X(fgN3+2)2#1#_&NzZL>)r_yL<>_qTzu_NFDS(1
zwk9uft~UaP(`M<@vX>KD=qI~3>wF~`)Gz+6&~fds#4x+=c^+;tH-ej!d`|^c?}y;8
zu-NAekg7;ewsELj$VIfm_*~G-haSg|&#i&fp}HG~rucNpf)LAtQIA&hSX4Ie4!>Eh
zobw#p_6hIcmpAMLJ~cj)+ChGEYUzY+z|QU$ZVWjGsF&7^M+^QkU?1}_QqTEVT1u9S
zj%4S|eSIa-$?;3ME}i>Ozw!PHvOLe7otw69j<+a+W^Y5{Q^b*V88?%{D26X=t%Y~I
zS459?VPWNb2=r~EkXt2v9`mEGI<6)Lj%n{~NsYAgiER(F<VGx)n0l_dIPO5B3~*}C
z+P@$D)x8yl-e8)ftWyId-b8l1M~kZHZz5L-aAY@u|2?`QGqqoX!Ex?^iX*&}4oXNz
zIhHyA-!Q!7Xx(IyfTz#8tazw~@)Tv02C*8R%R&x0iaDz6C3eVb{v>zhp$N4pZC&y%
zUj}w9>|Ec9##64R)jr44s}=G}ikRR~^gE?G-soYG$>=(3C;knR@+NeRTO8oJ{M^sC
zu$cclf1Jav-}Be?iMxxv8<9QR-0v)(3)1y;tf(UcK^oYzC%@PNWKsU|?z?_bk8j=Z
z<dJe_noX%-|B<{b>SQ=AytA(NfP$b{Gz%>uWH>UXXK4lTHI(gGNOMBHn%<?EzG)U5
z@!^=>Z7IUcA_y5$?xQ2=%SrAI<OjB<na9$8ZKmWdSs@i*jqhjZ3z+)`VK3tbi7C`x
zO>$6h0nc#Ds)yhEzi`z~h6#OrN`@a5bvLCe&dGFE1s~p053k6WL<s8F1YNG!qd3Q*
zw;ypNc*!b-cP-giuN$cXupN&o^sBBGj3<E$m9SNN4Z6nmEO*mf#J!3NBvlArcScLY
zQ3FxXD@XR}AJ&^X%BEn=dhe$if<4Qt($0xlh0l9{*y}`0ShB)vDOGdj{^)?Okdhyy
zt-@X9p)a&b=3Dod<=tpp-5T9Hsj9GxvjYgrC-Yu+2X3Zd?kx1BHYaVHEgiUJ4zw`D
zwI1=B;xKs%&WYyXC0*|$Tz;)((X#SoIJ{$&7`GNge=JBQDpRqKjhi?Q#xY7QRgX0K
zScr>m;Di~hdQ#0^Tit;Q@Nbk=WJ90G4I-yskSbLnS7+ORmwEKASd`)ncEW(lm_9&y
z;y>jP{>`^rCLUsZap5Dy1hgQd_4_OOhoWFk8CC%n02&YkZ~%A!+)uL)T=b94C36<U
zSupcaGmhP}4S(C%Ukg#)+&N4W2v>*8z#;#BS2RF607%G=Xy5If%Oko4CNz)iPqs!b
gPWR~bnyS&NSk{`FXN`jxx*HxyT4~3p|0ePO00WM{nE(I)

literal 0
HcmV?d00001

diff --git a/clickhouse-native-jdbc/src/test/resources/grpc_config.xml b/clickhouse-native-jdbc/src/test/resources/grpc_config.xml
deleted file mode 100644
index a6416daf..00000000
--- a/clickhouse-native-jdbc/src/test/resources/grpc_config.xml
+++ /dev/null
@@ -1,32 +0,0 @@
-<yandex>
-    <!-- gRPC protocol (see src/Server/grpc_protos/clickhouse_grpc.proto for the API) -->
-    <grpc_port>9100</grpc_port>
-    <grpc>
-        <enable_ssl>false</enable_ssl>
-
-        <!-- The following two files are used only if enable_ssl=1 -->
-        <ssl_cert_file>/path/to/ssl_cert_file</ssl_cert_file>
-        <ssl_key_file>/path/to/ssl_key_file</ssl_key_file>
-
-        <!-- Whether server will request client for a certificate -->
-        <ssl_require_client_auth>false</ssl_require_client_auth>
-
-        <!-- The following file is used only if ssl_require_client_auth=1 -->
-        <ssl_ca_cert_file>/path/to/ssl_ca_cert_file</ssl_ca_cert_file>
-
-        <!-- Default compression algorithm (applied if client doesn't specify another algorithm).
-             Supported algorithms: none, deflate, gzip, stream_gzip -->
-        <compression>deflate</compression>
-
-        <!-- Default compression level (applied if client doesn't specify another level).
-             Supported levels: none, low, medium, high -->
-        <compression_level>medium</compression_level>
-
-        <!-- Send/receive message size limits in bytes. -1 means unlimited -->
-        <max_send_message_size>-1</max_send_message_size>
-        <max_receive_message_size>-1</max_receive_message_size>
-
-        <!-- Enable if you want very detailed logs -->
-        <verbose_logs>true</verbose_logs>
-    </grpc>
-</yandex>
diff --git a/clickhouse-native-jdbc/src/test/resources/keymanagement/bin/generate.sh b/clickhouse-native-jdbc/src/test/resources/keymanagement/bin/generate.sh
new file mode 100644
index 00000000..eb93e96a
--- /dev/null
+++ b/clickhouse-native-jdbc/src/test/resources/keymanagement/bin/generate.sh
@@ -0,0 +1,42 @@
+#!/bin/sh
+
+# Versions:
+# Windows 10
+# OpenSSL Version: OpenSSL 3.1.2 1
+# Keytool Version: openjdk-17.0.2
+
+KEY_FILE=server.key
+CRT_FILE=server.crt
+PKCS12_FILE=server.p12
+JKS_FILE=server.jks
+PASSWORD=mypassword
+ALIAS=myalias
+
+echo "Generating the private key and certificate..."
+openssl req -subj "//CN=localhost" -new -newkey rsa:2048 -days 365 -nodes -x509 -keyout ${KEY_FILE} -out ${CRT_FILE}
+if [ $? -ne 0 ]; then
+    echo "Failed to generate the private key and certificate."
+    exit 1
+fi
+
+echo "Converting to PKCS12 format..."
+openssl pkcs12 -export -in ${CRT_FILE} -inkey ${KEY_FILE} -out ${PKCS12_FILE} -name ${ALIAS} -password pass:${PASSWORD}
+if [ $? -ne 0 ]; then
+    echo "Failed to convert to PKCS12 format."
+    exit 1
+fi
+
+echo "Importing keystore ${PKCS12_FILE} to ${JKS_FILE}..."
+keytool -importkeystore\
+        -srckeystore ${PKCS12_FILE}\
+        -srcstoretype PKCS12\
+        -srcstorepass ${PASSWORD}\
+        -destkeystore ${JKS_FILE}\
+        -deststoretype JKS\
+        -deststorepass ${PASSWORD}
+if [ $? -ne 0 ]; then
+    echo "Failed to import keystore."
+    exit 1
+fi
+
+echo "Done!"
\ No newline at end of file