DbAdapterRedis.hpp

Go to the documentation of this file.

#ifndef RAD_DB_ADAPTER_REDIS_HPP
#define RAD_DB_ADAPTER_REDIS_HPP

#include <rad/DbAdapter.hpp>

#include <hiredis.h>

#include <string>
#include <vector>
#include <map>

namespace rad {

class DbAdapterRedis : public DbAdapter
{
public:
    DbAdapterRedis();
    DbAdapterRedis(const std::string& ipaddr, const int port, const timeval& timeout);
    virtual ~DbAdapterRedis();

    void            Config(const std::string& endpoint, const timeval& timeout);

    int             Delete(const std::vector<std::string>& keys);
    bool            Exists(const std::string& key);

    std::string     Get(const std::string& key);
    std::vector<std::string> MultiGet(const std::vector<std::string>& keys);
    std::string     Get(const std::string& key, const std::string& field);
    std::vector<std::string> MultiGet(const std::string& key, const std::vector<std::string>& fields);
    std::map<std::string,std::string> Scan(const std::string& key, const std::string& pattern);

    void            Set(const std::string& key, const std::string& value);
    void            MultiSet(const std::vector<std::string>& kvs);
    void            Set(const std::string& key, const std::string& field, const std::string& value);
    void            MultiSet(const std::string& key, const std::vector<std::string>& fvs);

    void            Connect();
    void            Disconnect();
    bool            IsConnected();

    DbAdapterRedis(const DbAdapterRedis&) = delete;             
    DbAdapterRedis& operator= (const DbAdapterRedis&) = delete; 

private:
    bool            mIsConnected;
    std::string     mIpAddr;
    int             mPort;
    timeval         mTimeout;
    redisContext*   mContext;
};

} // namespace rad

#endif