代码优化，优化clickhousesink写入

1 files changed, 7 insertions, 0 deletions

diff --git a/src/main/java/com/zdjizhi/enums/LogMetadata.java b/src/main/java/com/zdjizhi/enums/LogMetadata.java
index 2949085..7c501b5 100644
--- a/src/main/java/com/zdjizhi/enums/LogMetadata.java
+++ b/src/main/java/com/zdjizhi/enums/LogMetadata.java
@@ -73,4 +73,11 @@ public enum LogMetadata {
         return StrUtil.concat(true, "INSERT INTO ", CK_DATABASE, ".", tableName,
                 "(", StrUtil.join(",", fields), ") VALUES (", StrUtil.join(",", placeholders), ")");
     }
+    public static String preparedSql(String tableName, String[] fields) {
+        String[] placeholders = new String[fields.length];
+        Arrays.fill(placeholders, "?");
+
+        return StrUtil.concat(true, "INSERT INTO ", CK_DATABASE, ".", tableName,
+                "(", StrUtil.join(",", fields), ") VALUES (", StrUtil.join(",", placeholders), ")");
+    }
 }