12.原创 Mybatis-Plus入门系列(12)- MybatisPlus之IService接口CRUD详解
12.原创 Mybatis-Plus入门系列(12)- MybatisPlus之IService接口CRUD详解
简介
Plust提供了一个顶级IService ，封装了很多CRUD操作，实际使用时，推荐直接在service层调用，Mapper：
- 采用 get 查询单行 remove 删除 list 查询集合 page 分页 前缀命名方式区分 Mapper 层避免混淆，
- 泛型 T 为任意实体对象
- 建议如果存在自定义通用 Service 方法的可能，请创建自己的 IBaseService 继承 Mybatis-Plus 提供的基类
- 对象 Wrapper 为 条件构造器
插入
Save
- boolean save(T entity);
插入单条数据，实际调用的是BaseMapper的insert；
/**
* 插入一条记录（选择字段，策略插入）
*
* @param entity 实体对象
*/
default boolean save(T entity) {
return SqlHelper.retBool(getBaseMapper().insert(entity));
}- boolean saveBatch(Collection entityList);
批量插入，默认批次提交数量1000条，实际调动的是Mybatis 自带批量保存，通过sqlSession执行。
/**
* 插入（批量）
*
* @param entityList 实体对象集合
*/
@Transactional(rollbackFor = Exception.class)
default boolean saveBatch(Collection<T> entityList) {
return saveBatch(entityList, DEFAULT_BATCH_SIZE);
}- boolean saveBatch(Collection entityList, int batchSize);
批量插入，指定插入批次数量
/**
* 插入（批量）
*
* @param entityList 实体对象集合
* @param batchSize 插入批次数量
*/
boolean saveBatch(Collection<T> entityList, int batchSize);SaveOrUpdate
- boolean saveOrUpdate(T entity);
保存或更新，当实体类存在主键值，并且在数据库中存在此数据时，会更新数据。否则才会插入数据。
public boolean saveOrUpdate(T entity) {
if (null == entity) {
return false;
} else {
TableInfo tableInfo = TableInfoHelper.getTableInfo(this.entityClass);
Assert.notNull(tableInfo, "error: can not execute. because can not find cache of TableInfo for entity!", new Object[0]);
String keyProperty = tableInfo.getKeyProperty();
Assert.notEmpty(keyProperty, "error: can not execute. because can not find column for id from entity!", new Object[0]);
Object idVal = ReflectionKit.getFieldValue(entity, tableInfo.getKeyProperty());
return !StringUtils.checkValNull(idVal) && !Objects.isNull(this.getById((Serializable)idVal)) ? this.updateById(entity) : this.save(entity);
}
}- boolean saveOrUpdate(T entity, Wrapper updateWrapper);
根据updateWrapper尝试更新，否继续执行saveOrUpdate(T)方法；
default boolean saveOrUpdate(T entity, Wrapper<T> updateWrapper) {
return this.update(entity, updateWrapper) || this.saveOrUpdate(entity);
}- boolean saveOrUpdateBatch(Collection entityList);
批量删除或者更新；默认批次提交数量1000条
@Transactional(rollbackFor = Exception.class)
@Override
public boolean saveOrUpdateBatch(Collection<T> entityList, int batchSize) {
TableInfo tableInfo = TableInfoHelper.getTableInfo(entityClass);
Assert.notNull(tableInfo, "error: can not execute. because can not find cache of TableInfo for entity!");
String keyProperty = tableInfo.getKeyProperty();
Assert.notEmpty(keyProperty, "error: can not execute. because can not find column for id from entity!");
return SqlHelper.saveOrUpdateBatch(this.entityClass, this.mapperClass, this.log, entityList, batchSize, (sqlSession, entity) -> {
Object idVal = ReflectionKit.getFieldValue(entity, keyProperty);
return StringUtils.checkValNull(idVal)
|| CollectionUtils.isEmpty(sqlSession.selectList(getSqlStatement(SqlMethod.SELECT_BY_ID), entity));
}, (sqlSession, entity) -> {
MapperMethod.ParamMap<T> param = new MapperMethod.ParamMap<>();
param.put(Constants.ENTITY, entity);
sqlSession.update(getSqlStatement(SqlMethod.UPDATE_BY_ID), param);
});
}- boolean saveOrUpdateBatch(Collection entityList, int batchSize);
批量删除或者更新；
Remove
实际调用的是BaseMapper中的相关delete方法。
- boolean remove(Wrapper queryWrapper);
根据 entity 条件，删除记录 - boolean removeById(Serializable id);
根据 ID 删除 - boolean removeByMap(Map<String, Object> columnMap);
根据 columnMap 条件，删除记录 - boolean removeByIds(Collection<? extends Serializable> idList);
删除（根据ID 批量删除）
Update
实际调用的是BaseMapper中的相关update方法。
- boolean update(Wrapper updateWrapper);
根据 UpdateWrapper 条件，更新记录 需要设置sqlset - boolean update(T entity, Wrapper updateWrapper );
根据 whereEntity 条件，更新记录 - boolean updateById(T entity);
根据 ID 选择修改 - boolean updateBatchById(Collection entityList);
根据ID 批量更新 - boolean updateBatchById(Collection entityList, int batchSize);
根据ID 批量更新
Select
Get
- T getById(Serializable id);
根据 ID 查询 - T getOne(Wrapper queryWrapper);
根据 Wrapper，查询一条记录。结果集，如果是多个会抛出异常，随机取一条加上限制条件 wrapper.last("LIMIT 1") - T getOne(Wrapper queryWrapper, boolean throwEx);
根据 Wrapper，查询一条记录,多个结果集时是否抛出异常 - Map<String, Object> getMap(Wrapper queryWrapper);
根据 Wrapper，查询一条记录，返回Map<String, Object>对象 - V getObj(Wrapper queryWrapper, Function<? super Object, V> mapper);
根据 Wrapper，查询一条记录
list
// 查询所有
List<T> list();
// 查询列表
List<T> list(Wrapper<T> queryWrapper);
// 查询（根据ID 批量查询）
Collection<T> listByIds(Collection<? extends Serializable> idList);
// 查询（根据 columnMap 条件）
Collection<T> listByMap(Map<String, Object> columnMap);
// 查询所有列表
List<Map<String, Object>> listMaps();
// 查询列表
List<Map<String, Object>> listMaps(Wrapper<T> queryWrapper);
// 查询全部记录
List<Object> listObjs();
// 查询全部记录
<V> List<V> listObjs(Function<? super Object, V> mapper);
// 根据 Wrapper 条件，查询全部记录
List<Object> listObjs(Wrapper<T> queryWrapper);
// 根据 Wrapper 条件，查询全部记录
<V> List<V> listObjs(Wrapper<T> queryWrapper, Function<? super Object, V> mapper);Page
// 无条件分页查询
IPage<T> page(IPage<T> page);
// 条件分页查询
IPage<T> page(IPage<T> page, Wrapper<T> queryWrapper);
// 无条件分页查询
IPage<Map<String, Object>> pageMaps(IPage<T> page);
// 条件分页查询
IPage<Map<String, Object>> pageMaps(IPage<T> page, Wrapper<T> queryWrapper);Count
// 查询总记录数
int count();
// 根据 Wrapper 条件，查询总记录数
int count(Wrapper<T> queryWrapper);问题
批量插入时，并不是很快。。。。
测试：
List<OrderTbl> list = new ArrayList<>();
for (int i = 0; i < 10000; i++) {
OrderTbl orderTbl1 = new OrderTbl().setMoney(100).setUserId("123").setCommodityCode("PHONE");
list.add(orderTbl1);
}
long timeMillis = System.currentTimeMillis();
boolean b = orderTblService.saveBatch(list);
System.err.println("耗时===》" + (System.currentTimeMillis() - timeMillis));- saveBatch单条插入1W条数据，一次：3417ms. 二次：3276ms. 三次：3438ms
- 数据库连接添加&rewriteBatchedStatements=true，单条插入1W条数据，一次：2098ms. 二次：2126ms. 三次：2290ms
来源：https://yunyanchengyu.blog.csdn.net/article/details/115349242