python访问mysql数据库多线程

import threading
import pymysql

# 数据库连接配置
config = {
    'host': 'localhost',
    'port': 3306,
    'user': 'your_username',
    'password': 'your_password',
    'db': 'your_database',
    'charset': 'utf8mb4',
    'cursorclass': pymysql.cursors.DictCursor
}

# 查询函数
def query_data(sql):
    conn = pymysql.connect(**config)
    try:
        with conn.cursor() as cursor:
            cursor.execute(sql)
            result = cursor.fetchall()
            print(result)
    finally:
        conn.close()

# 创建线程并执行查询
def run_threads():
    threads = []
    for i in range(10):
        sql = f'SELECT * FROM table{i}'
        t = threading.Thread(target=query_data, args=(sql,))
        threads.append(t)
        t.start()

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

if __name__ == '__main__':
    run_threads()