DBCStorage< T > Class Template Reference

#include <DBCStore.h>

Public Types
typedef DBStorageIterator< T >	iterator

Public Member Functions
	DBCStorage (char const *f)
	~DBCStorage ()
T const *	LookupEntry (uint32 id) const
T const *	AssertEntry (uint32 id) const
uint32	GetNumRows () const
char const *	GetFormat () const
uint32	GetFieldCount () const
bool	Load (char const *fn, SqlDbc *sql)
bool	LoadStringsFrom (char const *fn)
void	Clear ()
iterator	begin ()
iterator	end ()

Private Types
typedef std::list< char * >	StringPoolList

Private Member Functions
	DBCStorage (DBCStorage const &right)=delete
DBCStorage &	operator= (DBCStorage const &right)=delete

Private Attributes
char const *	fmt
uint32	nCount
uint32	fieldCount
union {
T **   asT
char **   asChar
}	indexTable
T *	dataTable
StringPoolList	stringPoolList

Member Typedef Documentation

template<class T>

typedef DBStorageIterator<T> DBCStorage< T >::iterator

template<class T>

typedef std::list<char*> DBCStorage< T >::StringPoolList

private

Constructor & Destructor Documentation

template<class T>

DBCStorage< T >::DBCStorage ( char const *  f )

inlineexplicit

 : fmt(f), nCount(0), fieldCount(0), dataTable(NULL)
 {
 indexTable.asT = NULL;
 }

template<class T>

DBCStorage< T >::~DBCStorage ( )

inline

{ Clear(); }

Here is the call graph for this function:

template<class T>

DBCStorage< T >::DBCStorage ( DBCStorage< T > const &  right )

privatedelete

Member Function Documentation

template<class T>

T const* DBCStorage< T >::AssertEntry ( uint32  id ) const

inline

 {
 T const* entry = LookupEntry(id);
 ASSERT(entry);
 return entry;
 }

Here is the call graph for this function:

template<class T>

iterator DBCStorage< T >::begin ( )

inline

{ return iterator(indexTable.asT, nCount); }

template<class T>

void DBCStorage< T >::Clear ( )

inline

 {
 if (!indexTable.asT)
 return;

 delete[] reinterpret_cast<char*>(indexTable.asT);
 indexTable.asT = NULL;
 delete[] reinterpret_cast<char*>(dataTable);
 dataTable = NULL;

 while (!stringPoolList.empty())
 {
 delete[] stringPoolList.front();
 stringPoolList.pop_front();
 }

 nCount = 0;
 }

Here is the caller graph for this function:

template<class T>

iterator DBCStorage< T >::end ( )

inline

{ return iterator(indexTable.asT, nCount, nCount); }

template<class T>

uint32 DBCStorage< T >::GetFieldCount ( ) const

inline

{ return fieldCount; }

Here is the caller graph for this function:

template<class T>

char const* DBCStorage< T >::GetFormat ( ) const

inline

{ return fmt; }

Here is the caller graph for this function:

template<class T>

uint32 DBCStorage< T >::GetNumRows ( ) const

inline

{ return nCount; }

template<class T>

bool DBCStorage< T >::Load ( char const *  fn, SqlDbc *  sql  )

