CME Prediction Markets MCP Server

#!/usr/bin/env python3 """Debug database connectivity""" import asyncio from src.data.models.database import engine from sqlalchemy import text async def test_db(): try: async with engine.begin() as conn: result = await conn.execute(text('SELECT 1 as test')) print('✅ Database connection OK:', result.scalar()) # Check if tables exist result = await conn.execute(text("SELECT count(*) FROM information_schema.tables WHERE table_schema = 'public'")) table_count = result.scalar() print(f'✅ Found {table_count} tables') return True except Exception as e: print(f'❌ Database error: {e}') return False if __name__ == "__main__": asyncio.run(test_db())