dbExecBase.h

Go to the documentation of this file.

 
// Copyright (c) 2013-2015 OpenM++
// This code is licensed under the MIT license (see LICENSE.txt for details)
 
#ifndef DB_EXEC_BASE_H
#define DB_EXEC_BASE_H
 
using namespace std;
 
#include "helper.h"
#include "dbExec.h"
 
namespace openm
{
    class DbExecBase
    {
    public:
        DbExecBase(const string & i_connectionStr);
 
        ~DbExecBase(void) noexcept { }
 
        bool isTransaction(void);
 
    protected:
        thread::id trxThreadId;
 
        NoCaseMap connProps;
 
    protected:
        bool isTransactionNonOwn(void);
 
        void setTransactionActive(void);
 
        void releaseTransaction(void);
 
        string strConnProperty(const string & i_key) const;
 
        bool boolConnProperty(const string & i_key) const;
 
        long long longConnProperty(const string & i_key, long i_default) const;
 
        static void runSqlScript(IDbExec * i_dbExec, const string & i_sqlScript);
 
    private:
        NoCaseMap parseConnectionStr(const string & i_connectionStr);
 
        // cleanup connection resources
        virtual void cleanup(void) noexcept = 0;
 
        // validate connection properties
        virtual void validateConnectionProps(void) = 0;
 
    private:
        DbExecBase(const DbExecBase & i_dbExec) = delete;
        DbExecBase & operator=(const DbExecBase & i_dbExec) = delete;
    };
 
    template<typename TContainer> 
    class RowContainerInserter : public IRowProcessor 
    {
    public:
 
        void processRow(IRowBaseUptr & i_row) override { rowContainer.push_back(std::move(i_row)); };
 
        TContainer rowContainer;
    };
 
    extern recursive_mutex dbMutex;
}
 
#endif  // DB_EXEC_BASE_H