psycopg2transaction 0.1.0

psycopg2 integration with transaction

This package provides two-phase commit integration between psycopg2 and the transaction package.

Sample usage:

>>> import psycopg2, psycopg2transaction, transaction

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

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

>>> transaction.commit()

This is just an example. The connection might come from a pool or otherwise already exist, as long as it is in a suitable state to start a distributed transaction.

Similarly, the transaction may come from the thread-local transaction manager, as shown above, or from an application-managed transaction manager.

The critical line in the example above is:

>>> psycopg2transaction.join(conn, trans)

The work done in the connection is committed by calling the transaction’s commit method, typically by calling commit on the transaction’s manager, as shown above.

If you use a thread-local transaction manager (as in the example above), you can omit the transaction argumet to join:

>>> psycopg2transaction.join(conn)

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

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

Changes

0.1.0 (2017-03-18)

Initial release