#ifndef DBCACHE_H
#define DBCACHE_H

#include <QObject>
#include <QSqlDatabase>
#include <QString>
#include <QHash>
#include <QVector>
#include <QVariant>
#include <hiredis.h>


class DBCache : public QObject
{
    Q_OBJECT
public:
    explicit DBCache(QObject *parent = nullptr);
    ~DBCache();


    // 初始化数据库连接
    bool initMySQL(const QString &host, int port,
                   const QString &user, const QString &password,
                   const QString &database);
    bool initRedis(const QString &host, int port,
                   const QString &password = "");

    // 执行查询，优先从Redis获取
    QVector<QHash<QString, QVariant>> query(const QString &sql);

    // 清除缓存
    void clearCache();

private:
    // Redis连接
    redisContext *m_redisContext;

    // MySQL连接
    QSqlDatabase m_mysqlDB;

    // 生成查询的哈希键
    QString generateCacheKey(const QString &sql) const;

    // 从Redis获取数据
    QVector<QHash<QString, QVariant>> getFromRedis(const QString &key);

    // 将数据存入Redis
    bool setToRedis(const QString &key,
                    const QVector<QHash<QString, QVariant>> &data);

    // 从MySQL查询数据
    QVector<QHash<QString, QVariant>> queryMySQL(const QString &sql);
};

#endif // DBCACHE_H