Python 连接 MySQL 数据库的示例
·
以下是一个使用 Python 连接 MySQL 数据库的示例。这个示例使用 mysql-connector-python 库来实现数据库连接和基本的操作。
安装依赖
首先,确保你已经安装了 mysql-connector-python 库。如果没有安装,可以使用以下命令进行安装:
pip install mysql-connector-python
示例代码
以下是一个简单的 Python 脚本,用于连接 MySQL 数据库并执行基本的查询操作:
import mysql.connector
from mysql.connector import Error
def create_connection(host_name, user_name, user_password, db_name):
"""创建与 MySQL 数据库的连接"""
connection = None
try:
connection = mysql.connector.connect(
host=host_name,
user=user_name,
password=user_password,
database=db_name
)
print("成功连接到 MySQL 数据库")
except Error as e:
print(f"连接错误: {e}")
return connection
def execute_query(connection, query):
"""执行单条 SQL 查询"""
cursor = connection.cursor()
try:
cursor.execute(query)
connection.commit()
print("查询成功")
except Error as e:
print(f"查询错误: {e}")
def main():
# 数据库连接参数
host = "localhost" # 数据库主机
user = "root" # 数据库用户名
password = "password" # 数据库密码
database = "mydatabase" # 数据库名称
# 创建连接
connection = create_connection(host, user, password, database)
# 示例查询:创建表
create_table_query = """
CREATE TABLE IF NOT EXISTS users (
id INT AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(100) NOT NULL,
age INT NOT NULL
);
"""
execute_query(connection, create_table_query)
# 示例查询:插入数据
insert_user_query = "INSERT INTO users (name, age) VALUES ('Alice', 30);"
execute_query(connection, insert_user_query)
# 关闭连接
if connection.is_connected():
connection.close()
print("数据库连接已关闭")
if __name__ == "__main__":
main()
代码说明
- 创建连接:
create_connection函数用于创建与 MySQL 数据库的连接,并返回连接对象。 - 执行查询:
execute_query函数用于执行 SQL 查询,并处理可能的错误。 - 主函数:在
main函数中,设置数据库连接参数,创建连接,执行创建表和插入数据的查询,最后关闭连接。
注意事项
- 确保 MySQL 服务正在运行,并且可以通过指定的主机和端口访问。
- 用户名和密码必须具有访问指定数据库的权限。
- 根据需要修改数据库连接参数。
运行该脚本后,你将能够连接到 MySQL 数据库并执行基本的 SQL 操作。
更多推荐
所有评论(0)