如何使用SQLAlchemy处理两阶段提交

我正在尝试使用SQLalchemy 0.6.8与Postgresql 8.3.4进行两阶段提交，但我认为我错过了一些东西......
工作流程像这样：如何使用SQLAlchemy处理两阶段提交

session = sessionmaker(engine)(autocommit=True) 
tx = session.connection().begin_twophase(xid) # Doesn't issue any SQL 
session.begin() 
session.add(obj1) 
session.flush() 
tx.prepare()

从另一个会话

session = sessionmaker(engine)(autocommit=True) 
session.connection().commit_prepared(xid, recover=True) # recover=True because otherwise it complains that you can't issue a COMMIT PREPARED from inside a transaction

这不会引发任何错误，但不会写什么表要么... O_O 我缺少什么

呢？

我试过在prepare()之后甚至封锁了应用程序，并从pgadmin发出了COMMIT PREPARED 'xid'，但仍然没有任何内容被写入。

来源

2012-01-27 Joril

如何两相会话应该

session = sessionmaker(engine)(twophase=True) session.add(obj1) session.prepare() # Find transaction id for k, v in s.transaction._connections.iteritems(): if isinstance(k, Connection): return v[1].xid

然后从另一个会话中工作，如果你正在冲洗和autocommitting？此外，会话在内部使用交易。你使用两个不同的抽象层次？ – 2012-01-27 18:02:08

如果我禁用自动提交，对connection（）的调用发出“BEGIN（隐式）”，然后begin_twophase提出“当事务已经在进行时无法启动两阶段事务。”...我会尝试跳过冲洗虽然 – Joril 2012-01-30 09:25:25

跳过刷新不会改变任何东西:(我应该使用sessionmaker（twophase = True）吗？ – Joril 2012-01-30 09:49:17

我设法得到它的工作，方法如下：

session = sessionmaker(engine)(twophase=True) 
session.connection().commit_prepared(xid, recover=True)

来源

2012-02-15 10:26:17 Joril

如何使用SQLAlchemy处理两阶段提交

回答

相关问题