使用Hibernate根据唯一键查找或插入

Question

我正在尝试编写一个将基于唯一但非主键返回Hibernate对象的方法。如果实体已经存在于数据库中，我想返回它，但是如果不存在，我想创建一个新实例并在返回之前保存它。

更新：
让我澄清一下，我为此编写的应用程序基本上是输入文件的批处理程序。系统需要逐行读取文件并将记录插入数据库。文件格式基本上是我们架构中几个表的非规范化视图，因此我要做的是解析父记录，或者将其插入db中，以便获得新的合成键，或者如果它已经存在，则选择它。然后，我可以在具有外键的其他表中添加其他关联的记录。

之所以变得棘手，是因为每个文件都需要完全导入或根本不导入，即，为给定文件完成的所有插入和更新都应该是一个事务的一部分。如果只有一个进程完成所有导入，则这很容易，但是我想尽可能在​​多个服务器之间进行分解。由于这些限制，我需要能够留在一个事务中，但是要处理已经存在记录的异常。

父记录的映射类如下所示：

@Entity
public class Foo {
    @Id
    @GeneratedValue(strategy = IDENTITY)
    private int id;
    @Column(unique = true)
    private String name;
    ...
}

我最初编写此方法的尝试如下：

public Foo findOrCreate(String name) {
    Foo foo = new Foo();
    foo.setName(name);
    try {
        session.save(foo)
    } catch(ConstraintViolationException e) {
        foo = session.createCriteria(Foo.class).add(eq("name", name)).uniqueResult();
    }
    return foo;
}

问题是当我要查找的名称存在时，对uniqueResult（）的调用将引发org.hibernate.AssertionFailure异常。完整的堆栈跟踪如下：

org.hibernate.AssertionFailure: null id in com.searchdex.linktracer.domain.LinkingPage entry (don't flush the Session after an exception occurs)
    at org.hibernate.event.def.DefaultFlushEntityEventListener.checkId(DefaultFlushEntityEventListener.java:82) [hibernate-core-3.6.0.Final.jar:3.6.0.Final]
    at org.hibernate.event.def.DefaultFlushEntityEventListener.getValues(DefaultFlushEntityEventListener.java:190) [hibernate-core-3.6.0.Final.jar:3.6.0.Final]
    at org.hibernate.event.def.DefaultFlushEntityEventListener.onFlushEntity(DefaultFlushEntityEventListener.java:147) [hibernate-core-3.6.0.Final.jar:3.6.0.Final]
    at org.hibernate.event.def.AbstractFlushingEventListener.flushEntities(AbstractFlushingEventListener.java:219) [hibernate-core-3.6.0.Final.jar:3.6.0.Final]
    at org.hibernate.event.def.AbstractFlushingEventListener.flushEverythingToExecutions(AbstractFlushingEventListener.java:99) [hibernate-core-3.6.0.Final.jar:3.6.0.Final]
    at org.hibernate.event.def.DefaultAutoFlushEventListener.onAutoFlush(DefaultAutoFlushEventListener.java:58) [hibernate-core-3.6.0.Final.jar:3.6.0.Final]
    at org.hibernate.impl.SessionImpl.autoFlushIfRequired(SessionImpl.java:1185) [hibernate-core-3.6.0.Final.jar:3.6.0.Final]
    at org.hibernate.impl.SessionImpl.list(SessionImpl.java:1709) [hibernate-core-3.6.0.Final.jar:3.6.0.Final]
    at org.hibernate.impl.CriteriaImpl.list(CriteriaImpl.java:347) [hibernate-core-3.6.0.Final.jar:3.6.0.Final]
    at org.hibernate.impl.CriteriaImpl.uniqueResult(CriteriaImpl.java:369) [hibernate-core-3.6.0.Final.jar:3.6.0.Final]

有谁知道导致此异常的原因是什么？休眠是否支持实现此目的的更好方法？

让我也先解释一下为什么我先插入然后选择是否以及何时失败。这需要在分布式环境中工作，因此我无法在检查之间进行同步以查看记录是否已存在以及插入是否存在。最简单的方法是让数据库通过检查每个插入上的约束冲突来处理此同步。

Answer 1

我有类似的批处理要求，进程运行在多个JVM上。我为此采取的方法如下。这很像jtahlborn的建议。但是，正如vbence所指出的，如果您使用NESTED事务，则当您遇到约束违例异常时，您的会话将无效。相反，我使用REQUIRES_NEW，它会挂起当前事务并创建一个新的独立事务。如果新事务回滚，则不会影响原始事务。

我正在使用Spring的TransactionTemplate，但如果您不希望依赖Spring，可以肯定可以轻松地对其进行翻译。

public T findOrCreate(final T t) throws InvalidRecordException {
   // 1) look for the record
   T found = findUnique(t);
   if (found != null)
     return found;
   // 2) if not found, start a new, independent transaction
   TransactionTemplate tt = new TransactionTemplate((PlatformTransactionManager)
                                            transactionManager);
   tt.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
   try {
     found = (T)tt.execute(new TransactionCallback<T>() {
        try {
            // 3) store the record in this new transaction
            return store(t);
        } catch (ConstraintViolationException e) {
            // another thread or process created this already, possibly
            // between 1) and 2)
            status.setRollbackOnly();
            return null;
        }
     });
     // 4) if we failed to create the record in the second transaction, found will
     // still be null; however, this would happy only if another process
     // created the record. let's see what they made for us!
     if (found == null)
        found = findUnique(t);
   } catch (...) {
     // handle exceptions
   }
   return found;
}