将对象保存到多个会话中的Hibernate方法

Question

将对象保存到多个会话中的Hibernate方法

14

我正在尝试使用Hibernate向多个数据库进行写操作。我已经将读写和写操作封装在一个单独的会话对象中。但是，当我尝试保存时，会出现许多错误，提示对象已与另一个会话相关联："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);
       }
}

我已尝试驱逐对象并刷新；但是，这会导致“行已被另一个事务更新或删除”的问题...即使两个会话指向不同的数据库。

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的复制功能。但是，即使没有错误也无法成功保存。

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

- D_C

映射对象关联的集合的级联策略是否配置不当是可能的吗？ - Marinos An

3个回答

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();
        }
    }

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

- hemant1900

1

是的，

问题就是它告诉你的那样。成功实现的方法是将其视为两个不同的事物，并进行两个不同的提交。

创建一个复合 Dao。在其中你有一个

Collection<Dao>

这个集合中的每个 Dao 实际上只是您现有代码的一个实例，为两个不同的数据源进行配置。然后，在您的组合 Dao 中，当您调用保存时，实际上会同时独立地保存到两个数据源。

你说过它是尽力而为的。那很容易。使用 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，以便哈希/相等不同，但我认为不需要这样做。

- Christian Bongiorno

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Vlad Mihalcea · Accepted Answer

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

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

也可以尝试显式设置事务边界：

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;
        }
   }
}