Spring Boot JPA批处理插入异常处理

如何解决Spring Boot JPA批处理插入异常处理

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

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

解决方法

Spring数据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数据JPA来完成工作之间没有任何区别。

我认为您只需要自己循环查看消息并捕获错误即可。

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