P8：python和MySQL在一起啦！

Posted 2021-04-06 冲哥说Excel

一、本期任务：

1、通过python+mysql实现数据库表格记录的读取（延伸：用于账号登录的验证）

2、账号信息存放于在MySQL数据库下

在上一期视频（P7）中，我们利用31行代码，创建一个class类（两个方法）的方式，实现了账号登录与验证。

本期继续优化，利用17行代码，通过访问MySQL中存放的数据来进行登录账号的验证。

二、pymysql模块相关知识点：

1.连接、关闭（游标）

2.execute()  ——防止SQL注入

3.增删改：conn.comiit()提交

4.fectchone\fetchmany\fetchall的区别

5.获取新增数据的自增ID

三、操作前提：安装pymysql工具

在命令窗口，通过pip3 install pymysql命令来进行安装，提示successful即可。

四、连接并创建数据库

#导入pymysql工具
import pymysql
#连接数据库服务器
conn = pymysql.connect('127.0.0.1','root','password')
#创建游标对数据库进行操作
cursor = conn.cursor()
#创建数据库(指定字符集，对出现中文的可防止乱码)
sql = '''
create database MyBase default character set utf8
default collate utf8_general_ci
'''
#执行创建后关闭
cursor.execute(sql)
cursor.close()

运行结果：Process finished with exit code 0

五、创建指定数据库下的表格

import pymysql
conn = pymysql.connect('127.0.0.1','root','password','MyBase')
cursor = conn.cursor()
sql ="create table px_plan(id int(3),
name varchar(4),content varchar(15),
px_type varchar(10),px_time varchar(8))"
cursor.execute(sql)
cursor.close()

运行结果：Process finished with exit code 0

六、在指定表格中插入数据

注意：在增删改（update、delete、insert）操作时，需用commit()进行提交，才能成功保存。否则，mysql中不会更新的。

1）通过“常量”来增加：

import pymysql
conn = pymysql.connect('127.0.0.1','root','password','MyBase')
cursor = conn.cursor()
sql = "insert into px_plan(id,name,
content,px_type,px_time) values(1,
'李世民','TS','复证','待定'),(2,
'李隆基','DT-1','取证','待定')



cursor.execute(sql)
conn.commit()
cursor.close()
conn.close()

运行结果：
Process finished with exit code 0

2）通过变量来增加：

 
   
   
 

  
    
    
  import pymysql
id = "3"
name = "刘备"
content = "RS"
px_type = "取证"
px_time = "2020年11月"
conn = pymysql.connect('127.0.0.1','root','666666','MyBase')
cursor = conn.cursor()
sql = "insert into px_plan(id,name,content,px_type,px_time) values(%s,%s,%s,%s,%s)"
cursor.execute(sql,[id,name,content,px_type,px_time])
#增删改，需要commit提交:update\delete\insert
conn.commit()
cursor.close()
conn.close()
 
   
   
 
 
   
   
 

  
    
    
  

 
   
   
 
 
   
   
 

  
    
    
  查询结果：
 
   
   
 
 
   
   
 

  
 
   
   
 
 
   
   
 

  
    
    
  

 
   
   
 

注：

1）在insert中，也可用executemanny提交多条记录：

sql = "insert into px_plan(id,name) values(%s,%s)"
cursor.executemanny(sql,[("4","关羽"),("5","张飞")])

若r=cursor.executemanny(sql,[("4","关羽"),("5","张飞")])，则：r是受影响额行数。

2）新增数据的自增id。cursor.lastrowid可拿到新增记录的id，如：

conn.commit()

print( cursor.lastrowid )

即可实现

七、查询mysql表格记录

 
   
   
 

  
    
    
  #查询所有数据
import pymysql
conn = pymysql.connect('127.0.0.1','root','password','MyBase')
cursor = conn.cursor()
 
   
   
 
 
   
   
 

  
    
    
  sql="select * from px_plan"

 
   
   
 
 
   
   
 

  
    
    
  cursor.execute(sql)
