[收藏]一个数据库操作例子

天云上人 · 发表于 2004-1-28 23:41:39

int CObserverLaneDB::InsertTollSplitWasteBook()
{
_ConnectionPtr pLocalConnectPtr;
_RecordsetPtr  pRstPtrTollRate;
_RecordsetPtr  pRstPtrSplitWastebook;

char pcSQL[300];
sprintf(pcSQL,"Select * from TBL_TOLL_RATE where Entry_Station_ID = %ld and Flag_Station1 = %ld and Flag_Station2 = %ld and Exit_Station_ID = %ld and Vehicle_Class = %ld and Vehicle_Case = %ld ",
g_ModelEntryInfo.m_PassCard.nEntryStationID,
g_ModelEntryInfo.m_PassCard.nFlagStation1,
g_ModelEntryInfo.m_PassCard.nFlagStation2,
g_ModelNodeInfo.m_nStationID,
g_ModelTollInfo.m_TollWasteBook.m_nVehicleClass,
g_ModelTollInfo.m_TollWasteBook.m_nVehicleCase
);

try
{
pLocalConnectPtr.CreateInstance(__uuidof(Connection));
pLocalConnectPtr->Open(m_pcConnection,"","",adConnectUnspecified);

pRstPtrTollRate.CreateInstance(__uuidof(Recordset));
pRstPtrTollRate->Open(pcSQL,
pLocalConnectPtr.GetInterfacePtr(),
adOpenStatic,
adLockPessimistic,
adCmdText);
pRstPtrSplitWastebook.CreateInstance(__uuidof(Recordset));
pRstPtrSplitWastebook->Open(_variant_t("TBL_SPLIT_WASTEBOOK_CURRENT"),
pLocalConnectPtr.GetInterfacePtr(),
adOpenUnspecified,
adLockPessimistic,
adCmdTable);

pRstPtrTollRate->MoveFirst();
for(int i = 0;i<pRstPtrTollRate->RecordCount;i++)
{
pRstPtrSplitWastebook->AddNew();
pRstPtrSplitWastebook->Fields->Item["NET_ID"]->Value= _variant_t((long)g_ModelNodeInfo.m_nNetID);

pRstPtrSplitWastebook->Fields->Item["STATION_ID"]->Value=_variant_t((long)g_ModelNodeInfo.m_nStationID);

pRstPtrSplitWastebook->Fields->Item["NODE_ID"]->Value=_variant_t((long)g_ModelNodeInfo.m_nNodeID);

pRstPtrSplitWastebook->Fields->Item["WASTE_NO"]->Value=_variant_t((long)m_nTableTollWasteNO);

COleDateTime CreationTime((time_t)g_ModelTollInfo.m_TollWasteBook.m_nCreationTime);
pRstPtrSplitWastebook->Fields->Item["SPLIT_TIME"]->Value=(DATE)CreationTime;

pRstPtrSplitWastebook->Fields->Item["WORK_DATE"]->Value=(DATE)g_ModelOperatorInfo.m_oletmWorkDate;

pRstPtrSplitWastebook->Fields->Item["SPLIT_NUMBER"]->Value=pRstPtrTollRate->Fields->Item["SPLIT_NUMBER"]->Value;

pRstPtrSplitWastebook->Fields->Item["SPLIT_SEQUENCE"]->Value=pRstPtrTollRate->Fields->Item["SPLIT_SEQUENCE"]->Value;

pRstPtrSplitWastebook->Fields->Item["OUT_OWNER_ID"]->Value=_variant_t((long)g_ModelNodeInfo.m_nOwnerID);

pRstPtrSplitWastebook->Fields->Item["OWNER_ID"]->Value=pRstPtrTollRate->Fields->Item["OWNER_ID"]->Value;

float fTollReceivable = g_ModelTollInfo.m_TollWasteBook.m_fTollReceivable;
float fOwnerToll = pRstPtrTollRate->Fields->Item["OWNER_TOLL"]->Value;
float fTollMoney = pRstPtrTollRate->Fields->Item["Toll_Money"]->Value;
pRstPtrSplitWastebook->Fields->Item["OWNER_TOLL"]->Value= fTollReceivable * fOwnerToll / fTollMoney;

pRstPtrSplitWastebook->Update();

m_nTableSplitTollWasteNOCount++;
pRstPtrTollRate->MoveNext();
}
pRstPtrSplitWastebook->Close();
pRstPtrTollRate->Close();
pLocalConnectPtr->Close();
m_nStatus = DB_OK;
return(m_nStatus);
}
catch(_com_error e)
{
g_ModelPrompt.strPrompt.Format("Êý¾Ý¿â²Ù×÷´íÎó£º%s£¬%s\nÇëÓëÏµÍ³¹ÜÀíÔ±ÁªÏµ£¡",e.ErrorMessage(),e.Description());
g_ModelPrompt.Notify();
m_nStatus = DB_ERROR;
return(m_nStatus);
}
}

