Dynamic‑SQL2 查询篇：MyBatis 增强利器，让 SQL 像写 Java 一样丝滑

Dynamic‑SQL2 查询篇：MyBatis 增强利器，让 SQL 像写 Java 一样丝滑

dynamic‑sql2 的查询能力设计目标：   写 SQL 要像写 Java 一样自然；复杂查询要像搭积木一样组合；结果映射要像操作集合一样顺滑。

本篇简述了：

• 基础查询
  
• 结果映射
  
• 分组 / Map / 分页
  
• Join / 子查询 / JSON 表
  
• 动态列引用
  
• 排序与 SQL 注入防御
  
• 忽略列
  
• 函数查询
  
• 正则匹配条件
  
• 动态库表名称（schema/table）机制
  
• 分页体系（dynamic‑sql2 / MyBatis / 逻辑分页）
  

引入依赖

截止至2026-01-21，最新版是0.1.8，项目地址：https://github.com/pengweizhong/dynamic-sql2

1.         
2.         <dependency>
3.             <groupId>com.dynamic-sql</groupId>
4.             dynamic-sql2-spring-boot-starter</artifactId>
5.             <version>0.1.8</version>
6.         </dependency>
7.         
8.         <dependency>
9.             <groupId>com.dynamic-sql</groupId>
10.             dynamic-sql2-spring-boot3-starter</artifactId>
11.             <version>0.1.8</version>
12.         </dependency>

复制代码

在repository层注入SqlContext  增删改查都和此对象交互：

1.     @Resource
2.     private SqlContext sqlContext;

复制代码

1. 基础查询与结果映射

1.1 查询列表

1. List<Product> list = sqlContext.select()
2.         .allColumn()
3.         .from(Product.class)
4.         .fetch()
5.         .toList();

复制代码

1.2 查询单列（标量）

1. LocalDate one = sqlContext.select()
2.         .column(Product::getCreatedAt)
3.         .from(Product.class)
4.         .limit(1)
5.         .fetch(LocalDate.class)
6.         .toOne();

复制代码

1.3 查询单条记录

1. Product product = sqlContext.select()
2.         .allColumn()
3.         .from(Product.class)
4.         .where(c -> c.andEqualTo(Product::getProductId, 7))
5.         .fetch()
6.         .toOne();

复制代码

或使用主键快捷方式：

1. Product product2 = sqlContext.selectByPrimaryKey(Product.class, 7);

复制代码

2. toList / toOne / toMap / toGroupingBy

2.1 分组 toGroupingBy

1. Map<Integer, HashSet<String>> groupingBy = sqlContext.select()
2.         .distinct()
3.         .allColumn()
4.         .from(User.class)
5.         .fetch()
6.         .toGroupingBy(
7.                 User::getUserId,
8.                 user -> user.getName() + "_hello",
9.                 HashSet::new,
10.                 ConcurrentHashMap::new
11.         );

复制代码

2.2 分组（带 DTO）

1. LinkedHashMap<String, HashSet<Integer>> groupingBy = sqlContext.select()
2.         .allColumn()
3.         .from(User.class)
4.         .limit(10)
5.         .fetch(User.class)
6.         .toGroupingBy(
7.                 User::getName,
8.                 User::getUserId,
9.                 HashSet::new,
10.                 LinkedHashMap::new
11.         );

复制代码

2.3 toMap（含重复 key 处理）

1. Map<Integer, String> map = sqlContext.select()
2.         .distinct()
3.         .allColumn()
4.         .from(User.class)
5.         .fetch()
6.         .toMap(
7.                 user -> 123,
8.                 user -> user.getName() + "_hello"
9.         );

复制代码

重复 key 会抛异常，可自定义合并策略：

1. .toMap(
2.     ProductView::getProductName,
3.     v -> v,
4.     (v1, v2) -> v1
5. );

复制代码

3. Join / 子查询 / JSON 表

3.1 多级 join + 别名 （自关联）

