import sys
import os
sys.path.insert(0, os.path.dirname(os.path.dirname(os.path.abspath(__file__))))

import asyncio
from app.core.database import async_session_maker
from sqlalchemy import text

async def check():
    async with async_session_maker() as db:
        r1 = await db.execute(text("SELECT table_name FROM information_schema.tables WHERE table_schema = 'public'"))
        print('Tables:', [row[0] for row in r1.fetchall()])
        r2 = await db.execute(text("SELECT column_name FROM information_schema.columns WHERE table_name = 'companies' AND table_schema = 'public'"))
        print('companies cols:', [row[0] for row in r2.fetchall()])
        r3 = await db.execute(text("SELECT column_name FROM information_schema.columns WHERE table_name = 'reconciliation_tasks' AND table_schema = 'public'"))
        print('reconciliation_tasks cols:', [row[0] for row in r3.fetchall()])
        r4 = await db.execute(text("SELECT column_name FROM information_schema.columns WHERE table_name = 'uploaded_files' AND table_schema = 'public'"))
        print('uploaded_files cols:', [row[0] for row in r4.fetchall()])

        r5 = await db.execute(text("SELECT id, name FROM companies LIMIT 5"))
        print('Companies:', r5.fetchall())
        r6 = await db.execute(text("SELECT id, company_id, name, status FROM reconciliation_tasks LIMIT 10"))
        print('Tasks:', r6.fetchall())
        r7 = await db.execute(text("SELECT id, task_id, company_id, file_type, parse_status, stored_filename FROM uploaded_files LIMIT 10"))
        print('UploadedFiles:', r7.fetchall())

asyncio.run(check())