优化TIS Flink实时增量通道启动速度

[baisui1981]

现象

有同学反馈TIS增量启动速度比较慢，一百张表的增量执行管道需要将近20分钟。

以下是启动执行日志链接：https://github.com/qlangtech/plugins-commercial/issues/1

问题分析：

根据典型的日志：

2024-09-26 21:01:20 WARN  c.qlangtech.tis.plugin.PluginStore- target xstream file is not exist:/home/sysadm/tis-uber/data/cfg_repo/tis_plugin_config/ap/ZF_MySQL_SR_ALL/com.qlangtech.tis.plugin.datax.SelectedTabExtend_batch.xml
2024-09-26 21:01:25 INFO  c.q.t.p.ds.BasicDataSourceFactory- tabmeta:PRI_COT_PAK_COTLOOK,colsSize:7,cols:CURDATE,COT_YEAR,PRODUCT_AREA,TYPE,NUMS,CREATE_TIME,UPDATE_TIME

下面那条通过表名获取对应的列元组信息，需要耗费5秒 时间，这个算比较耗费时间的，主要原因是：创建jdbc Connection对象费时，且没有使用dbcp的connection pool来缓存，所以当需要同步的表比较多时的确会比较耗时。

优化思路：

在整个启动过程中，引入Connection缓存机制，将对应构建jdbcURL->Connection的 映射关系作为缓存。启动过程只需要构对Connection实例进行一次初始化工作，将会大大缩减启动初始化时间。

[baisui1981]

• 引入线程绑定JDBC Connection 对象池(com.qlangtech.tis.plugin.ds.JDBCConnectionPool)，实现线程级连接器复用

• 将连接池嵌入TisExceptionInterceptor ,通过以下方式实现线程级复用 TisExceptionInterceptor:

  try (JDBCConnectionPool jdbcConnectionPool = JDBCConnectionPool.create()) {
    JDBCConnection.connectionPool.set(jdbcConnectionPool);
   // ...
  } finally {
    JDBCConnection.connectionPool.remove();
  }

  以下是 DataSourceFactory中通过对象池获取可用的JDBCConnection实例执行逻辑

  DataSourceFactory:

    public final JDBCConnection getConnection(String jdbcUrl, boolean verify) throws SQLException {
  
      JDBCConnectionPool connectionPool = JDBCConnection.connectionPool.get();
      JDBCConnection conn = null;
      if (connectionPool != null) {
          conn = connectionPool.getConnection(jdbcUrl, verify);
          if (conn == null) {
              return connectionPool.getConnection(jdbcUrl, verify, (url) -> {
                  try {
                      return createConnection(jdbcUrl, verify);
                  } catch (SQLException e) {
                      throw new RuntimeException(e);
                  }
              });
          } else {
              return conn;
          }
      } else {
          return createConnection(jdbcUrl, verify);
      }
  }