1. List<Map<String, Object>> list = sqlContext.select()
2.         .column("d1", DepartmentEntity::getId, "l5Id")
3.         .column("d2", DepartmentEntity::getId, "l4Id")
4.         .column("d3", DepartmentEntity::getId, "l3Id")
5.         .column("d4", DepartmentEntity::getId, "l2Id")
6.         .column("d5", DepartmentEntity::getId, "l1Id")
7.         .from(DepartmentEntity.class, "d1")
8.         .leftJoin(DepartmentEntity.class, "d2", c -> c.andEqualTo(new Column("d1","id"), new Column("d2","parent_id")))
9.         .leftJoin(DepartmentEntity.class, "d3", c -> c.andEqualTo(new Column("d2","id"), new Column("d3","parent_id")))
10.         .leftJoin(DepartmentEntity.class, "d4", c -> c.andEqualTo(new Column("d3","id"), new Column("d4","parent_id")))
11.         .leftJoin(DepartmentEntity.class, "d5", c -> c.andEqualTo(new Column("d4","id"), new Column("d5","parent_id")))
12.         .where(c -> c.andIn(DepartmentEntity::getId, Arrays.asList(1,2,3)))
13.         .fetchOriginalMap()
14.         .toList();

复制代码

3.2 子查询 join

1. List<Map<String, Object>> list = sqlContext.select()
2.         .allColumn(Product.class)
3.         .from(Product.class)
4.         .innerJoin(
5.                 select -> select.allColumn(Product.class)
6.                         .from(Category.class)
7.                         .join(Product.class, on -> on.andEqualTo(Category::getCategoryId, Product::getCategoryId))
8.                         .where(c -> c.andLessThanOrEqualTo(Category::getCategoryId, 10)),
9.                 "t",
10.                 on -> on.andEqualTo(Product::getProductId, bindAlias("t", Product::getProductId))
11.         )
12.         .fetchOriginalMap()
13.         .toList();

复制代码

3.3 JSON 表展开（JsonTable）

1. List<Object> list = sqlContext.select()
2.         .column("o", Order::getOrderId)
3.         .column("jt", Product::getProductName)
4.         .from(Order.class, "o")
5.         .join(() -> new JsonTable(
6.                         "o",
7.                         Order::getOrderDetails,
8.                         "$.items[*]",
9.                         JsonColumn.builder()
10.                                 .column("product_name")
11.                                 .dataType("VARCHAR(150)")
12.                                 .jsonPath("$.product")
13.                                 .build()
14.                 ),
15.                 "jt",
16.                 null
17.         )
18.         .fetch()
19.         .toList();

复制代码

4. 动态列引用 ColumnReference

1. List<Product> list = sqlContext.select()
2.         .column(Product::getProductId)
3.         .columnReference(columnReference())
4.         .from(Product.class)
5.         .fetch()
6.         .toList();

复制代码

1. AbstractColumnReference columnReference() {
2.     return ColumnReference.withColumns()
3.             .column(Product::getProductId)
4.             .columnReference(columnReference2())
5.             .column(Product::getProductName);
6. }

复制代码

5. 排序与 SQL 注入防御

5.1 链式排序

1. List<User> list = sqlContext.select()
2.         .allColumn()
3.         .from(User.class, "u")
4.         .orderBy(true, sortField, SortOrder.DESC)
5.         .thenOrderBy(false, User::getUserId)
6.         .thenOrderBy(true, User::getName)
7.         .fetch()
8.         .toList();

复制代码

5.2 ORDER BY 注入测试

1. sqlContext.select()
2.         .allColumn()
3.         .from(User.class)
4.         .orderBy("user_id; drop table users; --", SortOrder.DESC)
5.         .fetch()
6.         .toList();

复制代码

框架会拒绝非法字段名，抛出异常，避免注入。
6. 忽略列 ignoreColumn

