@Override
    public Connection getConn(String dbUrl, String userName, String password) {
        try {
            Class.forName(TIDB_DRIVER);
            Map<String, String> addParams = Maps.newHashMap();
            addParams.put("userCursorFetch", "true");
            String targetDbUrl = DtStringUtil.addJdbcParam(dbUrl, addParams, true);
            return DriverManager.getConnection(targetDbUrl, userName, password);
        } catch (ClassNotFoundException | SQLException e) {
            LOG.error("TiDB get connect error!", e);
            throw new RuntimeException("TiDB get connect error! ", e);

        }
    }
@author tiezhu
Date 2020/6/1
company www.dtstack.com
tidb/tidb-side/tidb-all-side/src/main/java/com/dtstack/flink/sql/side/tidb/TidbAllReqRow.java