Hibernate：插入来自不同线程的具有唯一约束的对象

Question

我有以下问题。我有 10 个线程创建插入数据库的对象。每个线程都有一个 ThreadLocal 和它自己的会话。所有对象在创建后都插入在一起。这些对象有一个标记为唯一的列。但是，我有一个问题，两个不同的线程可能会创建同一个对象。这种行为是需要的，但我不知道如何将它们插入到我的数据库中。

目前，每个线程都会查询所有插入数据库的对象，检查查询的对象是否存在，并将不存在的对象插入数据库。但是，由于在所有对象的查询中都可能不存在该对象，因此当我插入对象并且它们已经被另一个线程添加时，我会得到一个 ConstraintViolationException。但是，为每个对象执行数据库（或缓存）查询的性能会很差，因为我们试图在每个线程和分钟内添加 1000 个对象。如果我在每次插入后尝试刷新数据库，则会收到以下错误：Deadlock found when trying to get lock;尝试重启事务

所以我的问题是：我怎样才能插入同时具有来自不同线程的唯一约束的对象。

//编辑：目前我正在使用 Hibernate 和 MYSQL InnoDB

//Edit2：最后是我用来写单项的代码。

public class ItemWriterRunnable implements Callable<Object> {

    private final ThreadLocal<Session> session = new ThreadLocal<Session>();

    private Item item;

    public ItemWriterRunnable(Item item) {
        super();
        this.item= item;
    }

    protected Session currentSession() {
        Session s = this.session.get();
        // Open a new Session, if this thread has none yet
        if (s == null || !s.isOpen()) {
            s = HibernateUtils.getSessionFactory().openSession();
            // Store it in the ThreadLocal variable
            this.session.set(s);
        }
        return s;
    }

    @Override
    public Object call() throws Exception {
        Session currentSession = currentSession();
        try {
            currentSession.beginTransaction();
            currentSession.save(this.item);
            currentSession.getTransaction().commit();
        } catch (ConstraintViolationException e) {
            currentSession.getTransaction().rollback();
        } catch (RuntimeException e) {
            currentSession.getTransaction().rollback();
        } finally {
            currentSession.close();
            currentSession = null;
            this.session.remove();
        }
        return null;
    }
}

最好的问候， 安德烈

Answer 1

如果您在一个线程中写入多个对象，其中一个因为重复而失败，那么您必须确定哪个是重复的，将其从集合中删除，然后重试将其写入数据库（随着另一个失败的变化）。这需要很多时间。或者，您可以在写入集合之前阅读数据库以查看是否有任何重复项，并在写入之前删除重复项。如果这种读/检查/写模式不包含在同步块中，则它是有缺陷的，因为其他线程可能会在步骤之间写入重复项。修复此问题所需的同步将在每次写入时停止您的服务器，暂停所有现有线程，可能会损害性能。

相反，为每个对象生成一个线程，并在该线程中写入对象（不进行读取/检查）。大多数对象将毫无问题地写入，因为大多数对象都没有重复（假设，但它可能是正确的）。重复的对象将失败并出现异常，此时您可以终止该线程，因为相关工作已经完成。