archivebox.core.sqlite_backend.base

Module Contents

Classes

SQLiteCursorWrapper

DatabaseWrapper

Functions

_sqlite_lock_retry_timeout

_sqlite_lock_retry_interval

_format_sql

_log_locked_database

_connection_in_transaction

_recover_non_atomic_connection

_is_inside_atomic

_abort_locked_database

_retry_locked_database

API

archivebox.core.sqlite_backend.base._sqlite_lock_retry_timeout() float[source]
archivebox.core.sqlite_backend.base._sqlite_lock_retry_interval() float[source]
archivebox.core.sqlite_backend.base._format_sql(query: str, params=None) str[source]
archivebox.core.sqlite_backend.base._log_locked_database(query: str, params=None, *, attempt: int, elapsed: float, retry_interval: float) None[source]
archivebox.core.sqlite_backend.base._connection_in_transaction(connection) bool[source]
archivebox.core.sqlite_backend.base._recover_non_atomic_connection(db_wrapper, query: str) None[source]
archivebox.core.sqlite_backend.base._is_inside_atomic(db_wrapper) bool[source]
archivebox.core.sqlite_backend.base._abort_locked_database(query: str, params=None, *, elapsed: float, db_wrapper=None) None[source]
archivebox.core.sqlite_backend.base._retry_locked_database(action, query: str, params=None, *, db_wrapper=None)[source]
class archivebox.core.sqlite_backend.base.SQLiteCursorWrapper[source]

Bases: django.db.backends.sqlite3.base.SQLiteCursorWrapper

execute(query, params=None)[source]
executemany(query, param_list)[source]
class archivebox.core.sqlite_backend.base.DatabaseWrapper[source]

Bases: django.db.backends.sqlite3.base.DatabaseWrapper

create_cursor(name=None)[source]
_commit()[source]
_rollback()[source]