2.0.0项目初始化

datax-common/datax-common-database/src/main/java/cn/datax/common/database/DbQuery.java

@@ -59,6 +59,15 @@ public interface DbQuery {
     List<Map<String, Object>> queryList(String sql);
 
     /**
+     * 查询结果列表带查询参数
+     *
+     * @param sql
+     * @param args
+     * @return
+     */
+    List<Map<String, Object>> queryList(String sql, Object[] args);
+
+    /**
      * 查询结果分页
      *
      * @param sql
@@ -67,4 +76,14 @@ public interface DbQuery {
      * @return
      */
     PageResult<Map<String, Object>> queryByPage(String sql, long offset, long size);
+
+    /**
+     * 查询结果分页带查询参数
+     * @param sql
+     * @param args
+     * @param offset
+     * @param size
+     * @return
+     */
+    PageResult<Map<String, Object>> queryByPage(String sql, Object[] args, long offset, long size);
 }

datax-common/datax-common-database/src/main/java/cn/datax/common/database/query/DbQueryTemplate.java

@@ -67,10 +67,23 @@ public class DbQueryTemplate implements DbQuery {
     }
 
     @Override
+    public List<Map<String, Object>> queryList(String sql, Object[] args) {
+        return jdbcTemplate.queryForList(sql, args);
+    }
+
+    @Override
     public PageResult<Map<String, Object>> queryByPage(String sql, long offset, long size) {
         int total = count(sql);
         String pageSql = dbDialect.buildPaginationSql(sql, offset, size);
         List<Map<String, Object>> records = jdbcTemplate.queryForList(pageSql);
         return new PageResult<>(total, records);
     }
+
+    @Override
+    public PageResult<Map<String, Object>> queryByPage(String sql, Object[] args, long offset, long size) {
+        int total = count(sql);
+        String pageSql = dbDialect.buildPaginationSql(sql, offset, size);
+        List<Map<String, Object>> records = jdbcTemplate.queryForList(pageSql, args);
+        return new PageResult<>(total, records);
+    }
 }