SpringBoot2 Jpa批量删除 SpringBoot2 Jpa 批量删除功能的实现

/**
 * @function 批量删除
 * @param stu_id
 * @return
*/
@GetMapping("/del_stu")
@ResponseBody
public Msg batch_del_stu(@RequestParam("stu_id") String stu_id){
 // 接收包含stuId的字符串，并将它分割成字符串数组
 String[] stuList = stu_id.split(",");
 // 将字符串数组转为List<Intger> 类型
 List<Integer> LString = new ArrayList<Integer>();
 for(String str : stuList){
  LString.add(new Integer(str));
 }
 // 调用service层的批量删除函数
 studentsService.deleteBatch(LString);
 return Msg.success().add("数组", LString);
}

@Override
 public void deleteBatch(List<Integer> stuList) {
  // 第一种批量删除方法，是通过spring data中继承JpaRepository接口后，通过关键字拼接的方法进行删除，删除时候是通过ID一条一条删除的
//  studentsRepository.deleteStudentsByStuIdIn(stuList);
  // 第二种批量删除方法， 是通过自定义JPQL语句进行删除，使用的是 where stuId in （）的操作
  studentsRepository.deleteBatch(stuList);
 }

public interface StudentsRepository extends Repository<Students, Integer>, JpaRepository<Students, Integer> {
 /**
  * @function 自定义JPQL
  * @param ids
  */
 // 注意更新和删除是需要加事务的， 并且要加上 @Modify的注解
 @Modifying
 @Transactional
 @Query("delete from Students s where s.stuId in (?1)")
 void deleteBatch(List<Integer> ids);
 // 这个是通过spring data拼接关键字进行的操作
 void deleteStudentsByStuIdIn(List<Integer> ids);
}

deleteInBatch(Iterable<T> entities)
 
/**
 点进源码 看看。
 org.springframework.data.jpa.repository.support.SimpleJpaRepository#deleteInBatch
*/
 @Transactional
 public void deleteInBatch(Iterable<T> entities) { 
 Assert.notNull(entities, "The given Iterable of entities not be null!"); 
 if (!entities.iterator().hasNext()) {
 return;
 }
 
// 继续跟踪
 applyAndBind(getQueryString(DELETE_ALL_QUERY_STRING, entityInformation.getEntityName()), entities, em)
 .executeUpdate();
 }
 
/**
 org.springframework.data.jpa.repository.query.QueryUtils#applyAndBind
*/
 
public static <T> Query applyAndBind(String queryString, Iterable<T> entities, EntityManager entityManager) {
 // ... 省略一些code
 // 最后会形成 delete from xx表 x(表别名) where x.id =? or x.id=?... 一条sql语句
 
  String alias = detectAlias(queryString);
 StringBuilder builder = new StringBuilder(queryString);
 builder.append(" where"); 
 int i = 0; 
 while (iterator.hasNext()) { 
 iterator.next(); 
 builder.append(String.format(" %s = ?%d", alias, ++i)); 
 if (iterator.hasNext()) {
 builder.append(" or");
 }
 }
 
 Query query = entityManager.createQuery(builder.toString()); 
 iterator = entities.iterator();
 i = 0; 
 while (iterator.hasNext()) {
 query.setParameter(++i, iterator.next());
 } 
}