Python pymysql -- 2019-08-11 19:26:12

Posted gqy02

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Python pymysql -- 2019-08-11 19:26:12相关的知识，希望对你有一定的参考价值。

原文: http://106.13.73.98/__/31/

目录

关于sql注入

用户存在，绕过密码

用户不存在，绕过用户与密码

解决sql注入问题

commit()

增

改

删

查询数据库

fetchone()

fetchall()

fetchmany()

> 补充： >
> > 建立链接时间过长后会自动断开链接，可像下面这样解决： > ```python > conn.ping(reconnect=True) > ``` > 检查链接是否还存在，参数`reconnect=True` 表示如果链接已不存在，则重新建立链接 >
>

补充：

> 
  1. # 回滚，通常用于事务
  2. conn.rollback()

pymysql模块用于在Python程序中操作数据库.
该模块本质是一个套接字客户端软件.
Windows安装命令：pip3 install pymysql

基本使用：

  1. # 准备数据库、数据和远程用户：
  2.  
  3. mysql> select * from blog.userinfo;
  4. +----+------+-----+
  5. | id | name | pwd |
  6. +----+------+-----+
  7. |  1 | zyk  | ___ |
  8. +----+------+-----+
  9. 1 row in set (0.00 sec)
  10.  
  11. mysql> show grants for ‘zyk‘@‘%‘;
  12. +------------------------------------------+
  13. | Grants for zyk@%                         |
  14. +------------------------------------------+
  15. | GRANT ALL PRIVILEGES ON *.* TO ‘zyk‘@‘%‘ |
  16. +------------------------------------------+
  17. 1 row in set (0.00 sec)
  1. # 实现：使用Python程序实现用户登陆，如果用户存在则登陆成功
  2.  
  3. import pymysql
  4.  
  5. user, pwd = input(‘user:‘), input(‘pwd:‘)
  6.  
  7. # 1. 连接数据库
  8. conn = pymysql.connect(
  9.     host=‘127.0.0.1‘,
  10.     port=3306,
  11.     user=‘zyk‘,
  12.     password=‘user@zyk‘,
  13.     db=‘blog‘,  # 要连接的数据库名称
  14.     charset=‘utf8‘  # 要连接的数据库编码
  15. )
  16.  
  17. # 2. 创建游标
  18. cursor = conn.cursor()
  19.  
  20.  
  21. # 3. 执行sql语句
  22. sql = "select name,pwd from userinfo where name=‘%s‘ and pwd=‘%s‘" % (user, pwd)
  23.  
  24. result = cursor.execute(sql)  # 返回sql查询成功的记录数目（查到一条数据后便停止查询）
  25. # print(result)   # 即：成功返回1，否则0
  26.  
  27.  
  28. # 4. 关闭
  29. cursor.close()  # 关闭游标
  30. conn.close()  # 关闭连接
  31.  
  32. print(‘log in successfully!‘) if result else print(‘logon failure!‘)

关于sql注入

补充：最新版本的pymysql已经不能sql注入了，只要加了 "--" 就会报错.

用户存在，绕过密码

利用sql语句中的注释(--)，注释掉密码的部分.

  1. import pymysql
  2.  
  3. user, pwd = input(‘user:‘), input(‘pwd:‘)
  4.  
  5. # 1. 连接数据库
  6. conn = pymysql.connect(
  7.     host=‘127.0.0.1‘,
  8.     port=3306,
  9.     user=‘zyk‘,
  10.     password=‘user@zyk‘,
  11.     db=‘blog‘,  # 要连接的数据库名称
  12.     charset=‘utf8‘  # 要连接的数据库编码
  13. )
  14.  
  15. # 2. 创建游标
  16. cursor = conn.cursor()
  17.  
  18.  
  19. # 3. 执行sql语句
  20. # sql = "select name,pwd from userinfo where name=‘%s‘ and pwd=‘%s‘" % (user, pwd)
  21.  
  22. # 用户存在，绕过密码
  23. sql = "select name,pwd from userinfo where name=‘%s‘ -- abc‘ and pwd=‘%s‘" % (user, pwd)    # 注意：--后面要有一个空格，‘abc‘为任意字符，后面还要加个单引号
  24. print(sql)
  25.  
  26. result = cursor.execute(sql)  # 返回sql查询成功的记录数目
  27. # print(result)   # 即：成功返回1，否则0
  28.  
  29.  
  30. # 4. 关闭
  31. cursor.close()  # 关闭游标
  32. conn.close()  # 关闭连接
  33.  
  34.  
  35. print(‘log in successfully!‘) if result else print(‘logon failure!‘)
  36.  
  37.  
  38.  
  39. """
  40. 代码输出如下：
  42. user:zyk
  43. pwd:
  44. select name,pwd from userinfo where name=‘zyk‘ -- abc‘ and pwd=‘‘
  45. log in successfully!
  46. """

