python MySQL 数据库连接池代码示例

python MySQL 数据库连接池代码示例

"""python MySQL 连接池 """
import mysql.connector.pooling

config = {
    "host": "localhost",
    "port": 3306,
    "user": "root",
    "password": "root",
    "database": "yu"
}
try:
    pool = mysql.connector.pooling.MySQLConnectionPool(
        **config,
        pool_size=10 #连接池中的连接数量
    )
    con = pool.get_connection() #取空闲连接
    #开启事务
    con.start_transaction()
    cursor = con.cursor()
    sql = "UPDATE student SET age=age+5 WHERE stuid='202210'"
    cursor.execute(sql)
    con.commit()
except Exception  as e:
    if "con" in dir():
        con.rollback()
    print(e)