feat(db): update docstrings

This commit is contained in:
psychedelicious 2023-12-12 13:35:46 +11:00
parent 55b0c7cdc9
commit 18ba7feca1
2 changed files with 47 additions and 11 deletions

View File

@ -22,7 +22,12 @@ class MigrationVersionError(ValueError):
class MigrationDependency: class MigrationDependency:
"""Represents a dependency for a migration.""" """
Represents a dependency for a migration.
:param name: The name of the dependency
:param dependency_type: The type of the dependency (e.g. str, SomeClass, etc.)
"""
def __init__( def __init__(
self, self,
@ -55,26 +60,48 @@ class Migration(BaseModel):
Migration callbacks will be provided an open cursor to the database. They should not commit their Migration callbacks will be provided an open cursor to the database. They should not commit their
transaction; this is handled by the migrator. transaction; this is handled by the migrator.
If a migration needs an additional dependency, it must be provided with :meth:`provide_dependency`
before the migration is run.
Example Usage: Example Usage:
```py ```py
# Define the migrate callback # Define the migrate callback. The dependency may be accessed by name in the kwargs.
def migrate_callback(cursor: sqlite3.Cursor, **kwargs) -> None: def migrate_callback(cursor: sqlite3.Cursor, **kwargs) -> None:
some_dependency = kwargs["some_dependency"] # Execute SQL using the cursor, taking care to *not commit* a transaction
cursor.execute('ALTER TABLE bananas ADD COLUMN with_sushi BOOLEAN DEFAULT FALSE;')
... ...
# Instantiate the migration, declaring dependencies # Instantiate the migration
migration = Migration( migration = Migration(
from_version=0, from_version=0,
to_version=1, to_version=1,
migrate_callback=migrate_callback, migrate_callback=migrate_callback,
dependencies={"some_dependency": MigrationDependency(name="some_dependency", dependency_type=SomeType)}, )
```
If a migration needs an additional dependency, it must be provided with :meth:`provide_dependency`
before the migration is run. The migrator provides dependencies to the migrate callback,
raising an error if a dependency is missing or was provided the wrong type.
Example Usage:
```py
# Create a migration dependency. This migration needs access the image files service, so we set the type to the ABC of that service.
image_files_dependency = MigrationDependency(name="image_files", dependency_type=ImageFileStorageBase)
# Define the migrate callback. The dependency may be accessed by name in the kwargs. The migrator will ensure that the dependency is of the required type.
def migrate_callback(cursor: sqlite3.Cursor, **kwargs) -> None:
image_files = kwargs[image_files_dependency.name]
# Do something with image_files
...
# Instantiate the migration, including the dependency.
migration = Migration(
from_version=0,
to_version=1,
migrate_callback=migrate_callback,
dependencies={image_files_dependency.name: image_files_dependency},
) )
# Register the dependency before running the migration # Provide the dependency before registering the migration.
migration.provide_dependency(name="some_dependency", value=some_value) # (DiskImageFileStorage is an implementation of ImageFileStorageBase)
migration.provide_dependency(name="image_files", value=DiskImageFileStorage())
``` ```
""" """

View File

@ -10,11 +10,20 @@ class SQLiteMigrator:
""" """
Manages migrations for a SQLite database. Manages migrations for a SQLite database.
:param db: The instanceof :class:`SqliteDatabase` to migrate. :param db: The instance of :class:`SqliteDatabase` to migrate.
Migrations should be registered with :meth:`register_migration`. Migrations should be registered with :meth:`register_migration`.
Each migration is run in a transaction. If a migration fails, the transaction is rolled back. Each migration is run in a transaction. If a migration fails, the transaction is rolled back.
Example Usage:
```py
db = SqliteDatabase(db_path="my_db.db", logger=logger)
migrator = SQLiteMigrator(db=db)
migrator.register_migration(migration_1)
migrator.register_migration(migration_2)
migrator.run_migrations()
```
""" """
backup_path: Optional[Path] = None backup_path: Optional[Path] = None