cSQLDatabasePool.h

Go to the documentation of this file.

//
//
 
#ifndef _INC_cSQLDatabasePool_H
#define _INC_cSQLDatabasePool_H
#ifndef NO_PRAGMA_ONCE
#pragma once
#endif
 
#include "cSQLDatabase.h"
#include "GrayCore/include/cThreadLock.h"
 
namespace GrayLib
{
        class GRAYLIB_LINK cSQLDatabasePool
        {
 
        public:
                cStringF m_sConnectionString;   
                int m_nMaxConnections;
                TIMESYSD_t m_nMaxWait;
 
        private:
                mutable cThreadLockCount m_Lock;                        
                ITERATE_t m_iLastConnection;                            
                cArrayRef<cSQLDatabase> m_aConnections; 
 
        private:
                ITERATE_t AddConnection(cSQLDatabase* pDatabase);
                cSQLDatabasePtr FindFreeConnection() const;
 
        public:
                cSQLDatabasePool(cStringF sConnectionString = "", int nMaxConnections = 256, TIMESYSD_t nMaxWait = 1000);
                ~cSQLDatabasePool();
 
                HRESULT OpenConnectFirst(cStringF sConnectionString, cExceptionHolder* pEx = nullptr);
                void Close();
 
                ITERATE_t get_ConnectionCount() const
                {
                        return m_aConnections.GetSize();
                }
                bool isOpen() const
                {
                        return get_ConnectionCount();
                }
                bool isConfigured() const
                {
                        return !m_sConnectionString.IsEmpty();
                }
 
                HRESULT GetConnection(cSQLDatabasePtr& pConnection);
                cSQLDatabasePtr get_Connection()
                {
                        cSQLDatabasePtr pDatabase;
                        HRESULT hRes = GetConnection(pDatabase);
                        if (FAILED(hRes))
                                return nullptr;
                        return pDatabase;
                }
 
                HRESULT ExecuteSQLCmd(cSQLCmd& command, cExceptionHolder* pExceptionRet = nullptr);
                HRESULT ExecuteSQLAndFetch(cSQLCmd& oCmd, cSQLStatement& rResultSet, cExceptionHolder* pExceptionRet = nullptr, bool bWaitIfBusy = false);
                HRESULT ExecuteSQLOrInsert(cSQLCmdUpdate& Update, cExceptionHolder* pExceptionRet = nullptr);
        };
};
#endif // _INC_cSQLDatabasePool_H