import sys
sys.stdout.reconfigure(encoding="utf-8")
from pathlib import Path
from backend.models.database import SessionLocal
from sqlalchemy import text

sql = Path("db/migrations/monthly_plan_snapshots_grossup.sql").read_text(encoding="utf-8")
db = SessionLocal()
try:
    with db.connection().connection.cursor() as cur:
        cur.execute(sql)
    db.commit()
    print("OK migration applied")
finally:
    db.close()