import mysql.connector
from mysql.connector import pooling
数据库配置信息
config = {
'user': 'your_username', # 数据库用户名
'password': 'your_password', # 数据库密码
'host': 'localhost', # 数据库主机地址
'database': 'your_database', # 数据库名
'raise_on_warnings': True
}
创建数据库连接池
pool_name 是连接池的名称
pool_size 是连接池中保持的连接数量
connection_pool = pooling.MySQLConnectionPool(pool_name="mypool",
pool_size=5,
**config)
获取连接
try:
connection = connection_pool.get_connection()
print("连接池成功获取连接")
# 创建数据库(如果不存在)
cursor = connection.cursor()
create_database_query = "CREATE DATABASE IF NOT EXISTSyour_database
"
cursor.execute(create_database_query)
print("数据库创建成功(如果不存在)")
# 提交事务
connection.commit()
# 关闭游标和连接
cursor.close()
connection.close()
except mysql.connector.Error as e:
print(f"数据库连接池或数据库创建过程中出现错误:{e}")
finally:
# 关闭连接池
if connection_pool:
connection_pool.closeall()
print("连接池已关闭")
代码展示了如何使用Python的mysql.connector
库来创建一个MySQL数据库连接池,并创建一个名为your_database
的数据库,请确保将your_username
、your_password
和your_database
替换为实际的数据库用户名、密码和数据库名称,代码中还包括了异常处理和资源清理,以确保在操作过程中出现错误时能够正确地关闭资源。
原创文章,作者:未希,如若转载,请注明出处:https://www.kdun.com/ask/1177885.html
本网站发布或转载的文章及图片均来自网络,其原创性以及文中表达的观点和判断不代表本网站。如有问题,请联系客服处理。
发表回复