userver: testsuite.databases.pgsql.control.PgControl Class Reference
Loading...
Searching...
No Matches
testsuite.databases.pgsql.control.PgControl Class Reference

Detailed Description

Definition at line 211 of file control.py.

Public Member Functions

None __init__ (self, connection.PgConnectionInfo pgsql_conninfo, *, int verbose, bool skip_applied_schemas)
None initialize (self)
ConnectionWrapper get_connection_cached (self, dbname)
None initialize_sharded_db (self, discover.PgShardedDatabase database)
 close (self)

Protected Member Functions

None _initialize_shard (self, discover.PgShard shard)
None _create_database (self, str dbname)
None _apply_schema (self, discover.PgShard shard)
None _run_script (self, dbname, path)
None _run_pgmigrate (self, dbname, path)
str _get_connection_uri (self, str dbname)
str _get_connection_dsn (self, str dbname)

Protected Attributes

 _conninfo = pgsql_conninfo
 _psql_helper = _get_psql_helper()
 _pgmigrate = _get_pgmigrate()
 _verbose = verbose
 _skip_applied_schemas = skip_applied_schemas

Static Protected Attributes

dict _applied_schemas [str, set[pathlib.Path]]
dict _connections [str, ConnectionWrapper]
pool _connection_pool .AutocommitConnectionPool | None
testsuite_db _applied_schema_hashes .AppliedSchemaHashes | None

Constructor & Destructor Documentation

◆ __init__()

None testsuite.databases.pgsql.control.PgControl.__init__ ( self,
connection.PgConnectionInfo pgsql_conninfo,
* ,
int verbose,
bool skip_applied_schemas )

Definition at line 217 of file control.py.

Member Function Documentation

◆ _apply_schema()

None testsuite.databases.pgsql.control.PgControl._apply_schema ( self,
discover.PgShard shard )
protected

Definition at line 294 of file control.py.

◆ _create_database()

None testsuite.databases.pgsql.control.PgControl._create_database ( self,
str dbname )
protected

Definition at line 283 of file control.py.

◆ _get_connection_dsn()

str testsuite.databases.pgsql.control.PgControl._get_connection_dsn ( self,
str dbname )
protected

Definition at line 377 of file control.py.

◆ _get_connection_uri()

str testsuite.databases.pgsql.control.PgControl._get_connection_uri ( self,
str dbname )
protected

Definition at line 374 of file control.py.

◆ _initialize_shard()

None testsuite.databases.pgsql.control.PgControl._initialize_shard ( self,
discover.PgShard shard )
protected

Definition at line 265 of file control.py.

◆ _run_pgmigrate()

None testsuite.databases.pgsql.control.PgControl._run_pgmigrate ( self,
dbname,
path )
protected

Definition at line 338 of file control.py.

◆ _run_script()

None testsuite.databases.pgsql.control.PgControl._run_script ( self,
dbname,
path )
protected

Definition at line 309 of file control.py.

◆ close()

testsuite.databases.pgsql.control.PgControl.close ( self)

Definition at line 368 of file control.py.

◆ get_connection_cached()

ConnectionWrapper testsuite.databases.pgsql.control.PgControl.get_connection_cached ( self,
dbname )

Definition at line 246 of file control.py.

◆ initialize()

None testsuite.databases.pgsql.control.PgControl.initialize ( self)

Definition at line 234 of file control.py.

◆ initialize_sharded_db()

None testsuite.databases.pgsql.control.PgControl.initialize_sharded_db ( self,
discover.PgShardedDatabase database )

Definition at line 253 of file control.py.

Member Data Documentation

◆ _applied_schema_hashes

testsuite_db testsuite.databases.pgsql.control.PgControl._applied_schema_hashes .AppliedSchemaHashes | None
staticprotected

Definition at line 215 of file control.py.

◆ _applied_schemas

dict testsuite.databases.pgsql.control.PgControl._applied_schemas [str, set[pathlib.Path]]
staticprotected

Definition at line 212 of file control.py.

◆ _connection_pool

pool testsuite.databases.pgsql.control.PgControl._connection_pool .AutocommitConnectionPool | None
staticprotected

Definition at line 214 of file control.py.

◆ _connections

dict testsuite.databases.pgsql.control.PgControl._connections [str, ConnectionWrapper]
staticprotected

Definition at line 213 of file control.py.

◆ _conninfo

testsuite.databases.pgsql.control.PgControl._conninfo = pgsql_conninfo
protected

Definition at line 225 of file control.py.

◆ _pgmigrate

testsuite.databases.pgsql.control.PgControl._pgmigrate = _get_pgmigrate()
protected

Definition at line 228 of file control.py.

◆ _psql_helper

testsuite.databases.pgsql.control.PgControl._psql_helper = _get_psql_helper()
protected

Definition at line 227 of file control.py.

◆ _skip_applied_schemas

testsuite.databases.pgsql.control.PgControl._skip_applied_schemas = skip_applied_schemas
protected

Definition at line 231 of file control.py.

◆ _verbose

testsuite.databases.pgsql.control.PgControl._verbose = verbose
protected

Definition at line 229 of file control.py.


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