From 1d34504d04ac6744890c488930fe5c487469e960 Mon Sep 17 00:00:00 2001 From: Claude AI Date: Thu, 29 Jan 2026 10:02:10 +0000 Subject: [PATCH] feat: add Alembic database migrations setup - alembic.ini with configuration - alembic/env.py with model imports and connection handling - alembic/versions/ for migration scripts This completes Fase 1 Foundation implementation. Co-Authored-By: Claude Opus 4.5 --- services/api-gateway/alembic.ini | 44 +++++++++++++++ services/api-gateway/alembic/env.py | 56 +++++++++++++++++++ services/api-gateway/alembic/script.py.mako | 26 +++++++++ .../api-gateway/alembic/versions/.gitkeep | 0 4 files changed, 126 insertions(+) create mode 100644 services/api-gateway/alembic.ini create mode 100644 services/api-gateway/alembic/env.py create mode 100644 services/api-gateway/alembic/script.py.mako create mode 100644 services/api-gateway/alembic/versions/.gitkeep diff --git a/services/api-gateway/alembic.ini b/services/api-gateway/alembic.ini new file mode 100644 index 0000000..5860553 --- /dev/null +++ b/services/api-gateway/alembic.ini @@ -0,0 +1,44 @@ +# Alembic configuration file + +[alembic] +script_location = alembic +prepend_sys_path = . +version_path_separator = os + +sqlalchemy.url = driver://user:pass@localhost/dbname + +[post_write_hooks] + +[loggers] +keys = root,sqlalchemy,alembic + +[handlers] +keys = console + +[formatters] +keys = generic + +[logger_root] +level = WARN +handlers = console +qualname = + +[logger_sqlalchemy] +level = WARN +handlers = +qualname = sqlalchemy.engine + +[logger_alembic] +level = INFO +handlers = +qualname = alembic + +[handler_console] +class = StreamHandler +args = (sys.stderr,) +level = NOTSET +formatter = generic + +[formatter_generic] +format = %(levelname)-5.5s [%(name)s] %(message)s +datefmt = %H:%M:%S diff --git a/services/api-gateway/alembic/env.py b/services/api-gateway/alembic/env.py new file mode 100644 index 0000000..f3e0582 --- /dev/null +++ b/services/api-gateway/alembic/env.py @@ -0,0 +1,56 @@ +from logging.config import fileConfig +from sqlalchemy import engine_from_config, pool +from alembic import context +import os +import sys + +sys.path.insert(0, os.path.dirname(os.path.dirname(os.path.abspath(__file__)))) + +from app.core.config import get_settings +from app.core.database import Base +from app.models import * + +config = context.config +settings = get_settings() + +config.set_main_option("sqlalchemy.url", settings.DATABASE_URL) + +if config.config_file_name is not None: + fileConfig(config.config_file_name) + +target_metadata = Base.metadata + + +def run_migrations_offline() -> None: + url = config.get_main_option("sqlalchemy.url") + context.configure( + url=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 = engine_from_config( + config.get_section(config.config_ini_section, {}), + prefix="sqlalchemy.", + poolclass=pool.NullPool, + ) + + with connectable.connect() as connection: + context.configure( + connection=connection, target_metadata=target_metadata + ) + + with context.begin_transaction(): + context.run_migrations() + + +if context.is_offline_mode(): + run_migrations_offline() +else: + run_migrations_online() diff --git a/services/api-gateway/alembic/script.py.mako b/services/api-gateway/alembic/script.py.mako new file mode 100644 index 0000000..fbc4b07 --- /dev/null +++ b/services/api-gateway/alembic/script.py.mako @@ -0,0 +1,26 @@ +"""${message} + +Revision ID: ${up_revision} +Revises: ${down_revision | comma,n} +Create Date: ${create_date} + +""" +from typing import Sequence, Union + +from alembic import op +import sqlalchemy as sa +${imports if imports else ""} + +# revision identifiers, used by Alembic. +revision: str = ${repr(up_revision)} +down_revision: Union[str, None] = ${repr(down_revision)} +branch_labels: Union[str, Sequence[str], None] = ${repr(branch_labels)} +depends_on: Union[str, Sequence[str], None] = ${repr(depends_on)} + + +def upgrade() -> None: + ${upgrades if upgrades else "pass"} + + +def downgrade() -> None: + ${downgrades if downgrades else "pass"} diff --git a/services/api-gateway/alembic/versions/.gitkeep b/services/api-gateway/alembic/versions/.gitkeep new file mode 100644 index 0000000..e69de29