inline

 {
 DBCFileLoader dbc;
 // Check if load was successful, only then continue
 if (!dbc.Load(fn, fmt))
 return false;

 uint32 sqlRecordCount = 0;
 uint32 sqlHighestIndex = 0;
 Field* fields = NULL;
 QueryResult result = QueryResult(NULL);
 // Load data from sql
 if (sql)
 {
 std::string query = "SELECT * FROM " + sql->sqlTableName;
 if (sql->indexPos >= 0)
 query +=" ORDER BY " + *sql->indexName + " DESC";
 query += ';';


 result = WorldDatabase.Query(query.c_str());
 if (result)
 {
 sqlRecordCount = uint32(result->GetRowCount());
 if (sql->indexPos >= 0)
 {
 fields = result->Fetch();
 sqlHighestIndex = fields[sql->sqlIndexPos].GetUInt32();
 }

 // Check if sql index pos is valid
 if (int32(result->GetFieldCount() - 1) < sql->sqlIndexPos)
 {
 TC_LOG_ERROR("server.loading", "Invalid index pos for dbc:'%s'", sql->sqlTableName.c_str());
 return false;
 }
 }
 }

 char* sqlDataTable = NULL;
 fieldCount = dbc.GetCols();

 dataTable = reinterpret_cast<T*>(dbc.AutoProduceData(fmt, nCount, indexTable.asChar,
 sqlRecordCount, sqlHighestIndex, sqlDataTable));

 stringPoolList.push_back(dbc.AutoProduceStrings(fmt, reinterpret_cast<char*>(dataTable)));

 // Insert sql data into arrays
 if (result)
 {
 if (indexTable.asT)
 {
 uint32 offset = 0;
 uint32 rowIndex = dbc.GetNumRows();
 do
 {
 if (!fields)
 fields = result->Fetch();

 if (sql->indexPos >= 0)
 {
 uint32 id = fields[sql->sqlIndexPos].GetUInt32();
 if (indexTable.asT[id])
 {
 TC_LOG_ERROR("server.loading", "Index %d already exists in dbc:'%s'", id, sql->sqlTableName.c_str());
 return false;
 }

 indexTable.asT[id] = reinterpret_cast<T*>(&sqlDataTable[offset]);
 }
 else
 indexTable.asT[rowIndex]= reinterpret_cast<T*>(&sqlDataTable[offset]);

 uint32 columnNumber = 0;
 uint32 sqlColumnNumber = 0;

 for (; columnNumber < sql->formatString->size(); ++columnNumber)
 {
 if ((*sql->formatString)[columnNumber] == FT_SQL_ABSENT)
 {
 switch (fmt[columnNumber])
 {
 case FT_FLOAT:
 *reinterpret_cast<float*>(&sqlDataTable[offset]) = 0.0f;
 offset += 4;
 break;
 case FT_IND:
 case FT_INT:
 *reinterpret_cast<uint32*>(&sqlDataTable[offset]) = uint32(0);
 offset += 4;
 break;
 case FT_BYTE:
 *reinterpret_cast<uint8*>(&sqlDataTable[offset]) = uint8(0);
 offset += 1;
 break;
 case FT_LONG:
 *reinterpret_cast<uint64*>(&sqlDataTable[offset]) = uint64(0);
 offset += 8;
 break;
 case FT_STRING:
 // Beginning of the pool - empty string
 *reinterpret_cast<char**>(&sqlDataTable[offset]) = stringPoolList.back();
 offset += sizeof(char*);
 break;
 }
 }
 else if ((*sql->formatString)[columnNumber] == FT_SQL_PRESENT)
 {
 bool validSqlColumn = true;
 switch (fmt[columnNumber])
 {
 case FT_FLOAT:
 *reinterpret_cast<float*>(&sqlDataTable[offset]) = fields[sqlColumnNumber].GetFloat();
 offset += 4;
 break;
 case FT_IND:
 case FT_INT:
 *reinterpret_cast<uint32*>(&sqlDataTable[offset]) = fields[sqlColumnNumber].GetUInt32();
 offset += 4;
 break;
 case FT_BYTE:
 *reinterpret_cast<uint8*>(&sqlDataTable[offset]) = fields[sqlColumnNumber].GetUInt8();
 offset += 1;
 break;
 case FT_LONG:
 *reinterpret_cast<uint64*>(&sqlDataTable[offset]) = fields[sqlColumnNumber].GetUInt64();
 offset += 8;
 break;
 case FT_STRING:
 TC_LOG_ERROR("server.loading", "Unsupported data type in table '%s' at char %d", sql->sqlTableName.c_str(), columnNumber);
 return false;
 case FT_SORT:
 break;
 default:
 validSqlColumn = false;
 break;
 }
 if (validSqlColumn && (columnNumber != (sql->formatString->size()-1)))
 sqlColumnNumber++;
 }
 else
 {
 TC_LOG_ERROR("server.loading", "Incorrect sql format string '%s' at char %d", sql->sqlTableName.c_str(), columnNumber);
 return false;
 }
 }

 if (sqlColumnNumber != (result->GetFieldCount() - 1))
 {
 TC_LOG_ERROR("server.loading", "SQL and DBC format strings are not matching for table: '%s'", sql->sqlTableName.c_str());
 return false;
 }

 fields = NULL;
 ++rowIndex;
 } while (result->NextRow());
 }
 }

 // error in dbc file at loading if NULL
 return indexTable.asT != NULL;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

template<class T>

bool DBCStorage< T >::LoadStringsFrom ( char const *  fn )

inline

 {
 // DBC must be already loaded using Load
 if (!indexTable.asT)
 return false;

 DBCFileLoader dbc;
 // Check if load was successful, only then continue
 if (!dbc.Load(fn, fmt))
 return false;

 stringPoolList.push_back(dbc.AutoProduceStrings(fmt, reinterpret_cast<char*>(dataTable)));

 return true;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

template<class T>

T const* DBCStorage< T >::LookupEntry ( uint32  id ) const

inline

 {
 return (id >= nCount) ? NULL : indexTable.asT[id];
 }

Here is the caller graph for this function:

template<class T>

DBCStorage& DBCStorage< T >::operator= ( DBCStorage< T > const &  right )

privatedelete

Member Data Documentation

template<class T>

char** DBCStorage< T >::asChar

template<class T>

T** DBCStorage< T >::asT

template<class T>

T* DBCStorage< T >::dataTable

private

template<class T>

uint32 DBCStorage< T >::fieldCount

private

template<class T>

char const* DBCStorage< T >::fmt

private

union { ... } DBCStorage< T >::indexTable

template<class T>

uint32 DBCStorage< T >::nCount

private

template<class T>

StringPoolList DBCStorage< T >::stringPoolList

private

---

The documentation for this class was generated from the following file:

• src/server/shared/DataStores/DBCStore.h