void TProCtrller::ProDat(const char * fetSql)
{
/* Transformer Data */
void (TProCtrller::*pTranData)(DEST_REC &dst, SRCE_REC &src);
DEST_REC sBosRat;
SRCE_REC sBosDfs;
if (m_cSrcDatType == '0') {
pTranData = &TProCtrller::TransformVoice;
} else if (m_cSrcDatType == '1') {
pTranData = &TProCtrller::TransformData;
} else if (m_cSrcDatType == '2') {
pTranData = &TProCtrller::TransformGprs;
} else {
throw TException("Unknow TabType:[%c]", m_cSrcDatType);
}
for (std::vector < std::string >::iterator it = m_vInputDfsNames.begin();
it != m_vInputDfsNames.end(); ++it) {
printf("Process Table[%s]...\n", it->c_str());
m_cDbi.DBI_OpenFetCursor(it->c_str(), fetSql);
(this->*pTranData)(sBosRat, sBosDfs);
}
printf("Fetch:%u\tInsert:%u\n", m_iFetCount, m_iInsCount);
}
阅读(449) | 评论(0) | 转发(0) |