Connection settings new api (#1612)

* Added clickhouse-client test jar to test scope

* Add connection settings methods

* Remove method

* Fix method name

* Fix variable name

---------

Co-authored-by: mzitnik <[email protected]>

Author: mzitnik

client-v2/pom.xml

@@ -76,6 +76,13 @@
             <scope>compile</scope>
         </dependency>
 
+        <dependency>
+            <groupId>${project.parent.groupId}</groupId>
+            <artifactId>clickhouse-client</artifactId>
+            <version>${revision}</version>
+            <type>test-jar</type>
+            <scope>test</scope>
+        </dependency>
         <dependency>
             <groupId>org.slf4j</groupId>
             <artifactId>slf4j-simple</artifactId>

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

@@ -5,6 +5,8 @@
 
 import java.io.InputStream;
 import java.net.SocketException;
+import java.time.Duration;
+import java.time.temporal.ChronoUnit;
 import java.util.*;
 import com.clickhouse.client.api.metadata.TableSchema;
 import com.clickhouse.client.api.internal.TableSchemaParser;
@@ -15,6 +17,8 @@
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.Future;
 
+import static java.time.temporal.ChronoUnit.SECONDS;
+
 public class Client {
     public static final int TIMEOUT = 30_000;
     private Set<String> endpoints;
@@ -35,6 +39,11 @@ public static class Builder {
         public Builder() {
             this.endpoints = new HashSet<>();
             this.configuration = new HashMap<String, String>();
+            // TODO: set defaults configuration values
+            this.setConnectTimeout(30, SECONDS)
+                .setSocketTimeout(2, SECONDS)
+                .setSocketRcvbuf(804800)
+                .setSocketSndbuf(804800);
         }
 
         public Builder addEndpoint(String endpoint) {
@@ -63,7 +72,48 @@ public Builder addPassword(String password) {
             this.configuration.put("password", password);
             return this;
         }
+        // SOCKET SETTINGS
+        public Builder setConnectTimeout(long size) {
+            this.configuration.put("connect_timeout", String.valueOf(size));
+            return this;
+        }
+        public Builder setConnectTimeout(long amount, ChronoUnit unit) {
+            this.setConnectTimeout(Duration.of(amount, unit).toMillis());
+            return this;
+        }
 
+        public Builder setSocketTimeout(long size) {
+            this.configuration.put("socket_timeout", String.valueOf(size));
+            return this;
+        }
+        public Builder setSocketTimeout(long amount, ChronoUnit unit) {
+            this.setSocketTimeout(Duration.of(amount, unit).toMillis());
+            return this;
+        }
+        public Builder setSocketRcvbuf(long size) {
+            this.configuration.put("socket_rcvbuf", String.valueOf(size));
+            return this;
+        }
+        public Builder setSocketSndbuf(long size) {
+            this.configuration.put("socket_sndbuf", String.valueOf(size));
+            return this;
+        }
+        public Builder setSocketReuseaddr(boolean value) {
+            this.configuration.put("socket_reuseaddr", String.valueOf(value));
+            return this;
+        }
+        public Builder setSocketKeepalive(boolean value) {
+            this.configuration.put("socket_keepalive", String.valueOf(value));
+            return this;
+        }
+        public Builder setSocketTcpNodelay(boolean value) {
+            this.configuration.put("socket_tcp_nodelay", String.valueOf(value));
+            return this;
+        }
+        public Builder setSocketLinger(int secondsToWait) {
+            this.configuration.put("socket_linger", String.valueOf(secondsToWait));
+            return this;
+        }
         public Client build() {
             // check if endpoint are empty. so can not initiate client
             if (this.endpoints.isEmpty()) {