时间戳

首页 > 解决方案 > Spring boot JPA 批量插入异常处理

java - Spring boot JPA 批量插入异常处理

问题描述

我正在研究一个实时用例，该用例需要使用 Spring Boot JPA 将一批消息加载到 SQL Server 表中，将所有模型对象添加到列表中，并为批量加载执行此操作repository.saveAll(list)。由于性能原因，我无法通过记录插入进行记录。我正在寻找以下选项。

有什么方法可以读取导致错误的消息并继续将其他记录插入表中。我必须将此错误消息存储在某处，并且不应传递给下游应用程序。

标签： javaspring-boothibernatejpaspring-data-jpa

解决方案

Spring data JPA的saveAll方法，其实就是将记录列表一一保存：

/*
 * (non-Javadoc)
 * @see org.springframework.data.jpa.repository.JpaRepository#save(java.lang.Iterable)
 */
@Transactional
@Override
public <S extends T> List<S> saveAll(Iterable<S> entities) {

    Assert.notNull(entities, "Entities must not be null!");

    List<S> result = new ArrayList<S>();

    for (S entity : entities) {
        result.add(save(entity));
    }

    return result;
}

尽管如此，自己处理消息循环还是让 Spring data JPA 来完成工作之间的区别：saveAll使用属性spring.jpa.properties.hibernate.jdbc.batch_size=4来确定是否激活了批处理，并且根据批处理的大小，插入可以执行得更好。

我认为您只需要自己循环消息并自己捕获错误：

for(EnitityType entity: list){
  try{
    repository.save(entity);
  } catch (Exception e){
    // Do what you want
  }
}

推荐阅读