testsuite.databases.pgsql.control.ConnectionWrapper Class Reference

Detailed Description

Definition at line 54 of file control.py.

Public Member Functions
	__init__ (self, connection.PgConnectionInfo conninfo)
	initialize (self, frozenset[str] cleanup_exclude_tables)
connection.PgConnectionInfo	conninfo (self)
	returns :py:class:testsuite.databases.pgsql.connection.PgConnectionInfo
psycopg2.extensions.connection	conn (self)
	:returns: :py:class:psycopg2.extensions.connection
psycopg2.extensions.cursor	cursor (self, **kwargs)
	:returns: :py:class:psycopg2.extensions.cursor
psycopg2.extensions.cursor	dict_cursor (self, **kwargs)
	Returns dictionary cursor, see psycopg2.extras.DictCursor.
None	apply_queries (self, typing.Iterable[PgQuery] queries)
	Apply queries to database.
	close (self)
	schedule_truncation (self)

Protected Member Functions
None	_try_truncate_tables (self, cursor)
None	_truncate_tables (self, cursor)

Static Protected Member Functions
None	_apply_query (cursor, PgQuery query)

Protected Attributes
bool	_initialized = False
connection.PgConnectionInfo	_conninfo = conninfo
psycopg2.extensions.connection|None	_conn = None
list[str]|None	_tables = None
None|(concurrent.futures.Future[None])	_truncate_thread = None
	_executer = concurrent.futures.ThreadPoolExecutor(max_workers=1)

Constructor & Destructor Documentation

__init__()

testsuite.databases.pgsql.control.ConnectionWrapper.__init__	(		self,
		connection.PgConnectionInfo	conninfo )

Definition at line 55 of file control.py.

Member Function Documentation

_apply_query()

None testsuite.databases.pgsql.control.ConnectionWrapper._apply_query ( cursor, PgQuery query )

staticprotected

Definition at line 154 of file control.py.

_truncate_tables()

None testsuite.databases.pgsql.control.ConnectionWrapper._truncate_tables ( self, cursor )

protected

Definition at line 147 of file control.py.

_try_truncate_tables()

None testsuite.databases.pgsql.control.ConnectionWrapper._try_truncate_tables ( self, cursor )

protected

Definition at line 136 of file control.py.

apply_queries()

None testsuite.databases.pgsql.control.ConnectionWrapper.apply_queries	(		self,
		typing.Iterable[PgQuery]	queries )

Apply queries to database.

Definition at line 112 of file control.py.

close()

testsuite.databases.pgsql.control.ConnectionWrapper.close

(

self

)

Definition at line 124 of file control.py.

conn()

psycopg2.extensions.connection testsuite.databases.pgsql.control.ConnectionWrapper.conn

(

self

)

:returns: :py:class:psycopg2.extensions.connection

Definition at line 85 of file control.py.

conninfo()

connection.PgConnectionInfo testsuite.databases.pgsql.control.ConnectionWrapper.conninfo

(

self

)

returns :py:class:testsuite.databases.pgsql.connection.PgConnectionInfo

Definition at line 78 of file control.py.

cursor()

psycopg2.extensions.cursor testsuite.databases.pgsql.control.ConnectionWrapper.cursor	(		self,
		**	kwargs )

:returns: :py:class:psycopg2.extensions.cursor

Definition at line 100 of file control.py.

dict_cursor()

psycopg2.extensions.cursor testsuite.databases.pgsql.control.ConnectionWrapper.dict_cursor	(		self,
		**	kwargs )

Returns dictionary cursor, see psycopg2.extras.DictCursor.

:returns: :py:class:psycopg2.extensions.cursor

Definition at line 104 of file control.py.

initialize()

testsuite.databases.pgsql.control.ConnectionWrapper.initialize	(		self,
		frozenset[str]	cleanup_exclude_tables )

Definition at line 63 of file control.py.

schedule_truncation()

testsuite.databases.pgsql.control.ConnectionWrapper.schedule_truncation

(

self

)

Definition at line 127 of file control.py.

Member Data Documentation

_conn

psycopg2.extensions.connection | None testsuite.databases.pgsql.control.ConnectionWrapper._conn = None

protected

Definition at line 58 of file control.py.

_conninfo

connection.PgConnectionInfo testsuite.databases.pgsql.control.ConnectionWrapper._conninfo = conninfo

protected

Definition at line 57 of file control.py.

_executer

testsuite.databases.pgsql.control.ConnectionWrapper._executer = concurrent.futures.ThreadPoolExecutor(max_workers=1)

protected

Definition at line 61 of file control.py.

_initialized

bool testsuite.databases.pgsql.control.ConnectionWrapper._initialized = False

protected

Definition at line 56 of file control.py.

_tables

list[str] | None testsuite.databases.pgsql.control.ConnectionWrapper._tables = None

protected

Definition at line 59 of file control.py.

_truncate_thread

None | (concurrent.futures.Future[None]) testsuite.databases.pgsql.control.ConnectionWrapper._truncate_thread = None

protected

Definition at line 60 of file control.py.

---

The documentation for this class was generated from the following file:

• en/testsuite/databases/pgsql/control.py