cUIDManagerTable.h

Go to the documentation of this file.

//
//
 
#ifndef _INC_cUIDManagerTable_H
#define _INC_cUIDManagerTable_H
#ifndef NO_PRAGMA_ONCE
#pragma once
#endif
 
#include "cUID.h"
#ifdef USE_SQL
#include "cUIDManagerArray.h"
#include "GrayCore/include/cThreadLock.h"
#include "GrayCore/include/cString.h"
#include "GrayCore/include/cHashTable.h"
#include "GrayCore/include/cUnitTestDecl.h"
 
namespace GrayLib
{
        UNITTEST2_PREDEF(cUIDManagerTable);
 
        class GRAYLIB_LINK cSQLDatabasePool;
        class GRAYLIB_LINK cSQLDatabase;
        class GRAYLIB_LINK cSQLStatementQ;
         
        class GRAYLIB_LINK cUIDManagerTable : public IUIDManager
        {
 
                static const int k_RANGE_SIZE = 10000;          
 
        public:
                static const char k_FreePostfix[5];
 
        public:
                cUIDManagerTable(const cUIDRangeMask& mask, const char* pszTableName);
                ~cUIDManagerTable();
 
                HRESULT OpenPoolCheck(cSQLDatabase* pDB, cSQLStatementQ& rs);
                void ClosePool(cSQLDatabasePool& dbp);
 
                cString get_StatusString() const;
                bool IsFreeOrDeleted(UID_t uid) const;
 
                UIDINDEX_t get_UIDCount() const;
                cXObjectPtr FindObjIter(cHashIterator& e) const;
                virtual cXObjectPtr FindUIDObj(UID_t uid) const;
 
                HRESULT CreateUID(cSQLDatabasePool& db, cXObject* pObj);
                HRESULT LoadUID(cSQLDatabasePool& db, cXObject* pObj, UIDINDEX_t index);
                void DeleteUIDIndex(UID_t uid, bool bFree, bool bWasSaved);
                void DeleteUID(cXObject* pObj, bool bFree);
 
                void ClearDeletedUIDs(cSQLDatabasePool& db);
                void SaveFreeUIDs(cSQLDatabasePool& db); // Save all free UIDs back to database.
 
                // Only Node 0 can do this!
                HRESULT RebuildFreeUIDTable(cSQLDatabasePool& db, UIDINDEX_t dwMaxQty);
 
                UNITTEST_FRIEND(cUIDManagerTable);
 
        private:
                const char* get_TableName() const noexcept
                {
                        // get the name of the table that stores the full object.
                        return m_pszTableName;
                }
 
                int AddFreeUIDRange(UIDINDEX_t dwIndexBegin, UIDINDEX_t dwIndexEnd);
                HRESULT ClaimFreeUIDRangeRead(cSQLDatabasePool& db, const char* pszTable, int& nIndexes);
                HRESULT ClaimFreeUIDRange(cSQLDatabasePool& db);
 
                HRESULT SaveFreeUIDRange(cSQLDatabasePool& db, UIDINDEX_t dwIndexBegin, UIDINDEX_t dwIndexEnd);
                void Dump_DeletedUIDs();
 
        public:
                const cUIDRangeMask m_UIDRange;         
 
                cHashTableRef<cXObject, UID_t, 9> m_UsedUIDs; 
                bool m_bLogDelete;      
 
        private:
                mutable cThreadLockCount m_Lock;                
                cArraySortVal<UIDINDEX_t> m_DeletedIndexes; 
                cArraySortVal<UIDINDEX_t> m_FreeIndexes;        
                const char* m_pszTableName;     // get the name of the table that stores the full object. add 'Free' Postfix to this.
        };
} 
#endif // USE_SQL
#endif // _INC_cUIDManagerTable_H