pymysql 是python操作mysql数据库的模块
pip简介
pip 是通用的Python包管理工具，提供了对 Python 包的查找、下载、安装、卸载的功能。通过pip管里的Python包默认下载安装到python根目录/lib/site-packages目录下。
下载安装
pip3 install pymysql
执行新增
import pymysql; #创建连接 conn = pymysql.connect(host="127.0.0.1",port=3306,user="root",passwd="",db="firstmysql") #创建游标 cursor = conn.cursor() #执行函数 返回受影响的函数 effect_rows = cursor.execute("insert into db1(des) values('cs1')") print("受影响的行数",effect_rows) conn.commit() #关闭游标 cursor.close() #关闭连接 conn.close() # 获取最新自增ID new_id = cursor.lastrowid print("自增ID",new_id)
执行删除
import pymysql #创建连接 conn = pymysql.connect(host="127.0.0.1",port=3306,user="root",passwd="",db="firstmysql") #创建游标 cursor = conn.cursor() #执行函数 返回受影响的函数 effect_rows = cursor.execute("delete from db1 where id=1") print("受影响的行数",effect_rows) conn.commit() #关闭游标 cursor.close() #关闭连接 conn.close()
执行修改
import pymysql #创建连接 conn = pymysql.connect(host="127.0.0.1",port=3306,user="root",passwd="",db="firstmysql") #创建游标 cursor = conn.cursor() #执行函数 返回受影响的函数 effect_rows = cursor.execute("update db1 set des='222222222' where id=2") print("受影响的行数",effect_rows) conn.commit() #关闭游标 cursor.close() #关闭连接 conn.close()
执行查询
import pymysql #创建连接 conn = pymysql.connect(host="127.0.0.1",port=3306,user="root",passwd="",db="firstmysql") #创建游标 默认元祖 #cursor = conn.cursor() #游标设置为字典 cursor = conn.cursor(cursor=pymysql.cursors.DictCursor) #执行函数 返回受影响的函数 effect_rows = cursor.execute("select des from db1") print("受影响的行数",effect_rows) # #获取前一条数据 # print(cursor.fetchone()) # #获取前N条数据 # print(cursor.fetchmany(2)) #获取全部数据 print(cursor.fetchall()) conn.commit() #关闭游标 cursor.close() #关闭连接 conn.close()
fetch 默认查询返回元祖类型，可通过设置游标 cursor=pymysql.cursors.DictCursor 设置成字典类型
在fetch数据时按照顺序进行，可以使用cursor.scroll(num,mode)来移动游标位置，如：
- cursor.scroll(1,mode='relative') # 相对当前位置移动
- cursor.scroll(2,mode='absolute') # 相对绝对位置移动