在Python开发中，连接和操作数据库是一项常见的任务。MySQL是一个广泛使用的开源数据库管理系统，mysql-connector-python是一个官方的Python数据库连接器，可以用来连接MySQL数据库。在这篇文章中，我们将介绍如何使用mysql-connector-python连接MySQL数据库，并执行一些基本的数据库操作。
安装 mysql-connector-python
首先，确保你已经安装了mysql-connector-python库。如果尚未安装，可以通过pip进行安装：
pip install mysql-connector-python
创建数据库连接
在使用之前，你需要创建一个数据库连接。以下是一个完整的示例，展示了如何连接到MySQL数据库并执行一些基本的操作：
import mysql.connector
from mysql.connector import Error
def create_connection(host_name, user_name, user_password, db_name):
connection = None
try:
connection = mysql.connector.connect(
host=host_name,
user=user_name,
password=user_password,
database=db_name
)
print("成功连接到数据库")
except Error as e:
print(f"连接数据库时发生错误：{e}")
return connection
上述代码定义了一个 create_connection 函数，用于创建数据库连接。你需要传入主机名、用户名、密码和数据库名。
执行查询
一旦连接到数据库，你就可以执行SQL查询。以下是一个示例，展示了如何创建一个表、插入数据和查询数据：
def execute_query(connection, query):
cursor = connection.cursor()
try:
cursor.execute(query)
connection.commit()
print("查询成功")
except Error as e:
print(f"查询时发生错误：{e}")
def read_query(connection, query):
cursor = connection.cursor()
result = None
try:
cursor.execute(query)
result = cursor.fetchall()
return result
except Error as e:
print(f"读取数据时发生错误：{e}")
在上面的代码中，execute_query 函数用于执行INSERT、UPDATE和DELETE等语句，而 read_query 函数用于执行SELECT语句并返回查询结果。
示例：创建表、插入数据和查询数据
接下来，让我们将上述函数结合起来进行实际应用：
if __name__ == "__main__":
connection = create_connection("localhost", "root", "你的密码", "测试数据库")
create_table_query = """
CREATE TABLE IF NOT EXISTS users (
id INT AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(100) NOT NULL,
age INT,
gender ENUM('Male', 'Female') NOT NULL
);
"""
execute_query(connection, create_table_query)
insert_users_query = """
INSERT INTO users (name, age, gender) VALUES
('Alice', 25, 'Female'),
('Bob', 30, 'Male');
"""
execute_query(connection, insert_users_query)
select_users_query = "SELECT * FROM users;"
users = read_query(connection, select_users_query)
for user in users:
print(user)
总结
通过上述代码示例，我们成功地连接了MySQL数据库，创建了一个表，插入了一些数据，并读取和显示了这些数据。在实际开发中，你可能会遇到更复杂的操作和查询，但理解基本的连接和数据操作是非常重要的。
在处理数据库时，要注意关闭连接，以释放资源，通常可以使用 connection.close() 方法。希望这篇文章对你理解如何在Python中使用mysql-connector-python连接MySQL提供了一些帮助和启示。如需更多信息，可以查阅 mysql-connector-python官方文档。
