Skip to content
5 changes: 5 additions & 0 deletions row_query/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -26,12 +26,14 @@
QueryNotFoundError,
RegistryError,
RowQueryError,
SQLSanitizationError,
StrictModeViolation,
TransactionError,
TransactionStateError,
)
from row_query.core.migration import MigrationInfo, MigrationManager
from row_query.core.registry import SQLRegistry
from row_query.core.sanitizer import SQLSanitizer
from row_query.core.transaction import AsyncTransactionManager, TransactionManager
from row_query.mapping.model import ModelMapper

Expand All @@ -45,6 +47,8 @@
"AsyncEngine",
# Registry
"SQLRegistry",
# Sanitizer
"SQLSanitizer",
# Transaction
"TransactionManager",
"AsyncTransactionManager",
Expand All @@ -63,6 +67,7 @@
"ExecutionError",
"MultipleRowsError",
"ParameterBindingError",
"SQLSanitizationError",
"MappingError",
"ColumnMismatchError",
"StrictModeViolation",
Expand Down
4 changes: 2 additions & 2 deletions row_query/adapters/sqlite.py
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ def execute(
params: dict[str, Any] | None = None,
) -> sqlite3.Cursor:
"""Execute SQL and return a cursor."""
return connection.execute(sql, params or {})
return connection.execute(sql, params if params is not None else {})


class SqliteAsyncAdapter:
Expand Down Expand Up @@ -95,4 +95,4 @@ async def execute_async(
params: dict[str, Any] | None = None,
) -> Any:
"""Execute SQL asynchronously and return a cursor."""
return await connection.execute(sql, params or {})
return await connection.execute(sql, params if params is not None else {})
Loading