mysql多线程脚本

import threading
import mysql.connector.pooling

# 创建连接池
pool = mysql.connector.pooling.MySQLConnectionPool(pool_name="mypool",
                                                    pool_size=5,
                                                    host='localhost',
                                                    database='mydb',
                                                    user='user',
                                                    password='password')

# 线程安全访问数据库
def thread_task():
    try:
        conn = pool.get_connection()
        cursor = conn.cursor()
        cursor.execute("SELECT * FROM mytable")
        result = cursor.fetchall()
        cursor.close()
        conn.close()
    except mysql.connector.Error as err:
        print(f"Error: {err}")

threads = []
for i in range(10):
    t = threading.Thread(target=thread_task)
    threads.append(t)
    t.start()

for t in threads:
    t.join()

# 设置事务超时时间
conn = pool.get_connection()
cursor = conn.cursor()
cursor.execute("SET SESSION innodb_lock_wait_timeout = 5")