database

tipg.pg.database

tipg.db: database events.

connection_factory

Connection creation.

__call__ async

__call__(conn: Connection)

Create connection.

__init__

__init__(schemas: list[str], tipg_schema: str, user_sql_files: list[Path] | None = None) -> None

Init.

close_db_connection async

close_db_connection(app: FastAPI) -> None

Close connection.

connect_to_db async

connect_to_db(
    app: FastAPI,
    *,
    schemas: list[str],
    tipg_schema: str = "pg_temp",
    user_sql_files: list[Path] | None = None,
    settings: PostgresSettings | None = None,
    **kwargs
) -> None

Connect.