result = cursor.fetchall()
print(result)
cursor.close()
 
   
   
 
 
   
   
 

  
    
    
  

 
   
   
 
 
   
   
 

  
    
    
  查询结果：
 
   
   
 
 
   
   
 

  
    
    
  ((1, '李世民', 'TS', '复证', '待定'), (2, '李隆基', 'DT-1', '取证', '待定'), (3, '刘备', 'RS', '取证', '2020年11月'))
 
   
   
 
 
   
   
 

  
    
    
  Process finished with exit code 0
 
   
   
 

 八、案例分享：账号登录与验证（17行代码）

利用MySQL存放登录账户信息，方便进行登录验证。

在MySQL中的MyBase数据库下，有一个userinfo表格，存放着登录账户的信息，如下图：

 
   
   
 

  
    
    
  1 import pymysql
 
   
   
 

  
    
    
  

   
     
     
   2 while True:
3 user = input("用户名：")
4 pwd = input("密码：")
5 conn = pymysql.connect('127.0.0.1','root','password','MyBase')
6 cursor = conn.cursor()
7 sql = "select * from userinfo where username=%s and pswd=%s"
  
    
    
  

  
    
    
  

   
     
     
   8 cursor.execute(sql,[user,pwd])
  
    
    
  
  
    
    
  

   
     
     
   9 result = cursor.fetchone()
10 cursor.close()
11 conn.close()
12 if not result:
13 print("登录失败！")
14 continue
15 else:
16 print("登录成功！")

  
    
    
  
  
    
    
  

   
     
     
   17 break
  
    
    
  
  
    
    
  

   
     
     
   

  
    
    
  
 
   
   
 

  
    
    
  查询结果：
 
   
   
 
 
   
   
 

  
    
    
  用户名：liubei
 
   
   
 
 
   
   
 

  
    
    
  密码：222
 
   
   
 
 
   
   
 

  
    
    
  select * from userinfo where username='liubei' and pswd='222'
 
   
   
 
 
   
   
 

  
    
    
  登录失败！
 
   
   
 
 
   
   
 

  
    
    
  用户名：liubei
 
   
   
 
 
   
   
 

  
    
    
  密码：111
 
   
   
 
 
   
   
 

  
    
    
  select * from userinfo where username='liubei' and pswd='111'
 
   
   
 
 
   
   
 

  
    
    
  登录成功！
 
   
   
 
 
   
   
 

  
    
    
  

 
   
   
 
 
   
   
 

  
    
    
  Process finished with exit code 0
 
   
   
 

注意：

1.select语句中，为避免字符串拼接和防止sql注入,可将变量放在execute()语句中，比如：cursor.execute(sql,[user,pwd])

2.result = cursor.fetchone()中，fetchone每次只拿一条记录。如：检测用户名密码时，用fetchone，只需取一条记录。

3.fetchmany(n),代表一次取n条记录。取一次，指针跳转到下一次n处。

4.fetchall,取出所有记录（元组）。分页显示数据，可用fetchall，然后用sql语句limit分页。

显示如下：((1, '李世民', 'TS', '复证', '待定'),(2, '李隆基', 'DT-1', '取证', '待定'))。

若希望显示成字典的形式，可更改：

cursor = conn.cursor()

为：

 
   
   
 

  
    
    
  cursor = conn.cursor(cursor=pymysql.cursors.
  
    
    
  DictCursor
  
    
    
  )
 
   
   
 

结果：

[{'id': 1, 'name': '李世民', 'content': 'TS', 'px_type': '复证', 'px_time': '待定'}, {'id': 2, 'name': '李隆基', 'content': 'DT-1', 'px_type': '取证', 'px_time': '待定'}, {'id': 3, 'name': '刘备', 'content': 'RS', 'px_type': '取证', 'px_time': '2020年11月'}]