一、安装PyMySQL库
使用Python API连接MySQL数据库需要安装PyMySQL库。在终端执行以下命令进行安装:
pip install pymysql
安装完成后,在Python代码中导入PyMySQL库:
import pymysql
二、连接MySQL数据库
使用PyMySQL库连接MySQL数据库需要提供MySQL的连接参数,如host、port、user、password、database等。具体步骤如下:
1、连接数据库
conn = pymysql.connect(host='localhost', port=3306, user='root', password='xxxxxx', database='test')
其中,host填写MySQL数据库的IP地址或者域名;port填写MySQL数据库的端口号;user填写连接MySQL数据库的用户名;password填写连接MySQL数据库的密码;database填写要连接的数据库名。
2、创建游标
cursor = conn.cursor()
创建一个游标,相当于打开了一个MySQL连接,可以执行SQL语句。
三、执行SQL语句
连接到MySQL数据库后,可以执行SQL语句,常见的SQL语句包括:查询数据、插入、更新和删除等。
1、查询数据
sql = "SELECT * FROM students"
cursor.execute(sql)
result = cursor.fetchall()
for row in result:
print(row)
以上代码查询students表中的所有数据,并打印输出。execute方法用于执行SQL语句,fetchall方法用于返回查询结果。结果为元组类型。
2、插入数据
sql = "INSERT INTO students(name, age) VALUES (%s, %s)"
values = ('John', 18)
cursor.execute(sql, values)
conn.commit()
以上代码插入一个数据到students表中。sql语句中的%s表示占位符,用于接收动态变量。execute方法的第二个参数是一个元组类型,用于接收动态变量的值。执行完插入操作后,需要使用commit方法提交事务才能生效。
3、更新数据
sql = "UPDATE students SET age = %s WHERE name = %s"
values = (19, 'John')
cursor.execute(sql, values)
conn.commit()
以上代码更新students表中name为John的数据的age字段为19。
4、删除数据
sql = "DELETE FROM students WHERE name = %s"
values = ('John',)
cursor.execute(sql, values)
conn.commit()
以上代码删除students表中name为John的数据。
四、关闭连接
使用完MySQL数据库后,需要关闭连接,释放资源。
cursor.close()
conn.close()
以上代码关闭游标和连接。
总结
使用Python API连接处理MySQL数据可以大大提高数据处理效率和准确率。PyMySQL库为Python提供强大的MySQL数据库连接和操作功能,只需要简单的几行代码就可以完成MySQL数据的查询、插入、更新和删除等操作。