from logging.config import fileConfig from alembic import context from sqlalchemy import create_engine, pool from app.config import settings from app.db import Base import app.models # noqa: F401 - registriert die Tabellen bei Base config = context.config # WICHTIG: die Datenbank-URL NICHT ueber config.set_main_option() setzen. # alembic.ini wird von configparser mit BasicInterpolation gelesen, und # der deutet jedes "%" als Variablenreferenz. Ein URL-kodiertes Passwort # (z.B. "%21" fuer "!") laesst den Aufruf mit # ValueError: invalid interpolation syntax # scheitern. Die Engine wird deshalb hier direkt gebaut. if config.config_file_name is not None: fileConfig(config.config_file_name) target_metadata = Base.metadata def run_migrations_offline() -> None: context.configure( url=settings.database_url, target_metadata=target_metadata, literal_binds=True, dialect_opts={"paramstyle": "named"}, ) with context.begin_transaction(): context.run_migrations() def run_migrations_online() -> None: connectable = create_engine(settings.database_url, poolclass=pool.NullPool) with connectable.connect() as connection: context.configure( connection=connection, target_metadata=target_metadata, compare_type=True, ) with context.begin_transaction(): context.run_migrations() connectable.dispose() if context.is_offline_mode(): run_migrations_offline() else: run_migrations_online()