day15-pymysql模块的使用

# 实现：使用Python实现用户登录，如果用户存在则登录成功（假设该用户已在数据库中）


import pymysql
# user = input('请输入用户名：')
#
# pwd = input('请输入密码：')



# 1.连接
conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', password='123456', db='sxl', charset='utf8')


# 2.创建游标
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

#注意%s需要加引号   有sql注入问题li' or 1=1 -- zdxv  或lijie' -- zdxv
# sql = "select * from userinfo where name='%s' and pwd='%s'" %(user, pwd)  #注意修改内容及表
# print(sql)
# #解决sql注入问题
# sql="select * from userinfo where name=%s and pwd=%s" #！！！注意%s需要去掉引号，因为pymysql会自动为我们加上
# result=cursor.execute(sql,[user,pwd]) #pymysql模块自动帮我们解决sql注入的问题，只要我们按照pymysql的规矩来。

# 3.执行sql语句
# cursor.execute(sql)
# result=cursor.execute(sql) #执行sql语句，返回sql查询成功的记录数目
# print(result)


# #1.增加数据
# sql = "insert into userinfo(name,pwd) values (%s,%s)"
# # effect_row = cursor.execute(sql,(123,123))
# #同时插入多条数据
# # effect_row = cursor.executemany(sql,[('李四','110'),('王五','119')])
# # print(effect_row)
# # 2.改
# sql = "update userinfo set name = %s  where id = 4"
# effect_row = cursor.execute(sql,'111')
# print(effect_row)
# # 3.删
# sql = "delete from userinfo  where id >13"
# effect_row = cursor.execute(sql)
# print(effect_row)
# 4.查
sql = 'select * from userinfo'
num = cursor.execute(sql)  #11
# # 4.1fetchone():获取下一行数据，第一次为首行；
# #查询第一行的数据
# row = cursor.fetchone()
# print(row) # (1, 'lijie', '123')
# # 查询第二行数据
# row = cursor.fetchone()
# print(row) # (3, 'zz', '123')
# 4.2fetchall():获取所有的数据
# rows = cursor.fetchall()
# print(rows) #((1, 'lijie', '123'), (3, 'zz', '123'), (5, '王五', '119'), (6, '123', '123'))
#注1：在实例化的时候，将属性cursor设置为pymysql.cursors.DictCursor,每一行的数据都会生成一个字典
#[{'id': 1, 'name': 'lijie', 'pwd': '123'}, {'id': 3, 'name': 'zz', 'pwd': '123'}, {'id': 5, 'name': '王五', 'pwd': '119'}, {'id': 6, 'name': '123', 'pwd': '123'}]
# #注2：在fetchone示例中，在获取行数据的时候，可以理解开始的时候，有一个行指针指着第一行的上方，获取一行，它就向下移动一行，所以当行指针到最后一行的时候，就不能再获取到行的内容，所以我们可以使用如下方法来移动行指针：
# cursor.scroll(1,mode='relative')  # 相对当前位置移动
# cursor.scroll(3,mode='absolute') # 相对绝对位置移动 以第一行为参考
# # 第一个值为移动的行数，整数为向下移动，负数为向上移动，mode指定了是相对当前位置移动，还是相对于首行移动
row = cursor.fetchone()
print(row) # {'id': 1, 'name': 'lijie', 'pwd': '123'}  原始数据是135678
cursor.scroll(1,mode='relative')
row = cursor.fetchone()
print(row) # {'id': 5, 'name': '王五', 'pwd': '119'}
cursor.scroll(0,mode='absolute') #设置之后，光标相对于首行没有任何变化，所以打印的结果为第一行数据
row = cursor.fetchone()
print(row) # {'id': 1, 'name': 'lijie', 'pwd': '123'}
cursor.scroll(1,mode='absolute')
row = cursor.fetchone()
print(row) # {'id': 3, 'name': 'zz', 'pwd': '123'}
cursor.scroll(-1,mode='relative') #设置之后，光标相对于当前位置往前移动了一行
row = cursor.fetchone()
print(row) # {'id': 3, 'name': 'zz', 'pwd': '123'}
#4.3 fetchmany(4):获取4行数据
# row = cursor.fetchmany(2)
# print(row) # [{'id': 1, 'name': 'lijie', 'pwd': '123'}, {'id': 3, 'name': 'zz', 'pwd': '123'}]



#在数据库里增、删、改的时候,一定记得commit
conn.commit()





# 关闭连接，游标和连接都要关闭
cursor.close()
conn.close()

# if result:
#     print('登陆成功')
# else:
#     print('登录失败')