database_manager.h

//===========================================================================
#ifndef comfrm_DatabaseManagerH
#define comfrm_DatabaseManagerH
//===========================================================================
// Заготовка модуля DatabaseManager была сгенерирована CASE средством разработки SA2-DE.
// Все права защищены. (2015)
//
// В данном файле представлен исходный текст основного заголовочного файла модуля.
//
// ======================================= //
//       Параметры новой разработки.
// ======================================= //
// Имя комплекса:  GCAD  (gcd)
// Имя решения:    GCAD3 (gc3)   (прочерк если модуль относится лишь к комплексу)
// Имя проекта:    Client  (cli)   (прочерк если модуль относится лишь к решению)
// Полный SID:     cligc3
// Время создания: 17:19:51
// Дата создания:  2015-09-27
// ======================================= //
// ============================================================================================ //
//                             Параметры ревизии(версии):
// ============================================================================================ //
// [prd]Period:                     10/2012
// [aut]Author:                     Антон Першин
// [did]DeveloperID:                ap
// [pid]ProblemID:                  00001
// [rvs = did.date.pid]Revision:    //#ap.2012-10-08.00001
// [dsc]Description:                Класс для работы с таблицами БД и xdbt-файлами.
// [ccm]CodeComment:                rvs.{[s]Start | [e]End | []}{[n]New | [o]Old | [d]Develop}
// ============================================================================================ //
//========================================================================
// ДОПОЛНИТЕЛЬНЫЕ ПОДКЛЮЧЕНИЯ (Типы и модули, необходимые для .h - файла)
//------------------------------------------------------------------------
#include "sqltable.h"
#include "tree.h"
#include "libtools.h"
#include "anymap.h"

#include <vector>
#include <boost/function.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/asio.hpp>


//========================================================================
namespace com {
    namespace sys {
        class DatabaseAccess;

        class MAC_DLLEXPORT DatabaseManager
        {
        public:
            typedef std::function< void (std::shared_ptr<com::sql::SqlTable>) > OnTableReceivedClb;

            typedef std::function< void (bool) > OnCacheReadyClb;

        public:
            DatabaseManager(const std::string& defaultDD, std::unique_ptr<DatabaseAccess> defaultDbAccess,
                            const std::string& user, const std::string& psw, boost::asio::io_service& ioservice);
            virtual ~DatabaseManager();

            void requestTable(const std::string& table, OnTableReceivedClb clb, bool isCached = false);

            void executeSqlRequest(const std::string& request, OnTableReceivedClb clb, const std::string& db = "");

            std::shared_ptr<com::sql::SqlTable> getTable(const std::string& table);

            virtual void cacheTables(const std::vector<std::string>& tables, DatabaseManager::OnCacheReadyClb clb);

            void addDatabase(const std::string& dd, std::unique_ptr<DatabaseAccess> dbAccess);

            void setDefaultAuth(const std::string& user, const std::string& psw);

        protected:
            virtual void processReceivedTable(std::shared_ptr<com::sql::SqlTable> table);
            virtual void checkCache(DatabaseManager::OnCacheReadyClb clb, const std::vector<std::string>& checkList,
                                         std::shared_ptr<com::sql::SqlTable> table);
            std::tuple<std::string, std::string, std::string> parseTableName(const std::string& table);
            std::string getFullTableName(const std::string& table);

        private:
            void onTableLoaded(OnTableReceivedClb clb, bool isCached, const std::string& dd,
                               std::shared_ptr<com::sql::SqlTable> table);
        protected:
            std::map< std::string, std::unique_ptr<DatabaseAccess> > m_databases;
            std::map< std::string, std::shared_ptr<com::sql::SqlTable> > m_cachedTables;
            boost::asio::io_service& m_ioservice;
            std::string m_defaultUser;
            std::string m_defaultPassword;
            std::string m_defaultDD;
        };
    }
}
//===========================================================================
#endif
//===========================================================================