CMongoDatabaseEngineComp.h

// SPDX-License-Identifier: LGPL-2.1-or-later OR GPL-2.0-or-later OR GPL-3.0-or-later OR LicenseRef-ImtCore-Commercial
#pragma once
 
// mongocxx includes
#include <bsoncxx/json.hpp>
#include <mongocxx/client.hpp>
#include <mongocxx/instance.hpp>
 
 
// ACF includes
#include <imod/TModelWrap.h>
#include <ilog/TLoggerCompWrap.h>
#include <ifile/IFileNameParam.h>
 
// ImtCore includes
#include <imtbase/TModelUpdateBinder.h>
#include <imtdb/CDatabaseAccessSettings.h>
#include <imtmongo/IMongoDatabaseEngine.h>
 
 
namespace imtmongo
{
 
 
class CMongoDatabaseEngineAttr: public ilog::CLoggerComponentBase
{
public:
       typedef ilog::CLoggerComponentBase BaseClass;
       I_BEGIN_COMPONENT(CMongoDatabaseEngineAttr);
       I_END_COMPONENT;
};
 
 
class CMongoDatabaseEngineComp:
                     virtual public IMongoDatabaseEngine,
                     virtual public CMongoDatabaseEngineAttr
{
public:
       typedef CMongoDatabaseEngineAttr BaseClass;
 
       I_BEGIN_COMPONENT(CMongoDatabaseEngineComp);
              I_REGISTER_INTERFACE(imtmongo::IMongoDatabaseEngine)
              I_REGISTER_SUBELEMENT(DatabaseAccessSettings);
              I_REGISTER_SUBELEMENT_INTERFACE(DatabaseAccessSettings, imtdb::IDatabaseLoginSettings, ExtractDatabaseAccessSettings);
              I_REGISTER_SUBELEMENT_INTERFACE(DatabaseAccessSettings, istd::IChangeable, ExtractDatabaseAccessSettings);
              I_REGISTER_SUBELEMENT_INTERFACE(DatabaseAccessSettings, imod::IModel, ExtractDatabaseAccessSettings);
              I_ASSIGN(m_databaseAccessSettingsCompPtr, "DatabaseAccessSettings", "Settings for database access", false, "DatabaseAccessSettings");
              I_ASSIGN(m_dbTypeAttrPtr, "DbType", "The property holds database connections using the driver", true, "MongoDB");
              I_ASSIGN(m_dbNameAttrPtr, "DbName", "The property holds connection's database name", true, "agisbil");
              I_ASSIGN(m_userNameAttrPtr, "UserName", "The property holds connection's user name", true, "postgres");
              I_ASSIGN(m_paswordAttrPtr, "Pasword", "The property holds connection's password.", true, "12345");
              I_ASSIGN(m_hostNameAttrPtr, "HostName", "The property holds connection's host name.", true, "localhost");
              I_ASSIGN(m_maintenanceDatabaseNameAttrPtr, "MaintainanceDatabase", "Name of Maintenance database. It's necessary for creating database if it not exists", true, "postgres");
              I_ASSIGN(m_migrationFolderPathCompPtr, "MigrationFolderPath", "The property holds the folder contains SQL migraton script", false, "MigrationFolderPath");
              I_ASSIGN(m_autoCreateDatabaseAttrPtr, "AutoCreateDatabase", "The property holds behavior to create database on startup.\n Possible values:\n0 - will not create new database;\n1 - will create database once;\n2 - will create database at each startup", true, 1);
              I_ASSIGN(m_autoCreateTablesAttrPtr, "AutoCreateTables", "The property holds behavior to create tables on startup.\n Possible values:\n0 - will not create new tables;\n1 - will create tables once;\n2 - will create tables at each startup", true, 1);
              I_ASSIGN(m_portAttrPtr, "Port", "The property holds connection's port number", true, 270);
       I_END_COMPONENT;
 
       CMongoDatabaseEngineComp();
 
       static void DrectBindValue(QByteArray* string, const QByteArray& what, const QByteArray& expr);
       static void DrectBindValueInsertDefault(QByteArray* string, const QByteArray& what);
       static void DrectBindValueUpdateDefault(QByteArray* string, const QByteArray& what);
 
       virtual mongocxx::database* GetDatabase() override;
 
protected:
 
       void OnDatabaseAccessChanged(const istd::IChangeable::ChangeSet& changeSet, const imtdb::IDatabaseLoginSettings* databaseAccessSettingsPtr);
 
       // reimplemented (icomp::CComponentBase)
       virtual void OnComponentCreated() override;
       virtual void OnComponentDestroyed() override;
 
private:
 
       //bool IsDatabaseServerConnected() const;
 
       QString GetDatabaseName() const;
       QString GetHostName() const;
       int GetPort() const;
       QString GetUserName() const;
       QString GetPassword() const;
 
 
       template <typename Interface>
       static Interface* ExtractDatabaseAccessSettings(CMongoDatabaseEngineComp& component)
       {
              return &component.m_workingAccessSettings;
       }
 
private:
       I_REF(imtdb::IDatabaseLoginSettings, m_databaseAccessSettingsCompPtr);
       I_ATTR(QByteArray, m_dbTypeAttrPtr);
       I_ATTR(QByteArray, m_dbNameAttrPtr);
       I_ATTR(QByteArray, m_userNameAttrPtr);
       I_ATTR(QByteArray, m_paswordAttrPtr);
       I_ATTR(QByteArray, m_hostNameAttrPtr);
       I_ATTR(QByteArray, m_maintenanceDatabaseNameAttrPtr);
       I_ATTR(QByteArray, m_databaseCreationScriptPathAttrPtr);
       I_REF(ifile::IFileNameParam, m_migrationFolderPathCompPtr);
       I_ATTR(int, m_autoCreateDatabaseAttrPtr);
       I_ATTR(int, m_autoCreateTablesAttrPtr);
       I_ATTR(int, m_portAttrPtr);
 
       imtbase::TModelUpdateBinder<imtdb::IDatabaseLoginSettings, CMongoDatabaseEngineComp> m_databaseAccessObserver;
 
       imod::TModelWrap<imtdb::CDatabaseAccessSettings> m_workingAccessSettings;
 
       mongocxx::client * m_client;
       mongocxx::database* m_database;
 
};
 
 
} // namespace imtmongo