@Override
    public JsonObject buildJdbcConfig() {
        JsonObject tidbClientConfig = new JsonObject();
        RdbSideTableInfo sideTableInfo = (RdbSideTableInfo) sideInfo.getSideTableInfo();
        tidbClientConfig.put("url", sideTableInfo.getUrl())
                .put("driver_class", TIDB_DRIVER)
                .put("max_pool_size", sideTableInfo.getAsyncPoolSize())
                .put("user", sideTableInfo.getUserName())
                .put("password", sideTableInfo.getPassword())
                .put("provider_class", DT_PROVIDER_CLASS)
                .put("preferred_test_query", PREFERRED_TEST_QUERY_SQL)
                .put("test_connection_on_checkin", DEFAULT_TEST_CONNECTION_ON_CHECKIN)
                .put("idle_connection_test_period", DEFAULT_IDLE_CONNECTION_TEST_PEROID);

        return tidbClientConfig;
    }
@author tiezhu
Date 2020/6/1
company www.dtstack.com
tidb/tidb-side/tidb-async-side/src/main/java/com/dtstack/flink/sql/side/tidb/TidbAsyncReqRow.java