可见，我们只输入了用户名，并没有输入密码（密码被注释掉了），依然显示登陆成功.

用户不存在，绕过用户与密码

利用or语法，添加一条结果为True的语句，并注释掉密码的部分.

  1. import pymysql
  2.  
  3. user, pwd = input(‘user:‘), input(‘pwd:‘)
  4.  
  5. # 1. 连接数据库
  6. conn = pymysql.connect(
  7.     host=‘127.0.0.1‘,
  8.     port=3306,
  9.     user=‘zyk‘,
  10.     password=‘user@zyk‘,
  11.     db=‘blog‘,  # 要连接的数据库名称
  12.     charset=‘utf8‘  # 要连接的数据库编码
  13. )
  14.  
  15. # 2. 创建游标
  16. cursor = conn.cursor()
  17.  
  18.  
  19. # 3. 执行sql语句
  20. # sql = "select name,pwd from userinfo where name=‘%s‘ and pwd=‘%s‘" % (user, pwd)
  21.  
  22. # 用户不存在，绕过用户与密码
  23. sql = "select name,pwd from userinfo where name=‘%s‘ or 1=1 -- abc‘ and pwd=‘%s‘" % (user, pwd)
  24. print(sql)
  25.  
  26. result = cursor.execute(sql)  # 返回sql查询成功的记录数目
  27. # print(result)   # 即：成功返回1，否则0
  28.  
  29.  
  30. # 4. 关闭
  31. cursor.close()  # 关闭游标
  32. conn.close()  # 关闭连接
  33.  
  34.  
  35. print(‘log in successfully!‘) if result else print(‘logon failure!‘)
  36.  
  37.  
  38.  
  39. """
  40. 代码输出如下：
  42. user:
  43. pwd:
  44. select name,pwd from userinfo where name=‘‘ or 1=1 -- abc‘ and pwd=‘‘
  45. log in successfully!
  46. """

可见，我们并为输入用户名和密码，依然显示登陆成功.

解决sql注入问题

pymysql模块自带解决sql注入的问题，只要我们按照pymysql模块的规定就行.

  1. import pymysql
  2.  
  3. user, pwd = input(‘user:‘), input(‘pwd:‘)
  4.  
  5. # 1. 连接数据库
  6. conn = pymysql.connect(
  7.     host=‘127.0.0.1‘,
  8.     port=3306,
  9.     user=‘zyk‘,
  10.     password=‘user@zyk‘,
  11.     db=‘blog‘,  # 要连接的数据库名称
  12.     charset=‘utf8‘  # 要连接的数据库编码
  13. )
  14.  
  15. # 2. 创建游标
  16. cursor = conn.cursor()
  17.  
  18.  
  19. # 3. 执行sql语句
  20. # sql = "select name,pwd from userinfo where name=‘%s‘ and pwd=‘%s‘" % (user, pwd)
  21. # result = cursor.execute(sql)  # 返回sql查询成功的记录数目
  22. # print(result)   # 即：成功返回1，否则0
  23.  
  24. # 改写为（execute帮我们拼接字符串，我们无需且一定不能再为%s加引号）
  25. sql = ‘select name,pwd from userinfo where name=%s and pwd=%s‘
  26.  
  27. # 改写为（用agrs参数传入用户名及密码）
  28. result = cursor.execute(sql, [user, pwd])
  29.  
  30.  
  31. # 4. 关闭
  32. cursor.close()  # 关闭游标
  33. conn.close()  # 关闭连接
  34.  
  35.  
  36. print(‘log in successfully!‘) if result else print(‘logon failure!‘)

execute的arges参数可以接受list、tuple或dict：
如果args是一个列表或元组，%s可以用作查询中的占位符。
如果args是一个dict， %(name)s可以用作查询中的占位符。

  1. # arges参数为dict时的写法：
  2. sql = ‘select name,pwd from userinfo where name=%(name)s and pwd=%(pwd)s‘
  3. result = cursor.execute(sql, ‘name‘: user, ‘pwd‘: pwd)

commit()

在数据库里增、删、改，只是在内存中操作，所以必须要进行提交，否则插入的数据不但不会生效，还会影响到自增id.

