您好，登录后才能下订单哦！
密码登录
登录注册
点击 登录注册 即表示同意《亿速云用户服务条款》
本篇内容介绍了“如何使用pyMySql连接mysql”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！
安装
| pip3 install pymysql |
常用函数：
execute() 执行语句并返回收影响的行数
import pymysql # 创建连接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 创建游标 cursor = conn.cursor() # 执行SQL，并返回收影响行数 effect_row = cursor.execute("insert into t2 VALUES(1,'ray')") # 执行SQL，并返回受影响行数 # effect_row = cursor.execute("update hosts set host = '1.1.1.2' where nid > %s", (1,)) # 执行SQL，并返回受影响行数 # effect_row = cursor.executemany("insert into hosts(host,color_id)values(%s,%s)", [("1.1.1.11",1),("1.1.1.11",2)]) # 提交，不然无法保存新建或者修改的数据 conn.commit() # 关闭游标 cursor.close() # 关闭连接 conn.close() |
import pymysql # 创建连接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 创建游标 cursor = conn.cursor() # 执行SQL，并返回收影响行数 truple_str='ray' effect_row = cursor.execute("insert into t2 VALUES(3,%s)",truple_str) print(effect_row) truple_str='suen' effect_row = cursor.execute("insert into t2 VALUES(4,%s)",truple_str) print(effect_row) # 提交，不然无法保存新建或者修改的数据 conn.commit() # 关闭游标 cursor.close() # 关闭连接 conn.close() |
import pymysql # 创建连接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 创建游标 cursor = conn.cursor() # 执行SQL，并返回收影响行数 truple_str=('lalala',1) cursor.execute('update t2 set t_name=%s where t_id=%s',truple_str) # 提交，不然无法保存新建或者修改的数据 conn.commit() # 关闭游标 cursor.close() # 关闭连接 conn.close() |
import pymysql # 创建连接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 创建游标 cursor = conn.cursor() # 执行SQL，并返回收影响行数 # truple_str=('lalala',1) tid=1 cursor.execute('delete from t2 where t_id=%s',tid) # 提交，不然无法保存新建或者修改的数据 conn.commit() # 关闭游标 cursor.close() # 关闭连接 conn.close() |
executemany()执行条语句，以元组的形式传入
import pymysql # 创建连接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 创建游标 cursor = conn.cursor() # 执行SQL，并返回收影响行数 truple_str=[ (5,'aaa'), (6,'bbb'), (7,'ccc'), (8,'ddd') ] cursor.executemany("insert into t2 VALUES(%s,%s)",truple_str) # 提交，不然无法保存新建或者修改的数据 conn.commit() # 关闭游标 cursor.close() # 关闭连接 conn.close() |
fecheone()
fechemany()
fecheall()
注：在fetch数据时按照顺序进行，可以使用cursor.scroll(num,mode)来移动游标位置，如：
cursor.scroll(1,mode='relative') # 相对当前位置移动，正数为向下移动，负数为向上移动
cursor.scroll(2,mode='absolute') # 相对绝对位置移动
import pymysql # 创建连接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 创建游标 cursor = conn.cursor() # 执行SQL，并返回收影响行数 # truple_str=('lalala',1) cursor.execute('select * from t2') #fech 是去内存中获取 res = cursor.fetchone() print(res) res = cursor.fetchmany(7) #指定获取的条目数 print(res) res = cursor.fetchall() print(res) # 关闭游标 cursor.close() # 关闭连接 conn.close() |
import pymysql # 创建连接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 创建游标 cursor = conn.cursor() # 执行SQL，并返回收影响行数 # truple_str=('lalala',1) cursor.execute('select * from t2') #fech 是去内存中获取 res = cursor.fetchone() print(res) res = cursor.fetchone() print(res) cursor.scroll(0,mode='absolute') res = cursor.fetchall() print(res) cursor.scroll(-1,mode='relative') res = cursor.fetchall() print(res) # 关闭游标 cursor.close() # 关闭连接 conn.close() |
import pymysql # 创建连接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 创建游标 cursor = conn.cursor() # 执行SQL，并返回收影响行数 # truple_str=('lalala',1) cursor.execute('select * from t2') #fech 是去内存中获取 while 1: res = cursor.fetchone() if res == None: break print(res) # 关闭游标 cursor.close() # 关闭连接 conn.close() |
cursor修改，改变获取后的结果为字典集合
import pymysql # 创建连接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 创建游标 cursor = conn.cursor(cursor=pymysql.cursors.DictCursor) # 执行SQL，并返回收影响行数 # truple_str=('lalala',1) cursor.execute('select * from t2') #fech 是去内存中获取 while 1: res = cursor.fetchone() if res == None: break print(res) # 关闭游标 cursor.close() # 关闭连接 conn.close() |
lastrowid 获取最后的自增序列号
import pymysql # 创建连接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 创建游标 cursor = conn.cursor() cursor.executemany('insert into t3(t_name) VALUES (%s)',[('aaa07'),('aaa08'),('aaa09')]) conn.commit() tid=cursor.lastrowid print(tid) # 关闭游标 cursor.close() # 关闭连接 conn.close() |
“如何使用pyMySql连接mysql”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站，小编将为大家输出更多高质量的实用文章！
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。