singlestoredb

import singlestoredb as s2 import os # Get connection details from environment variables for security HOST = os.environ.get('SINGLESTOREDB_HOST', '127.0.0.1') PORT = int(os.environ.get('SINGLESTOREDB_PORT', '3306')) USER = os.environ.get('SINGLESTOREDB_USER', 'root') PASSWORD = os.environ.get('SINGLESTOREDB_PASSWORD', 'password') DATABASE = os.environ.get('SINGLESTOREDB_DATABASE', 'test_db') try: # Establish a connection with s2.connect( host=HOST, port=PORT, user=USER, password=PASSWORD, database=DATABASE ) as conn: print("Successfully connected to SingleStoreDB!") # Create a cursor object with conn.cursor() as cur: # Execute a query cur.execute("CREATE TABLE IF NOT EXISTS my_table (id INT, name VARCHAR(255))") cur.execute("INSERT INTO my_table (id, name) VALUES (%s, %s)", (1, 'Alice')) conn.commit() print("Table created and data inserted.") # Fetch results cur.execute("SELECT * FROM my_table") for row in cur.fetchall(): print(row) except s2.Error as e: print(f"Database error: {e}") except Exception as e: print(f"An unexpected error occurred: {e}")