pymyspl模块

  • 2020 年 1 月 19 日
  • 筆記

pymysql的下载和使用

  该模块本质就是一个套接字客户端软件,使用前需要事先安装,能够让我们在

  Python程序中操作数据库.

  pymysql模块的下载:

  在Python安装文件中找到scripts文件 shift+右键打开powershell,接着如下图:

  pymysql的使用 (数据均已存在)

实现:

#导入模块  import pymysql    username = input('请输入用户名:')  password = input('请输入密码:')    #创建连接  conn = pymysql.connect(      host = '127.0.0.1',      user = 'root',      database = 'db1',      port = 3306,      charset = 'utf8'  )  #创建游标  cur = conn.cursor()  sql = 'select * from login where name = "%s" and password = %s ' %(username,password)  #注意 name 在创建的表中未vachar类型 ,所以必选要加 "" .  print(sql)    rescount = cur.execute(sql)#执行sql语句,返回sql查询成功的记录数目  print(rescount)    if rescount:      print('成功')  else:      print('失败')  #关闭连接,游标  cur.close()  conn.close

  注意 : — + 空格 为注释

  前端是不安全的,在上述的操作中存在漏洞,

  正确解决方法为:

#导入模块  import pymysql    username = input('请输入用户名:')  password = input('请输入密码:')    #创建连接  conn = pymysql.connect(      host = '127.0.0.1',      user = 'root',      database = 'db1',      port = 3306,      charset = 'utf8'  )  #创建游标  cur = conn.cursor()  sql = 'select * from login where name = %s and password = %s '  #注意 name 在此时不能再加 "" .  print(sql)    rescount = cur.execute(sql,[username,password])  #由我们对sql进行字符串拼接改为execute帮我们做字符串拼接,可以是列表 元祖 字典.pymysql模块自动帮我们解决sql注入问题.  print(rescount)    if rescount:      print('成功')  else:      print('失败')  #关闭  cur.close()  conn.close

  注意:当为字典时:

增 删 改 (conn.commit())

 commit() 方法:在数据库里增删改的时候,必须进行提交,否则插入的数据不生效.

import pymysql  username = input('请输入用户名:')    pwd = input('请输入密码:')        # 1.连接  conn = pymysql.connect(host='localhost', port=3306, user='root', password='', db='db1', charset='utf8')      # 2.创建游标  cursor = conn.cursor()      # 操作  # 增  # sql = "insert into userinfo(username,password) values (%s,%s)"      # effect_row = cursor.execute(sql,(username,password))  #同时插入多条数据  #cursor.executemany(sql,[('李四','110'),('王五','119')])    # print(effect_row)#    # 改  # sql = "update userinfo set username = %s  where id = 2"  # effect_row = cursor.execute(sql,username)  # print(effect_row)      # 删  sql = "delete from userinfo  where id = 2"  effect_row = cursor.execute(sql)  print(effect_row)      #一定记得commit  conn.commit()    # 4.关闭游标  cursor.close()    # 5.关闭连接  conn.close()

查  fetchone , fetchmany , fetchall 

fetchone():获取下一行数据,第一次为首行;  fetchall():获取所有行数据源  fetchmany(4):获取4行数据

  查看一下表内容:

#导入模块  import pymysql    #创建连接  conn = pymysql.connect(      host = '127.0.0.1',      user = 'root',      database = 'db1',      port = 3306,      charset = 'utf8'  )  #创建游标  cur = conn.cursor(cursor=pymysql.cursors.DictCursor)#加入此句可以让结果以字典的形式呈现.  #cur = conn.cursor()#默认我们获取到的返回值是元祖,只能看到每行的数据,却不知到每一列  #代表的是什么.  sql = 'select * from login'  print(sql)    rescount = cur.execute(sql)  print(rescount)    # row = cur.fetchone()  # print(row)  # row = cur.fetchone()#上一条查询后光标会向下移动  # print(row)  row1 = cur.fetchall()#查出所有结果  print(row1)  #fetchmany....  #关闭  cur.close()  conn.close

   在fetchone示例中,在获取行数据的时候,可以理解开始的时候,有一个行指针指着第一行的上方,

  获取一行,它就向下移动一行,所以当行指针到最后一行的时候,就不能再获取到行的内容,所以

  我们可以使用如下方法来移动行指针

cursor.scroll(1,mode='relative')  # 相对当前位置移动  cursor.scroll(2,mode='absolute') # 相对绝对位置移动  第一个值为移动的行数,整数为向下移动,负数为向上移动,mode指定了是相对当前位置移动,还是相对于首行移动
# 1.Python实现用户登录  # 2.Mysql保存数据    import pymysql    # 1.连接  conn = pymysql.connect(host='localhost', port=3306, user='root', password='', db='db8', charset='utf8')      # 2.创建游标  cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)    sql = 'select * from userinfo'  cursor.execute(sql)      # 查询第一行的数据  row = cursor.fetchone()  print(row) # (1, 'mjj', '123')    # 查询第二行数据  row = cursor.fetchone() # (3, '张三', '110')  print(row)    cursor.scroll(-1,mode='relative') #设置之后,光标相对于当前位置往前移动了一行,所以打印的结果为第二行的数据  row = cursor.fetchone()  print(row)    cursor.scroll(0,mode='absolute') #设置之后,光标相对于首行没有任何变化,所以打印的结果为第一行数据  row = cursor.fetchone()  print(row)    # 4.关闭游标  cursor.close()    # 5.关闭连接  conn.close()    #结果如下    {'id': 1, 'username': 'mjj', 'pwd': '123'}  {'id': 3, 'username': '张三', 'pwd': '110'}  {'id': 3, 'username': '张三', 'pwd': '110'}  {'id': 1, 'username': 'mjj', 'pwd': '123'}