fix client to accept configuration

Author: chernser

examples/client/src/main/java/com/clickhouse/examples/formats/ProtobufMain.java

@@ -2,11 +2,14 @@
 
 import com.clickhouse.client.ClickHouseClient;
 import com.clickhouse.client.ClickHouseConfig;
+import com.clickhouse.client.ClickHouseCredentials;
+import com.clickhouse.client.ClickHouseException;
 import com.clickhouse.client.ClickHouseNode;
 import com.clickhouse.client.ClickHouseNodeSelector;
 import com.clickhouse.client.ClickHouseProtocol;
 import com.clickhouse.client.ClickHouseRequest;
 import com.clickhouse.client.ClickHouseResponse;
+import com.clickhouse.client.config.ClickHouseClientOption;
 import com.clickhouse.client.http.config.ClickHouseHttpOption;
 import com.clickhouse.config.ClickHouseOption;
 import com.clickhouse.data.ClickHouseFormat;
@@ -27,14 +30,10 @@
 public class ProtobufMain {
 
     private static final Logger log = Logger.getLogger(ProtobufMain.class.getName());
-    private final String host = "localhost";
-    private final int port = 8123;
 
     public void write(List<Message> messages) {
         try (ClickHouseClient client = getClient()) {
-            ClickHouseRequest.Mutation mutation =
-                    client.write(ClickHouseNode.builder().host(host).port(ClickHouseProtocol.HTTP, port).build());
-
+            ClickHouseRequest.Mutation mutation = client.write(getServer());
             mutation.table("default.ui_events");
             mutation.format(ClickHouseFormat.Protobuf);
             ClickHouseResponse response = mutation.data((out) -> {
@@ -55,8 +54,7 @@ public void write(List<Message> messages) {
 
     public List<Message> read() {
         try (ClickHouseClient client = getClient()) {
-            ClickHouseRequest request =
-                    client.read(ClickHouseNode.builder().host(host).port(ClickHouseProtocol.HTTP, port).build());
+            ClickHouseRequest request = client.read(getServer());
 
             request.table("default.ui_events");
             request.format(ClickHouseFormat.Protobuf);
@@ -70,6 +68,9 @@ public List<Message> read() {
             }
 
             return messages;
+        } catch (ClickHouseException e) {
+            log.log(Level.SEVERE, "Failed to read data from server: " + getClient().getConfig(), e);
+            throw new RuntimeException(e);
         } catch (Exception e) {
             log.log(Level.SEVERE, "Failed to write data", e);
             throw new RuntimeException(e);
@@ -115,4 +116,14 @@ protected ClickHouseClient getClient() {
                 .nodeSelector(ClickHouseNodeSelector.of(ClickHouseProtocol.HTTP))
                 .build();
     }
+
+    protected ClickHouseNode getServer() {
+        return ClickHouseNode.builder()
+                .host(System.getProperty("chHost", "localhost"))
+                .addOption(ClickHouseClientOption.SSL.getKey(), String.valueOf(Boolean.getBoolean("chSsl")))
+                .port(ClickHouseProtocol.HTTP, Integer.getInteger("chPort", 8123))
+                .credentials(ClickHouseCredentials.fromUserAndPassword(
+                        System.getProperty("chUser", "default"), System.getProperty("chPassword", "")))
+                .build();
+    }
 }