Hibernate 将对象保存到多个会话

Question

我正在尝试使用休眠写入多个数据库。我已将 write 和 read/write 会话封装在单个会话对象中。但是，当我去保存时，我得到了很多错误，这些对象已经与另一个会话相关联："Illegal attempt to associate a collection with two open sessions"

这是我的代码：

public class MultiSessionObject implements Session {

       private Session writeOnlySession;
       private Session readWriteSession;

       @Override
       public void saveOrUpdate(Object arg0) throws HibernateException {
              readWriteSession.saveOrUpdate(arg0);
              writeOnlySession.saveOrUpdate(arg0);
       }
}

我试过驱逐对象并冲洗；但是，这会导致 "Row was updated or deleted by another transaction" 出现问题...即使两个会话都指向不同的数据库。

public class MultiSessionObject implements Session {

       private Session writeOnlySession;
       private Session readWriteSession;

       @Override
       public void saveOrUpdate(Object arg0) throws HibernateException {
              readWriteSession.saveOrUpdate(arg0);
              readWriteSession.flush();
              readWriteSession.evict(arg0);

              writeOnlySession.saveOrUpdate(arg0);
              writeOnlySession.flush();
              writeOnlySession.evict(arg0);
       }
}

除上述之外，我还尝试使用hibernate的复制功能。这也是没有错误的成功。

有没有人成功地将一个对象保存到两个具有相同架构的数据库中？

Answer 1

是的，

问题正是它告诉你的。成功实现这一目标的方法是将其视为具有 2 次不同提交的 2 种不同事物。

创建一个 composite 道。其中有一个

Collection<Dao>

集合中的每个 Dao 都只是为 2 个不同数据源配置的现有代码的一个实例。然后，在你的复合 dao 中，当你调用 save 时，你实际上是独立地保存到两者。

带外你说你是尽力而为。所以，这很容易。使用 spring-retry 在您的个人 dao 保存方法周围创建一个切点，以便它们尝试几次。最终放弃。

public interface Dao<T> {

    void save(T type);
}

使用 applicationContext.xml 创建此实例的新实例，其中每个实例指向不同的数据库。当你在那里时，使用 spring-retry 围绕你的保存方法播放重试切入点。转到应用程序上下文示例的底部。

public class RealDao<T> implements Dao<T> {

    @Autowired
    private Session session;

    @Override
    public void save(T type) {
        // save to DB here
    }
}

复合

public class CompositeDao<T> implements Dao<T> {

    // these instances are actually of type RealDao<T>
    private Set<Dao<T>> delegates;

    public CompositeDao(Dao ... daos) {
        this.delegates = new LinkedHashSet<>(Arrays.asList(daos));

    }

    @Override
    public void save(T stuff) {
        for (Dao<T> delegate : delegates) {
            try {
                delegate.save(stuff);
            } catch (Exception e) {
                // skip it. Best effort
            }
        }
    }
}

每个 'stuff' 是否保存在它自己的单独会话中。由于会话在 'RealDao' 个实例上进行，因此您知道，当第一个完成时，它已完全保存或失败。 Hibernate 可能希望你有一个不同的 ID，这样 hash/equals 就不同了，但我不这么认为。

Answer 2

saveOrUpdate 尝试将给定实体重新附加到当前运行会话，因此代理（LAZY 关联）绑定到 Hibernate 会话。尝试使用 merge instead of saveOrUpdate，因为 merge 只是将分离的实体状态复制到新检索的托管实体。这样，提供的参数永远不会附加到会话。

另一个问题是事务管理。如果你使用线程绑定事务，那么如果你想从同一个线程更新两个数据源，你需要两个显式事务。

也尝试明确设置事务边界：

public class MultiSessionObject implements Session {

   private Session writeOnlySession;
   private Session readWriteSession;

   @Override
   public void saveOrUpdate(Object arg0) throws HibernateException {

        Transaction readWriteSessionTx = null;
        try {
            readWriteSessionTx = readWriteSession.beginTransaction();
            readWriteSession.merge(arg0);
            readWriteSessionTx.commit();
        } catch (RuntimeException e) {
            if ( readWriteSessionTx != null && readWriteSessionTx.isActive() ) 
                readWriteSessionTx.rollback();
            throw e;
        }

        Transaction writeOnlySessionTx = null;
        try {
            writeOnlySessionTx = writeOnlySession.beginTransaction();
            writeOnlySession.merge(arg0);
            writeOnlySessionTx.commit();
        } catch (RuntimeException e) {
            if ( writeOnlySessionTx != null && writeOnlySessionTx.isActive() ) 
                writeOnlySessionTx.rollback();
            throw e;
        }
   }
}

Answer 3

如其他答案中所述，如果您使用的是 Session，那么您可能需要将 2 个更新分开，并放在两个不同的事务中。实体的分离实例（在 evict 之后）应该能够在第二次更新操作中重复使用。

另一种方法是像这样使用 StatelessSession（我尝试了一个简单的程序，所以必须处理交易。我假设你必须以不同的方式处理交易）

public static void main(final String[] args) throws Exception {
        final StatelessSession session1 = HibernateUtil.getReadOnlySessionFactory().openStatelessSession();
        final StatelessSession session2 = HibernateUtil.getReadWriteSessionFactory().openStatelessSession();
        try {
            Transaction transaction1 = session1.beginTransaction();
            Transaction transaction2 = session2.beginTransaction();
            ErrorLogEntity entity = (ErrorLogEntity) session1.get(ErrorLogEntity.class, 1);
            entity.setArea("test");
            session1.update(entity);
            session2.update(entity);
            transaction1.commit();
            transaction2.commit();
            System.out.println("Entry details: " + entity);
        } finally {
            session1.close();
            session2.close();
            HibernateUtil.getReadOnlySessionFactory().close();
            HibernateUtil.getReadWriteSessionFactory().close();
        }
    }

StatelessSession的问题在于它不使用任何缓存，也不支持关联对象的级联。您需要手动处理。

Hibernate 将对象保存到多个会话

Hibernate Save Object to Multiple Sessions

java

orm

session

hibernate

transactions