ace.database

ace.database.connection

class ace.database.connection.ConnectionManager[source]

Bases: object

__init__()[source]
make_connection() pyodbc.Connection | None[source]
fetchone()[source]
fetchall()[source]
execute(sql_query, *params)[source]
close()[source]
set_context()[source]
class ace.database.connection.SqlServerConnection[source]

Bases: ConnectionManager

make_connection()[source]
__init__()
close()
execute(sql_query, *params)
fetchall()
fetchone()
set_context()
class ace.database.connection.SqlServerConnectionADIntegrated[source]

Bases: ConnectionManager

make_connection()[source]

Creates a SQL Server connection using Active Directory Integrated authentication. This method uses Windows/Azure AD authentication instead of SQL Server authentication. Use tcp: prefix to force TCP/IP protocol (not Named Pipes)

__init__()
close()
execute(sql_query, *params)
fetchall()
fetchone()
set_context()
ace.database.connection.get_connection_class()[source]

Factory function to get the appropriate connection class based on DBMS_TYPE and DATABASE_AUTH_METHOD.

ace.database.connection.ace_connection

alias of SqlServerConnection

ace.database.query_builder

class ace.database.query_builder.Condition(column: str, value: str | int | None, operator: str = '=')[source]

Bases: object

__init__(column: str, value: str | int | None, operator: str = '=')[source]
class ace.database.query_builder.BaseQueryBuilder(table_name: str, columns: list | str = '*')[source]

Bases: ABC

abstractmethod build_query(*args, **kwargs)[source]
__init__(table_name: str, columns: list | str = '*')[source]
class ace.database.query_builder.SelectQueryBuilder(table_name: str, columns: list | str = '*')[source]

Bases: BaseQueryBuilder

build_query(order_by: str = None, limit: int = None, offset: int = None, conditions: list[Condition] = None)[source]
__init__(table_name: str, columns: list | str = '*')

ace.database.utils

class ace.database.utils.DatabaseUtils[source]

Bases: object

A utility class for database operations.

static get_database_connection()[source]

Returns a database connection object.

class ace.database.utils.CodeUtils[source]

Bases: object

A utility class for code-related operations.

static fetchone(table, columns: list[str], conditions: list[Condition], sql_query=None)[source]
static fetchall(query, params=None)[source]

Module contents