增

  1. import pymysql
  2.  
  3. user, pwd = input(‘user:‘), input(‘pwd:‘)
  4.  
  5.  
  6. conn = pymysql.connect(
  7.     host=‘127.0.0.1‘,
  8.     port=3306,
  9.     user=‘zyk‘,
  10.     password=‘user@zyk‘,
  11.     db=‘blog‘,  # 要连接的数据库名称
  12.     charset=‘utf8‘  # 要连接的数据库编码
  13. )
  14.  
  15. # 创建游标
  16. cursor = conn.cursor()
  17.  
  18.  
  19. # 增
  20. sql = ‘insert into userinfo(name, pwd) values (%s, %s)‘
  21. effect_row = cursor.execute(sql,(user, pwd))
  22. print(effect_row)   # 返回增加的记录数
  23.  
  24. # 同时插入多条数据：executemany()
  25. # effect_row = cursor.executemany(sql, [("张三", ‘123‘), ("李四", ‘456‘)])
  26.  
  27.  
  28. # 一定要记得提交
  29. conn.commit()
  30.  
  31.  
  32. # 关闭
  33. cursor.close()
  34. conn.close()

改

  1. import pymysql
  2.  
  3. new_name = input(‘>>> ‘)
  4.  
  5. conn = pymysql.connect(
  6.     host=‘127.0.0.1‘,
  7.     port=3306,
  8.     user=‘zyk‘,
  9.     password=‘user@zyk‘,
  10.     db=‘blog‘,  # 要连接的数据库名称
  11.     charset=‘utf8‘  # 要连接的数据库编码
  12. )
  13.  
  14. # 创建游标
  15. cursor = conn.cursor()
  16.  
  17.  
  18. # 改
  19. sql = "update userinfo set name=%s where name=‘zyk‘"
  20. effect_row = cursor.execute(sql, new_name)
  21. print(effect_row)   # 返回修改的记录数
  22.  
  23. # 一定要记得提交
  24. conn.commit()
  25.  
  26.  
  27. # 关闭
  28. cursor.close()
  29. conn.close()

删

  1. import pymysql
  2.  
  3. conn = pymysql.connect(
  4.     host=‘127.0.0.1‘,
  5.     port=3306,
  6.     user=‘zyk‘,
  7.     password=‘user@zyk‘,
  8.     db=‘blog‘,  # 要连接的数据库名称
  9.     charset=‘utf8‘  # 要连接的数据库编码
  10. )
  11.  
  12. cursor = conn.cursor()
  13.  
  14.  
  15. # 删
  16. sql = "delete from userinfo where name=‘张三‘ or name=‘李四‘"    # 同时删除多条记录
  17. effect_row = cursor.execute(sql)
  18. print(effect_row)   # 返回删除的记录数
  19.  
  20. # 一定要记得提交
  21. conn.commit()
  22.  
  23.  
  24. # 关闭
  25. cursor.close()
  26. conn.close()

查询数据库

  • fetchone()        # 获取下一行数据，第一次为首行
  • fetchall()        # 获取所有行数据
  • fetchmany(4)        # 获取4行数

