python多线程mysql

import multiprocessing

def worker():
    print("Worker")

if __name__ == "__main__":
    processes = [multiprocessing.Process(target=worker) for _ in range(4)]
    for p in processes:
        p.start()
    for p in processes:
        p.join()

import threading
import mysql.connector

lock = threading.Lock()
db = mysql.connector.connect(host="localhost", user="user", password="password", database="database")
cursor = db.cursor()

def insert_data(data):
    with lock:
        query = "INSERT INTO table (column) VALUES (%s)"
        cursor.execute(query, (data,))
        db.commit()

threads = []
for i in range(10):
    t = threading.Thread(target=insert_data, args=(i,))
    threads.append(t)
    t.start()

for t in threads:
    t.join()

from mysql.connector.pooling import MySQLConnectionPool

pool = MySQLConnectionPool(pool_name="mypool", pool_size=5, host="localhost", user="user", password="password", database="database")

def get_connection():
    return pool.get_connection()

def insert_data(data):
    conn = get_connection()
    cursor = conn.cursor()
    query = "INSERT INTO table (column) VALUES (%s)"
    cursor.execute(query, (data,))
    conn.commit()
    cursor.close()
    conn.close()

threads = []
for i in range(10):
    t = threading.Thread(target=insert_data, args=(i,))
    threads.append(t)
    t.start()

for t in threads:
    t.join()