sqldbwriter.h

Go to the documentation of this file.

/*
 * Copyright (C) 2018-2025 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.
*/
 
#ifndef SQLDBWRITER_H
#define SQLDBWRITER_H
 
#include <QObject>
#include <QSqlDatabase>
#include <QDir>
#include <QSqlQuery>
#include "async.h"
#include "heart_global.h"
#include "config.h"
#include "iobjectprovider.h"
#include <QVariant>
#include <QCoreApplication>
#include <dbobject.h>
 
class QSqlDatabase;
class PlayerDBData;
 
namespace QH {

class HEARTSHARED_EXPORT SqlDBWriter : public Async, public iObjectProvider
{
    Q_OBJECT
public:
    SqlDBWriter(QThread *thread);

    virtual bool initDb(const QString &initDbParams = DEFAULT_DB_PATH);

    virtual bool initDb(const QVariantMap &params);

    virtual bool isValid() const;
 
    bool getAllObjects(const PKG::DBObject &templateObject,
                       QList<QSharedPointer<PKG::DBObject>> &result) override;
    bool updateObject(const QSharedPointer<PKG::DBObject> &ptr, bool wait = false) override;
    bool deleteObject(const QSharedPointer<PKG::DBObject> &ptr, bool wait = false) override;
    bool insertObject(const QSharedPointer<PKG::DBObject> &ptr, bool wait = false,
                      const QWeakPointer<unsigned int>& autoincrementIdResult = {}) override;
    bool replaceObject(const QSharedPointer<PKG::DBObject> &ptr, bool wait = false) override;
 
    void setSQLSources(const QStringList &list) override;
    bool doQuery(const QString& query, const QVariantMap& bindValues = {}, bool wait = false, QSqlQuery *result = nullptr) const override;
    bool doSql(const QString &sqlFile, bool wait) const override;

    QString databaseLocation() const;
 
    virtual ~SqlDBWriter() override;

    virtual bool updateQuery(const QSharedPointer<QH::PKG::DBObject> &ptr) const;

    virtual bool selectQuery(const QH::PKG::DBObject &requestObject,
                             QList<QSharedPointer<QH::PKG::DBObject>> &result);

    virtual bool deleteQuery(const QSharedPointer<QH::PKG::DBObject> &deleteObject) const;

    virtual bool insertQuery(const QSharedPointer<QH::PKG::DBObject>& insertObject,
                             const QWeakPointer<unsigned int>& autoIncrementID = {}) const;

    virtual bool replaceQuery(const QSharedPointer<QH::PKG::DBObject>& insertObject) const;
protected slots:
 
 
protected:

    bool enableFK();

    bool disableFK();

    virtual QVariantMap getInitParams(const QString& initFile) const;

    virtual QVariantMap defaultInitPararm() const;

    virtual QSqlDatabase initSqlDataBasse(const QString &driverName,
                                          const QString &name);

    QSqlDatabase* db();

    const QSqlDatabase* db() const;
 
private:

    bool workWithQuery(QSqlQuery &q,
                      const std::function< PKG::PrepareResult (QSqlQuery &)> &prepareFunc,
                      const std::function<bool()>& cb) const;
 
    bool exec(QSqlQuery *sq, const QString &sqlFile) const;

    bool initDbPrivate(const QVariantMap &params);

    bool doQueryPrivate(const QString& query,
                        const QVariantMap &bindValues,
                        QSqlQuery *result) const;
 
    bool doSqlPrivate(const QString &sqlFile) const;
 
    bool initSuccessful = false;
    QVariantMap _config;
    QStringList _SQLSources;
 
    QSqlDatabase *_db = nullptr;    
};
 
}
#endif // SQLDBWRITER_H