database

tipg.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: Optional[List[Path]] = 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: Optional[List[Path]] = None,
    settings: Optional[PostgresSettings] = None,
    **kwargs
) -> None

Connect.