import mysql.connector

# Configure database connection information (replace with your actual configuration)
db_config = {
    "host": "10.10.10.10",
    "user": "test",
    "port": 7981,
    "password": "test123",
    "database": "test"
}
# Establish a connection + Create a single cursor (reuse this cursor for all SQL operations)
conn = mysql.connector.connect(**db_config)
cursor = conn.cursor(buffered=True)

# 1. Create table
cursor.execute("""
CREATE TABLE IF NOT EXISTS test_table (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(50) NOT NULL,
    age TINYINT DEFAULT 0
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4
""")

# 2. Insert a row of data and commit the transaction
cursor.execute("INSERT INTO test_table (name, age) VALUES (%s, %s)", ("Tom", 22))
conn.commit()

# 3. Query data and print it.
cursor.execute("SELECT * FROM test_table WHERE name = %s", ("Tom",))
data = cursor.fetchone()
print("Query result:", data)

# Close cursor and connection
cursor.close()
conn.close()

import pymysql

# Configure database connection information (replace with your actual configuration)
db_config = {
    "host": "10.10.10.10",
    "user": "test",
    "port": 7981,
    "password": "test123",
    "database": "test"
}

# Establish a connection + Create a cursor
conn = pymysql.connect(**db_config)
cursor = conn.cursor()

# 1. Create table
cursor.execute("""
CREATE TABLE IF NOT EXISTS test_table (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(50) NOT NULL,
    age TINYINT DEFAULT 0
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4
""")

# 2. Insert a row of data and commit the transaction
cursor.execute("INSERT INTO test_table (name, age) VALUES (%s, %s)", ("Tom", 22))
conn.commit()

# 3. Query data and print it.
cursor.execute("SELECT * FROM test_table WHERE name = %s", ("Tom",))
data = cursor.fetchone()
print("Query result:", data)

# Close cursor and connection
cursor.close()
conn.close()

import MySQLdb

# Configure database connection information (replace with your actual configuration)
db_config = {
    "host": "10.10.10.10",
    "user": "test",
    "port": 7981,
    "password": "test123",
    "database": "test"
}


# Establish a connection + Create a cursor
conn = MySQLdb.connect(**db_config)
cursor = conn.cursor()

# 1. Create table
cursor.execute("""
CREATE TABLE IF NOT EXISTS test_table (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(50) NOT NULL,
    age TINYINT DEFAULT 0
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4
""")

# 2. Insert a row of data and commit the transaction
cursor.execute("INSERT INTO test_table (name, age) VALUES (%s, %s)", ("Tom", 22))
conn.commit()

# 3. Query data and print it.
cursor.execute("SELECT * FROM test_table WHERE name = %s", ("Tom",))
data = cursor.fetchone()
print("Query result:", data)

# Close cursor and connection
cursor.close()
conn.close()

import asyncio
import aiomysql

# Configure database connection information (replace with your actual configuration)
db_config = {
    "host": "10.10.10.10",
    "user": "test",
    "port": 7981,
    "password": "test123",
    "db": "test"
}


async def main():
    # 1. Establish an asynchronous connection
    conn = await aiomysql.connect(**db_config)
    # 2. Create an asynchronous cursor
    cursor = await conn.cursor()

    # 3. Create table
    await cursor.execute("""
    CREATE TABLE IF NOT EXISTS test_table (
        id INT AUTO_INCREMENT PRIMARY KEY,
        name VARCHAR(50) NOT NULL,
        age TINYINT DEFAULT 0
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4
    """)

    # 4. Insert a row of data and commit the transaction
    await cursor.execute("INSERT INTO test_table (name, age) VALUES (%s, %s)", ("Tom", 22))
    await conn.commit()

    # 5. Query data and print it.
    await cursor.execute("SELECT * FROM test_table WHERE name = %s", ("Tom",))
    data = await cursor.fetchone()
    print("Query result:", data)

    # 6. Close cursor and connection
    await cursor.close()
    conn.close()

# Asynchronous startup method compatible with Python 3.6 (replace asyncio.run())
if __name__ == "__main__":
    # 1. Obtain the default event loop
    loop = asyncio.get_event_loop()
    # 2. Run the asynchronous main function
    loop.run_until_complete(main())
    # 3. Close the event loop
    loop.close()

from sqlalchemy import create_engine, Column, Integer, String
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base

# 1. Basic configuration: Create base class + database connection engine
Base = declarative_base()
# Connection string format: mysql+driver://username:password@host:port/database?charset
engine = create_engine("mysql+mysqldb://test:test123@10.10.10.10:7981/test?charset=utf8mb4")

# 2. Define the ORM model (corresponding to the test_table)
class TestTable(Base):
    __tablename__ = "test_table"  # Table name
    id = Column(Integer, primary_key=True, autoincrement=True)  # Auto-incrementing primary key
    name = Column(String(50), nullable=False)  # Username
    age = Column(Integer, default=0)  # Age

# 3. Create session (for database operations)
Session = sessionmaker(bind=engine)
session = Session()

# 4. Create table (if not exists)
Base.metadata.create_all(engine)

# 5. Insert a row of data
new_data = TestTable(name="Tom", age=22)
session.add(new_data)
session.commit()  # Commit the transaction

# 6. Query data and print it.
query_data = session.query(TestTable).filter(TestTable.name == "Tom").first()
print("Query result:", (query_data.id, query_data.name, query_data.age))

# 7. Close the session
session.close()