多线程mysql例子

import threading
import mysql.connector

# 数据库连接配置
config = {
    'user': 'your_username',
    'password': 'your_password',
    'host': 'your_host',
    'database': 'your_database'
}

# 数据库操作函数
def db_operation(query):
    try:
        conn = mysql.connector.connect(**config)
        cursor = conn.cursor()
        cursor.execute(query)
        result = cursor.fetchall()
        print(f"Thread {threading.current_thread().name}: {result}")
    except mysql.connector.Error as err:
        print(f"Thread {threading.current_thread().name}: Error - {err}")
    finally:
        cursor.close()
        conn.close()

# 创建多个线程执行数据库操作
threads = []
queries = [
    "SELECT * FROM table1",
    "SELECT * FROM table2",
    "SELECT * FROM table3"
]

for i, query in enumerate(queries):
    thread = threading.Thread(target=db_operation, args=(query,), name=f"Thread-{i}")
    threads.append(thread)
    thread.start()

# 等待所有线程完成
for thread in threads:
    thread.join()