[Feature] Support clickhouse jdbc datasource(StarRocks#40894)

DataScientistSamChan · Mar 24, 2024 · 8d2c86d · 8d2c86d
1 parent ba55aeb
commit 8d2c86d
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/java-extensions/jdbc-bridge/src/main/java/com/starrocks/jdbcbridge/JDBCScanner.java b/java-extensions/jdbc-bridge/src/main/java/com/starrocks/jdbcbridge/JDBCScanner.java
@@ -30,6 +30,7 @@
 import java.sql.Time;
 import java.sql.Timestamp;
 import java.time.LocalDateTime;
+import java.time.LocalDate;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.HashSet;
@@ -117,6 +118,7 @@ public void open() throws Exception {
             BigDecimal.class,
             java.sql.Date.class,
             Timestamp.class,
+            LocalDate.class,
             LocalDateTime.class,
             Time.class,
             String.class

diff --git a/java-extensions/udf-extensions/src/main/java/com/starrocks/udf/UDFHelper.java b/java-extensions/udf-extensions/src/main/java/com/starrocks/udf/UDFHelper.java
@@ -346,6 +346,9 @@ public static void getResultFromBoxedArray(int type, int numRows, Object boxedRe
                 if (boxedResult instanceof Date[]) {
                     getStringDateResult(numRows, (Date[]) boxedResult, columnAddr);
                 } else if(boxedResult instanceof String[]){
+                    for(String i: boxedResult){
+                        log.info("boxedResult element :" + i);
+                    }
                     getStringBoxedResult(numRows, (String[]) boxedResult, columnAddr);
                 }else {
                     throw new UnsupportedOperationException("unsupported type:" + boxedResult);