pg.py

def connect_to_postgres(host, port, dbname, user, password):
    try:
        conn = psycopg2.connect(
            host=host,
            port=port,
            dbname=dbname,
            user=user,
            password=password
        )
        print("✅ Connexion réussie à PostgreSQL")
        return conn
    except OperationalError as e:
        print("❌ Erreur de connexion :", e)
        return None


conn = connect_to_postgres(
    host="localhost",
    port=5432,
    dbname="ma_base",
    user="mon_user",
    password="mon_mot_de_passe"
)

if conn:
    # Créer un curseur
    cur = conn.cursor()
    cur.execute("SELECT version();")
    version = cur.fetchone()
    print("Version PostgreSQL :", version)

    # Fermer le curseur et la connexion
    cur.close()
    conn.close()