singlestoredb_quickstart_create_table_insert_query.py

1import singlestoredb as s2
2
3# Connection details - replace with your actual credentials
4HOST = '127.0.0.1'
5PORT = 3306
6USER = 'root'
7PASSWORD = 'your_password'
8DATABASE = 'test_db'
9
10# Establish a connection to the database
11conn = s2.connect(host=HOST, port=PORT, user=USER, password=PASSWORD, database=DATABASE)
12
13with conn.cursor() as cur:
14    # Create a table
15    cur.execute("CREATE TABLE IF NOT EXISTS messages (id INT AUTO_INCREMENT PRIMARY KEY, content TEXT)")
16    
17    # Insert data into the table
18    cur.execute("INSERT INTO messages (content) VALUES (%s)", ("Hello from SingleStore!",))
19    
20    # Commit the transaction
21    conn.commit()
22    
23    # Query the data
24    cur.execute("SELECT * FROM messages")
25    
26    # Fetch and print the results
27    for row in cur.fetchall():
28        print(row)
29
30# Close the connection
31conn.close()