Thread-safe connection manager for psycopg2 connections.
This package includes a managed connection for psycopg2 that provides thread-safe exclusive access to an underlying psycopg2.connection object.
This allows many threads to share the same connection instance (avoiding the TCP and process startup cost associated with establishing a new PostgreSQL connection) and ensures that threads do not release the connection with a transaction still in progress – either due to developer error, or an unhandled exception while a thread is interacting with the database.
ManagedConnection also will ensure that a connection that is closed upon entering the managed context will be opened.
Creating a Managed Connection
>>> from pgmanagedconnection import ManagedConnection >>> >>> dsn = 'postgres:///postgres' # a libpq connection string >>> manager = ManagedConnection(dsn) >>> manager <ManagedConnection: postgres:///postgres (closed)>
>>> with manager() as connection: ... cursor = connection.cursor() ... cursor.execute('SELECT 1') ... cursor.fetchone() ... connection.commit() (1,)
Dealing with Uncommitted Transactions
Leaving a transaction open when exiting the context manager will lead to a RuntimeError. This also results in any open transactions implicitly being rolled back.
>>> with manager() as connection: ... cursor = connection.cursor() ... cursor.execute('SELECT 1') Traceback (most recent call last): ... RuntimeError: Did not commit or rollback open transaction before releasing connection.
Dealing with Errors
The currently open transaction will be rolled back if an unhandled exception is encountered.
>>> import psycopg2 >>> with manager() as connection: ... cursor = connection.cursor() ... cursor.execute('SELECT 1') ... assert manager.status is psycopg2.extensions.TRANSACTION_STATUS_INTRANS ... raise NotImplementedError() Traceback (most recent call last): ... NotImplementedError >>> manager.status is psycopg2.extensions.TRANSACTION_STATUS_IDLE True
The test suite can be run with make test.
It assumes a running and accessible PostgreSQL server. The connection details are deferred to the underlying libpq implementation, and default values can be specified using libpq environment variables.
tox is also supported as a test runner (if installed.)
Testing with Docker
$ export PGPORT=5432 $ docker run -dp $PGPORT:5432 postgres $ PGUSER=postgres make test
If using boot2docker, the PGHOST environment variable will also need to be set to the virtual machine IP address.
$ PGUSER=postgres PGHOST=$(boot2docker ip) make test
|Filename, size||File type||Python version||Upload date||Hashes|
|Filename, size psycopg2-managed-connection-1.0.0.tar.gz (3.4 kB)||File type Source||Python version None||Upload date||Hashes View|
Hashes for psycopg2-managed-connection-1.0.0.tar.gz