Hibernate将对象保存到多个会话

我试图使用hibernate写入多个数据库。 我在单个会话对象中封装了写入和读取/写入会话。 但是，当我去保存时，我收到很多错误，表明对象已经与另一个会话相关联：“非法尝试将集合与两个打开的会话相关联”

这是我的代码：

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被另一个事务更新或删除”的问题……即使两个会话都指向不同的数据库。

 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的复制function。 这也没有成功，没有错误。

有没有人成功将对象保存到两个具有相同模式的数据库中？

Answer 1

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

另一个问题是交易管理。 如果您使用线程绑定事务，那么如果要从同一个线程更新两个DataSource，则需要两个显式事务。

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

 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 2

如其他答案中所述，如果您正在使用Session那么您可能需要将两个更新分开并在两个不同的事务中。 实体的分离实例（在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的问题在于它不使用任何缓存，也不支持关联对象的级联。 您需要手动处理。

Answer 3

是啊，

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

创建一个复合道。 在它你有一个

 Collection 

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

带外你说你这是最好的努力。 所以，这很容易。 使用弹簧重试在各个dao保存方法周围创建一个切点，以便他们尝试几次。 最终放弃。

 public interface Dao { void save(T type); } 

使用applicationContext.xml创建此实例，其中每个实例指向不同的数据库。 当你在那里时，使用弹簧重试来围绕你的保存方法进行重试点切换。 转到底部以获取应用程序上下文示例。

 public class RealDao implements Dao { @Autowired private Session session; @Override public void save(T type) { // save to DB here } } 

复合材料

 public class CompositeDao implements Dao { // these instances are actually of type RealDao private Set> delegates; public CompositeDao(Dao ... daos) { this.delegates = new LinkedHashSet<>(Arrays.asList(daos)); } @Override public void save(T stuff) { for (Dao delegate : delegates) { try { delegate.save(stuff); } catch (Exception e) { // skip it. Best effort } } } } 

每个“东西”都保存在它自己的单独会话中。 由于会话在’RealDao’实例上，然后您知道，在第一次完成时它完全保存或失败。 Hibernate 可能希望你有一个不同的ID，以便hash / equals不同但我不这么认为。