float CObserverLaneDB::GetTollRate()
{

_ConnectionPtr pLocalConnectPtr;
_RecordsetPtr  pRstPtrTollRate;
_RecordsetPtr  pRstPtrOrganInfo;

float fToll = -1;
char pcSQL[300];
int  nSplitCount = 0;
switch(g_ModelNodeInfo.m_nNodeType)
{
case NODE_TYPE_ENTRY:
return(0);
break;
case NODE_TYPE_EXIT:
case NODE_TYPE_MAIN_LANE:
switch(g_ModelTollInfo.m_TollWasteBook.m_nVehicleCase)
{
case VEHICLE_CASE_URGENT:
case VEHICLE_CASE_ILLEGAL:
case VEHICLE_CASE_OFFDUTY_ILLEGAL:
case VEHICLE_CASE_MOTORCADE:
case VEHICLE_CASE_COMMUTATION_TICKET:
case VEHICLE_CASE_ETC:
case VEHICLE_CASE_BAD_CARD:
case VEHICLE_CASE_NO_CARD:
sprintf(pcSQL,"Select * from TBL_TOLL_RATE where Vehicle_Class = %ld and Vehicle_Case = %ld ",
g_ModelTollInfo.m_TollWasteBook.m_nVehicleClass,
g_ModelTollInfo.m_TollWasteBook.m_nVehicleCase);
break;
default:
sprintf(pcSQL,"Select * from TBL_TOLL_RATE where Entry_Station_ID = %ld and Flag_Station1 = %ld and Flag_Station2 = %ld and Exit_Station_ID = %ld and Vehicle_Class = %ld and Vehicle_Case = %ld ",
g_ModelEntryInfo.m_PassCard.nEntryStationID,
g_ModelEntryInfo.m_PassCard.nFlagStation1,
g_ModelEntryInfo.m_PassCard.nFlagStation2,
g_ModelNodeInfo.m_nStationID,
g_ModelTollInfo.m_TollWasteBook.m_nVehicleClass,
g_ModelTollInfo.m_TollWasteBook.m_nVehicleCase);
break;
}

try
{
pLocalConnectPtr.CreateInstance(__uuidof(Connection));
pLocalConnectPtr->Open(m_pcConnection,"","",adConnectUnspecified);

pRstPtrTollRate.CreateInstance(__uuidof(Recordset));
pRstPtrTollRate->Open(pcSQL,
pLocalConnectPtr.GetInterfacePtr(),
adOpenStatic,
adLockPessimistic,
adCmdText);
if(pRstPtrTollRate->RecordCount > 0)
{
fToll = pRstPtrTollRate->Fields->Item["TOLL_MONEY"]->Value;
if(pRstPtrTollRate->RecordCount > 1 && pRstPtrTollRate->RecordCount < 5 )
{
memset(g_ModelDeviceInfo.m_Printer.m_pcSplitInfo,0,sizeof(g_ModelDeviceInfo.m_Printer.m_pcSplitInfo));
pRstPtrTollRate->MoveFirst();
for(int i = 0;i<pRstPtrTollRate->RecordCount;i++)
{
sprintf(pcSQL,"Select * from TBL_ORGANINFO where MAINOWNER_ID = %ld",(long)pRstPtrTollRate->Fields->Item["OWNER_ID"]->Value);
pRstPtrOrganInfo.CreateInstance(__uuidof(Recordset));
pRstPtrOrganInfo->Open(pcSQL,
pLocalConnectPtr.GetInterfacePtr(),
adOpenStatic,
adLockPessimistic,
adCmdText);
nSplitCount++;
char pcBuf[10];
if(0 == nSplitCount%3)
{
sprintf(pcBuf," : %.2f \n",(float)pRstPtrTollRate->Fields->Item["OWNER_TOLL"]->Value);
}else
{
sprintf(pcBuf," : %.2f ",(float)pRstPtrTollRate->Fields->Item["OWNER_TOLL"]->Value);
}
strncat(g_ModelDeviceInfo.m_Printer.m_pcSplitInfo,(LPCSTR)(_bstr_t)(pRstPtrOrganInfo->Fields->Item["ORGAN_NAME"]->Value),4);
strcat(g_ModelDeviceInfo.m_Printer.m_pcSplitInfo,pcBuf);
pRstPtrOrganInfo->Close();
pRstPtrTollRate->MoveNext();
}
}

}else fToll = -1;

pRstPtrTollRate->Close();
pLocalConnectPtr->Close();
m_nStatus = DB_OK;
return(fToll);
}
catch(_com_error e)
{
g_ModelPrompt.strPrompt.Format("Êý¾Ý¿â²Ù×÷´íÎó£º%s£¬%s\nÇëÓëÏµÍ³¹ÜÀíÔ±ÁªÏµ£¡",e.ErrorMessage(),e.Description());
g_ModelPrompt.Notify();
m_nStatus = DB_ERROR;
return(fToll);
}

break;
case NODE_TYPE_OPEN:
sprintf(pcSQL,"Select * from TBL_TOLL_RATE where Vehicle_Class = %ld",
g_ModelTollInfo.m_TollWasteBook.m_nVehicleClass
);
try
{
pLocalConnectPtr.CreateInstance(__uuidof(Connection));
pLocalConnectPtr->Open(m_pcConnection,"","",adConnectUnspecified);

pRstPtrTollRate.CreateInstance(__uuidof(Recordset));
pRstPtrTollRate->Open(pcSQL,
pLocalConnectPtr.GetInterfacePtr(),
adOpenStatic,
adLockPessimistic,
adCmdText);
if(pRstPtrTollRate->RecordCount > 0)
{
fToll = pRstPtrTollRate->Fields->Item["TOLL_MONEY"]->Value;
}else fToll = -1;

pRstPtrTollRate->Close();
pLocalConnectPtr->Close();
m_nStatus = DB_OK;
return(fToll);
}
catch(_com_error e)
{
g_ModelPrompt.strPrompt.Format("Êý¾Ý¿â²Ù×÷´íÎó£º%s£¬%s\nÇëÓëÏµÍ³¹ÜÀíÔ±ÁªÏµ£¡",e.ErrorMessage(),e.Description());
g_ModelPrompt.Notify();
m_nStatus = DB_ERROR;
return(fToll);
}
break;
default:
m_nStatus = DB_ERROR;
break;
}
return(fToll);
}

		自动登录	找回密码
密码			注册