您的位置:

使用Python API连接处理MySQL数据

一、安装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数据的查询、插入、更新和删除等操作。