Python 并发写入 MySQL 数据库示例

以下是一个简单的 Python 程序，演示如何在 MySQL 数据库中并发写入数据：

import mysql.connector
import threading

# 创建 MySQL 连接
mydb = mysql.connector.connect(
  host='localhost',
  user='yourusername',
  password='yourpassword',
  database='mydatabase'
)

# 定义插入函数
def insert_data(name, age):
    mycursor = mydb.cursor()
    sql = 'INSERT INTO customers (name, age) VALUES (%s, %s)'
    val = (name, age)
    mycursor.execute(sql, val)
    mydb.commit()
    print(mycursor.rowcount, '记录插入成功。')

# 定义线程函数
def insert_thread(name, age):
    for i in range(100):
        insert_data(name, age)

# 创建两个线程并启动它们
t1 = threading.Thread(target=insert_thread, args=('Alice', 20))
t2 = threading.Thread(target=insert_thread, args=('Bob', 25))
t1.start()
t2.start()

# 等待线程完成
t1.join()
t2.join()

# 关闭 MySQL 连接
mydb.close()

该程序创建了一个 MySQL 连接，并定义了一个插入函数 insert_data()，用于将数据插入到 MySQL 数据库中的 customers 表中。然后，定义了一个线程函数 insert_thread()，用于启动多个线程并在每个线程中调用 insert_data() 函数，以模拟并发写入数据的情况。

在主程序中，创建了两个线程，并启动它们。然后等待线程完成，并关闭 MySQL 连接。

需要注意的是，由于 MySQL 是一个关系型数据库，其插入操作是有锁机制的，因此并发写入可能会导致性能下降。因此，在实际应用中，需要根据实际情况来选择合适的并发策略。