通过数据库中的唯一约束进行重复检查不起作用

Question

我有一个 Spring Boot 服务，它应该在事务中将两种类型的多个实体持久化到 Oracle DB。第一个实体类型的表很大（每天 3 个 Mio。条目，分区，...），我有一个问题，我需要对重复项做出反应。我使用一些字段来创建哈希，并且我在该字段的数据库中具有唯一约束。我认为按实体保存AndFlush 并对ConstraintViolationException 做出反应是一个聪明的主意。根据保存第一个实体列表的结果，我需要创建第二个实体并保存它，但它会回滚所有内容。 我现在的问题是，如果这种方法通常是错误的，还是好的并且有一些小问题？如果它通常是错误的，那么我应该如何做这个重复检查（预先选择不是一个选项）？

这里有一些伪代码可以让你更好地理解

@Entity
public class Foo{

    public String uniqueHash;
    
    // couple of other properties that will be used to calculate the hash
}

@Entity
public class Bar{

    private List goodIds;
    private List badIds;
    
    public Bar(List goodIds, List badIds){
        this.goodIds = goodIds;
        this.badIds = badIds;
    }
}

@Repository
@Transactional(noRollbackFor = PersistenceException.class)
public interface FooRepository extends JpaRepository<Foo, String> {
  Foo saveAndFlush(Foo f) throws PersistenceException;
}

@Repository
@Transactional(noRollbackFor = PersistenceException.class)
public interface BarRepository extends JpaRepository<Bar, String> {
  Bar saveAndFlush(Bar b) throws PersistenceException;
}

SomeService

@Transactional(noRollbackFor = PersistenceException.class)
public void doSomething(List<Foo> foos){

    List<String> goodIds = new ArrayList();
    List<String> badIds = new ArrayList();
        
    for (Foo foo : foos) {
      try {     
        fooRepository.saveAndFlush(foo);
        goodIds.add(foo.getId());
      } catch (PersistenceException e) {
        if (e.getCause() instanceof ConstraintViolationException) {
          badIds.add(foo.getId);
        } else {
          throw e;
        }
      }
    }
    barRepository.saveAndFlush(new Bar(goodIds, badIds));
}

Answer 1

最后，我找到了实现预期行为的方法，甚至更好的是，我能够摆脱这些“noRollBackFor”属性。我只重构了流程并尝试将所有内容保存在事务中，如果失败，则在调用方法上捕获异常，输入被“清理”并再次调用事务方法（递归）。这些重复是罕见的情况（每 10k Foo 实例发生一次），因此从性能角度来看，有这些后续事务很好。这里又是修改后的伪代码

@Entity
public class Foo{

    public String uniqueHash;
    
    // couple of other properties that will be used to calculate the hash
}

@Entity
public class Bar{

    private List goodIds;
    private List badIds;
    
    public Bar(List goodIds, List badIds){
        this.goodIds = goodIds;
        this.badIds = badIds;
    }
    
    public List getGoodIds(){
      return goodIds;
    }
    
    public List getBadIds(){
      return badIds;
    }
}

@Repository
public interface FooRepository extends JpaRepository<Foo, String> {
}

@Repository
public interface BarRepository extends JpaRepository<Bar, String> {
}

public class FooException extends RuntimeException {

  private final Foo foo;

  public FooException(String message, Foo foo) {
    super(message);
    this.foo = foo;
  }
  
  public getFoo(){
  return foo;
  }
}

SomeService

public void doSomething(List<Foo> foos, Bar bar){
        try{
        doSomethingTransactional(foos,bar);
        }
        catch (FooException e) {           
          bar.getBadIds().add(e.getFoo().getId());
          foos.remove(foo);
          doSomething(foos, bar);
        }
}


@Transactional
public void doSomethingTransactional(List<Foo> foos, Bar bar){
        
    for (Foo foo : foos) {
      try {     
        fooRepository.saveAndFlush(foo);
        bar.getGoodIds.add(foo.getId());
      } catch(DataAccessException e) {
        if (e.getCause() instanceof ConstraintViolationException 
        && ((ConstraintViolationException) e.getCause()).getConstraintName().contains("Some DB Message")) {
          throw new FooException("Foo already exists", foo);
        } else {
          throw e;
        }
      }
    }
    barRepository.saveAndFlush(bar);
}

Answer 2

您也许可以使用自定义 @SQLInsert 来为此目的使用 Oracle 的 MERGE 语句。另见https://stackoverflow.com/a/64764412/412446