该博文展示地是基本示例，实际使用时可能需要进行调整。例如，你可能需要添加错误处理来确保数据库连接问题不会导致脚本崩溃，或者你可能需要调整查询以匹配你的数据。
此外，你需要确保你的系统有足够的内存和处理能力来支持并行处理。如果数据库查询非常消耗资源，你可能需要考虑使用并发处理而不是并行处理，以避免系统过载。

import threading
import mysql.connector# 定义一个函数来执行数据库查询
def query_database(database):while True:try:# 连接到数据库conn = mysql.connector.connect(host="localhost", user="user", password="password", database=database)cursor = conn.cursor()# 执行你的查询cursor.execute("SELECT * FROM your_table")results = cursor.fetchall()print(f"Results from {database}: {results}")# 关闭连接cursor.close()conn.close()breakexcept Exception as e:print(f"An error occurred while connecting to {database}: {e}")# 创建两个线程，每个线程连接到一个不同的数据库
threads = []
threads.append(threading.Thread(target=query_database, args=("Database1",)))
threads.append(threading.Thread(target=query_database, args=("Database2",)))# 启动线程
for thread in threads:thread.start()# 等待所有线程完成
for thread in threads:thread.join()