导入MySQL数据库连接所需的库 import mysql.connector from mysql.connector import pooling 配置数据库连接池参数 config = { 'user': 'your_username', # 数据库用户名 'password': 'your_password', # 数据库密码 'host': 'your_host', # 数据库主机地址 'database': 'your_database', # 数据库名 'raise_on_warnings': True, 'pool_name': 'mypool', 'pool_size': 5 # 连接池大小,可根据实际情况调整 } 创建数据库连接池 connection_pool = pooling.MySQLConnectionPool(pool_name=config['pool_name'], pool_size=config['pool_size'], **config) 测试连接池 try: # 从连接池中获取连接 connection = connection_pool.get_connection() cursor = connection.cursor() # 创建数据库(如果数据库不存在) cursor.execute("CREATE DATABASE IF NOT EXISTS your_database") # 提交事务 connection.commit() # 关闭游标和连接 cursor.close() connection.close() print("数据库连接池创建成功,并且数据库已创建或确认存在。") except mysql.connector.Error as error: print(f"数据库连接池创建失败或发生错误: {error}") finally: # 关闭连接池 if connection_pool is not None: connection_pool.closeall() print("数据库连接池已关闭。")
原创文章,作者:未希,如若转载,请注明出处:https://www.kdun.com/ask/1126996.html
本网站发布或转载的文章及图片均来自网络,其原创性以及文中表达的观点和判断不代表本网站。如有问题,请联系客服处理。
发表回复