@Override
    public Connection getConn(String dbUrl, String userName, String password) {
        try {
            Class.forName(DB2_DRIVER);
            Connection conn = DriverManager.getConnection(dbUrl, userName, password);
            return conn;
        } catch (Exception e) {
            LOG.error("", e);
            throw new RuntimeException("", e);
        }
    }
Date: 2019/11/20
Company: www.dtstack.com

@author xiuzhu
db2/db2-side/db2-all-side/src/main/java/com/dtstack/flink/sql/side/db2/Db2AllReqRow.java