database.h

Go to the documentation of this file.

 
#ifndef DATABASE_H
#define DATABASE_H
 
#include <memory>
#include <soci/soci.h>
#include <nlohmann/json.hpp>
#include "private-impl/soci_custom_types.hpp"
 
#include "../app/app.h"
#include "logging.h"
 
// #define __file__ "core/tables/database.h"
 
namespace mantis
{
    using json = nlohmann::json;
 
    class DatabaseUnit
    {
    public:
        DatabaseUnit();
        ~DatabaseUnit();
 
        bool connect(DbType backend, const std::string& conn_str);
 
        void disconnect() const;
 
        bool migrate() const;
 
        [[nodiscard]] std::shared_ptr<soci::session> session() const;
 
        [[nodiscard]] soci::connection_pool& connectionPool() const;
 
        [[nodiscard]] bool isConnected() const;
 
        const std::string __class_name__ = "mantis::DatabaseUnit";
 
    private:
        void writeCheckpoint() const;
 
        std::unique_ptr<soci::connection_pool> m_connPool;
    };
 
    class MantisLoggerImpl : public soci::logger_impl
    {
    public:
        void start_query(std::string const& query) override
        {
            logger_impl::start_query(query);
            Log::trace("$ sql << {}", query);
            // Log::trace("$ sql << {}\n\t└── Values ({})", query, params);
        }
 
    private:
        logger_impl* do_clone() const override
        {
            return new MantisLoggerImpl();
        }
    };
}
 
#endif //DATABASE_H