python 多线程连mysql

import threading
import mysql.connector.pooling

# 创建数据库连接池
db_config = {
    "host": "localhost",
    "user": "root",
    "password": "password",
    "database": "test"
}
pool = mysql.connector.pooling.MySQLConnectionPool(pool_name="mypool", pool_size=5, **db_config)

# 线程锁
lock = threading.Lock()

def worker():
    try:
        # 从连接池中获取连接
        conn = pool.get_connection()
        cursor = conn.cursor()
        
        # 执行数据库操作
        with lock:
            cursor.execute("SELECT * FROM table")
            result = cursor.fetchall()
        
        # 关闭连接
        cursor.close()
        conn.close()
    except Exception as e:
        print(f"Error: {e}")

# 创建多个线程
threads = []
for i in range(10):
    t = threading.Thread(target=worker)
    threads.append(t)
    t.start()

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

import mysql.connector.pooling

# 创建数据库连接池，限制最大连接数为5
pool = mysql.connector.pooling.MySQLConnectionPool(pool_name="mypool", pool_size=5, **db_config)

def worker():
    try:
        # 从连接池中获取连接
        conn = pool.get_connection()
        cursor = conn.cursor()
        
        # 执行数据库操作
        cursor.execute("SELECT * FROM table")
        result = cursor.fetchall()
        
        # 关闭连接
        cursor.close()
        conn.close()  # 连接会返回到连接池，而不是真正关闭
    except Exception as e:
        print(f"Error: {e}")