Python中的MySQL操作：使用mysql-connector-python-CFANZ编程社区

在现代的软件开发中，数据库是存储和检索数据的关键组件。MySQL是世界上最流行的开源数据库之一，广泛用于网站和服务端应用程序。Python通过mysql-connector-python模块提供了与MySQL数据库进行交互的能力。在本文中，我们将看到如何在Python中使用这个模块来执行基本的数据库操作。

安装mysql-connector-python

在开始之前，你需要确保mysql-connector-python模块已经安装在你的Python环境中。你可以使用pip命令轻松安装它：

pip install mysql-connector-python

连接到MySQL数据库

要与MySQL数据库进行交互，首先需要建立连接。这里是如何使用mysql.connector模块来连接数据库的一个例子：

import mysql.connector
from mysql.connector import Error

try:
    connection = mysql.connector.connect(
        host='localhost',       # 数据库主机地址
        user='yourusername',    # 数据库用户名
        passwd='yourpassword',  # 数据库密码
        database='yourdb'       # 数据库名
    )
    if connection.is_connected():
        db_Info = connection.get_server_info()
        print("成功连接到MySQL数据库，MySQL Server版本为：", db_Info)
except Error as e:
    print("连接错误:", e)
finally:
    if (connection.is_connected()):
        connection.close()
        print("MySQL连接已关闭")

创建数据库和表

连接到数据库后，你可能需要创建新的数据库或表：

# 创建数据库
cursor = connection.cursor()
cursor.execute("CREATE DATABASE example_db")

# 创建表
cursor.execute("CREATE TABLE example_table (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), price DECIMAL(10, 2))")

插入数据

向MySQL表中插入数据可以使用execute()方法：

query = "INSERT INTO example_table (name, price) VALUES (%s, %s)"
values = ("Product1", 100.50)

cursor.execute(query, values)
connection.commit()

print(cursor.rowcount, "记录插入成功。")

查询数据

查询数据同样可以使用execute()方法：

cursor.execute("SELECT * FROM example_table")

rows = cursor.fetchall()

for row in rows:
    print(row)

更新和删除数据

更新和删除数据也是基础的数据库操作：

# 更新数据
update_query = "UPDATE example_table SET price = %s WHERE name = %s"
data = (110.50, "Product1")
cursor.execute(update_query, data)
connection.commit()

# 删除数据
delete_query = "DELETE FROM example_table WHERE name = %s"
prod_name = ("Product1",)
cursor.execute(delete_query, prod_name)
connection.commit()

错误处理

当操作数据库时，错误处理是非常重要的：

try:
    # 尝试执行数据库操作
    cursor.execute(some_query)
    connection.commit()
except mysql.connector.Error as error:
    print("操作失败：{}".format(error))
    connection.rollback()  # 回滚改动