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'}