1. List<?> list = sqlContext.select()
2.         .allColumn()
3.         .ignoreColumn(TempUserEntity::getName)
4.         .ignoreColumn(TempDeptEntity::getName)
5.         .from(TempUserEntity.class)
6.         .join(TempDeptEntity.class, on -> on.andEqualTo(TempUserEntity::getId, TempDeptEntity::getId))
7.         .fetch()
8.         .toList();

复制代码

7. 日期函数 DateFormat / Now

1. YearMonth yearMonth = sqlContext.select()
2.         .column(new DateFormat(new Now(), "%Y-%m"))
3.         .from(Dual.class)
4.         .fetch(YearMonth.class)
5.         .toOne();

复制代码

8. 正则匹配 andMatches（扩展点）

1. List<User> list = sqlContext.select()
2.         .allColumn()
3.         .from(User.class)
4.         .where(c -> c.andMatches(User::getEmail, ".*@gmail\\.com"))
5.         .fetch()
6.         .toList();

复制代码

9. 动态库表名称（schema/table）

dynamic‑sql2 的 @Table 支持占位符解析，可动态：

• schema
  
• table
  
• alias
  
• dataSourceName
  

9.1 动态 schema

从0.1.8起，自定义值库表解析器，这在同一实例相似业务下跨库时不同的命令库表命名规则时非常有用，不会影响查询速度。

1. @Table(schema = "${tenant.schema:user_center}", name = "t_user")

复制代码

配置：

1. tenant.schema = tenant_001

复制代码

SQL效果片段：

1. FROM tenant_001.t_user

复制代码

9.2 动态表名（含默认值）

1. @Table(name = "${tenant.table.user:t_user}")

复制代码

9.3 动态数据源（最高优先级）

1. @Table(dataSourceName = "ds_user")

复制代码

9.4 全局alias

1. @Table(name = "t_user", alias = "u")

复制代码

10. 分页体系（PageHelper）

dynamic-sql2内置了分页支持的查询
10.1 dynamic‑sql2 分页

1. PageInfo<List<User>> pageInfo = PageHelper.of(1, 10)
2.         .selectPage(() -> sqlContext.select()
3.                 .allColumn()
4.                 .from(User.class)
5.                 .fetch()
6.                 .toList());

复制代码

10.2 MyBatis 分页

1. PageInfo<List<User>> pageInfo = PageHelper.ofMybatis(1, 10)
2.         .selectPage(() -> sqlContext.select()
3.                 .allColumn()
4.                 .from(User.class)
5.                 .fetch()
6.                 .toList());

复制代码

Dynamic-SQL2支持mybatis的分页，但是需要引入拓展包：

1. <dependency>
2.     <groupId>com.dynamic-sql</groupId>
3.     dynamic-sql2-extension</artifactId>
4.     <version>0.1.6</version>
5.     <scope>compile</scope>
6. </dependency>

复制代码

该拓展包除了支持Mybatis分页外，和其映射规则也是完全兼容。
10.3 applyWhere（实验性）

该场景有时会遇到类似情况：有的依赖jar有自己独立的逻辑体系，但是又想修改其内部SQL，在不改变内部逻辑的情况下，在外部尝试修改SQL语句。目前只是实验阶段，有足够的场景场景支撑和更多的测试后，才会Release该特性。

1. PageInfo<List<User>> pageInfo = PageHelper.of(1, 3)
2.         .applyWhere(c -> c.andGreaterThanOrEqualTo(User::getAge, 18))
3.         .selectPage(
4.                             //假设这是无法修改/不允许更改的内部SQL，通常是jar的形式提供
5.                             () -> sqlContext.select()
6.                 .allColumn()
7.                 .from(User.class)
8.                 .fetch()
9.                 .toList());

复制代码

10.4 逻辑分页（集合内存分页）

1. PageInfo<List<Integer>> pageInfo = PageHelper.ofLogic(2, 3)
2.         .selectPage(Arrays.asList(1,2,3,4,5,6,7));

复制代码

11. 分页 + 动态库表名称示例

1. @Table(
2.     schema = "${tenant.schema:user_center}",
3.     name = "${tenant.table.user:t_user}",
4.     alias = "u"
5. )
6. public class User {}

