connection info

Author: todd5167

core/src/main/java/com/dtstack/flink/sql/side/AbstractSideTableInfo.java

@@ -170,4 +170,19 @@ public int getAsyncPoolSize() {
     public void setAsyncPoolSize(int asyncPoolSize) {
         this.asyncPoolSize = asyncPoolSize;
     }
+
+    @Override
+    public String toString() {
+        return "Cache Info{" +
+                "cacheType='" + cacheType + '\'' +
+                ", cacheSize=" + cacheSize +
+                ", cacheTimeout=" + cacheTimeout +
+                ", asyncCapacity=" + asyncCapacity +
+                ", asyncTimeout=" + asyncTimeout +
+                ", asyncPoolSize=" + asyncPoolSize +
+                ", asyncTimeoutNumLimit=" + asyncTimeoutNumLimit +
+                ", partitionedJoin=" + partitionedJoin +
+                ", cacheMode='" + cacheMode + '\'' +
+                '}';
+    }
 }

rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/all/AbstractRdbAllReqRow.java

@@ -78,11 +78,7 @@ public AbstractRdbAllReqRow(BaseSideInfo sideInfo) {
     public void open(Configuration parameters) throws Exception {
         super.open(parameters);
         RdbSideTableInfo tableInfo = (RdbSideTableInfo) sideInfo.getSideTableInfo();
-        LOG.info("jdbc url: {} ", tableInfo.getUrl());
-        LOG.info("query table name: {}", tableInfo.getTableName());
-        LOG.info("all cache type: {}", tableInfo.getCacheType());
-        LOG.info("all cache size: {}", tableInfo.getCacheSize());
-        LOG.info("all cache timeout: {}", tableInfo.getCacheTimeout());
+        LOG.info("rdb dim table config info: {} ", tableInfo.toString());
     }
 
 

rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/async/RdbAsyncReqRow.java

@@ -89,13 +89,7 @@ protected void init(BaseSideInfo sideInfo) {
     public void open(Configuration parameters) throws Exception {
         super.open(parameters);
         RdbSideTableInfo rdbSideTableInfo = (RdbSideTableInfo) sideInfo.getSideTableInfo();
-        LOG.info("use rdb pool size: {}", rdbSideTableInfo.getAsyncPoolSize());
-        LOG.info("jdbc url: {} ", rdbSideTableInfo.getUrl());
-        LOG.info("query table name: {}", rdbSideTableInfo.getTableName());
-        LOG.info("async cache type: {}", rdbSideTableInfo.getCacheType());
-        LOG.info("async cache mode: {}", rdbSideTableInfo.getCacheMode());
-        LOG.info("async cache capacity: {}", rdbSideTableInfo.getAsyncCapacity());
-        LOG.info("async cache timeout: {}", rdbSideTableInfo.getAsyncTimeout());
+        LOG.info("rdb dim table config info: {} ", rdbSideTableInfo.toString());
     }
 
     @Override

rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/table/RdbSideTableInfo.java

@@ -99,4 +99,15 @@ public String getPassword() {
     public void setPassword(String password) {
         this.password = password;
     }
+
+    @Override
+    public String toString() {
+        String cacheInfo = super.toString();
+        String connectionInfo = "Rdb Side Connection Info{" +
+                "url='" + url + '\'' +
+                ", tableName='" + tableName + '\'' +
+                ", schema='" + schema + '\'' +
+                '}';
+        return cacheInfo + " , " + connectionInfo;
+    }
 }