python—pymysql的增删改查操作实例展示
Python使用pymysql连接数据库
1.导包
import pymysql
2.连接数据库
connection = pymysql.connect( host='', # 数据库地址 port=3306, #端口 user='', # 数据库用户名 password='', # 数据库密码 db='', # 数据库名称 # charset = 'utf8 -- UTF-8 Unicode' )
3.创建游标
cursor = connection.cursor()
4.数据操作
查询
#SQL语句 sql = 'select * from user' #execute执行操作 cursor.execute(sql) result = cursor.fetchall() print(type(result),cursor.rowcount) print(result)
fetchall 查询时获取结果集中的所有行，一行构成一个元组，然后再将这些元组返回（即嵌套元组）。
ferchone 查询时获取结果集的第一行数据，返回一个元组，该元组元素即为第一行数据，如果没有则为null（注：在python中使用应为None）
execute 为单条数据插入
executemany 批量数据插入
cursor.rowcount 用来记录操作次数
插入(批量插入）
#插入SQL语句
sql = 'insert into user(username,sex,password,pid,tel) values (%s,%s,%s,%s,%s)'
#插入数据
data = [
('test1', '男', '123456', 3, '110'),
('test2', '女', '123456', 2, '120'),
]
#拼接并执行SQL语句
cursor.executemany(sql,data)
#涉及写操作要提交
connection.commit()
print(cursor.rowcount)不管数据库中的数据类型是什么，在sql语句中统一使用字符串类型%s connection.commit() 涉及写操作要提交
修改
#修改SQL语句 sql = 'update user set tel="12345622" where id="64"' #执行SQL语句 cursor.execute(sql) connection.commit() print(cursor.rowcount)
删除
#删除SQL语句 sql = 'delete from user where id = 64' cursor.execute(sql) connection.commit() print(cursor.rowcount)
关闭
#关闭游标 cursor.close() #关闭连接 connection.close()