怎么用多线程查询数据库

使用多线程查询数据库可以提高查询效率，以下是一些步骤：

1. 导入相关的库，如 threading、pymysql。

2. 创建一个数据库连接池，用于多线程共享数据库连接。

3. 定义一个查询函数，该函数将在每个线程中被调用。该函数接受一个查询语句作为参数，并使用共享的数据库连接池来执行查询。

4. 创建多个线程，每个线程都调用查询函数并传递查询语句。

5. 等待所有线程完成查询并收集查询结果。

以下是一个简单的示例代码：

import threading
import pymysql
from queue import Queue

# 创建数据库连接池
db_pool = Queue(maxsize=10)
for i in range(10):
    db = pymysql.connect(host='localhost', user='root', password='password', database='test')
    db_pool.put(db)

# 定义查询函数
def query(query_str):
    db = db_pool.get()
    cursor = db.cursor()
    cursor.execute(query_str)
    result = cursor.fetchall()
    cursor.close()
    db_pool.put(db)
    return result

# 创建多个线程执行查询
threads = []
queries = ['SELECT * FROM table1', 'SELECT * FROM table2', 'SELECT * FROM table3']
for query_str in queries:
    t = threading.Thread(target=query, args=(query_str,))
    threads.append(t)
    t.start()

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

# 收集查询结果
results = []
for t in threads:
    results.append(t.result())