复制代码

分页查询：

1. PageInfo<List<User>> pageInfo = PageHelper.of(1, 10)
2.         .selectPage(() -> sqlContext.select()
3.                 .allColumn()
4.                 .from(User.class)
5.                 .fetch()
6.                 .toList());

复制代码

最终 SQL：

1. SELECT u.*
2. FROM tenant_001.user_2025 u
3. LIMIT 10 OFFSET 0

复制代码

拓展

自定义函数

对于Dynamic-SQL2没有提供的函数，如何自定义呢？非常简单，继承ColumnFunctionDecorator抽象类重写getFunctionToString方法即可，然后代码中就可以引用了。
比如已存在的max函数为例：

1. /*
2. * Copyright (c) 2024 PengWeizhong. All Rights Reserved.
3. *
4. * This source code is licensed under the MIT License.
5. * You may obtain a copy of the License at:
6. * https://opensource.org/licenses/MIT
7. *
8. * See the LICENSE file in the project root for more information.
9. */
10. package com.dynamic.sql.core.column.function.windows.aggregate;
13. import com.dynamic.sql.core.FieldFn;
14. import com.dynamic.sql.core.Version;
15. import com.dynamic.sql.core.column.function.AbstractColumFunction;
16. import com.dynamic.sql.core.column.function.ColumnFunctionDecorator;
17. import com.dynamic.sql.core.column.function.windows.WindowsFunction;
18. import com.dynamic.sql.enums.SqlDialect;
19. import com.dynamic.sql.utils.ExceptionUtils;
20. import com.dynamic.sql.model.TableAliasMapping;
22. import java.util.Map;
25. public class Max extends ColumnFunctionDecorator implements AggregateFunction, WindowsFunction {
27.     public Max(AbstractColumFunction delegateFunction) {
28.         super(delegateFunction);
29.     }
31.     public <T, F> Max(FieldFn<T, F> fn) {
32.         super(fn);
33.     }
35.     public <T, F> Max(String tableAlias, FieldFn<T, F> fn) {
36.         super(tableAlias, fn);
37.     }
39.     @Override
40.     public String getFunctionToString(SqlDialect sqlDialect, Version version, Map<String, TableAliasMapping> aliasTableMap) throws UnsupportedOperationException {
41.         if (sqlDialect == SqlDialect.ORACLE) {
42.             return "MAX(" + delegateFunction.getFunctionToString(sqlDialect, version, aliasTableMap) + ")".concat(appendArithmeticSql(sqlDialect, version));
43.         }
44.         if (sqlDialect == SqlDialect.MYSQL) {
45.             return "max(" + delegateFunction.getFunctionToString(sqlDialect, version, aliasTableMap) + ")".concat(appendArithmeticSql(sqlDialect, version));
46.         }
47.         throw ExceptionUtils.unsupportedFunctionException("max", sqlDialect);
48.     }
49. }

复制代码

之后在代码中直接引用该类：

1.     @Test
2.     void testMax() {
3.         Integer max = sqlContext.select()
4.                 .column(new Max(Product::getProductId))
5.                 .from(Product.class)
6.                 .fetch(Integer.class)
7.                 .toOne();
8.         System.out.println(max);
9.     }

复制代码

打印的SQL
[code]2026-01-21 13:27:03 [main] DEBUG com.dynamic.sql.core.database.SqlDebugger - dataSource -->     Preparing: select max(`p`.`product_id`) as productId from `dynamic_sql2`.`products` as `p`2026-01-21 13:27:03 [main] DEBUG com.dynamic.sql.core.database.SqlDebugger - dataSource -->    Parameters: 2026-01-21 13:27:03 [main] DEBUG com.dynamic.sql.core.database.SqlDebugger - dataSource

用心讨论，共获提升！

新版吗？好像是停更了吧。

这个好，看起来很实用

谢谢分享，辛苦了

收藏一下   不知道什么时候能用到