cSQLDatabase.h

Go to the documentation of this file.

//
//
 
#ifndef _INC_cSQLDatabase_H
#define _INC_cSQLDatabase_H
#ifndef NO_PRAGMA_ONCE
#pragma once
#endif
 
#include "cSQLBase.h"
#include "cSQLCmd.h"
#include "GrayCore/include/cArraySort.h"
#include "GrayCore/include/cAtom.h"
#include "GrayCore/include/cFilePath.h"
 
namespace GrayLib
{
        class GRAYLIB_LINK cSQLCmd;
        class GRAYLIB_LINK cSQLCmdUpdate;
        class GRAYLIB_LINK cSQLCmdWhere;
        class GRAYLIB_LINK cSQLDriver;
        class GRAYLIB_LINK cSQLStatement;
        DECLARE_INTERFACE(ISQLDatabase);
 
        class GRAYLIB_LINK cSQLDatabase
        : public cSQLBase
        , public cRefBase
        {
 
        private:
                cSQLConnectionString m_ConnectionString;        
                bool m_bIsConnected;                    
                cSQLConfigDB m_ConfigDB;                
 
        public:
                cSQLDriver* m_pSQLDriver;               
 
        protected:
                void ChangeCriticalWait(int iDelta);
                HRESULT ReadConfigDB();
                bool AllocISQLDatabase(cSQLDriver* pSQLDriver);
                HRESULT OpenConnectInt(cExceptionHolder* pExceptionHolder, int iMaxRetries, TIMESYS_t nTimeStart);
 
        public:
                cSQLDatabase();
                virtual ~cSQLDatabase();
 
                ISQLDatabase* get_ISQLDatabase() const;
 
                bool isConnected() const
                {
                        return m_bIsConnected;
                }
                bool IsExtReferenced(int nCheckVal = 1) const;
                virtual cSQLDriver* get_SQLDriver() const
                {
                        return m_pSQLDriver;
                }
                virtual cSQLBase* get_SQLParent() const;
 
                HRESULT OpenConnect(cStringF sConnectionString, cExceptionHolder* pExceptionHolder = nullptr, int iMaxRetries = 3);
                HRESULT RetryOpenConnect(cExceptionHolder* pExceptionHolder = nullptr, int iMaxRetries = 100);
                bool Close(bool bDestroyHandle);
 
                bool get_AutoCommit() const;
                void put_AutoCommit(bool bAutoCommit); // makes all transactions COMMIT immediately
 
                const cSQLConfigDB& GetConfigDB();
 
                HRESULT ExecuteSQLCmd( cSQLCmd& oCmd, cExceptionHolder* pExceptionRet = nullptr);
                HRESULT ExecuteSQLAndFetch(cSQLCmd& oCmd, cSQLStatement& rResultSet, cExceptionHolder* pExceptionRet = nullptr, bool bWaitIfBusy=false);
                HRESULT ExecuteSQLOrInsert(cSQLCmdUpdate& oCmdUpdate, cExceptionHolder* pExceptionRet);
 
                HRESULT EndTransaction(bool bCommit);
        };
 
        typedef cRefPtr<cSQLDatabase> cSQLDatabasePtr;
};
#endif // _INC_cSQLDatabase_H