脚本之家，脚本语言编程技术及教程分享平台！
分类导航

Python|VBS|Ruby|Lua|perl|VBA|Golang|PowerShell|Erlang|autoit|Dos|bat|

服务器之家 - 脚本之家 - Python - python笔记:mysql、redis操作方法

python笔记:mysql、redis操作方法

2020-11-21 22:08Python教程网 Python

下面小编就为大家带来一篇python笔记:mysql、redis操作方法。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧

模块安装：

数据操作用到的模块pymysql，需要通过pip install pymysql进行安装。

redis操作用的模块是redis，需要通过pip install redis进行安装。

检验是否安装成功：进入到Python命令行模式，输入import pymysql、 import redis ，无报错代表成功；

mysql操作方法如下：

查询数据：fetchone、fetchmany(n)、fetchall()

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
import pymysql
#建立mysql连接,ip、端口、用户名、密码(passwd,不能写成其他，例如：pwd或者p，否则报错)、库名
conn = pymysql.connect(host='127.0.0.1', user='root', passwd='123456', db='szz', port=3306, charset='utf8')
#创建游标
cur = conn.cursor(cursor=pymysql.cursors.DictCursor) #指定cursor的类型为字典，返回结果类型是字典，不再是元组
#执行sql，返回值是int，查询出来的结果有几条
cur.execute('select * from test')
#获取第一条数据,游标cur所在的位置为1，游标从0开始，查询结果类型为：字典
row_1 = cur.fetchone()
cur.scroll(0, mode='absolute')  #将游标移动到初始位置
#获取前n行数据
row_2 = cur.fetchmany(n)
cur.scroll(0, mode='absolute')  #将游标移动到初始位置
#获取所有数据，返回结果类型是：list，里面元素是字典
row_3 = cur.fetchall()
cur.scroll(0, mode='absolute')  #将游标移动到初始位置
print(row_2)
#关闭游标
cur.close()
#关闭连接
conn.close()

增加、更新、删除数据

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
import pymysql
#建立mysql连接
conn = pymysql.connect(host='127.0.0.1', user='root', passwd='123456', db='szz', port=3306, charset='utf8')
#创建游标
cur = conn.cursor(cursor=pymysql.cursors.DictCursor) #指定cursor的类型为字典，返回结果类型是字典，不再是元组
#执行sql
sql = 'insert into test values(5, "断点", "e10adc3949ba59abbe56e057f20f883e")'
sql_update = 'update test set name="薛之谦" where id=2 '
sql_del = 'delete from test where id = 3'
cur.execute(sql_del)
#insert、update、delete语句需要进行commit,否则无法保证修改或者新建的数据
conn.commit()
#关闭游标
cur.close()
#关闭连接
conn.close()

cursor的相对、绝对位置移动

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
import pymysql
#建立mysql连接
conn = pymysql.connect(host='192.168.3.66', user='root', passwd='123456', db='szz', port=3306, charset='utf8')
#创建游标
cur = conn.cursor(cursor=pymysql.cursors.DictCursor) #指定cursor的类型为字典，返回结果类型是字典，不再是元组
num = cur.execute('select * from testlhl')
print(num)                      #返回结果是int类型
 
row_1 = cur.fetchone()       # 此时游标的位置在1，数据库取值从0下标开始,获取数据库第一条数据
cur.scroll(2, mode='absolute')   #absolute绝对位置，直接是将游标从0位置移动到指定的位置2
row_2 = cur.fetchone()       #读取数据库第3条数据，游标在3位置
cur.scroll(2, mode='relative')   #relative相对位置，相对于游标当前所在位置，进行移动，移动1位,游标在4位置，若相对移动的位置超过下标，则报out of range
row_3 = cur.fetchone()       #读取第5条数据
#关闭游标
cur.close()
#关闭连接
conn.close()

mysql的增删改查公共方法，代码如下：

?
1
2
3
4
5
6
7
8
9
10
11
12
def getconn(host, user, passwd, db, sql, port=3306,charset='utf8'):
  conn = pymysql.connect(host=host, user=user, passwd=passwd, port=port, db=db, charset=charset) #建立连接
  cur = conn.cursor(cursor=pymysql.cursors.DictCursor)    #建立游标并指定游标类型
  cur.execute(sql)                      #执行sql
  if sql.startswith('select'):                #判断sql是否是select
    res = cur.fetchone()
  else:
    conn.commit()                      #insert\delete\update语句执行完毕后需要进行commit
    res = 88
  cur.close()                         #关闭游标
  conn.close()                        #关闭连接
  return res

redis操作方法如下：

key的类型是string，进行set操作，模式{key, value},如下：

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
import redis
db = 0
#连接redis,password不简写(否则或报错)，db若不写，则默认操作db0
conn_redis = redis.Redis(host='127.0.0.1', port=6379, password='123456', db=db)
#给redis添加值，传值方式是key-value，key不可重复，value的形式尽量是string，也可以传list、字典，redis内存放的是字节res = conn_redis.set('name', 'testredis')
#print(res)  #返回值是布尔类型，set成功，则返回true
conn_redis.set('days', '[10,4,5,12,44]')
 
#set key值到redis内，且可以设置过期时间，10s
result = conn_redis.setex('session', 'abcder1233@sdfrr', 10)  #单位是s
print(result)  #返回值是布尔类型，set成功，则返回true
 