表内容如下：
![在这里插入图片描述](http://106.13.73.98/media/ai/2019-03/a9d04dbf-2fee-42ac-89e3-4668738730c0.png)

fetchone()

  1. import pymysql
  2.  
  3. # 连接数据库
  4. conn = pymysql.connect(
  5.     host=‘localhost‘,
  6.     port=3306,
  7.     user=‘zyk‘,
  8.     password=‘user@zyk‘,
  9.     db=‘blog‘,
  10.     charset=‘utf8‘
  11. )
  12.  
  13. # 创建游标
  14. cursor = conn.cursor()
  15.  
  16.  
  17. # 执行sql语句
  18. sql = ‘select * from userinfo‘
  19. cursor.execute(sql)
  20.  
  21.  
  22. # 查询第一行数据
  23. row = cursor.fetchone()
  24. print(row)
  25.  
  26. # 查询第二行数据
  27. row = cursor.fetchone()
  28. print(row)
  29.  
  30.  
  31. # 关闭
  32. cursor.close()
  33. conn.close()
  34.  
  35.  
  36.  
  37. """
  38. 输出：
  40. (1, ‘zyk‘, ‘___‘)
  41. (2, ‘张三‘, ‘123‘)
  42. """

如上：在获取行数据的时候，可以理解为开始。有一个行指针指向第一行，获取一行，他就向下移动一行。所以当行指针移动到最后一行时，便无法在获取到数据了(None)。此时我们可以使用如下方法来移动行指针：

  • cursor.scroll(1, mode=‘relative‘)        # 相对当前位置移动
  • cursor.scroll(2, mode=‘absolute‘)        # 相对绝对位置移动

值1为移动的行数，relative：可指定负数(向上移动)；adsolute：0为第一行；
mode指定的是相对于当前行移动还是?相对于首行移动.??????

fetchall()

  1. import pymysql
  2.  
  3. # 连接数据库
  4. conn = pymysql.connect(
  5.     host=‘localhost‘,
  6.     port=3306,
  7.     user=‘zyk‘,
  8.     password=‘user@zyk‘,
  9.     db=‘blog‘,
  10.     charset=‘utf8‘
  11. )
  12.  
  13. # 创建游标
  14. cursor = conn.cursor()
  15.  
  16.  
  17. # 执行sql语句
  18. sql = ‘select * from userinfo‘
  19. cursor.execute(sql)
  20.  
  21.  
  22. # 获取所有数据
  23. rows = cursor.fetchall()
  24. print(rows)
  25.  
  26.  
  27. # 关闭
  28. cursor.close()
  29. conn.close()
  30.  
  31.  
  32.  
  33. """
  34. 输出：
  36. ((1, ‘zyk‘, ‘___‘), (2, ‘张三‘, ‘123‘), (3, ‘李四‘, ‘456‘))
  37. """

默认情况下，我们获取到的返回值是元组，可使用以下方式来返回字典：

  1. # 在实例化时，将属性cursor设置为：
  2. cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

fetchmany()

  1. import pymysql
  2.  
  3. # 连接数据库
  4. conn = pymysql.connect(
  5.     host=‘localhost‘,
  6.     port=3306,
  7.     user=‘zyk‘,
  8.     password=‘user@zyk‘,
  9.     db=‘blog‘,
  10.     charset=‘utf8‘
  11. )
  12.  
  13. # 创建游标
  14. cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
  15.  
  16.  
  17. # 执行sql语句
  18. sql = ‘select * from userinfo‘
  19. cursor.execute(sql)
  20.  
  21.  
  22. # 获取2条数据
  23. rows = cursor.fetchmany(2)
  24. print(rows)
  25.  
  26.  
  27. # 如果此时想要再获取已经获取过的数据，就需要移动行指针
  28. cursor.scroll(0, mode=‘absolute‘)   # 移动到第一行
  29.  
  30. rows = cursor.fetchall()
  31. print(rows)
  32.  
  33.  
  34. # 关闭
  35. cursor.close()
  36. conn.close()
  37.  
  38.  
  39.  
  40. """
  41. 输出：
  43. [‘id‘: 1, ‘name‘: ‘zyk‘, ‘pwd‘: ‘___‘, ‘id‘: 2, ‘name‘: ‘张三‘, ‘pwd‘: ‘123‘]
  44. [‘id‘: 1, ‘name‘: ‘zyk‘, ‘pwd‘: ‘___‘, ‘id‘: 2, ‘name‘: ‘张三‘, ‘pwd‘: ‘123‘, ‘id‘: 3, ‘name‘: ‘李四‘, ‘pwd‘: ‘456‘]
  45. """

 

 

人生中不可避免的定律

定律一：财富定律
勤劳不一定能够致富，但懒惰一定不能致富.

定律二：忙碌定律
人可以为了自己的梦想而去忙碌，但不能因为你忙碌而失去梦想.

定律三：担心定律
你越是担心的事情越有可能发生.

定律四：执着定律
任何的事情都不可过分执着，无论是风光还是难堪这些都会过去.

定律五：堵住定律
有很多越是输不起的人，越是喜欢下大赌注.

定律六：目标定律
目标太多，最后只会是失去目标，知道自己想要什么的人，能比都想要的人更容易成功.

定律七：方向定律
如果一个人不知道自己要向往哪个码头，那么不管什么风都不会是顺风.

定律八：诱惑定律
凡是抵挡不住诱惑的人，十之八九是没有经历过诱惑的人，这与诱惑大小无关.

定律九：时间定律
时间就是生命，对于男人来说是积累，对于女人来说是消耗.

 

年轻本无价，一身碌碌无为
让无价变为了低价，你应该珍惜自己的机会.

原文: http://106.13.73.98/__/31/

以上是关于Python pymysql -- 2019-08-11 19:26:12的主要内容，如果未能解决你的问题，请参考以下文章

pymysql.err.InterfaceError: (0, '') 对 sql 表进行大量推送时出错

python安装PyMySQL

PyMySQL == 0.7.11，MySQL服务器已经消失[重复]

python如何使用pymysql模块

Python/MySQL（pymysql使用）

Python pymysql模块