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 的官方文档以获取更多详细信息。