core.db_manager

source

BaseDBManager

class BaseDBManager()

Base class for database managers

SyncDBManager(BaseDBManager)

class SyncDBManager(
  username: str,
  password: str,
  host: str,
  port: int,
  database: str,
  drivername: str,
  schema: Optional[str] = None,
)

Class for managing a database connection through a standard database engine. Uses the parameters to build a connection URL.

Methods

execute_and_fetch(stmnt: Any)

Execute a query (stmnt) using the specified connection and return all results

execute(stmnt: Any)`

Execute a query (stmnt) using the specified connection

list_tables()

Get the table names using the specified connection

TrinoDBManager(BaseDBManager)

class TrinoDBManager(
  username: str,
  host: str,
  port: int,
  catalog: str,
  password: Optional[str] = None,
  drivername: Optional[str] = None,
  schema: Optional[str] = None,
  database: Optional[str] = None,
)

Class for managing a database connection through Trino. Uses the parameters to build a connection URL.

Methods

execute_and_fetch(stmnt: Any)

Execute a query (stmnt) using the specified connection and return all results

execute(stmnt: Any)`

Execute a query (stmnt) using the specified connection

list_tables()

Get the table names using the specified connection

Relationships

imported by execute_query

imported by query_solvers

imported by setting_database