PyMySql是一个用Python编写的纯Python MySQL客户端库，它允许您使用Python与MySQL数据库进行交互。在本篇文章中，我将为您提供使用PyMySQL库的学习教程，帮助您快速上手。
安装PyMySQL库
在使用PyMySQL之前，我们需要先安装PyMySQL库。可以使用pip来安装：
pip install pymysql
连接MySQL数据库
在使用PyMySQL之前，我们需要先连接到MySQL数据库。以下是连接到数据库的示例代码：
import pymysql# 连接到数据库connection = pymysql.connect( host="localhost", user="root", password="password", database="mydatabase")# 打印数据库连接状态print("Database connected successfully")
这里我们使用pymysql.connect()方法来连接数据库。我们需要提供数据库的主机名，用户名，密码和数据库名称。如果连接成功，将会打印Database connected successfully。
创建表
在使用PyMySQL之前，我们需要先创建一个表。以下是创建表的示例代码：
import pymysql# 连接到数据库connection = pymysql.connect( host="localhost", user="root", password="password", database="mydatabase")# 创建表with connection.cursor() as cursor: sql = "CREATE TABLE customers (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), address VARCHAR(255))" cursor.execute(sql)# 提交更改connection.commit()print("Table created successfully")
这里我们使用connection.cursor()方法创建一个游标对象，然后使用execute()方法执行SQL语句。最后，我们使用connection.commit()提交更改。如果表创建成功，将会打印Table created successfully。
插入数据
接下来，我们将向刚刚创建的表中插入数据。以下是插入数据的示例代码：
import pymysql# 连接到数据库connection = pymysql.connect( host="localhost", user="root", password="password", database="mydatabase")# 插入数据with connection.cursor() as cursor: sql = "INSERT INTO customers (name, address) VALUES (%s, %s)" val = ("John", "Highway 21") cursor.execute(sql, val)# 提交更改connection.commit()print("Data inserted successfully")
这里我们使用execute()方法执行SQL语句，将数据插入到数据库中。最后，我们使用connection.commit()提交更改。如果数据插入成功，将会打印Data inserted successfully。
查询数据
接下来，我们将查询刚刚插入的数据。以下是查询数据的示例代码：
import pymysql# 连接到数据库connection = pymysql.connect( host="localhost", user="root", password="password", database="mydatabase")# 查询数据with connection.cursor() as cursor: sql = "SELECT * FROM customers" cursor.execute(sql) result = cursor.fetchall()# 打印结果for row in result: print(row)
这里我们使用execute()方法执行SQL语句，查询数据库中的所有数据。使用fetchall()方法获取所有结果。最后，我们遍历结果并打印每一行数据。
更新数据
接下来，我们将更新刚刚插入的数据。以下是更新数据的示例代码：
import pymysql# 连接到数据库connection = pymysql.connect( host="localhost", user="root", password="password", database="mydatabase")# 更新数据with connection.cursor() as cursor: sql = "UPDATE customers SET address = %s WHERE name = %s" val = ("Canyon 123", "John") cursor.execute(sql, val)# 提交更改connection.commit()print("Data updated successfully")
这里我们使用execute()方法执行SQL语句，更新数据。最后，我们使用connection.commit()提交更改。如果数据更新成功，将会打印Data updated successfully。
删除数据
最后，我们将删除刚刚插入的数据。以下是删除数据的示例代码：
import pymysql# 连接到数据库connection = pymysql.connect( host="localhost", user="root", password="password", database="mydatabase")# 删除数据with connection.cursor() as cursor: sql = "DELETE FROM customers WHERE name = %s" val = ("John",) cursor.execute(sql, val)# 提交更改connection.commit()print("Data deleted successfully")
这里我们使用execute()方法执行SQL语句，删除数据。最后，我们使用connection.commit()提交更改。如果数据删除成功，将会打印Data deleted successfully。
总结
在本教程中，我们介绍了如何使用 PyMySQL 连接到 MySQL 数据库，并执行查询、插入、更新和删除操作。当然，这只是 PyMySQL 功能的冰山一角，你可以查看 PyMySQL 的官方文档以获取更多详细信息。
