mdbquery.cpp

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

// 注意事项： 无
//---------------------------------------------------------------------------
void  CMdbQuery::setFieldValByName(const char *szFieldName,int nFieldType,const void *pVal)
{
//cerr << "enter setFieldValByName" << endl;
	if(m_psCurRecord == m_ppsRecords.end())
	{
//		cerr << "enter exception" << endl;		
		throwException(MDB_EC_NORMAL,MDB_ET_FOUND_EOR,"CMdbQuery::setFieldValByName Error,End of Record Found,Tbl:%s\n",m_psTblMeta->m_szTblName);
	}
//	cerr << "create mdbTbl" << endl; 
	CMdbTbl cMdbTbl(m_pcAlloc,m_pcDbDict,m_psTblMeta);
//	cerr << "update index" << endl; 
	updateIndex(&cMdbTbl,szFieldName,nFieldType,pVal);
//	cerr << "update table" << endl;
//	cerr << "m_psCurRecord:" << (void *)(*m_psCurRecord) << endl;
	cMdbTbl.setFieldValByName(*m_psCurRecord,szFieldName,nFieldType,pVal);
// 	cerr << "leave setFieldValByName" << endl;
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void  CMdbQuery::getFieldValByName(const char *szFieldName,int nFieldType,void *pVal)
{
	if(m_psCurRecord == m_ppsRecords.end())
	{
		throwException(MDB_EC_NORMAL,MDB_ET_FOUND_EOR,"CMdbQuery::getFieldValByName Error,End of Record Found,Tbl:%s\n",m_psTblMeta->m_szTblName);
	}
	CMdbTbl cMdbTbl(m_pcAlloc,m_pcDbDict,m_psTblMeta);
	cMdbTbl.getFieldValByName(*m_psCurRecord,szFieldName,nFieldType,pVal);
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void  CMdbQuery::setFieldValByIndex(int nFieldIndex,int nFieldType,const void *pVal)
{
	if(m_psCurRecord == m_ppsRecords.end())
	{
		throwException(MDB_EC_NORMAL,MDB_ET_FOUND_EOR,"CMdbQuery::setFieldValByIndex Error,End of Record Found,Tbl:%s\n",m_psTblMeta->m_szTblName);
	}
	CMdbTbl cMdbTbl(m_pcAlloc,m_pcDbDict,m_psTblMeta);
	CDbColumnMeta *psColMeta = m_pcDbDict->getColumnMeta(m_psTblMeta,nFieldIndex);
	updateIndex(&cMdbTbl,psColMeta->m_szColName,nFieldType,pVal);
 	cMdbTbl.setFieldValByIndex(*m_psCurRecord,nFieldIndex,nFieldType,pVal);
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void  CMdbQuery::getFieldValByIndex(int nFieldIndex,int nFieldType,void *pVal)
{
	if(m_psCurRecord == m_ppsRecords.end())
	{
		throwException(MDB_EC_NORMAL,MDB_ET_FOUND_EOR,"CMdbQuery::getFieldValByIndex Error,End of Record Found,Tbl:%s\n",m_psTblMeta->m_szTblName);
	}
	CMdbTbl cMdbTbl(m_pcAlloc,m_pcDbDict,m_psTblMeta);
 	cMdbTbl.getFieldValByIndex(*m_psCurRecord,nFieldIndex,nFieldType,pVal);
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void CMdbQuery::deleteRec()
{
	
	if(m_psCurRecord == m_ppsRecords.end())
	{
		throwException(MDB_EC_NORMAL,MDB_ET_FOUND_EOR,"CMdbQuery::deleteRec Error,End of Record Found,Tbl:%s\n",m_psTblMeta->m_szTblName);
	}
	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.remove(*m_psCurRecord);
		
	}
	
 	cMdbTbl.removeRecord(*m_psCurRecord);
 	CListIter cTmpRecord = m_psCurRecord;
 	if(m_psCurRecord == m_ppsRecords.begin())
 	{
 		m_psCurRecord = m_ppsRecords.end();
 	}
 	else if(!m_ppsRecords.empty())
 	{
 		--m_psCurRecord;
 	}
 	m_ppsRecords.erase(cTmpRecord);
 	
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void  CMdbQuery::createRec()
{
	CMdbTbl cMdbTbl(m_pcAlloc,m_pcDbDict,m_psTblMeta);
 	CRecordNode  *psRecordNode = cMdbTbl.createRecord();
 	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.insert(psRecordNode);
	}
	if(m_psCurRecord == m_ppsRecords.end() || m_ppsRecords.empty())
	{
			//cerr << "m_psCurRecord1:NULL" << endl;
	}
	else
	{
		//cerr << "m_psCurRecord1:" << (void *)(*m_psCurRecord) << endl;
	}
	if(m_psCurRecord != m_ppsRecords.end() && !m_ppsRecords.empty())
 	{
 		++m_psCurRecord;
 	}
 	//cerr << "m_psCurRecord2:" << (void *)(*m_psCurRecord) << endl;
 	m_ppsRecords.insert(m_psCurRecord,psRecordNode);
 	--m_psCurRecord;
 	//cerr << "m_psCurRecord3:" << (void *)(*m_psCurRecord) << endl;
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void CMdbQuery::CMdbField::operator=(char nVal)
{
	m_cMdbQuery.setFieldValByName(m_szFieldName,FT_INT8,&nVal);
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void CMdbQuery::CMdbField::operator=(unsigned char nVal)
{
	m_cMdbQuery.setFieldValByName(m_szFieldName,FT_UINT8,&nVal);
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void CMdbQuery::CMdbField::operator=(short nVal)
{
	m_cMdbQuery.setFieldValByName(m_szFieldName,FT_INT16,&nVal);
}


//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void CMdbQuery::CMdbField::operator=(unsigned short nVal)
{
	m_cMdbQuery.setFieldValByName(m_szFieldName,FT_UINT16,&nVal);
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void CMdbQuery::CMdbField::operator=(int nVal)
{
	m_cMdbQuery.setFieldValByName(m_szFieldName,FT_INT32,&nVal);
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void CMdbQuery::CMdbField::operator=(unsigned int nVal)
{
	m_cMdbQuery.setFieldValByName(m_szFieldName,FT_UINT32,&nVal);
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void CMdbQuery::CMdbField::operator=(long nVal)
{
	m_cMdbQuery.setFieldValByName(m_szFieldName,FT_INT32,&nVal);
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void CMdbQuery::CMdbField::operator=(unsigned long nVal)
{
	m_cMdbQuery.setFieldValByName(m_szFieldName,FT_UINT32,&nVal);
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void CMdbQuery::CMdbField::operator=(long long nVal)
{
	m_cMdbQuery.setFieldValByName(m_szFieldName,FT_INT64,&nVal);
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void CMdbQuery::CMdbField::operator=(unsigned long long nVal)
{
	m_cMdbQuery.setFieldValByName(m_szFieldName,FT_UINT64,&nVal);
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
void CMdbQuery::CMdbField::operator=(const char *pVal)
{
	m_cMdbQuery.setFieldValByName(m_szFieldName,FT_STRING,pVal);
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
CMdbQuery::CMdbField::operator char()
{
	char nVal;
	m_cMdbQuery.getFieldValByName(m_szFieldName,FT_INT8,&nVal);
	return nVal;
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
CMdbQuery::CMdbField::operator unsigned char()
{
	unsigned char nVal;
	m_cMdbQuery.getFieldValByName(m_szFieldName,FT_UINT8,&nVal);
	return nVal;
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
CMdbQuery::CMdbField::operator short()
{
	short nVal;
	m_cMdbQuery.getFieldValByName(m_szFieldName,FT_INT16,&nVal);
	return nVal;
}

//----------------------------------------------------------------------------
// 函数原型： CWorkFlow::CWorkFlow(int nBucketNum)
// 函数功能： CWorkFlow    构造函数
// 传入参数： 无
// 传出参数： 无
// 函数返回： 无
// 注意事项： 无
//---------------------------------------------------------------------------
CMdbQuery::CMdbField::operator unsigned short()
{