redis4qt.h

#ifndef REDIS4QT_H
#define REDIS4QT_H

#include "redis4qt_global.h"
#include "redis_types.h"
#include <QObject>
#include <QMutex>
#include <QSettings>

using namespace Redis4Qt_Types;

class RedisCore;
class QTimer;

struct ThreadRedis
{
    QMutex*      lock;
    QThread*     thread;
    RedisCore* core;
};

class REDIS4QTAPI Redis4Qt : public QObject
{
    Q_OBJECT
public:
    Redis4Qt();
    ~Redis4Qt();
    void setRedisCof(QString strCfg);

    int key_del(QString key, bool *error = NULL);

    QString key_dump(QString key, bool *error = NULL);

    bool key_exists(QString key, bool *error = NULL);

    bool key_expire(QString key,int seconds, bool *error = NULL);

    bool key_expireat(QString key, qint64 timestamp, bool *error = NULL);

    QStringList keys(QString pattern, bool *error = NULL);

    int key_pttl(QString key, bool *error = NULL);

    int key_ttl(QString key, bool *error = NULL);

    bool key_rename(QString key, QString newkey, bool *error = NULL);

    QString key_type(QString key, bool *error = NULL);


    bool string_set(QString key, QString value, bool *error = NULL);

    QString string_get(QString key, bool *error = NULL);

    QString string_getrange(QString key, int start, int stop, bool *error = NULL);

    QStringList string_mget(QStringList keys, bool *error = NULL);

    bool string_mset(QMap<QString, QVariant> map, bool *error = NULL);

    int string_incr(QString key, bool *error = NULL);

    int string_incrby(QString key,int interval, bool *error = NULL);

    int string_decr(QString key, bool *error = NULL);

    int string_decrby(QString key,int interval, bool *error = NULL);

    int string_append(QString key, QString value, bool *error = NULL);


    QStringList list_blpop(QString key, int timeout, bool *error = NULL);

    QStringList list_brpop(QString key, int timeout, bool *error = NULL);

    QStringList list_brpoplpush(QString source, QString destination, int timeout, bool *error = NULL);

    QString list_index(QString key, int index, bool *error = NULL);

    int list_insert(QString key, QString position, QString pivot, QString value, bool *error = NULL);

    int list_len(QString key, bool *error = NULL);

    QString list_lpop(QString key, bool *error = NULL);

    int list_lpush(QString key, QString value, bool *error = NULL);

    int list_lpush(QString key, QStringList values, bool *error = NULL);

    int list_lpushx(QString key, QStringList values, bool *error = NULL);

    QStringList list_range(QString key, int start, int end, bool *error = NULL);

    int list_rem(QString key, int count, QString value, bool *error = NULL);

    int list_set(QString key, int index, QString value, bool *error = NULL);

    bool list_trim(QString key, int start, int stop, bool *error = NULL);

    QString list_rpop(QString key, bool *error = NULL);

    QString list_rpoplpush(QString source, QString destination, bool *error = NULL);

    int list_rpush(QString key, QString value, bool *error = NULL);

    int list_rpush(QString key, QStringList values, bool *error = NULL);

    int list_rpushx(QString key, QStringList values, bool *error = NULL);


    int set_add(QString key, QString member, bool *error = NULL);

    int set_add(QString key, QStringList members, bool *error = NULL);

    int set_card(QString key, bool *error = NULL);

    QStringList set_diff(QStringList keys, bool *error = NULL);

    int set_diffstore(QString destination, QStringList keys, bool *error = NULL);

    QStringList set_inter(QStringList keys, bool *error = NULL);

    int set_interstore(QString destination, QStringList keys, bool *error = NULL);

    bool set_ismember(QString key, QString member, bool *error = NULL);

    QStringList set_members(QString key, bool *error = NULL);

    bool set_move(QString source, QString destination, QString member, bool *error = NULL);

    QString set_pop(QString key, bool *error = NULL);

    QStringList set_randmember(QString key, bool *error = NULL);

    QStringList set_randmember(QString key, int count, bool *error = NULL);

    int set_rem(QString key, QString member, bool *error = NULL);

    int set_rem(QString key, QStringList members, bool *error = NULL);

    QStringList set_union(QStringList keys, bool *error = NULL);

    int set_unionstore(QString destination, QStringList keys, bool *error = NULL);


    int hash_del(QString key, QString field, bool *error = NULL);

    int hash_del(QString key, QStringList fields, bool *error = NULL);

    bool hash_exists(QString key, QString field, bool *error = NULL);

    QString hash_get(QString key, QString field, bool *error = NULL);

    QVariantMap hash_getall(QString key, bool *error = NULL);

    int hash_incrby(QString key, QString field, int increment, bool *error = NULL);

    float hash_incrbyfloat(QString key, QString field, float increment, bool *error = NULL);

    QStringList hash_keys(QString key, bool *error = NULL);

    int hash_len(QString key, bool *error = NULL);

    QStringList hash_mget(QString key, QStringList fields, bool *error = NULL);

    bool hash_mset(QString key, QMap<QString,QVariant> map, bool *error = NULL);

    bool hash_set(QString key, QString field, QString value, bool *error = NULL);

    bool hash_setnx(QString key, QString field, QString value, bool *error = NULL);

    QStringList hash_values(QString key, bool *error = NULL);

    void publish(QString channel, QString message, bool *error = NULL);

    void subscribe(QString channel, bool *error = NULL);

    void unsubscribe(QString channel, bool *error = NULL);

    void psubscribe(QString channel, bool *error = NULL);

    void punsubscribe(QString channel, bool *error = NULL);

    int getLastError();

private:
    RedisCore *getRedisInstance();
    bool validKey(QString &key, QString funcName, bool *error);
    bool validKeys(QStringList &key, QString funcName, bool *error);
    void setLastError(int error);
    QVariant dealwithCmd(FuncType type, QVariantList &data, bool *error);
    QVariant excuteCmd(FuncType type, RedisCore* redis, QVariantList &data);

private:
    QString                 m_redisHost;
    qint16                  m_redisPort;
    int                     m_redisCmdTimeout;
    QMap<void *, ThreadRedis>  m_redis;
    QSettings    *m_Settings;
    QMutex                  m_Lock;
};

#endif // REDIS4QT_H