Spring boot JPA批量插入异常处理

Question

我正在研究一个实时用例，需要使用spring boot JPA将一批消息加载到SQL server表中，将所有模型对象添加到列表中，并对批加载＜code＞存储库进行此操作。saveAll（list）。由于性能原因，我无法逐个记录插入。我正在寻找以下选项。

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

Answer 1

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
  }
}