WIP

Author: Paultagoras

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

@@ -5,7 +5,11 @@
 import com.clickhouse.client.api.internal.ValidationUtils;
 import com.clickhouse.data.ClickHouseColumn;
 
+import java.beans.Introspector;
+import java.io.BufferedInputStream;
 import java.io.InputStream;
+import java.lang.reflect.Field;
+import java.lang.reflect.Method;
 import java.net.SocketException;
 import java.time.Duration;
 import java.time.temporal.ChronoUnit;
@@ -15,13 +19,15 @@
 import com.clickhouse.client.api.query.QueryResponse;
 import com.clickhouse.client.api.query.QuerySettings;
 import com.clickhouse.data.ClickHouseFormat;
+import com.clickhouse.data.format.BinaryStreamUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.slf4j.MDC;
 import org.slf4j.helpers.BasicMDCAdapter;
 
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.Future;
+import java.util.stream.Collectors;
 
 import static java.time.temporal.ChronoUnit.SECONDS;
 
@@ -30,6 +36,7 @@ public class Client {
     private Set<String> endpoints;
     private Map<String, String> configuration;
     private List<ClickHouseNode> serverNodes = new ArrayList<>();
+    private Map<Class<?>, POJOSerializer> serializers = new HashMap<>();
     private static final  Logger LOG = LoggerFactory.getLogger(Client.class);
 
     private Client(Set<String> endpoints, Map<String,String> configuration) {
@@ -161,6 +168,32 @@ public boolean ping(int timeout) {
     public void register(Class<?> clazz, TableSchema schema) {
         //This is just a placeholder
         //Create a new POJOSerializer with static .serialize(object, columns) methods
+
+        serializers.put(clazz, (obj, stream, columns) -> {
+            List<Method> getters = Arrays.stream(clazz.getMethods())
+                    .filter(n -> {
+                        String methodName = n.getName();
+                        if (methodName.startsWith("get")) {
+                            String fieldName = methodName.substring(3);
+                            return schema.containsColumn(fieldName);
+                        }
+                        return false;
+                    })//We only care about fields that are in the schema
+                    .toList();
+
+            for (Method method : getters) {
+                LOG.info("Method: {}", method.getName());
+                System.out.println(method.getName());
+                try {
+                    Object value = method.invoke(obj);
+                    System.out.println(value);
+                    //Serialize the value to the stream
+                    BinaryStreamUtils.writeString(stream, value.toString());//This is just a placeholder
+                } catch (Exception e) {
+                    LOG.error("Error invoking method: {}", method.getName());
+                }
+            }
+        });
     }
 
     /**

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

@@ -2,9 +2,9 @@
 
 import com.clickhouse.data.ClickHouseColumn;
 
-import java.io.InputStream;
+import java.io.OutputStream;
 import java.util.List;
 
 public interface POJOSerializer {
-    InputStream serialize(Object obj, List<ClickHouseColumn> columns);
+    void serialize(Object obj, OutputStream outputStream, List<ClickHouseColumn> columns);
 }

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

@@ -52,5 +52,15 @@ public void addColumn(String name, String type) {
         columns.add(ClickHouseColumn.of(name, type));
         metadata.computeIfAbsent(name, k -> new HashMap<>()).put("type", type);
     }
+
+    public boolean containsColumn(String name) {
+        for (ClickHouseColumn column : columns) {
+            if (column.getColumnName().equalsIgnoreCase(name)) {
+                return true;
+            }
+        }
+
+        return false;
+    }
 }
 

client-v2/src/main/java/com/clickhouse/client/api/metadata/TableSchema.java

@@ -3,6 +3,7 @@
 import com.clickhouse.client.api.InsertResponse;
 import com.clickhouse.client.api.InsertSettings;
 import com.clickhouse.client.api.Client;
+import com.clickhouse.client.api.metadata.TableSchema;
 import com.clickhouse.client.generators.InsertDataGenerator;
 import com.clickhouse.data.ClickHouseColumn;
 import com.clickhouse.data.ClickHouseFormat;
@@ -29,6 +30,16 @@ public void setUp() {
                 .build();
     }
 
+    @Test(groups = { "unit" }, enabled = true)
+    public void registerSimplePOJOs() throws ClickHouseException, SocketException, ExecutionException, InterruptedException {
+        System.out.println("registerSimplePOJOs");
+        InsertSettings settings = new InsertSettings()
+                .setDeduplicationToken("1234567890")
+                .setQueryId(String.valueOf(UUID.randomUUID()));
+
+        client.register(Object.class, new TableSchema());
+    }
+
     @Test(groups = { "unit" }, enabled = false)
     public void insertSimplePOJOs() throws ClickHouseException, SocketException, ExecutionException, InterruptedException {
         InsertSettings settings = new InsertSettings()