From dbf464aebd7b55b1ed613f27a610fa1ca8ee1b93 Mon Sep 17 00:00:00 2001 From: weiye Date: Thu, 16 Apr 2020 19:30:42 +0800 Subject: [PATCH] =?UTF-8?q?clickhouse=E5=BB=BA=E8=A1=A8=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/wugui/datax/admin/tool/table/ClickHouse.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/datax-admin/src/main/java/com/wugui/datax/admin/tool/table/ClickHouse.java b/datax-admin/src/main/java/com/wugui/datax/admin/tool/table/ClickHouse.java index d5206379..53141c15 100644 --- a/datax-admin/src/main/java/com/wugui/datax/admin/tool/table/ClickHouse.java +++ b/datax-admin/src/main/java/com/wugui/datax/admin/tool/table/ClickHouse.java @@ -2,9 +2,11 @@ package com.wugui.datax.admin.tool.table; import com.wugui.datax.admin.tool.database.ColumnInfo; import com.wugui.datax.admin.tool.query.BaseQueryTool; +import lombok.extern.slf4j.Slf4j; import java.util.List; +@Slf4j public class ClickHouse { public static String database_name = ""; @@ -53,7 +55,7 @@ public class ClickHouse { } break; default: - System.out.println(c.getType()); + log.info(c.getType()); break; } } else { @@ -87,7 +89,7 @@ public class ClickHouse { } break; default: - System.out.println("=============尚未捕获的数据类型" + c.getType()); + log.info("=============尚未捕获的数据类型{}",c.getType()); break; } } @@ -95,7 +97,7 @@ public class ClickHouse { } String afterSQl = String.format(" ,datacenter_insert_time DateTime DEFAULT now() COMMENT '数据中心数据抽取入库时间' ) ENGINE = MergeTree PARTITION BY id ORDER BY id", primatyKey, preSql); stringBuilder.append(afterSQl); - System.out.println(stringBuilder.toString()); + log.info(stringBuilder.toString()); return stringBuilder.toString(); } }