enhance the ai agent facibility

Author: baisui1981

create-ln.sh

@@ -0,0 +1,10 @@
+# https://blog.csdn.net/qq_38425719/article/details/102515854
+
+#CURRENT_PATH=`$(pwd)`;
+for f in `find $(pwd)  -name '*.tpi' -print`
+do
+   echo " ln -s $f "
+   rm -f /opt/data/tis/libs/plugins/${f##*/}
+   ln -s $f /opt/data/tis/libs/plugins/${f##*/}
+done ;
+

pkg.sh

@@ -93,7 +93,7 @@
         <module>executor/tis-datax-executor</module>
         <module>tis-datax-local-executor-utils</module>
         <module>tis-datax-kingbase-plugin</module>
-
+        <module>tis-datax-kingbase-v8-plugin</module>
 
 
     </modules>

tis-datax/pom.xml

@@ -10,7 +10,6 @@
 import com.qlangtech.tis.plugin.ds.BasicDataSourceFactory;
 import com.qlangtech.tis.plugin.ds.ColumnMetaData;
 import com.qlangtech.tis.plugin.ds.DBConfig;
-
 import com.qlangtech.tis.plugin.ds.DataDumpers;
 import com.qlangtech.tis.plugin.ds.DataSourceFactory;
 import com.qlangtech.tis.plugin.ds.DataType;
@@ -20,10 +19,10 @@
 import com.qlangtech.tis.plugin.ds.SplitTableStrategy;
 import com.qlangtech.tis.plugin.ds.TISTable;
 import com.qlangtech.tis.plugin.ds.TableInDB;
-import com.qlangtech.tis.plugin.ds.TableNotFoundException;
+import com.qlangtech.tis.plugin.timezone.TISTimeZone;
 import com.qlangtech.tis.runtime.module.misc.IControlMsgHandler;
 import com.qlangtech.tis.sql.parser.tuple.creator.EntityName;
-import dm.jdbc.driver.DmdbType;
+import dm.jdbc.desc.Configuration;
 import org.apache.commons.lang.StringUtils;
 
 import java.sql.Connection;
@@ -32,6 +31,7 @@
 import java.sql.SQLException;
 import java.sql.Statement;
 import java.sql.Types;
+import java.time.ZoneId;
 import java.util.ArrayList;
 import java.util.Iterator;
 import java.util.LinkedHashMap;
@@ -56,6 +56,9 @@ public class DaMengDataSourceFactory extends BasicDataSourceFactory implements D
     @FormField(ordinal = 1, validate = {Validator.require})
     public SplitTableStrategy splitTableStrategy;
 
+    @FormField(ordinal = 12, validate = {Validator.require})
+    public TISTimeZone timeZone;
+
     //https://blog.csdn.net/Shadow_Light/article/details/100749537
 
     @Override
@@ -69,6 +72,11 @@ protected String getNodeDesc() {
         return Objects.requireNonNull(splitTableStrategy, "splitTableStrategy can not be null").getNodeDesc();
     }
 
+    @Override
+    public final Optional<ZoneId> getTimeZone() {
+        return Optional.of(timeZone.getTimeZone());
+    }
+
     @Override
     public void fillTableInDB(TableInDB tabs) {
         super.fillTableInDB(tabs);
@@ -106,12 +114,14 @@ public JDBCConnection createConnection(String jdbcUrl, Optional<Properties> prop
         java.util.Properties info = props.orElse(new java.util.Properties());
 
         if (this.userName != null) {
-            info.put("user", this.userName);
+            info.put(Configuration.user.getName(), this.userName);
         }
         if (password != null) {
-            info.put("password", password);
+            info.put(Configuration.password.getName(), password);
         }
         //info.put("connectTimeout", "60000");
+        info.setProperty(Configuration.localTimezone.getName() //
+                , Objects.requireNonNull(this.timeZone, "timezone can not be null").getTimeZone().getId());
         Connection connect = driver.connect(jdbcUrl, info);
         connect.setAutoCommit(true);
         return new JDBCConnection(connect, jdbcUrl);
@@ -524,6 +534,7 @@ public static class DefaultDescriptor extends BasicRdbmsDataSourceFactoryDescrip
         public Optional<String> getDefaultDataXReaderDescName() {
             return Optional.of(DataXDaMengReader.DATAX_NAME);
         }
+
         @Override
         public boolean supportFacade() {
             return false;

…ncr/flink/alert/AddMonitorForEvents.java …ncr/flink/alert/AddMonitorForEvents.javatis-incr/tis-realtime-flink/src/main/java/com/qlangtech/plugins/incr/flink/alert/AddMonitorForEvents.java renamed to tis-datax/tis-datax-common-plugin/src/main/java/com/qlangtech/plugins/incr/flink/alert/AddMonitorForEvents.java tis-incr/tis-realtime-flink/src/main/java/com/qlangtech/plugins/incr/flink/alert/AddMonitorForEvents.java renamed to tis-datax/tis-datax-common-plugin/src/main/java/com/qlangtech/plugins/incr/flink/alert/AddMonitorForEvents.java

@@ -17,5 +17,10 @@
   },
   "nodeDesc": {
     "disable": true
+  },
+  "timeZone": {
+    "dftVal": "default",
+    "label": "所在时区",
+    "help": "设置服务端所在时区，有两种输入方式：1. default 从下拉框中选择，2. customize：用户手动输入时区编码"
   }
 }

tis-datax/tis-datax-common-plugin/src/main/java/com/qlangtech/tis/zeppelin/TISZeppelinClient.java

@@ -20,7 +20,7 @@
 
 import com.qlangtech.tis.extension.TISExtension;
 import com.qlangtech.tis.plugin.datax.DataXPostgresqlReader;
-import com.qlangtech.tis.plugin.ds.kingbase.KingBaseDataSourceFactory;
+import com.qlangtech.tis.plugin.ds.kingbase.BasicKingBaseDataSourceFactory;
 
 /**
  *
@@ -33,7 +33,7 @@ public class DataXKingBaseReader extends DataXPostgresqlReader {
     public static class KingBaseDescriptor extends DefaultDescriptor{
         @Override
         public String getDisplayName() {
-            return KingBaseDataSourceFactory.KingBase_NAME;
+            return BasicKingBaseDataSourceFactory.KingBase_NAME;
         }
 
         @Override

…ncr/flink/alert/AddMonitorForEvents.json …ncr/flink/alert/AddMonitorForEvents.jsontis-incr/tis-realtime-flink/src/main/resources/com/qlangtech/plugins/incr/flink/alert/AddMonitorForEvents.json renamed to tis-datax/tis-datax-common-plugin/src/main/resources/com/qlangtech/plugins/incr/flink/alert/AddMonitorForEvents.json tis-incr/tis-realtime-flink/src/main/resources/com/qlangtech/plugins/incr/flink/alert/AddMonitorForEvents.json renamed to tis-datax/tis-datax-common-plugin/src/main/resources/com/qlangtech/plugins/incr/flink/alert/AddMonitorForEvents.json

@@ -21,7 +21,7 @@
 import com.qlangtech.tis.extension.TISExtension;
 import com.qlangtech.tis.plugin.datax.DataXPostgresqlWriter;
 import com.qlangtech.tis.plugin.datax.common.AutoCreateTable;
-import com.qlangtech.tis.plugin.ds.kingbase.KingBaseDataSourceFactory;
+import com.qlangtech.tis.plugin.ds.kingbase.BasicKingBaseDataSourceFactory;
 
 import java.util.Objects;
 
@@ -32,8 +32,8 @@
 public class DataXKingBaseWriter extends DataXPostgresqlWriter {
 
     @Override
-    public KingBaseDataSourceFactory getDataSourceFactory() {
-        return (KingBaseDataSourceFactory) super.getDataSourceFactory();
+    public BasicKingBaseDataSourceFactory getDataSourceFactory() {
+        return (BasicKingBaseDataSourceFactory) super.getDataSourceFactory();
     }
 
 
@@ -50,7 +50,7 @@ public KingBaseDescriptor() {
 
         @Override
         public String getDisplayName() {
-            return KingBaseDataSourceFactory.KingBase_NAME;
+            return BasicKingBaseDataSourceFactory.KingBase_NAME;
         }
 
         @Override