python的pymysql模块安装与使用

article/2025/11/8 7:09:36

文章目录

- - 一、pymysql的安装：
  - 二、pymysql基本控制函数：
  - 三、数据库数据的添加：
  - 四、数据库数据的删除：
  - 五、数据库数据的修改：
  - 六、数据库数据的批量添加：
  - 七、数据库数据的查询(取出)：

一、pymysql的安装：

在cmd命令行输入pip install pymysql安装，import pymysql导入

二、pymysql基本控制函数：

方法	描述
connect()	连接数据库
cursor()	创建游标,使我们能够输入sql语句并执行
execute()	执行mysql，更新单条数据
commit()	将修改提交到数据库
close()	关闭连接
fetchone()	查找并获取一条数据
fetchall()	获取所有数据
fetchmany(size)	获取指定条数的数据

connect可填的参数：

host：数据库的地址
user：数据库用户名称
password：数据库密码
db：数据库的名称
port：域名

三、数据库数据的添加：

import pymysql#连接数据库
conn=pymysql.connect(host='localhost',user='root',password='123456',db='pymysql_demo',port=3306)
#创建游标
cursor=conn.cursor()#sql语句,user是表的名称
sql="insert into user (name,age) value(%s,%s)"
#参数
name="li"
age=23
#传入参数到sql语句并执行
cursor.execute(sql,(name,age))#提交对数据库的修改
conn.commit()
#关闭游标和数据库连接
cursor.close()
conn.close()

数据库成功添加一条数据
在这里插入图片描述

四、数据库数据的删除：

import pymysql#连接数据库
conn=pymysql.connect(host='localhost',user='root',password='123456',db='pymysql_demo',port=3306)
#创建游标
cursor=conn.cursor()#sql语句
sql="delete from user where name=%s"#删除名字为name的所有数据
#参数
name="li"
#执行语句
cursor.execute(sql,name)#提交修改
conn.commit()
#关闭游标和连接
cursor.close()
conn.close()

这样就成功删除name为li的数据

五、数据库数据的修改：

import pymysqlconn=pymysql.connect(host='localhost',user='root',password='123456',db='pymysql_demo',port=3306)
cursor=.conn.cursor()#对数据进行修改的sql语句
sql="update user set age=%s where name=%s"#需要修改的数据放在set后面
#参数
name='li'
age=20
cursor.execute(sql,(age,name))#这里的数据位置一定要和sql语句的位置一样！
conn.commit()
cursor.close()
conn.close()

li的age从原来的23修改成20，同理可修改其他数据

六、数据库数据的批量添加：

与数据的添加相比没有太大变动，只是多添加了数据

import pymysqlconn=pymysql.connect(host='localhost',user='root',password='123456',db='pymysql_demo',port=3306)
cursor=conn.cursor()
#sql语句,user为表的名字
sql="insert into user (name,age) values(%s,%s)"
name1='wang'
age1=25
name2='wu'
age2=29
data=((name1,age1),(name2,age2))
#execute变成了executemany
cursor.executemany(sql,data)
conn.commit()
cursor.close()
conn.close()

这样就添加了两条数据

七、数据库数据的查询(取出)：

import pymysqlconn=pymysql.connect(host='localhost',user='root',password='123456',db='pymysql_demo',port=3306)
cursor=conn.cursor()
#sql语句
sql="select * from user"
cursor.execute(sql)
value1=cursor.fetchone()#查找取出一条数据，注意！这条数据不会出现在下一次取出中
value2=cursor.fetchmany(2)#取出2条数据
value3=cursor.fetchall()#取出所有数据conn.commit()
curspr.close()
conn.close()