利用Navicat Premium 15软件连接mysql数据库，新建testdb数据库，并添加2个表usertest和userinfo。
main.py
#!/usr/bin/python3
# -*- coding: utf-8 -*-
import reimport pymysql # 导入模块myConn = pymysql.connect(host='127.0.0.1', # 主机模块port=3306, # 端口号user='root', # 用户名password='root', # 密码database='testdb', # 需要连接的数据库charset='utf8' # 指定编码utf8
)if __name__ == '__main__':# myCursor = myConn.cursor() # 获取游标，默认游标类型为元组形式myCursor = myConn.cursor(pymysql.cursors.DictCursor) # 获取的查询结果更加规范化 便于分辨sql = "select * from userTest;"row_count = myCursor.execute(sql) # row_count 受影响的行数for x in myCursor.fetchall(): # 取出所有的print(x)try:# ===插入记录===sql = "INSERT INTO userTest(id,name,age) VALUES(%s, %s, %s)"val = (6, "John", 23)myCursor.execute(sql, val) # 执行sql语句"""val = [(7, "Lily", 30),(8, "Martin", 35),(9, "Sally", 32)]myCursor.executemany(sql, val) # 插入多行数据时,执行sql语句"""# ===修改记录===# 以字符串形式书写SQL语句sql = "update userTest set name = '刘琪' where name = '韩寒'; "# 执行SQL语句row_count = myCursor.execute(sql)# ===删除记录===# 以字符串形式书写SQL语句sql = "delete from userTest where name= '王五' ;"# 执行SQL语句row_count = myCursor.execute(sql)myConn.commit() # 增删改操作时,需要进行提交except Exception as err:# 检查异常原因是否是感兴趣的result1 = re.search('Duplicate entry.*key.*PRIMARY', str(err))# 如果是，什么都不用做# 否则（也不知道是什么原因），那就回滚吧if result1 is None:myConn.rollback()raisemyCursor = myConn.cursor(pymysql.cursors.DictCursor) # 获取的查询结果更加规范化 便于分辨sql = "select * from userTest;"row_count = myCursor.execute(sql) # row_count受影响的行数for x in myCursor.fetchall(): # 取出所有的print(x)# =====使用数据来进行一下用户名和密码的认证操作======myCursor = myConn.cursor(pymysql.cursors.DictCursor)usr = input('请输入用户名：').strip()pwd = input('请输入密码：').strip()# 当已知用户名时 破解密码为 (feng'-- dfadasdad)# 当未知用户名密码时 破解密码为 (fsdf' or 1=1 -- fdsfsdfs)try:sql = "select * from userinfo where username='%s' and password='%s';" % (usr, pwd)# res我们说是得到的行数，如果这个行数不为零，说明用户输入的用户名和密码存在，如果为0说明不存在row_count = myCursor.execute(sql) # pymysql 模块会自动将输入的特殊字符删除print(row_count) # 如果输入的用户名和密码错误，这个结果为0，如果正确，这个结果为1if row_count:print('登陆成功')else:print('用户名和密码错误！')except Exception as err:# 检查异常原因是否是感兴趣的result1 = re.search('Duplicate entry.*key.*PRIMARY', str(err))# 如果是，什么都不用做# 否则（也不知道是什么原因），那就回滚吧if result1 is None:myConn.rollback()raisemyCursor.close() # 关闭游标myConn.close() # 关闭连接
