feat: 添加重载方法。

This commit is contained in:
Suomm 2023-07-08 22:59:44 +08:00
parent 184cc23355
commit 5017ce7643

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
* 有多出了实体类本身的字段内容可以转换为 dtovo 等场景 * 有多出了实体类本身的字段内容可以转换为 dtovo 等场景
* *
* @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 条件