pyexasol Exasol Python Driver

import os
from pyexasol import ExaConnection

# Replace with your Exasol connection details or environment variables
EXASOL_HOST = os.environ.get('EXASOL_HOST', '127.0.0.1')
EXASOL_PORT = os.environ.get('EXASOL_PORT', '8563')
EXASOL_USER = os.environ.get('EXASOL_USER', 'sys')
EXASOL_PASSWORD = os.environ.get('EXASOL_PASSWORD', 'exasol')

try:
    # Connect to the Exasol database
    # For production, ensure proper SSL options and fingerprint are used
    # For local/testing without certs, add: websocket_sslopt={'check_hostname': False, 'verify_mode': 0}
    # See warnings for v1.0.0 regarding strict certificate verification defaults.
    con = ExaConnection(
        dsn=f"{EXASOL_HOST}:{EXASOL_PORT}",
        user=EXASOL_USER,
        password=EXASOL_PASSWORD
    )
    print("Successfully connected to Exasol.")

    # Execute a DDL statement
    con.execute("CREATE SCHEMA IF NOT EXISTS MY_SCHEMA")
    con.execute("OPEN SCHEMA MY_SCHEMA")

    # Execute a DML statement
    con.execute("CREATE OR REPLACE TABLE my_table (id INT, name VARCHAR(100))")
    con.execute("INSERT INTO my_table VALUES (1, 'Alice'), (2, 'Bob')")

    # Fetch data
    stmt = con.execute("SELECT * FROM my_table ORDER BY id")
    results = stmt.fetchall()
    print("Fetched results:", results)

    # Fetch data into a pandas DataFrame (requires `pyexasol[pandas]`)
    # import pandas as pd
    # df = con.export_to_pandas("SELECT * FROM my_table")
    # print("Fetched into DataFrame:\n", df)

except Exception as e:
    print(f"An error occurred: {e}")
finally:
    if 'con' in locals() and con.is_connected():
        con.close()
        print("Connection closed.")