admin/mybatis-flex
1
0
Fork 0
mirror of https://gitee.com/mybatis-flex/mybatis-flex.git synced 2025-12-08 09:38:26 +08:00
Code Issues Packages Projects Releases Wiki Activity

!117 feat：BaseMapper 添加更多方法

Browse Source 
Merge pull request !117 from 王帅/main
This commit is contained in:
Michael Yang 2023-07-08 15:12:16 +00:00 committed by Gitee
commit 305ed645a8
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
5 changed files with 272 additions and 61 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
docs/zh/base/add-delete-update.md
View File

@ -8,22 +8,30 @@ MyBatis-Flex 内置了一个名为 `BaseMapper` 的接口，它实现了基本
`BaseMapper` 的接口提供了 insert 和 insertBatch 方法，用于新增数据； `BaseMapper` 的接口提供了 insert 和 insertBatch 方法，用于新增数据；
- **insert**： 新增 1 条数据 - **insert(entity)**：新增 1 条数据，不忽略 null 值的字段
- **insertSelective**： 新增 1 条数据，忽略 null 值的字段 - **insertSelective(entity)**：新增 1 条数据，忽略 null 值的字段
- **insertBatch**： 新增多条数据 - **insert(entity, ignoreNulls)**：插入实体类数据，并设置是否忽略 null 值字段。
- **insertBatch(entities, int size)**： 批量插入 entity 数据，按 size 切分 - **insertWithPk(entity)**：插入带有主键的实体类，不忽略 null 值字段。
- **insertSelectiveWithPk(entity)**：插入带有主键的实体类，忽略 null 值字段。
- **insertWithPk(entity, ignoreNulls)**：带有主键的插入，并设置是否忽略 null 值字段。
- **insertBatch(entities)**：新增多条数据
- **insertBatch(entities, size)**：批量插入 entity 数据，按 size 切分
- **insertOrUpdate(entity)**：插入或者更新，若主键有值，则更新，若没有主键值，则插入，插入或者更新都不会忽略 null 值字段。
- **insertOrUpdateSelective(entity)**：插入或者更新，若主键有值，则更新，若没有主键值，则插入，插入或者更新都会忽略 null 值字段。
- **insertOrUpdate(entity, ignoreNulls)**：插入或者更新，若主键有值，则更新，若没有主键值，则插入，并设置是否忽略 null 值字段。
## 删除数据 ## 删除数据
`BaseMapper` 的接口提供了 deleteById、deleteBatchByIds、deleteByMap、deleteByQuery 方法，用于删除数据； `BaseMapper` 的接口提供了 deleteById、deleteBatchByIds、deleteByMap、deleteByQuery 方法，用于删除数据；
- **deleteById(id)** ：根据主键 id 删除数据，复合主键需要传入一个数组，例如 [1,100] - **deleteById(id)**：根据主键 id 删除数据，复合主键需要传入一个数组，例如 [1,100]
- **deleteBatchByIds(idList)** ：根据主键的 集合，批量删除多条数据 - **deleteBatchByIds(ids)**：根据主键的 集合，批量删除多条数据
- **deleteByMap(map)** ：根据 `map<字段名，值>` 组成的条件删除数据，字段名和值的关系为相等的关系，同时，防止 "不小心" 全表 - **deleteBatchByIds(ids, size)**：根据多个主键批量删除数据，并按 size 切分。
删除数据，map 的值不允许为 null 或者 空数据。 - **deleteByMap(map)**：根据 `map<字段名，值>` 组成的条件删除数据，字段名和值的关系为相等的关系，同时，防止 "不小心" 全表
- **deleteByCondition(condition)**：根据 condition 构建的条件来删除数据 删除数据，map 的值不允许为 null 或者 空数据。
- **deleteByQuery(queryWrapper)**：根据 queryWrapper 组成的条件删除数据。 - **deleteByCondition(condition)**：根据 QueryCondition 构建的条件来删除数据
- **deleteByQuery(queryWrapper)**：根据 QueryWrapper 组成的条件删除数据。
**deleteByQuery(queryWrapper)** 方法示例： **deleteByQuery(queryWrapper)** 方法示例：
@ -56,15 +64,27 @@ delete from tb_account where id >= 100;
`BaseMapper` 的接口提供了 update、updateByMap、updateByQuery 方法，用于更新数据； `BaseMapper` 的接口提供了 update、updateByMap、updateByQuery 方法，用于更新数据；
- **update(entity)**：根据主键更新到 entity 到数据库，要求主键值不能为空，否则会抛出异常。同时，数据为 null 的字段 **不会** 更新到数据库。 - **update(entity)**：根据主键更新到 entity 到数据库，要求主键值不能为空，否则会抛出异常。同时，数据为 null 的字段 **不会**
- **update(entity, ignoreNulls)**：根据主键更新到 entity 到数据库，要求主键值不能为空。ignoreNulls 为是否忽略 null 字段，如果为 false，所有 null 字段都会更新到数据库。 更新到数据库。
- **updateByMap(entity, map)**：根据 `map<字段名，值>` 组成的条件更新到 entity 到数据库，entity 可以没有主键（如果有也会被忽略）, entity 的 null 属性，会自动被忽略。 - **update(entity, ignoreNulls)**：根据主键更新到 entity 到数据库，要求主键值不能为空。ignoreNulls 为是否忽略 null 字段，如果为
- **updateByCondition(entity, condition)**：根据 condition 构建的条件更新到 entity 到数据库，entity 可以没有主键（如果有也会被忽略）, entity 的 null 属性，会自动被忽略。 false，所有 null 字段都会更新到数据库。
- **updateByCondition(entity, ignoreNulls, condition)**：ignoreNulls 是否忽略 null 值，默认为 true，如果为 false，所有 null 字段都会更新到数据库。 - **updateByMap(entity, map)**：根据 `map<字段名，值>` 组成的条件更新到 entity 到数据库，entity 可以没有主键（如果有也会被忽略）,
- **updateByQuery(entity, queryWrapper)**：根据 queryWrapper 组成的条件更新到 entity 到数据库，entity 可以没有主键（如果有也会被忽略）, entity 的 null 属性，会自动被忽略。 entity 的 null 属性，会自动被忽略。
- **updateByQuery(entity, ignoreNulls, queryWrapper)**：据 queryWrapper 组成的条件更新到 entity 到数据库，entity 可以没有主键（如果有也会被忽略）。 ignoreNulls 用于是否忽略 entity 的 null 属性 - **updateByCondition(entity, condition)**：根据 condition 构建的条件更新到 entity 到数据库，entity 可以没有主键（如果有也会被忽略）,
， 若 ignoreNulls 为 false，entity 的所有 null 属性都会被更新到数据库。 entity 的 null 属性，会自动被忽略。
- **updateNumberAddByQuery(fieldName,value,queryWrapper)**：通过 `update table set field = field + 1 where ... ` 的这种方向更新数据库某个字段内容。 - **updateByCondition(entity, ignoreNulls, condition)**：ignoreNulls 是否忽略 null 值，默认为 true，如果为 false，所有 null
字段都会更新到数据库。
- **updateByQuery(entity, queryWrapper)**：根据 queryWrapper 组成的条件更新到 entity 到数据库，entity 可以没有主键（如果有也会被忽略）,
entity 的 null 属性，会自动被忽略。
- **updateByQuery(entity, ignoreNulls, queryWrapper)**：据 queryWrapper 组成的条件更新到 entity 到数据库，entity
可以没有主键（如果有也会被忽略）。 ignoreNulls 用于是否忽略 entity 的 null 属性
， 若 ignoreNulls 为 false，entity 的所有 null 属性都会被更新到数据库。
- **updateNumberAddByQuery(fieldName,value,queryWrapper)**：通过 `update table set field = field + 1 where ... `
的这种方向更新数据库某个字段内容。
- **updateNumberAddByQuery(column,value,queryWrapper)**：通过 `update table set field = field + 1 where ... `
的这种方向更新数据库某个字段内容。
- **updateNumberAddByQuery(fn,value,queryWrapper)**：通过 `update table set field = field + 1 where ... `
的这种方向更新数据库某个字段内容。
## 部分字段更新 ## 部分字段更新

