湖北住房和城乡建设部网站济南专业做网站
背景
在现代应用程序中，数据库是存储和管理数据的核心组件。MySQL 是一种流行的关系型数据库管理系统，广泛用于 Web 应用程序和数据分析。Python 提供了多种库来与 MySQL 数据库进行交互，最常用的包括 pymysql 和 MySQL Connector/Python。本文将介绍如何在 Python 中调用 MySQL 数据库，包括安装库、创建连接、执行查询和处理结果。
1. 安装所需库
在开始之前，您需要确保安装了与 MySQL 交互的库。以下是安装 pymysql 和 mysql-connector-python 的命令：
使用 pymysql
pip install pymysql
使用 mysql-connector-python
pip install mysql-connector-python
2. 创建数据库连接
在 Python 中，您需要创建一个与 MySQL 数据库的连接。以下是使用 pymysql 和 mysql-connector-python 创建连接的示例。
使用 pymysql
import pymysql# 数据库连接参数config = {'host': 'localhost','user': 'dbuser','password': 'your_password','db': 'your_database','charset': 'utf8',}# 创建连接connection = pymysql.connect(**config)使用 mysql-connector-python
import mysql.connector# 创建连接connection = mysql.connector.connect(host='localhost',user='dbuser',password='your_password',database='your_database')3. 执行查询
一旦建立了连接，您可以使用游标对象来执行 SQL 查询。以下是执行查询的示例。
使用 pymysql
try:with connection.cursor() as cursor:# 执行 SQL 查询sql = "SELECT * FROM your_table"cursor.execute(sql)# 获取所有结果results = cursor.fetchall()for row in results:print(row)finally:connection.close() # 关闭连接使用 mysql-connector-python
try:cursor = connection.cursor()# 执行 SQL 查询sql = "SELECT * FROM your_table"cursor.execute(sql)# 获取所有结果results = cursor.fetchall()for row in results:print(row)finally:cursor.close() # 关闭游标connection.close() # 关闭连接4. 插入数据
除了查询数据，您还可以插入数据到数据库中。以下是插入数据的示例。
使用 pymysql
try:with connection.cursor() as cursor:# 插入数据sql = "INSERT INTO your_table (column1, column2) VALUES (%s, %s)"cursor.execute(sql, ('value1', 'value2'))connection.commit() # 提交事务finally:connection.close() # 关闭连接使用 mysql-connector-python
try:cursor = connection.cursor()# 插入数据sql = "INSERT INTO your_table (column1, column2) VALUES (%s, %s)"cursor.execute(sql, ('value1', 'value2'))connection.commit() # 提交事务finally:cursor.close() # 关闭游标connection.close() # 关闭连接5. 处理异常
在与数据库交互时，处理异常是非常重要的。您可以使用 try...except 块来捕获和处理可能发生的错误。
示例
try:connection = pymysql.connect(**config)with connection.cursor() as cursor:# 执行 SQL 查询sql = "SELECT * FROM your_table"cursor.execute(sql)results = cursor.fetchall()for row in results:print(row)except pymysql.MySQLError as e:print(f"Error: {e}")finally:connection.close() # 确保连接被关闭