Databases

Module pglift.databases exposes the following API to manipulate PostgreSQL databases:

pglift.databases.apply(instance: PostgreSQLInstance, database: Database) → ApplyResult

Apply state described by specified interface model as a PostgreSQL database.

The instance should be running and not a standby.

pglift.databases.exists(instance: PostgreSQLInstance, name: str) → bool

Return True if named database exists in ‘instance’.

The instance should be running.

pglift.databases.ls(instance: PostgreSQLInstance, dbnames: Sequence[str] = ()) → list[Database]

List databases in instance.

Parameters:

dbnames – restrict operation on databases with a name in this list.

pglift.databases.get(instance: PostgreSQLInstance, name: str) → Database

Return the database object with specified name.

Raises:

DatabaseNotFound – if no database with specified ‘name’ exists.

pglift.databases.drop(instance: PostgreSQLInstance, database: DatabaseDropped) → None

Drop a database from a primary instance.

Raises:

DatabaseNotFound – if no database with specified ‘name’ exists.

pglift.databases.run(instance: ~pglift.models.system.PostgreSQLInstance, sql_command: str, *, dbnames: ~collections.abc.Sequence[str] = (), exclude_dbnames: ~collections.abc.Sequence[str] = (), notice_handler: ~pglift.types.NoticeHandler = <function default_notice_handler>) → dict[str, list[dict[str, Any]]]

Execute a SQL command on databases of instance.

Parameters:

• dbnames – restrict operation on databases with a name in this list.

• exclude_dbnames – exclude databases with a name in this list from the operation.

• notice_handler – a function to handle notice.

Returns:

a dict mapping database names to query results, if any.

Raises:

psycopg.ProgrammingError – in case of unprocessable query.