mdbquery.cpp

一个自行开发的内存数据管理的包

//----------------------------------------------------------------------------
// 程序名称：   Table.cpp
// 程序说明：   CTable类实现
// 程序作者：   陈立峰
// 程序版本：   1.0
// 开始日期：   2005-06-09
//----------------------------------------------------------------------------
#include <sched.h>
#include <iostream>
#include "MdbQuery.h"

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
CMdbQuery::CMdbQuery(MALLOC *pcAlloc,ACE_Process_Mutex *pcLatch,CMdbDict *pcDbDict,int nMyPid,const char *szTableName,int nFieldCnt,const char **szFieldNames,int *pnFieldTypes,void **ppVals,bool bUpdate):m_cMdbField(*this),m_nMyPid(nMyPid),m_bUpdate(bUpdate)
{
	CRecordNode *psRecordNode;
	m_pcAlloc = pcAlloc;
	m_pcLatch = pcLatch;
	m_pcDbDict = pcDbDict;
	
	
	if(m_bUpdate)
	{
		ownerTableMeta(szTableName);
	}
	else
	{
		shareTableMeta(szTableName);
	}
	
	try
	{
		CMdbTbl cMdbTbl(pcAlloc,pcDbDict,m_psTblMeta);
		
		if(nFieldCnt >= 0)
		{
			int i;
			for(i=0;i<m_pcDbDict->getIndexCnt(m_psTblMeta);i++)
			{
				CDbIndexMeta *psIndexMeta = m_pcDbDict->getIndexMeta(m_psTblMeta,i);
				CMdbHtIndex cMdbHtIndex(pcAlloc,pcDbDict,&cMdbTbl,psIndexMeta);
				CHtIndexNode *psPrevIndexNode = NULL;
				bool bHit;
				psRecordNode = cMdbHtIndex.query(psPrevIndexNode,nFieldCnt,szFieldNames,pnFieldTypes,ppVals,bHit);
				if(!bHit)
				{
					continue;
				}
				if(psRecordNode != NULL)
				{
					do
					{
						m_ppsRecords.push_back(psRecordNode);
					}while((psRecordNode = (cMdbHtIndex.query(psPrevIndexNode,nFieldCnt,szFieldNames,pnFieldTypes,ppVals,bHit))) != NULL);
					m_psCurRecord = m_ppsRecords.end();
					return;
				}
				else
				{
					m_psCurRecord = m_ppsRecords.end();
					return;
				}
			}
				
			CRecordNode *psPrevRecordNode = NULL;
			while((psRecordNode = cMdbTbl.queryRecord(psPrevRecordNode,nFieldCnt,szFieldNames,pnFieldTypes,ppVals)) != NULL)
			{
					//cerr << "found by scan tbl" << endl;
				m_ppsRecords.push_back(psRecordNode);
				psPrevRecordNode = psRecordNode;
			}
		}
		m_psCurRecord = m_ppsRecords.end();
	}
	catch(const Exception &e) //防止构造函数中抛异常，而不释放表锁
	{
		cleanUp();
		throw;
	}
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void  CMdbQuery::insertTableMeta(SCreateTblPara *psCreateTblPara,SCreateIdxesPara *psCreateIdxesPara)
{
	ACE_Guard<ACE_Process_Mutex>  cGuard(*m_pcLatch);
	if(!cGuard.locked())
	{
		throwException(MDB_EC_NORMAL,MDB_ET_GET_DICT_LOCK_FAIL,"CMdbQuery::insertTableMeta Error,Can not get Dict Lock\n");
			//continue;
	}
	m_psTblMeta = m_pcDbDict->insertTableMeta(psCreateTblPara,psCreateIdxesPara);
		
	if(ownerTable() == false)
	{	
		cGuard.release();
		throwException(MDB_EC_NORMAL,MDB_ET_LOGIC_ERROR,"CMdbQuery::insertTableMeta Error,Can not OwnerTable\n");	
	}
	else
	{
			cGuard.release();
			return;
	}
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
CMdbQuery::CMdbQuery(MALLOC *pcAlloc,ACE_Process_Mutex *pcLatch,CMdbDict *pcDbDict,int nMyPid,SCreateTblPara *psCreateTblPara,SCreateIdxesPara *psCreateIdxesPara):m_cMdbField(*this),m_nMyPid(nMyPid)
{
	m_pcAlloc = pcAlloc;
	m_pcLatch = pcLatch;
	m_pcDbDict = pcDbDict;
	m_bUpdate = true;

	insertTableMeta(psCreateTblPara,psCreateIdxesPara);
	
	try
	{	
		CMdbTbl cMdbTbl(pcAlloc,pcDbDict,m_psTblMeta);
		m_psCurRecord = m_ppsRecords.end();
	}
	catch(const Exception &e) //防止构造函数中抛异常，而不释放表锁
	{
		cleanUp();
		throw;
	}
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void  CMdbQuery::deleteTableMeta(const char *szTableName)
{
	ACE_Guard<ACE_Process_Mutex>  cGuard(*m_pcLatch);
	if(!cGuard.locked())
	{
		throwException(MDB_EC_NORMAL,MDB_ET_LOGIC_ERROR,"CMdbQuery::deleteTableMeta Error,Can not get Lock,Tbl:%s\n",szTableName);
	}
	m_pcDbDict->deleteTableMeta(szTableName);
	m_psTblMeta = NULL;
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
CMdbQuery::CMdbQuery(MALLOC *pcAlloc,ACE_Process_Mutex *pcLatch,CMdbDict *pcDbDict,int nMyPid,const char *szTableName):m_cMdbField(*this),m_nMyPid(nMyPid)
{

	m_pcAlloc = pcAlloc;
	m_pcLatch = pcLatch;
	m_pcDbDict = pcDbDict;
	m_bUpdate = true;
	ownerTableMeta(szTableName);
	
	try
	{
		CMdbTbl cMdbTbl(m_pcAlloc,m_pcDbDict,m_psTblMeta);
	 	for(int i=0;i<m_pcDbDict->getIndexCnt(m_psTblMeta);i++)
		{
			CDbIndexMeta *psIndexMeta = m_pcDbDict->getIndexMeta(m_psTblMeta,i);
			CMdbHtIndex cMdbHtIndex(m_pcAlloc,m_pcDbDict,&cMdbTbl,psIndexMeta);
			cMdbHtIndex.truncate();
		}
	 	cMdbTbl.truncate();
	 	deleteTableMeta(m_psTblMeta->m_szTblName);
	 	m_psCurRecord = m_ppsRecords.end();
	 }
	 catch(const Exception &e)  //防止构造函数中抛异常，而不释放表锁
	 {
		cleanUp();
		throw;
	 }
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void CMdbQuery::destroy()
{
	cleanUp();
 	delete this;
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
inline void CMdbQuery::cleanUp()
{
	if(m_bUpdate)
	{
		unOwnerTableMeta();
	}
	else
	{
		unShareTableMeta();
	}
 	m_ppsRecords.clear();
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void CMdbQuery::clear()
{
	CMdbTbl cMdbTbl(m_pcAlloc,m_pcDbDict,m_psTblMeta);
 	CListIter pcIter;
 	for(int i=0;i<m_pcDbDict->getIndexCnt(m_psTblMeta);i++)
	{
		CDbIndexMeta *psIndexMeta = m_pcDbDict->getIndexMeta(m_psTblMeta,i);
		CMdbHtIndex cMdbHtIndex(m_pcAlloc,m_pcDbDict,&cMdbTbl,psIndexMeta);
		pcIter = m_ppsRecords.begin();
		while(pcIter != m_ppsRecords.end())
		{
			cMdbHtIndex.remove(*pcIter);
			pcIter++;
		}
	}
 	
 	pcIter = m_ppsRecords.begin();
	while(pcIter != m_ppsRecords.end())
	{
		cMdbTbl.removeRecord(*pcIter);
		pcIter++;
	}
	m_ppsRecords.clear();
 	m_psCurRecord = m_ppsRecords.end();
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
bool CMdbQuery::nextRec()
{
	if(m_psCurRecord == m_ppsRecords.end())
	{
		m_psCurRecord = m_ppsRecords.begin();
	}
	else
	{
		++m_psCurRecord;
	}
	if(m_psCurRecord == m_ppsRecords.end())
	{
		return false;
	}
	else
	{
		return true;
	}
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
bool CMdbQuery::prevRec()
{
	if(m_psCurRecord == m_ppsRecords.begin())
	{
		m_psCurRecord = m_ppsRecords.end();
	}
	else
	{
		--m_psCurRecord;
	}
	if(m_psCurRecord == m_ppsRecords.end())
	{
		return false;
	}
	else
	{
		return true;
	}
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void CMdbQuery::updateIndex(CMdbTbl *pcMdbTbl,const char *szFieldName,int nFieldType,const void *pVal)
{
	for(int i=0;i<m_pcDbDict->getIndexCnt(m_psTblMeta);i++)
	{
		CDbIndexMeta *psIndexMeta = m_pcDbDict->getIndexMeta(m_psTblMeta,i);
		CMdbHtIndex cMdbHtIndex(m_pcAlloc,m_pcDbDict,pcMdbTbl,psIndexMeta);
		cMdbHtIndex.update(*m_psCurRecord,szFieldName,nFieldType,pVal);
	}
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无