封装redis

Posted 2020-11-10 彼得潘jd

import  redis
class MyRedis():
    def __init__(self,ip,password,port=6379,db=10): #构造函数
        try:

            self.r=redis.Redis(host=ip,password=password,port=port,db=db)

        except Exception as e:
            print(‘redis连接失败,错误信息%s‘%e)

    def str_get(self, k):
        res = self.r.get(k)  # r连接数据库
        if res:
            return res.decode()

    def str_set(self,k,v,time=None):
        self.r.set(k,v,time)

    def str_delete(self, k):
        tag=self.r.exists(k) #判断这个key是否存在
        if tag:
            self.r.delete(k)
            print(‘删除成功‘)
        else:
            print(‘KEY不存在‘)

    def hash_get(self, name, k):
        res = self.r.hget(name, k)
        if res:
            return res.decode()

    def hash_set(self, name, k, v):
        self.r.hset(name, k, v)

    def hash_getall(self, name):
        data= {}
        res = self.r.hgetall(name)
        if res:
            for k, v in res.items():  # 字典变成decode
                k=k.decode()
                v=v.decode()
                data[k] = v
        return data

    def hash_del(self,name,k):
        res=self.r.hdel(name,k)
        if res:
            print(‘删除成功‘)
            return 1
        else:
            print(‘删除失败,该KEY不存在‘)
            return 0

    @property #属性方法
    def clean_redis(self):
        self.r.flushdb()  # 清空redis
        print(‘清空redis成功!‘)
        return 0



my=MyRedis(‘XXX.XXX.XXX.XXX‘,‘XXXXXX‘)
my.str_set(‘jd5‘,‘test5‘)
print(my.str_get(‘jd5‘))
my.str_delete(‘jd4‘)
my.hash_set(‘测试‘,‘测试1‘,‘10000‘)
print(my.hash_get(‘测试‘,‘测试1‘))
my.hash_getall(‘测试‘)
my.hash_del(‘测试‘,‘测试1‘)my.clean_redis