test_pooler.py

import asyncio
import asyncpg
import ssl
import logging

logging.basicConfig(level=logging.DEBUG)
logger = logging.getLogger(__name__)

async def test_pooled_connection():
    try:
        # Create SSL context
        ssl_context = ssl.create_default_context()
        ssl_context.check_hostname = False
        ssl_context.verify_mode = ssl.CERT_NONE

        # Create connection pool
        pool = await asyncpg.create_pool(
            host='aws-0-eu-central-1.pooler.supabase.com',
            port=5432,
            user='postgres.juycnkjuzylnbruwaqmp',
            password='Lovyelias5584.',
            database='postgres',
            ssl=ssl_context,
            min_size=1,
            max_size=10
        )

        async with pool.acquire() as conn:
            version = await conn.fetchval('SELECT version()')
            print(f"Connected successfully! PostgreSQL version: {version}")
            
            # Test a simple query
            result = await conn.fetchval('SELECT 1')
            print(f"Test query result: {result}")

        await pool.close()
        print("Connection pool closed successfully")
        return True

    except Exception as e:
        print(f"Connection error: {str(e)}")
        return False

if __name__ == "__main__":
    asyncio.run(test_pooled_connection())