Pythonを使用してデータベースにマルチスレッドで接続する方法は何ですか？

1年 ago
優斗, 朝陽
1 minute

Pythonで複数のスレッドを使用してデータベースに接続するには、threadingモジュールを使用して複数のスレッドを作成します。以下は、データベースに接続する方法を示す簡単なサンプルコードです。

import threading
import pymysql

def connect_database():
    # 连接数据库
    conn = pymysql.connect(host='localhost', user='root', password='password', database='test')
    cursor = conn.cursor()
    
    # 执行SQL查询
    cursor.execute('SELECT * FROM users')
    rows = cursor.fetchall()
    
    # 打印查询结果
    for row in rows:
        print(row)
    
    # 关闭数据库连接
    cursor.close()
    conn.close()

# 创建多个线程
threads = []
for i in range(5):
    thread = threading.Thread(target=connect_database)
    threads.append(thread)

# 启动所有线程
for thread in threads:
    thread.start()

# 等待所有线程结束
for thread in threads:
    thread.join()

上記のコードでは、5つのスレッドを作成するためにthreading.Threadクラスを使用し、各スレッドはデータベースに接続してクエリを実行します。そして、start()メソッドを使用してすべてのスレッドを起動し、join()メソッドで全てのスレッドが終了するのを待ちます。

データベースへの複数スレッド接続時には、データベース接続やクエリ操作のスレッドセーフを確保して、データ競合や異常な状況を防ぐ必要があります。スレッドセーフを確保するためには、スレッドロックやコネクションプールなどの方法を検討することができます。

bannerAds