如何使用MySQL的鎖定機制處理並發存取衝突

import threading
import mysql.connector

# 创建锁对象
lock = threading.Lock()

# 数据库连接配置
config = {
    'user': 'username',
    'password': 'password',
    'host': 'localhost',
    'database': 'database_name'
}

def do_something():
    # 获取数据库连接对象
    conn = mysql.connector.connect(**config)
    cursor = conn.cursor()

    try:
        # 加锁
        lock.acquire()

        # 执行操作
        cursor.execute("SELECT * FROM table_name")

        # 处理结果
        results = cursor.fetchall()
        for row in results:
            # 处理每一行数据
            pass
        
        # 提交事务
        conn.commit()

    except Exception as e:
        # 发生错误时回滚事务
        conn.rollback()
        print("Error: ", e)

    finally:
        # 释放锁
        lock.release()

        # 关闭连接
        cursor.close()
        conn.close()

# 创建多个线程并启动
threads = []
for i in range(10):
    t = threading.Thread(target=do_something)
    threads.append(t)
    t.start()

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