#批量插入redis，可以写入多个key-valye
conn_redis.mset(a='xiaohei', b='xiaobai', c='xiaohuang')
#设置key时，可以设置文件夹，user文件夹，key:test,value:haha
conn_redis.set('user:test','haha')

获取redis内的数据，通过key值进行获取

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
import redis
import json
db = 0
#连接redis,password不简写(否则或报错)，db若不写，则默认操作db0
conn_redis = redis.Redis(host='127.0.0.1', port=6379, password='123456', db=db)
#获取redis的值，返回结果类型是bytes
res = conn_redis.get('abcd')
#使用decode()将bytes类型转换为字符串：输出>>>>>testredis
new_res = res.decode()
#使用json的loads，将json串(字符串)转换为字典
dic_res = json.loads(new_res)
 
#获取不存在的key，返回结果为None
res1 = conn_redis.get('asdfg')
print(res1.decode())    #输出>>>>>>'NoneType' object has no attribute 'decode'
 
#获取所有的keys,且循环遍历进行输入，使用decode()转换为字符串
list_keys = conn_redis.keys()
for key in list_keys:
  print(key.decode())
 
#获取所有的key中以n开头的key，返回结果类型是list，元素类型是bytes 输出>>>>>[b'nbeee', b'name', b'nest']
print(conn_redis.keys('n*'))

删除redis内的值，通过key删除

?
1
2
3
4
5
6
7
8
9
10
11
import redis
db = 0
#连接redis,password不简写(否则或报错)，db若不写，则默认操作db0
conn_redis = redis.Redis(host='192.168.3.66', port=6379, password='123456', db=db)
#删除存在的key，删除key后，redis内不存在该key，返回结果为1,删除了一个key
res = conn_redis.delete('a')
#删除不存在的key，返回结果为0，没有删除key
res1 = conn_redis.delete('d')
#删除多个key，返回结果n， 删除了几个key就返回数字几
asdf = conn_redis.delete('a', 'b', 'c')
print(asdf)

key的类型是hash，进行set操作，模式：{key，{key1,value}}如下

?
1
2
3
4
5
6
7
8
import redis
db = 0
#连接redis,password不简写(否则或报错)，db若不写，则默认操作db0
conn_redis = redis.Redis(host='192.168.3.66', port=6379, password='123456', db=db)
#hash类型的key，模式{name,{key,value}}，里面key不能重复，返回值为int
res = conn_redis.hset('user_session', 'lhl', 'sunny')
#hash类型的key，添加值时也可以设置文件夹
conn_redis.hset('session:redis_test', 'age', 18)

key的类型是hash，进行get操作，如下

?
1
2
3
4
5
6
7
8
import redis
db = 0
#连接redis,password不简写(否则或报错)，db若不写，则默认操作db0
conn_redis = redis.Redis(host='192.168.3.66', port=6379, password='123456', db=db)
#获取hash类型中的某个name下的某个key对应的value ,获取指定name里面的key的值,返回结果类似是bytes
res = conn_redis.hget('user_session', 'week')
#获取hash类型中name里面所有的key，返回结果是字典>>>>>输出：{b'test': b'sunny', b'week': b'sunny'}
all = conn_redis.hgetall('user_session')

key的类型是hash，进行delete操作，如下

?
1
2
3
4
5
6
7
8
import redis
db = 0
#连接redis,password不简写(否则或报错)，db若不写，则默认操作db0
conn_redis = redis.Redis(host='192.168.3.66', port=6379, password='123456', db=db)
#hash类型的key，删除整个key, delete(name)，返回结果为1
res = conn_redis.delete('user_session')
#hash类型的key，删除指定name里的key,若删除的key或者name不存在，则返回0
res = conn_redis.hdel('user_session', 'week')

redis的set、get公共操作方法如下

?
1
2
3
4
5
6
7
8
def opRedis(host, password, key, value=None, port=6379,db=0):   #redis操作时需要传入key\value
  conn_redis = redis.Redis(host=host, password=password, port=port, db=db)  #获取redis连接
  if value:              #判断value是否传值，如果不为None,则是set
    conn_redis.setex(key, value, 60)  #设置key的过期时间，60s
    res = 88
  else:
    res = conn_redis.get(key).decode()   #将从redis内读取的值，由bytes转换为字符串
  return res

以上这篇python笔记:mysql、redis操作方法就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持服务器之家。

  • Python
  • redis
  • mysql

    • 延伸 · 阅读

    精彩推荐
    最近更新
    编辑推荐
    阅读排行
    热门标签
    2048 　 6006 　 contextlib 　 SLOTS 　 MELIAE 　 FEEDPARSER 　 暂存 　 持久性管理 　 pickle模块 　 THREADING 　 reduce 　 nignx 　 装饰器 　 函数式编程 　 兔子毒药 　 监控文件 　 流量监控 　 Web框架 　 办公工具 　 PIL库 　 高斯模糊 　 wxPython 　 import 　 自定义模块 　 Python开发 　 元类 　 metaclass 　 魔术方法 　 DNSPod 　 动态解析域名 　
    © 2019-2023 脚本之家 | 服务器之家(www.zzvips.com)旗下站点 版权所有关于我们联系我们版权申明网站地图