SpringBoot2 Jpa 批量刪除功能的實(shí)現(xiàn)

更新時(shí)間：2021年01月29日 15:47:53 作者：易水墨龍吟

這篇文章主要介紹了SpringBoot2 Jpa 批量刪除功能的實(shí)現(xiàn)，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧

前臺(tái)處理

首先前臺(tái)先要獲取所有的要?jiǎng)h除數(shù)據(jù)的ID，并將ID拼接成字符串例如： 2,3,4,5，然后通過(guò)GET請(qǐng)求返送到后臺(tái)。

后臺(tái)處理

控制器接收

/**
 * @function 批量刪除
 * @param stu_id
 * @return
*/
@GetMapping("/del_stu")
@ResponseBody
public Msg batch_del_stu(@RequestParam("stu_id") String stu_id){
 // 接收包含stuId的字符串，并將它分割成字符串?dāng)?shù)組
 String[] stuList = stu_id.split(",");
 // 將字符串?dāng)?shù)組轉(zhuǎn)為L(zhǎng)ist<Intger> 類(lèi)型
 List<Integer> LString = new ArrayList<Integer>();
 for(String str : stuList){
  LString.add(new Integer(str));
 }
 // 調(diào)用service層的批量刪除函數(shù)
 studentsService.deleteBatch(LString);
 return Msg.success().add("數(shù)組", LString);
}

service層

@Override
 public void deleteBatch(List<Integer> stuList) {
  // 第一種批量刪除方法，是通過(guò)spring data中繼承JpaRepository接口后，通過(guò)關(guān)鍵字拼接的方法進(jìn)行刪除，刪除時(shí)候是通過(guò)ID一條一條刪除的
//  studentsRepository.deleteStudentsByStuIdIn(stuList);
  // 第二種批量刪除方法， 是通過(guò)自定義JPQL語(yǔ)句進(jìn)行刪除，使用的是 where stuId in （）的操作
  studentsRepository.deleteBatch(stuList);
 }

Repository接口層

public interface StudentsRepository extends Repository<Students, Integer>, JpaRepository<Students, Integer> {
 /**
  * @function 自定義JPQL
  * @param ids
  */
 // 注意更新和刪除是需要加事務(wù)的， 并且要加上 @Modify的注解
 @Modifying
 @Transactional
 @Query("delete from Students s where s.stuId in (?1)")
 void deleteBatch(List<Integer> ids);
 // 這個(gè)是通過(guò)spring data拼接關(guān)鍵字進(jìn)行的操作
 void deleteStudentsByStuIdIn(List<Integer> ids);
}

附加

@Modifying注解

1、在@Query注解中編寫(xiě)JPQL實(shí)現(xiàn)DELETE和UPDATE操作時(shí)候必須加上@Modifying注解，通知Spring Data這是一個(gè)delete或者updata操作

2、 updata和delete操作需要使用事務(wù)，此時(shí)需要定義service層，在service方法上添加事務(wù)操作

3、注意JPQL不支持insert操作

@Query 如果在注解中添加 nativeQuery=true 是支持原生SQL查詢(xún)

補(bǔ)充：SpringJPA 批量刪除引起的StackOverFlow

項(xiàng)目里有一處根據(jù)Id，批量刪除一些歷史數(shù)據(jù)的代碼(xxxRepository.deleteInBatch(list);)，發(fā)現(xiàn)傳入list過(guò)大時(shí)，出現(xiàn)棧溢出(StackOverFlowError) 。

解決方法：

list切分成多份，循環(huán)批量刪除。

下面是簡(jiǎn)單的了解一下執(zhí)行流程。

deleteInBatch(Iterable<T> entities)
 
/**
 點(diǎn)進(jìn)源碼 看看。
 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;
 }
 
// 繼續(xù)跟蹤
 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
 // 最后會(huì)形成 delete from xx表 x(表別名) where x.id =? or x.id=?... 一條sql語(yǔ)句
 
  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());
 } 
}

結(jié)合日志記錄的錯(cuò)誤信息，進(jìn)入到org.hibernate.hql.internal.antlr.HqlSqlBaseWalker#logicalExpr 方法