pymysql实现数据库的增删改查

Posted 2023-03-14

import pymysql
conn=pymysql.connect(    #1.创建连接对象
    host="127.0.0.1",    #数据库服务所在的主机地址
    port=3306,           #占用的端口号
    user="root",         #用户名
    db="bee",            #pymysql连接操作的数据库
    charset="utf8"       #指定字符集uft8
)
cur = conn.cursor()       #2、创建游标
#3数据库操作
#3建表
# create_bumen=create table bumen(bumen_id int,bumen_name varchar(50));
# cur.execute(create_bumen)  #通过游标执行sql语句
#3.1添加数据
# insert_bumen="insert into bumen values(%s,%s);"
# cur.execute(insert_bumen,(1,"运维部"))  #单条插入
# cur.executemany(insert_bumen,[       #批量插入
#     (2,"开发部"),(3,"测试部"),(4,"市场部"),(5,"HR")
# ])
#3.2查询数据
select_bumen="select * from bumen ;"
cur.execute(select_bumen)
# print(cur.fetchone())    #抓取单条数据
# print(cur.fetchmany(2))  #接着抓取两条数据
print(cur.fetchall())    #抓取剩余所有数据
#3.3数据的更新
# update_bumen="update bumen set bumen_name=%s where bumen_id=%s;"
# cur.execute(update_bumen,(DEVELOPMENT,2))       #单条更新
# cur.executemany(update_bumen,[("TESTING",3),("OPS",1)])
#数据的删除
delete_bumen="delete from bumen where bumen_id=%s;"
cur.execute(delete_bumen,1)   #单条删除
cur.executemany(delete_bumen,[2,3])   #批量删除

#4.提交事务（保证数据写操作成功）以及关闭资源
conn.commit()  #提交事务
cur.close()    #关闭游标资源
conn.close()    #挂碧连接资源

运行结果