psycopg2transaction 0.1.1

psycopg2与事务的集成

本软件包提供了psycopg2和transaction包之间的两阶段提交集成。

示例用法

>>> import psycopg2, psycopg2transaction, transaction

>>> conn = psycopg2.connect(mydsn)
>>> trans = transaction.get()
>>> psycopg2transaction.join(conn, trans)

>>> ... do things with the psycopg2 connection

>>> transaction.commit()

这只是一个示例。连接可能来自池或其他方式已经存在，只要它处于可以开始分布式事务的状态。

同样，事务可能来自如上所示的线程局部事务管理器，或者来自应用程序管理的事务管理器。

示例中的关键行是

>>> psycopg2transaction.join(conn, trans)

通过调用事务的commit方法提交连接中的工作，通常是通过调用事务管理器的commit，如上所示。

如果您使用线程局部事务管理器（如示例中所示），则可以省略join的transaction参数

>>> psycopg2transaction.join(conn)

>>> dsn = 'dbname=test'
>>> conn = psycopg2transaction.join(dsn)
...
>>> conn = psycopg2transaction.join(dsn)
...
>>> transaction.commit()

>>> conn = psycopg2transaction.join(dsn, notify='myjobs')

变更