63
docs/zh/base/query.md
View File

@ -8,22 +8,29 @@
- **selectOneByMap(map)**：根据 `map<字段名，值>` 组成的条件查询 1 条数据，若命中多条数据，则只返回第一条数据。 - **selectOneByMap(map)**：根据 `map<字段名，值>` 组成的条件查询 1 条数据，若命中多条数据，则只返回第一条数据。
- **selectOneByCondition(condition)**：根据 condition 组成的条件查询 1 条数据，若命中多条数据，则只返回第一条数据。 - **selectOneByCondition(condition)**：根据 condition 组成的条件查询 1 条数据，若命中多条数据，则只返回第一条数据。
- **selectOneByQuery(query)**：根据 QueryWrapper 组成的条件查询 1 条数据，若命中多条数据，**则抛出错误!!!**。一般情况下，用户可以主动添加 `limit(1)` 来阻止返回多条的情况。 - **selectOneByQuery(query)**：根据 QueryWrapper 组成的条件查询 1 条数据，若命中多条数据，**则抛出错误!!!**。一般情况下，用户可以主动添加 `limit(1)` 来阻止返回多条的情况。
- **selectOneByQueryAs(query, asType)**：和 `selectOneByQuery` 方法类似，但是在某些场景下，`query` 可能包含了 `left join` 等多表查询，返回的数据和 entity 字段不一致时， - **selectOneByQueryAs(query, asType)**：和 `selectOneByQuery` 方法类似，但是在某些场景下，`query` 可能包含了 `left join`
可以通过 `asType` 参数来指定接收的数据类型（通常是 dto、vo 等）。 等多表查询，返回的数据和 entity 字段不一致时，
可以通过 `asType` 参数来指定接收的数据类型（通常是 dto、vo 等）。
- **selectListByIds(idList)**：根据多个 id 查询，返回多条数据 - **selectListByIds(idList)**：根据多个 id 查询，返回多条数据
- **selectListByMap(map)**：根据 `map<字段名，值>` 组成的条件查询数据。 - **selectListByMap(map)**：根据 `map<字段名，值>` 组成的条件查询数据。
- **selectListByMap(map, count)**：根据 `map<字段名，值>` 组成的条件查询数据，只取前 count 条。 - **selectListByMap(map, count)**：根据 `map<字段名，值>` 组成的条件查询数据，只取前 count 条。
- **selectListByCondition(condition)**：根据 condition 组成的条件查询数据。 - **selectListByCondition(condition)**：根据 condition 组成的条件查询数据。
- **selectListByCondition(condition, count)**：根据 condition 组成的条件查询数据，只取前 count 条。 - **selectListByCondition(condition, count)**：根据 condition 组成的条件查询数据，只取前 count 条。
- **selectListByQuery(query)**： 根据 QueryWrapper 组成的条件查询数据。 - **selectListByQuery(query)**： 根据 QueryWrapper 组成的条件查询数据。
- **selectListByQueryAs(query, asType)**： 和 `selectListByQuery` 方法类似，但是在某些场景下，`query` 可能包含了 `left join` 等多表查询，返回的数据和 entity 字段不一致时， - **selectListByQuery(query, consumers)**： 根据 QueryWrapper 组成的条件查询数据。
- **selectListByQueryAs(query, asType)**： 和 `selectListByQuery` 方法类似，但是在某些场景下，`query`
可能包含了 `left join` 等多表查询，返回的数据和 entity 字段不一致时，
可以通过 `asType` 参数来指定接收的数据类型（通常是 dto、vo 等）。
- **selectListByQueryAs(query, asType, consumers)**： 和 `selectListByQuery` 方法类似，但是在某些场景下，`query`
可能包含了 `left join` 等多表查询，返回的数据和 entity 字段不一致时，
可以通过 `asType` 参数来指定接收的数据类型（通常是 dto、vo 等）。 可以通过 `asType` 参数来指定接收的数据类型（通常是 dto、vo 等）。
- **selectAll**：查询所有数据。 - **selectAll**：查询所有数据。
- **selectObjectByQuery(query)**：查询只返回 1 列，并只有 1 条数据的场景。 - **selectObjectByQuery(query)**：查询只返回 1 列，并只有 1 条数据的场景。
- **selectObjectByQueryAs(query)**：查询只返回 1 列，并只有 1 条数据的场景。
- **selectObjectListByQuery(query)**：查询只返回 1 列场景，比如 `QueryWrapper.create().select(ACCOINT.ID).from(...)`。 - **selectObjectListByQuery(query)**：查询只返回 1 列场景，比如 `QueryWrapper.create().select(ACCOINT.ID).from(...)`。
- **selectObjectListByQueryAs(query, asType)**：对 `selectObjectListByQuery` 进行封装，并转换为特定的类型。 - **selectObjectListByQueryAs(query, asType)**：对 `selectObjectListByQuery` 进行封装，并转换为特定的类型。
- **selectCountByCondition**：根据 QueryWrapper 查询数据量。 - **selectCountByCondition(condition)**：根据 QueryWrapper 查询数据量。
- **selectCountByQuery**：根据 QueryWrapper 查询数据量。 - **selectCountByQuery(queryWrapper)**：根据 QueryWrapper 查询数据量。
## 游标查询 ## 游标查询
@ -55,7 +62,32 @@ Db.tx(() -> {
- 1、数据查询并写入到缓存 - 1、数据查询并写入到缓存
- 2、Excel 导出等 - 2、Excel 导出等
## 查询 Map 集合
```java
List<Row> selectRowsByQuery(QueryWrapper queryWrapper);
```
## Relations 注解查询
- **selectOneWithRelationsByMap(map)**
- **selectOneWithRelationsByCondition(condition)**
- **selectOneWithRelationsByQuery(queryWrapper)**
- **selectOneWithRelationsByQueryAs(queryWrapper, asType)**
- **selectListWithRelationsByQuery(queryWrapper)**
- **selectListWithRelationsByQueryAs(queryWrapper, asType)**
- **selectListWithRelationsByQueryAs(queryWrapper, asType, consumers)**
- **selectAllWithRelations()**
- **paginateWithRelations(pageNumber, pageSize, queryWrapper)**
- **paginateWithRelations(pageNumber, pageSize, condition)**
- **paginateWithRelations(pageNumber, pageSize, totalRow, queryWrapper)**
- **paginateWithRelations(pageNumber, pageSize, totalRow, condition)**
- **paginateWithRelations(page, queryWrapper)**
- **paginateWithRelations(page, queryWrapper, consumers)**
- **paginateWithRelationsAs(pageNumber, pageSize, queryWrapper, asType)**
- **paginateWithRelationsAs(pageNumber, pageSize, totalRow, queryWrapper, asType)**
- **paginateWithRelationsAs(page, queryWrapper, asType)**
- **paginateWithRelationsAs(page, queryWrapper, asType, consumers)**
## 多表查询（关联查询） ## 多表查询（关联查询）
@ -201,11 +233,20 @@ System.out.println(results);
在 MyBatis-Flex 的 BaseMapper 中，提供了如下的分页查询功能： 在 MyBatis-Flex 的 BaseMapper 中，提供了如下的分页查询功能：
```java ```java
Page<T> paginate(int pageNumber, int pageSize, QueryWrapper queryWrapper); default Page<T> paginate(int pageNumber,int pageSize,QueryWrapper queryWrapper);
Page<T> paginate(int pageNumber, int pageSize, int totalRow, QueryWrapper queryWrapper); default Page<T> paginate(int pageNumber,int pageSize,QueryCondition whereConditions);
Page<T> paginate(int pageNumber, int pageSize, QueryCondition condition); default Page<T> paginate(int pageNumber,int pageSize,int totalRow,QueryWrapper queryWrapper);
Page<T> paginate(int pageNumber, int pageSize, int totalRow, QueryCondition condition); default Page<T> paginate(int pageNumber,int pageSize,int totalRow,QueryCondition whereConditions);
default Page<T> paginate(Page<T> page,QueryWrapper queryWrapper);
default Page<T> paginate(Page<T> page,QueryWrapper queryWrapper,Consumer<FieldQueryBuilder<T>>...consumers);
default<R> Page<R> paginateAs(int pageNumber,int pageSize,QueryWrapper queryWrapper,Class<R> asType);
default<R> Page<R> paginateAs(int pageNumber,int pageSize,int totalRow,QueryWrapper queryWrapper,Class<R> asType)
default<R> Page<R> paginateAs(Page<R> page,QueryWrapper queryWrapper,Class<R> asType)
default<R> Page<R> paginateAs(Page<R> page,QueryWrapper queryWrapper,Class<R> asType,Consumer<FieldQueryBuilder<R>>...consumers)
``` ```
- pageNumber： 当前页码，从 1 开始 - pageNumber： 当前页码，从 1 开始
- pageSize： 每 1 页的数据量 - pageSize： 每 1 页的数据量

189
mybatis-flex-core/src/main/java/com/mybatisflex/core/BaseMapper.java
View File

@ -51,7 +51,14 @@ import static com.mybatisflex.core.query.QueryMethods.count;
public interface BaseMapper<T> { public interface BaseMapper<T> {
/** /**
* 插入实体类数据。 * 默认批量处理切片数量。
*/
int DEFAULT_BATCH_SIZE = 1000;
// === 增（insert） ===
/**
* 插入实体类数据，不忽略 {@code null} 值。
* *
* @param entity 实体类 * @param entity 实体类
* @return 受影响的行数 * @return 受影响的行数
@ -83,20 +90,19 @@ public interface BaseMapper<T> {
int insert(@Param(FlexConsts.ENTITY) T entity, @Param(FlexConsts.IGNORE_NULLS) boolean ignoreNulls); int insert(@Param(FlexConsts.ENTITY) T entity, @Param(FlexConsts.IGNORE_NULLS) boolean ignoreNulls);
/** /**
* 插入带有主键的实体类。 * 插入带有主键的实体类，不忽略 {@code null} 值。
* *
* @param entity 实体类，不忽略 {@code null} 值 * @param entity 实体类
* @return 受影响的行数 * @return 受影响的行数
*/ */
default int insertWithPk(T entity) { default int insertWithPk(T entity) {
return insertWithPk(entity, false); return insertWithPk(entity, false);
} }
/** /**
* 插入带有主键的实体类。 * 插入带有主键的实体类，忽略 {@code null} 值。
* *
* @param entity 实体类，忽略 {@code null} 值 * @param entity 实体类
* @return 受影响的行数 * @return 受影响的行数
*/ */
default int insertSelectiveWithPk(T entity) { default int insertSelectiveWithPk(T entity) {
@ -134,8 +140,7 @@ public interface BaseMapper<T> {
*/ */
default int insertBatch(List<T> entities, int size) { default int insertBatch(List<T> entities, int size) {
if (size <= 0) { if (size <= 0) {
// 默认 1000 size = DEFAULT_BATCH_SIZE;
size = 1000;
} }
int sum = 0; int sum = 0;
int entitiesSize = entities.size(); int entitiesSize = entities.size();
@ -148,7 +153,7 @@ public interface BaseMapper<T> {
} }
/** /**
* 新增 或者 更新，若主键有值，则更新，若没有主键值，则插入。 * 插入或者更新，若主键有值，则更新，若没有主键值，则插入，插入或者更新都不会忽略 {@code null} 值。
* *
* @param entity 实体类 * @param entity 实体类
* @return 受影响的行数 * @return 受影响的行数
@ -158,7 +163,17 @@ public interface BaseMapper<T> {
} }
/** /**
* 新增 或者 更新，若主键有值，则更新，若没有主键值，则插入。 * 插入或者更新，若主键有值，则更新，若没有主键值，则插入，插入或者更新都会忽略 {@code null} 值。
*
* @param entity 实体类
* @return 受影响的行数
*/
default int insertOrUpdateSelective(T entity) {
return insertOrUpdate(entity, true);
}
/**
* 插入或者更新，若主键有值，则更新，若没有主键值，则插入。
* *
* @param entity 实体类 * @param entity 实体类
* @param ignoreNulls 是否忽略 {@code null} 值 * @param ignoreNulls 是否忽略 {@code null} 值
@ -174,6 +189,8 @@ public interface BaseMapper<T> {
} }
} }
// === 删（delete） ===
/** /**
* 根据主键删除数据。如果是多个主键的情况下，需要传入数组，例如：{@code new Integer[]{100,101}}。 * 根据主键删除数据。如果是多个主键的情况下，需要传入数组，例如：{@code new Integer[]{100,101}}。
* *
@ -204,7 +221,7 @@ public interface BaseMapper<T> {
*/ */
default int deleteBatchByIds(List<? extends Serializable> ids, int size) { default int deleteBatchByIds(List<? extends Serializable> ids, int size) {
if (size <= 0) { if (size <= 0) {
size = 1000;//默认1000 size = DEFAULT_BATCH_SIZE;
} }
int sum = 0; int sum = 0;
int entitiesSize = ids.size(); int entitiesSize = ids.size();
@ -248,6 +265,8 @@ public interface BaseMapper<T> {
@DeleteProvider(type = EntitySqlProvider.class, method = "deleteByQuery") @DeleteProvider(type = EntitySqlProvider.class, method = "deleteByQuery")
int deleteByQuery(@Param(FlexConsts.QUERY) QueryWrapper queryWrapper); int deleteByQuery(@Param(FlexConsts.QUERY) QueryWrapper queryWrapper);
// === 改（update） ===
/** /**
* 根据主键来更新数据，若实体类属性数据为 {@code null}，该属性不会新到数据库。 * 根据主键来更新数据，若实体类属性数据为 {@code null}，该属性不会新到数据库。
* *
@ -323,6 +342,7 @@ public interface BaseMapper<T> {
* @param entity 实体类 * @param entity 实体类
* @param ignoreNulls 是否忽略空值 * @param ignoreNulls 是否忽略空值
* @param queryWrapper 条件 * @param queryWrapper 条件
* @return 受影响的行数
* @see com.mybatisflex.core.provider.EntitySqlProvider#updateByQuery(Map, ProviderContext) * @see com.mybatisflex.core.provider.EntitySqlProvider#updateByQuery(Map, ProviderContext)
*/ */
@UpdateProvider(type = EntitySqlProvider.class, method = "updateByQuery") @UpdateProvider(type = EntitySqlProvider.class, method = "updateByQuery")
@ -334,6 +354,7 @@ public interface BaseMapper<T> {
* @param fieldName 字段名 * @param fieldName 字段名
* @param value 值（大于等于 0 加，小于 0 减） * @param value 值（大于等于 0 加，小于 0 减）
* @param queryWrapper 条件 * @param queryWrapper 条件
* @return 受影响的行数
* @see EntitySqlProvider#updateNumberAddByQuery(Map, ProviderContext) * @see EntitySqlProvider#updateNumberAddByQuery(Map, ProviderContext)
*/ */
@UpdateProvider(type = EntitySqlProvider.class, method = "updateNumberAddByQuery") @UpdateProvider(type = EntitySqlProvider.class, method = "updateNumberAddByQuery")
@ -345,6 +366,7 @@ public interface BaseMapper<T> {
* @param column 字段名 * @param column 字段名
* @param value 值（大于等于 0 加，小于 0 减） * @param value 值（大于等于 0 加，小于 0 减）
* @param queryWrapper 条件 * @param queryWrapper 条件
* @return 受影响的行数
* @see EntitySqlProvider#updateNumberAddByQuery(Map, ProviderContext) * @see EntitySqlProvider#updateNumberAddByQuery(Map, ProviderContext)
*/ */
default int updateNumberAddByQuery(QueryColumn column, Number value, QueryWrapper queryWrapper) { default int updateNumberAddByQuery(QueryColumn column, Number value, QueryWrapper queryWrapper) {
@ -358,6 +380,7 @@ public interface BaseMapper<T> {
* @param fn 字段名 * @param fn 字段名
* @param value 值（大于等于 0 加，小于 0 减） * @param value 值（大于等于 0 加，小于 0 减）
* @param queryWrapper 条件 * @param queryWrapper 条件
* @return 受影响的行数
* @see EntitySqlProvider#updateNumberAddByQuery(Map, ProviderContext) * @see EntitySqlProvider#updateNumberAddByQuery(Map, ProviderContext)
*/ */
default int updateNumberAddByQuery(LambdaGetter<T> fn, Number value, QueryWrapper queryWrapper) { default int updateNumberAddByQuery(LambdaGetter<T> fn, Number value, QueryWrapper queryWrapper) {
@ -367,6 +390,8 @@ public interface BaseMapper<T> {
return updateNumberAddByQuery(column, value, queryWrapper); return updateNumberAddByQuery(column, value, queryWrapper);
} }
// === 查（select） ===
/** /**
* 根据主键查询数据。 * 根据主键查询数据。
* *
@ -414,14 +439,14 @@ public interface BaseMapper<T> {
* *
* @param queryWrapper 条件 * @param queryWrapper 条件
* @param asType 接收数据类型 * @param asType 接收数据类型
* @return 数据内容 * @return 实体类数据
*/ */
default <R> R selectOneByQueryAs(QueryWrapper queryWrapper, Class<R> asType) { default <R> R selectOneByQueryAs(QueryWrapper queryWrapper, Class<R> asType) {
return MapperUtil.getSelectOneResult(selectListByQueryAs(queryWrapper, asType)); return MapperUtil.getSelectOneResult(selectListByQueryAs(queryWrapper, asType));
} }
/** /**
* 根据 Map 构建的条件来查询数据。 * 根据 Map 构建的条件来查询 1 条数据。
* *
* @param whereConditions 条件 * @param whereConditions 条件
* @return 实体类数据 * @return 实体类数据
@ -432,7 +457,7 @@ public interface BaseMapper<T> {
} }
/** /**
* 根据查询条件查询数据。 * 根据查询条件查询 1 条数据。
* *
* @param whereConditions 条件 * @param whereConditions 条件
* @return 实体类数据 * @return 实体类数据
@ -457,7 +482,7 @@ public interface BaseMapper<T> {
* *
* @param queryWrapper 条件 * @param queryWrapper 条件
* @param asType 接收数据类型 * @param asType 接收数据类型
* @return 数据内容 * @return 实体类数据
*/ */
default <R> R selectOneWithRelationsByQueryAs(QueryWrapper queryWrapper, Class<R> asType) { default <R> R selectOneWithRelationsByQueryAs(QueryWrapper queryWrapper, Class<R> asType) {
return MapperUtil.queryRelations(this, MapperUtil.getSelectOneResult(selectListByQueryAs(queryWrapper, asType))); return MapperUtil.queryRelations(this, MapperUtil.getSelectOneResult(selectListByQueryAs(queryWrapper, asType)));
@ -497,7 +522,7 @@ public interface BaseMapper<T> {
} }
/** /**
* 根据查询条件查询数据。 * 根据查询条件查询多条数据。
* *
* @param whereConditions 条件 * @param whereConditions 条件
* @return 数据列表 * @return 数据列表
@ -508,7 +533,7 @@ public interface BaseMapper<T> {
} }
/** /**
* 根据查询条件查询数据。 * 根据查询条件查询多条数据。
* *
* @param whereConditions 条件 * @param whereConditions 条件
* @param count 数据量 * @param count 数据量
@ -565,7 +590,7 @@ public interface BaseMapper<T> {
/** /**
* 根据查询条件查询数据列表，要求返回的数据为 asType。这种场景一般用在 left join 时， * 根据查询条件查询数据列表，要求返回的数据为 asType。这种场景一般用在 left join 时，
* 有多出了实体类本身的字段内容，可以转换为 dto、vo 等场景时。 * 有多出了实体类本身的字段内容，可以转换为 dto、vo 等场景。
* *
* @param queryWrapper 条件 * @param queryWrapper 条件
* @param asType 接收数据类型 * @param asType 接收数据类型
@ -608,7 +633,7 @@ public interface BaseMapper<T> {
} }
/** /**
* 查询实体类及其 relation 注解字段。 * 查询实体类及其 Relation 注解字段。
* *
* @param queryWrapper 条件 * @param queryWrapper 条件
*/ */
@ -617,7 +642,7 @@ public interface BaseMapper<T> {
} }
/** /**
* 查询实体类及其 relation 注解字段。 * 查询实体类及其 Relation 注解字段。
* *
* @param queryWrapper 条件 * @param queryWrapper 条件
* @param asType 要求返回的数据类型 * @param asType 要求返回的数据类型
@ -642,7 +667,7 @@ public interface BaseMapper<T> {
} }
/** /**
* 查询实体类及其 relation 注解字段。 * 查询实体类及其 Relation 注解字段。
* *
* @param queryWrapper 条件 * @param queryWrapper 条件
* @param asType 返回的类型 * @param asType 返回的类型
@ -670,7 +695,7 @@ public interface BaseMapper<T> {
} }
/** /**
* 查询全部数据，及其 relation 字段内容。 * 查询全部数据，及其 Relation 字段内容。
* *
* @return 数据列表 * @return 数据列表
*/ */
@ -800,7 +825,7 @@ public interface BaseMapper<T> {
} }
/** /**
* 分页查询，及其 relation 字段内容。 * 分页查询，及其 Relation 字段内容。
* *
* @param pageNumber 当前页码 * @param pageNumber 当前页码
* @param pageSize 每页的数据量 * @param pageSize 每页的数据量
@ -826,7 +851,7 @@ public interface BaseMapper<T> {
} }
/** /**
* 分页查询，及其 relation 字段内容。 * 分页查询，及其 Relation 字段内容。
* *
* @param pageNumber 当前页码 * @param pageNumber 当前页码
* @param pageSize 每页的数据量 * @param pageSize 每页的数据量
@ -853,7 +878,7 @@ public interface BaseMapper<T> {
} }
/** /**
* 分页查询，及其 relation 字段内容。 * 分页查询，及其 Relation 字段内容。
* *
* @param pageNumber 当前页码 * @param pageNumber 当前页码
* @param pageSize 每页的数据量 * @param pageSize 每页的数据量
@ -882,7 +907,7 @@ public interface BaseMapper<T> {
} }
/** /**
* 分页查询。 * 分页查询，及其 Relation 字段内容。
* *
* @param pageNumber 当前页码 * @param pageNumber 当前页码
* @param pageSize 每页的数据量 * @param pageSize 每页的数据量
@ -901,11 +926,10 @@ public interface BaseMapper<T> {
* *
* @param page 包含了页码、每页的数据量，可能包含数据总量 * @param page 包含了页码、每页的数据量，可能包含数据总量
* @param queryWrapper 条件 * @param queryWrapper 条件
* @param consumers 字段查询
* @return page 数据 * @return page 数据
*/ */
default Page<T> paginate(Page<T> page, QueryWrapper queryWrapper, Consumer<FieldQueryBuilder<T>>... consumers) { default Page<T> paginate(Page<T> page, QueryWrapper queryWrapper) {
return paginateAs(page, queryWrapper, null, consumers); return paginateAs(page, queryWrapper, null);
} }
/** /**
@ -914,12 +938,76 @@ public interface BaseMapper<T> {
* @param page 包含了页码、每页的数据量，可能包含数据总量 * @param page 包含了页码、每页的数据量，可能包含数据总量
* @param queryWrapper 条件 * @param queryWrapper 条件
* @param consumers 字段查询 * @param consumers 字段查询
* @return page 数据
*/
default Page<T> paginate(Page<T> page, QueryWrapper queryWrapper, Consumer<FieldQueryBuilder<T>>... consumers) {
return paginateAs(page, queryWrapper, null, consumers);
}
/**
* 分页查询，及其 Relation 字段内容。
*
* @param page 包含了页码、每页的数据量，可能包含数据总量
* @param queryWrapper 条件
* @return 分页数据
*/
default Page<T> paginateWithRelations(Page<T> page, QueryWrapper queryWrapper) {
return paginateWithRelationsAs(page, queryWrapper, null);
}
/**
* 分页查询，及其 Relation 字段内容。
*
* @param page 包含了页码、每页的数据量，可能包含数据总量
* @param queryWrapper 条件
* @param consumers 字段查询
* @return 分页数据 * @return 分页数据
*/ */
default Page<T> paginateWithRelations(Page<T> page, QueryWrapper queryWrapper, Consumer<FieldQueryBuilder<T>>... consumers) { default Page<T> paginateWithRelations(Page<T> page, QueryWrapper queryWrapper, Consumer<FieldQueryBuilder<T>>... consumers) {
return paginateWithRelationsAs(page, queryWrapper, null, consumers); return paginateWithRelationsAs(page, queryWrapper, null, consumers);
} }
/**
* 分页查询。
*
* @param pageNumber 当前页码
* @param pageSize 每页的数据量
* @param queryWrapper 条件
* @param asType 接收数据类型
* @return 分页数据
*/
default <R> Page<R> paginateAs(int pageNumber, int pageSize, QueryWrapper queryWrapper, Class<R> asType) {
Page<R> page = new Page<>(pageNumber, pageSize);
return MapperUtil.doPaginate(this, page, queryWrapper, asType, false);
}
/**
* 分页查询。
*
* @param pageNumber 当前页码
* @param pageSize 每页的数据量
* @param totalRow 数据总量
* @param queryWrapper 条件
* @param asType 接收数据类型
* @return 分页数据
*/
default <R> Page<R> paginateAs(int pageNumber, int pageSize, int totalRow, QueryWrapper queryWrapper, Class<R> asType) {
Page<R> page = new Page<>(pageNumber, pageSize, totalRow);
return MapperUtil.doPaginate(this, page, queryWrapper, asType, false);
}
/**
* 分页查询。
*
* @param page 包含了页码、每页的数据量，可能包含数据总量
* @param queryWrapper 条件
* @param asType 接收数据类型
* @return 分页数据
*/
default <R> Page<R> paginateAs(Page<R> page, QueryWrapper queryWrapper, Class<R> asType) {
return MapperUtil.doPaginate(this, page, queryWrapper, asType, false);
}
/** /**
* 分页查询。 * 分页查询。
* *
@ -934,7 +1022,48 @@ public interface BaseMapper<T> {
} }
/** /**
* 分页查询。 * 分页查询，及其 Relation 字段内容。
*
* @param pageNumber 当前页码
* @param pageSize 每页的数据量
* @param queryWrapper 条件
* @param asType 接收数据类型
* @return 分页数据
*/
default <R> Page<R> paginateWithRelationsAs(int pageNumber, int pageSize, QueryWrapper queryWrapper, Class<R> asType) {
Page<R> page = new Page<>(pageNumber, pageSize);
return MapperUtil.doPaginate(this, page, queryWrapper, asType, true);
}
/**
* 分页查询，及其 Relation 字段内容。
*
* @param pageNumber 当前页码
* @param pageSize 每页的数据量
* @param totalRow 数据总量
* @param queryWrapper 条件
* @param asType 接收数据类型
* @return 分页数据
*/
default <R> Page<R> paginateWithRelationsAs(int pageNumber, int pageSize, int totalRow, QueryWrapper queryWrapper, Class<R> asType) {
Page<R> page = new Page<>(pageNumber, pageSize, totalRow);
return MapperUtil.doPaginate(this, page, queryWrapper, asType, true);
}
/**
* 分页查询，及其 Relation 字段内容。
*
* @param page 包含了页码、每页的数据量，可能包含数据总量
* @param queryWrapper 条件
* @param asType 接收数据类型
* @return 分页数据
*/
default <R> Page<R> paginateWithRelationsAs(Page<R> page, QueryWrapper queryWrapper, Class<R> asType) {
return MapperUtil.doPaginate(this, page, queryWrapper, asType, true);
}
/**
* 分页查询，及其 Relation 字段内容。
* *
* @param page 包含了页码、每页的数据量，可能包含数据总量 * @param page 包含了页码、每页的数据量，可能包含数据总量
* @param queryWrapper 条件 * @param queryWrapper 条件

3
mybatis-flex-core/src/main/java/com/mybatisflex/core/dialect/impl/OracleDialect.java
View File

@ -22,6 +22,7 @@ import com.mybatisflex.core.row.Row;
import com.mybatisflex.core.row.RowCPI; import com.mybatisflex.core.row.RowCPI;
import com.mybatisflex.core.table.TableInfo; import com.mybatisflex.core.table.TableInfo;
import com.mybatisflex.core.util.CollectionUtil; import com.mybatisflex.core.util.CollectionUtil;
import com.mybatisflex.core.util.SqlUtil;
import com.mybatisflex.core.util.StringUtil; import com.mybatisflex.core.util.StringUtil;
import java.util.List; import java.util.List;
@ -167,7 +168,7 @@ public class OracleDialect extends CommonsDialectImpl {
String tableNameWrap = StringUtil.isNotBlank(schema) String tableNameWrap = StringUtil.isNotBlank(schema)
? wrap(getRealSchema(schema)) + REFERENCE + wrap(getRealTable(tableName)) ? wrap(getRealSchema(schema)) + REFERENCE + wrap(getRealTable(tableName))
: wrap(getRealTable(tableName)); : wrap(getRealTable(tableName));
String questionStrings = buildQuestion(attrs.size()); String questionStrings = SqlUtil.buildSqlParamPlaceholder(attrs.size());
for (int i = 0; i < rows.size(); i++) { for (int i = 0; i < rows.size(); i++) {
sql.append(INTO).append(tableNameWrap); sql.append(INTO).append(tableNameWrap);

20
mybatis-flex-core/src/main/java/com/mybatisflex/core/relation/package-info.java Normal file
View File

@ -0,0 +1,20 @@
/*
* Copyright (c) 2022-2023, Mybatis-Flex (fuhai999@gmail.com).
* <p>
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
* <p>
* http://www.apache.org/licenses/LICENSE-2.0
* <p>
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
/**
* 多表关联注解实现。
*/
package com.mybatisflex.core.relation;