app/testdb.py

# test_db.py
from app.database import engine
from sqlalchemy import text
import asyncio


async def test_connection():
    async with engine.connect() as conn:
        result = await conn.execute(text("SELECT 1"))
        print("DB Connection OK:", result.scalar())


asyncio.run(test_connection())