sqlitedbcache.cpp

Go to the documentation of this file.

/*
 * Copyright (C) 2018-2024 QuasarApp.
 * Distributed under the lgplv3 software license, see the accompanying
 * Everyone is permitted to copy and distribute verbatim copies
 * of this license document, but changing it is not allowed.
*/
 
#ifdef HEART_DB_CACHE
 
#include "asyncsqldbwriter.h"
#include "sqlitedbcache.h"
#include <QThread>
 
namespace QH {
 
// Private implementation.
class SQLiteDBCachePrivate: public AsyncSqlDBWriter {
 
public:
    SQLiteDBCachePrivate():
        AsyncSqlDBWriter() {
        thread()->setObjectName("DBCache");
    }
 
    // SqlDBWriter interface
protected:
    QSqlDatabase initSqlDataBasse(const QString &driverName,
                                  const QString &name) override;
 
    bool initDb(const QVariantMap &params) override;
 
    friend class SQLiteDBCache;
};
 
QSqlDatabase SQLiteDBCachePrivate::initSqlDataBasse(const QString &driverName,
                                                    const QString &name) {
 
    return QSqlDatabase::addDatabase(driverName,
                                     name + "::memory:");
 
}
 
bool SQLiteDBCachePrivate::initDb(const QVariantMap &params) {
 
    if (params.value("DBDriver").toString() != "QSQLITE") {
        QuasarAppUtils::Params::log(" the SQLiteDBCache class support only the QSQLITE driver.",
                                    QuasarAppUtils::Error);
        return false;
    }
 
    return SqlDBWriter::initDb(params);
}
 
// Main class members.
SQLiteDBCache::SQLiteDBCache() {
    _private = new SQLiteDBCachePrivate();
}
 
SQLiteDBCache::~SQLiteDBCache() {
    delete _private;
}
 
bool SQLiteDBCache::init(const QVariantMap &params) {
 
    if (!ISqlDBCache::init(params)) {
        return false;
    }
 
    return _private->initDb(params);
}
 
void SQLiteDBCache::deleteFromCache(const QSharedPointer<PKG::DBObject> &delObj) {
    _private->deleteObject(delObj, true);
}
 
bool SQLiteDBCache::insertToCache(const QSharedPointer<PKG::DBObject> &obj) {
    return _private->insertObject(obj, true);
}
 
bool SQLiteDBCache::updateCache(const QSharedPointer<PKG::DBObject> &obj) {
    return _private->updateObject(obj, true);
}
 
QList<QSharedPointer<QH::PKG::DBObject>>
SQLiteDBCache::getFromCache(const PKG::DBObject *obj) {
 
    QList<QSharedPointer<QH::PKG::DBObject>> list;
    if (!_private->getAllObjects(*obj, list)) {
        return QList<QSharedPointer<QH::PKG::DBObject>>{};
    };
 
    return list;
}
 
}
 
#endif