`

DBManager.h

 
阅读更多
  1. //SaioSqlce.cpp:implementationoftheCDBManageclass.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  4. #ifndefSAIOSQLCE_DLL_FILE
  5. #defineSAIOSQLCE_DLL_FILE
  6. #endif
  8. #include"stdafx.h"
  9. #include"SAIOSQLCEDBManage.h"
  10. #include"SaioSqlce.h"
  14. #ifdef_DEBUG
  15. #undefTHIS_FILE
  16. staticcharTHIS_FILE[]=__FILE__;
  17. #definenewDEBUG_NEW
  18. #endif
  21. //本机数据库文件
  22. #defineCUP_DB_FILE_T("\\Saio\\UserPrograms\\WIC\\WICDB.sdf")
  23. #defineCUP_DB_TEMP_T("\\Saio\\UserPrograms\\WIC\\WICDB.sd2")
  24. //////////////////////////////////////////////////////////////////////
  25. //Construction/Destruction
  26. //////////////////////////////////////////////////////////////////////
  28. CDBManage::CDBManage()
  29. {
  31. }
  33. CDBManage::~CDBManage()
  34. {
  36. }
  38. //打开数据库
  39. BOOLCDBManage::OpenDB()
  40. {
  41. InitConnectvariable(_T("\\Saio\\UserPrograms\\WIC\\WICDB.sdf"));
  43. returnOpenConnection();
  44. }
  46. //关闭数据库
  47. BOOLCDBManage::CloseDB()
  48. {
  49. BOOLbRet=TRUE;
  50. bRet=CloseRecordset();
  51. bRet&=CloseConnection();
  53. returnbRet;
  54. }
  56. //收缩数据库
  57. BOOLCDBManage::ShrinkDB()//需要修改
  58. {
  59. CloseDB();
  61. TCHARszDbPwd[]=_T("");//如果有密码需要填入
  63. BOOLbRet=TRUE,bDelRet=FALSE;
  64. DWORDdwErr=0;
  65. HRESULThr=NOERROR;
  66. DBPROPSETdbpropset[2];
  67. DBPROPdbprop[2];
  69. IDBProperties*pIDBProperties=NULL;
  70. IDBCreateSession*pIDBCreateSession=NULL;
  71. ISSCECompact*pISSCECompact=NULL;
  72. IDBSchemaRowset*pIDBSchemaRowset=NULL;
  74. VariantInit(&dbprop[0].vValue);
  76. hr=CoCreateInstance(CLSID_SQLSERVERCE_2_0,0,CLSCTX_INPROC_SERVER,IID_IDBProperties,(void**)&pIDBProperties);
  77. if(FAILED(hr))
  78. {
  79. dwErr=GetLastError();
  80. bRet=FALSE;
  81. gotoExit;
  82. }
  84. dbprop[0].dwPropertyID=DBPROP_INIT_DATASOURCE;
  85. dbprop[0].dwOptions=DBPROPOPTIONS_REQUIRED;
  86. dbprop[0].vValue.vt=VT_BSTR;
  87. dbprop[0].vValue.bstrVal=SysAllocString(CUP_DB_FILE);
  88. if(NULL==dbprop[0].vValue.bstrVal)
  89. {
  90. hr=E_OUTOFMEMORY;
  91. dwErr=GetLastError();
  92. bRet=FALSE;
  93. gotoExit;
  94. }
  96. dbprop[1].dwPropertyID=DBPROP_SSCE_DBPASSWORD;
  97. dbprop[1].dwOptions=DBPROPOPTIONS_REQUIRED;
  98. dbprop[1].vValue.vt=VT_BSTR;
  99. dbprop[1].vValue.bstrVal=SysAllocString(szDbPwd);
  101. dbpropset[0].guidPropertySet=DBPROPSET_DBINIT;
  102. dbpropset[0].rgProperties=dbprop;
  103. dbpropset[0].cProperties=1;
  104. ;
  105. dbpropset[1].guidPropertySet=DBPROPSET_SSCE_DBINIT;
  106. dbpropset[1].rgProperties=&dbprop[1];
  107. dbpropset[1].cProperties=1;
  110. hr=pIDBProperties->SetProperties(2,dbpropset);
  111. if(FAILED(hr))
  112. {
  113. dwErr=GetLastError();
  114. bRet=FALSE;
  115. gotoExit;
  116. }
  118. hr=pIDBProperties->QueryInterface(IID_ISSCECompact,(void**)&pISSCECompact);
  119. if(FAILED(hr))
  120. {
  121. dwErr=GetLastError();
  122. bRet=FALSE;
  123. gotoExit;
  124. }
  126. bDelRet=DeleteFile(CUP_DB_TEMP);
  128. SysFreeString(dbprop[0].vValue.bstrVal);
  129. dbprop[0].vValue.bstrVal=SysAllocString(CUP_DB_TEMP);
  130. if(NULL==dbprop[0].vValue.bstrVal)
  131. {
  132. hr=E_OUTOFMEMORY;
  133. dwErr=GetLastError();
  134. bRet=FALSE;
  135. gotoExit;
  136. }
  138. hr=pISSCECompact->Compact(1,dbpropset);
  139. if(FAILED(hr))
  140. {
  141. dwErr=GetLastError();
  142. bRet=FALSE;
  143. gotoExit;
  144. }
  145. bDelRet=CopyFile(CUP_DB_TEMP,CUP_DB_FILE,FALSE);
  146. if(bDelRet)
  147. {
  148. bDelRet=DeleteFile(CUP_DB_TEMP);
  149. }
  151. Exit:
  153. VariantClear(&dbprop[0].vValue);
  155. if(NULL!=pISSCECompact)
  156. {
  157. pISSCECompact->Release();
  158. }
  159. if(NULL!=pIDBSchemaRowset)
  160. {
  161. pIDBSchemaRowset->Release();
  162. }
  163. if(NULL!=pIDBCreateSession)
  164. {
  165. pIDBCreateSession->Release();
  166. }
  167. if(NULL!=pIDBProperties)
  168. {
  169. pIDBProperties->Release();
  170. }
  172. returnbRet;
  173. }
  175. //初始化系统数据库
  176. BOOLCDBManage::InitDB()
  177. {
  178. BOOLbRet=TRUE;
  180. //关闭记录
  181. CloseRecordset();
  183. //用户表
  184. bRet&=InitUserTable();
  186. //参数表
  187. bRet&=InitParamTable();
  189. //APL表
  190. bRet&=InitAPLTable();
  192. //价格表
  193. bRet&=InitPriceTable();
  195. //传输表
  196. bRet&=InitTransTable();
  198. //更新表
  199. bRet&=InitUpdateTable();
  201. returnbRet;
  202. }
  204. //初始化用户表
  205. BOOLCDBManage::InitUserTable()//ok
  206. {
  207. BOOLbRet=TRUE;
  209. //删除用户表
  210. CStringcsSql=_T("DROPTableUserTb");
  211. ExecuteSQL(csSql);
  214. //新建用户表
  215. csSql=_T("CREATETABLEUserTb(uidnvarchar(6)PRIMARYKEY,pwdnvarchar(6)NOTNULL,privilegenchar(1)NOTNULL);");
  216. bRet&=ExecuteSQL(csSql);
  218. //CStringcsPwd=CMd5::Encrypt(_T("1234"));
  219. //csSql.Format(_T("INSERTINTOUserTb(uid,pwd,privilege)VALUES('1234','%s','1');"),csPwd);
  220. //如果需要加密采取以上的方法(:~
  222. //添加普通用户Cashier(1234/1234/1)
  223. csSql=_T("INSERTINTOUserTb(uid,pwd,privilege)VALUES('1234','1234','1');");
  224. bRet&=ExecuteSQL(csSql);
  226. //csPwd=CMd5::Encrypt(_T("123456"));
  227. //csSql.Format(_T("INSERTINTOUserTb(uid,pwd,privilege)VALUES(123456,'%s',2);"),csPwd);
  228. //如果需要加密采取以上的方法(:~
  230. //添加主管操作员Admin(123456/123456/2)
  231. csSql=_T("INSERTINTOUserTb(uid,pwd,privilege)VALUES('123456','123456','2');");
  232. bRet&=ExecuteSQL(csSql);
  234. returnbRet;
  235. }
  237. BOOLCDBManage::InitParamTable()//ok
  238. {
  239. BOOLbRet=TRUE;
  241. //删除Param表
  242. CStringcsSql=_T("DROPTableParamTb");
  243. ExecuteSQL(csSql);
  245. //新建APL表
  246. csSql=_T("CREATETABLEParamTb(pidsmallintPRIMARYKEY,pnamenvarchar(30),pvaluenvarchar(40));");
  247. bRet&=ExecuteSQL(csSql);
  251. returnbRet;
  252. }
  254. BOOLCDBManage::InitAPLTable()//ok
  255. {
  256. BOOLbRet=TRUE;
  258. //删除APL表
  259. CStringcsSql=_T("DROPTableAPLTb");
  260. ExecuteSQL(csSql);
  262. //新建APL表
  263. csSql=_T("CREATETABLEAPLTb(upcnvarchar(17)PRIMARYKEY,descriptionnvarchar(50),categorynchar(2),subcategorynchar(3),punitnvarchar(10),maxpricenchar(6),ptypenchar(2));");
  265. bRet&=ExecuteSQL(csSql);
  267. //--------------------------临时插入测试数据jacky2008-10-18-----------
  268. csSql=_T("INSERTINTOAPLTbVALUES('TestUPC1','JustForTest1','1','1-1','Unit1','40.25','1');");
  269. bRet&=ExecuteSQL(csSql);
  271. csSql=_T("INSERTINTOAPLTbVALUES('TestUPC2','JustForTest2','2','2-1','Unit2','2.01','2');");
  272. bRet&=ExecuteSQL(csSql);
  274. csSql=_T("INSERTINTOAPLTbVALUES('TestUPC3','JustForTest3','3','3-1','Unit3','1.2','1');");
  275. bRet&=ExecuteSQL(csSql);
  276. //---------------------------End插入测试数据--------------------------
  278. returnbRet;
  279. }
  281. BOOLCDBManage::InitPriceTable()//ok
  282. {
  283. BOOLbRet=TRUE;
  285. //删除Price表
  286. CStringcsSql=_T("DROPTablePriceTb");
  287. ExecuteSQL(csSql);
  289. //新建Price表
  290. csSql=_T("CREATETABLEPriceTb(upcnchar(17)PRIMARYKEY,pricenchar(6));");
  291. bRet&=ExecuteSQL(csSql);
  293. //--------------------------临时插入测试数据jacky2008-10-18-----------
  294. //MessageBox(NULL,_T("InitPriceTbData"),_T("OpenRecordset"),MB_OK);
  296. csSql=_T("INSERTINTOPriceTbVALUES('a1b2c3d4','12.34');");
  297. bRet&=ExecuteSQL(csSql);
  299. csSql=_T("INSERTINTOPriceTbVALUES('TestUPC1','34.45');");
  300. bRet&=ExecuteSQL(csSql);
  302. csSql=_T("INSERTINTOPriceTbVALUES('TestUPC2','0.45');");
  303. bRet&=ExecuteSQL(csSql);
  304. //---------------------------End插入测试数据--------------------------
  306. returnbRet;
  307. }
  309. BOOLCDBManage::InitTransTable()//ok
  310. {
  311. BOOLbRet=TRUE;
  313. //删除Trans表
  314. CStringcsSql=_T("DROPTableTransTb");
  315. ExecuteSQL(csSql);
  317. //新建Trans表
  318. csSql=_T("CREATETABLETransTb(traceidnchar(6)PRIMARYKEY,msgtypenchar(4),amountnchar(12),uidnchar(4),transdatenchar(6),transtimenchar(6),aiicodenvarchar(12));");
  319. bRet&=ExecuteSQL(csSql);
  321. //--------------------------临时插入测试数据jacky2008-10-18-----------
  322. csSql=_T("INSERTINTOTransTbVALUES('001','1','10','1234','081018','143302','0810181433');");
  323. bRet&=ExecuteSQL(csSql);
  325. csSql=_T("INSERTINTOTransTbVALUES('002','2','20','1234','061018','143366','0610181433');");
  326. bRet&=ExecuteSQL(csSql);
  328. csSql=_T("INSERTINTOTransTbVALUES('003','3','30','1234','081018','143100','0810181431');");
  329. bRet&=ExecuteSQL(csSql);
  330. ////---------------------------End插入测试数据--------------------------
  332. returnbRet;
  333. }
  335. BOOLCDBManage::InitUpdateTable()//ok
  336. {
  337. BOOLbRet=TRUE;
  339. //删除Update表
  340. CStringcsSql=_T("DROPTableUpdateTb");
  341. ExecuteSQL(csSql);
  343. //新建Update表
  344. csSql=_T("CREATETABLEUpdateTb(tidnchar(2)PRIMARYKEY,tnamenvarchar(20),lupdatenchar(6),luptimenchar(6));");
  345. bRet&=ExecuteSQL(csSql);
  347. returnbRet;
  348. }
  350. BOOLCDBManage::AnalyzeBalance(BIItembiInput,Balance*balOutput)
  351. {
  352. //1根据byCategorybySubCategory
  353. //2==>获得upc
  354. //3==>让后查询APLTb,获取相关信息
  356. CStringcsSQL;
  357. WCHARwcCategory[2];
  358. WCHARwcSubCategory[3];
  360. VARIANTvarUPC;
  361. VARIANTvarUnit;
  362. VARIANTvarDescription;
  363. VariantInit(&varUPC);
  364. VariantInit(&varUnit);
  365. VariantInit(&varDescription);
  367. BOOLbRet=TRUE;
  368. DWORDdwNum;
  369. charTempArray[50];
  371. if(balOutput==NULL)
  372. returnFALSE;
  374. memcpy(TempArray,biInput.byCategory,sizeof(biInput.byCategory));
  375. dwNum=MultiByteToWideChar(CP_ACP,0,TempArray,-1,NULL,0);
  376. MultiByteToWideChar(CP_ACP,0,TempArray,-1,wcCategory,dwNum);
  378. memcpy(TempArray,biInput.bySubCategory,sizeof(biInput.bySubCategory));
  379. dwNum=MultiByteToWideChar(CP_ACP,0,TempArray,-1,NULL,0);
  380. MultiByteToWideChar(CP_ACP,0,TempArray,-1,wcSubCategory,dwNum);
  382. csSQL.Format(_T("SELECT*FROMAPLTbWHEREcategory='%s'ANDsubcategory='%s';"),wcCategory,wcSubCategory);
  383. MessageBox(NULL,csSQL,_T("OpenRecordset"),MB_OK);
  385. //bRet&=ExecuteSQL(csSQL);
  386. bRet&=OpenRecordset(csSQL);
  389. if(GetRecordCount(csSQL)==0)//无法匹配
  390. {
  391. return(bRet&=FALSE);
  392. }
  393. else
  394. {
  395. MoveFirst();
  397. varUPC=GetCollect(_T("upc"));
  398. dwNum=WideCharToMultiByte(CP_OEMCP,NULL,varUPC.bstrVal,-1,NULL,0,NULL,FALSE);
  399. WideCharToMultiByte(CP_OEMCP,NULL,varUPC.bstrVal,-1,TempArray,dwNum,NULL,FALSE);
  400. //strcpy(balOutput->szItemUPC,"hello");
  401. //Errorr????Jacky2008-10-11
  402. //memcpy(balOutput->szItemUPC,"1234",4);
  403. memcpy(balOutput->szItemUPC,TempArray,dwNum);
  404. //for(intiUPC=0;iUPC<(int)dwNum;iUPC++)
  405. //{
  406. //balOutput->szItemUPC[iUPC]=TempArray[iUPC];
  407. //}s
  408. MessageBox(NULL,varUPC.bstrVal,_T("OpenRecordset"),MB_OK);
  410. varUnit=GetCollect(_T("punit"));
  411. dwNum=WideCharToMultiByte(CP_OEMCP,NULL,varUnit.bstrVal,-1,NULL,0,NULL,FALSE);
  412. WideCharToMultiByte(CP_OEMCP,NULL,varUnit.bstrVal,-1,TempArray,dwNum,NULL,FALSE);
  413. //memcpy(balOutput->szUnit,TempArray,dwNum);
  414. //strncpy(balOutput->szUnit,TempArray,dwNum);
  415. MessageBox(NULL,varUnit.bstrVal,_T("OpenRecordset"),MB_OK);
  417. varDescription=GetCollect(_T("description"));
  418. dwNum=WideCharToMultiByte(CP_OEMCP,NULL,varDescription.bstrVal,-1,NULL,0,NULL,FALSE);
  419. WideCharToMultiByte(CP_OEMCP,NULL,varDescription.bstrVal,-1,TempArray,dwNum,NULL,FALSE);
  420. //memcpy(balOutput->szItemDesc,TempArray,dwNum);
  421. //strncpy(balOutput->szItemDesc,TempArray,dwNum);
  422. MessageBox(NULL,varDescription.bstrVal,_T("OpenRecordset"),MB_OK);
  424. //for(inti=0;i<sizeof(biInput.byBenefitQuantity);i++)
  425. //{
  426. //balOutput->szBenefitQuantity[i]=biInput.byBenefitQuantity[i];
  427. //}
  428. //memcpy(balOutput->szBenefitQuantity,biInput.byBenefitQuantity,sizeof(balOutput->szBenefitQuantity));
  429. }
  431. returnbRet;
  432. }
  434. BOOLCDBManage::GetItemFromUPC(CStringcsUPC,ItemList*ilOutput)
  435. {
  436. CStringcsSql;
  437. BOOLbRet=TRUE;
  439. if(csUPC.GetLength()>=17)//UPC长度过长
  440. {
  441. returnFALSE;
  442. }
  444. csSql.Format(_T("SELECT*FROMAPLTb,PriceTbWHEREAPLTB.upc=PriceTb.upcANDAPLTB.upc='%s';"),csUPC);
  446. bRet&=OpenRecordset(csSql);
  448. if(GetRecordCount(csSql)==0)
  449. {
  450. returnFALSE;
  451. }
  452. else
  453. {
  454. //++添加向ItemList保存数据的过程jacky2008-10-20
  455. }
  457. returnbRet;
  458. }
  460. BOOLCDBManage::GetItemFromCategory(CStringcsCategory,CStringcsSubcategory,Balance*balOutput,EndBalance*ebalOutput)
  461. {
  462. BOOLbRet=TRUE;
  463. returnbRet;
  464. }
  466. BOOLCDBManage::SetItemPrice(CStringcsUpc,CStringcsPrice)//测试完毕
  467. {
  468. BOOLbRet=TRUE;
  469. CStringcsSQL;
  471. if((csUpc.GetLength()>17)||(csPrice.GetLength()>6))//字符长度过长
  472. {
  473. returnFALSE;
  474. }
  476. //if()//检查价格格式的合法性??如果有必要的话
  477. //{
  478. //}
  480. //UpdateField
  481. csSQL.Format(_T("UPDATEPriceTbSETprice='%s'WHEREupc='%s';"),csPrice,csUpc);
  482. bRet&=ExecuteSQL(csSQL);
  484. //Makesurethatfieldisupdated,Checkit
  485. csSQL.Format(_T("SELECT*FROMPriceTbWHEREupc='%s'ANDprice='%s';"),csUpc,csPrice);
  486. if(GetRecordCount(csSQL)==0)//Therecorddoesn'texist
  487. {
  488. bRet&=FALSE;
  489. }
  491. returnbRet;
  492. }
  494. BOOLCDBManage::CheckPwdData(CStringcsUid,CStringcsPwd)//测试完毕
  495. {
  496. BOOLbRet=TRUE;
  497. CStringcsSql;
  499. if((csUid.GetLength()>6)||(csPwd.GetLength()>6))//字符长度过长
  500. {
  501. returnFALSE;
  502. }
  504. csSql.Format(_T("SELECTuidFROMUserTbWHEREuid='%s'ANDpwd='%s';"),csUid,csPwd);
  505. //bRet&=ExecuteSQL(csSql);
  507. if(GetRecordCount(csSql)==0)//记录不存在
  508. {
  509. bRet&=FALSE;
  510. }
  512. returnbRet;
  513. }
  515. BOOLCDBManage::CheckParamData(){BOOLbRet=TRUE;returnbRet;}
  517. BOOLCDBManage::CheckCardData(){BOOLbRet=TRUE;returnbRet;}
  519. BOOLCDBManage::CheckResponseCode(){BOOLbRet=TRUE;returnbRet;}
  521. BOOLCDBManage::CheckUPC(){BOOLbRet=TRUE;returnbRet;}
  523. BOOLCDBManage::CheckNSF(){BOOLbRet=TRUE;returnbRet;}
  525. BOOLCDBManage::CheckAmountData(){BOOLbRet=TRUE;returnbRet;}
  527. BOOLCDBManage::CheckCountData(){BOOLbRet=TRUE;returnbRet;}
  529. BOOLCDBManage::GetLastTransData(LastTransaction*ltGet)
  530. {
  531. VARIANTvTraceid;
  532. VARIANTvMsgtype;
  533. VARIANTvAmount;
  534. VARIANTvUid;
  535. VARIANTvTransdate;
  536. VARIANTvTranstime;
  537. VARIANTvAiicode;
  539. VariantInit(&vTraceid);
  540. VariantInit(&vMsgtype);
  541. VariantInit(&vAmount);
  542. VariantInit(&vUid);
  543. VariantInit(&vTransdate);
  544. VariantInit(&vTranstime);
  545. VariantInit(&vAiicode);
  547. BOOLbRet=TRUE;
  548. charTempArray[20];//将Unicode转换为ASCII
  549. LONGlRcdSize;
  550. CStringcsSql=_T("SELECT*FROMTransTb;");
  551. DWORDdwNum;
  554. if(ltGet==NULL)
  555. returnFALSE;
  556. //bRet&=ExecuteSQL(csSql);
  557. //bRet&=MoveFirst();
  558. //MessageBox(NULL,csSql,_T("OpenRecordset"),MB_OK);
  560. bRet&=OpenRecordset(csSql);
  562. if((lRcdSize=GetRecordCount(csSql))==0)//如果当前数据记录为空
  563. {
  564. return(bRet&=FALSE);
  565. }
  566. else
  567. {
  568. MoveFirst();
  569. for(longi=0;i<lRcdSize-1;i++)
  570. /*while(!IsEOF())//移动到最后一条记录*/
  571. {
  572. MoveNext();
  573. }
  575. //vTranstime=GetCollect(_T("transtime"));
  576. //MessageBox(NULL,vTranstime.bstrVal,_T("transtime"),MB_OK);
  578. vTraceid=GetCollect(_T("traceid"));
  579. dwNum=WideCharToMultiByte(CP_OEMCP,NULL,vTraceid.bstrVal,-1,NULL,0,NULL,FALSE);//确定转换字节大小
  580. WideCharToMultiByte(CP_OEMCP,NULL,vTraceid.bstrVal,-1,TempArray,dwNum,NULL,FALSE);
  581. memcpy(ltGet->TraceNum,TempArray,dwNum);
  583. vMsgtype=GetCollect(_T("msgtype"));
  584. dwNum=WideCharToMultiByte(CP_OEMCP,NULL,vMsgtype.bstrVal,-1,NULL,0,NULL,FALSE);
  585. WideCharToMultiByte(CP_OEMCP,NULL,vMsgtype.bstrVal,-1,TempArray,dwNum,NULL,FALSE);
  586. memcpy(ltGet->byMsgType,TempArray,dwNum);
  588. vAmount=GetCollect(_T("amount"));
  589. dwNum=WideCharToMultiByte(CP_OEMCP,NULL,vAmount.bstrVal,-1,NULL,0,NULL,FALSE);
  590. WideCharToMultiByte(CP_OEMCP,NULL,vAmount.bstrVal,-1,TempArray,dwNum,NULL,FALSE);
  591. memcpy(ltGet->byTransAmount,TempArray,dwNum);
  593. vUid=GetCollect(_T("uid"));
  594. dwNum=WideCharToMultiByte(CP_OEMCP,NULL,vUid.bstrVal,-1,NULL,0,NULL,FALSE);
  595. WideCharToMultiByte(CP_OEMCP,NULL,vUid.bstrVal,-1,TempArray,dwNum,NULL,FALSE);
  596. memcpy(ltGet->byCashierID,TempArray,dwNum);
  598. vTransdate=GetCollect(_T("transdate"));
  599. dwNum=WideCharToMultiByte(CP_OEMCP,NULL,vTransdate.bstrVal,-1,NULL,0,NULL,FALSE);
  600. WideCharToMultiByte(CP_OEMCP,NULL,vTransdate.bstrVal,-1,TempArray,dwNum,NULL,FALSE);
  601. memcpy(ltGet->byLocalTransDate,TempArray,dwNum);
  603. vTranstime=GetCollect(_T("transtime"));
  604. dwNum=WideCharToMultiByte(CP_OEMCP,NULL,vTranstime.bstrVal,-1,NULL,0,NULL,FALSE);
  605. WideCharToMultiByte(CP_OEMCP,NULL,vTranstime.bstrVal,-1,TempArray,dwNum,NULL,FALSE);
  606. memcpy(ltGet->byLocalTransTime,TempArray,dwNum);
  608. vAiicode=GetCollect(_T("aiicode"));
  609. dwNum=WideCharToMultiByte(CP_OEMCP,NULL,vAiicode.bstrVal,-1,NULL,0,NULL,FALSE);
  610. WideCharToMultiByte(CP_OEMCP,NULL,vAiicode.bstrVal,-1,TempArray,dwNum,NULL,FALSE);
  611. memcpy(ltGet->byAcquirerCode,TempArray,dwNum);
  612. }
  614. returnbRet;
  615. }
  617. //LastTransactionltExample={"004","4","40","123","08102","11111","08102011111"};
  618. //LastTransactionltExample={"004","4","40","1234","081020","111111","081020111111"};
  619. BOOLCDBManage::SetLastTransData(LastTransactionltSet)//OK,但是LastTransaction初始化并没有达到实际的大小
  620. {
  621. WCHARwcTraceNum[6];
  622. WCHARwcMsgType[4];
  623. WCHARwcTransAmount[12];
  624. WCHARwcCashierID[4];
  625. WCHARwcLTDate[6];
  626. WCHARwcLTTime[6];
  627. WCHARwcAcquirerCode[12];
  629. //CStringstrTraceNum=ltSet.TraceNum;
  630. //CStringstrMsgType=ltSet.byMsgType;
  631. //CStringstrTransAmount=ltSet.byTransAmount;
  632. //CStringstrCashierID=ltSet.byCashierID;
  633. //CStringstrLTDate=ltSet.byLocalTransDate;
  634. //CStringstrLTTime=ltSet.byLocalTransTime;
  635. //CStringstrAcquirerCode=ltSet.byAcquirerCode;
  637. charTempArray[20];
  638. BOOLbRet=TRUE;
  639. CStringcsSQL;
  640. DWORDdwNum;
  642. memcpy(TempArray,ltSet.TraceNum,sizeof(ltSet.TraceNum));
  643. dwNum=MultiByteToWideChar(CP_ACP,0,TempArray,-1,NULL,0);
  644. MultiByteToWideChar(CP_ACP,0,TempArray,-1,wcTraceNum,dwNum);
  646. memcpy(TempArray,ltSet.byMsgType,sizeof(ltSet.byMsgType));
  647. dwNum=MultiByteToWideChar(CP_ACP,0,TempArray,-1,NULL,0);
  648. MultiByteToWideChar(CP_ACP,0,TempArray,-1,wcMsgType,dwNum);
  650. memcpy(TempArray,ltSet.byTransAmount,sizeof(ltSet.byTransAmount));
  651. dwNum=MultiByteToWideChar(CP_ACP,0,TempArray,-1,NULL,0);
  652. MultiByteToWideChar(CP_ACP,0,TempArray,-1,wcTransAmount,dwNum);
  654. memcpy(TempArray,ltSet.byCashierID,sizeof(ltSet.byCashierID));
  655. dwNum=MultiByteToWideChar(CP_ACP,0,TempArray,-1,NULL,0);
  656. MultiByteToWideChar(CP_ACP,0,TempArray,-1,wcCashierID,dwNum);
  658. memcpy(TempArray,ltSet.byLocalTransDate,sizeof(ltSet.byLocalTransDate));
  659. dwNum=MultiByteToWideChar(CP_ACP,0,TempArray,-1,NULL,0);
  660. MultiByteToWideChar(CP_ACP,0,TempArray,-1,wcLTDate,dwNum);
  662. memcpy(TempArray,ltSet.byLocalTransTime,sizeof(ltSet.byLocalTransTime));
  663. dwNum=MultiByteToWideChar(CP_ACP,0,TempArray,-1,NULL,0);
  664. MultiByteToWideChar(CP_ACP,0,TempArray,-1,wcLTTime,dwNum);
  666. memcpy(TempArray,ltSet.byAcquirerCode,sizeof(ltSet.byAcquirerCode));
  667. dwNum=MultiByteToWideChar(CP_ACP,0,TempArray,-1,NULL,0);
  668. MultiByteToWideChar(CP_ACP,0,TempArray,-1,wcAcquirerCode,dwNum);
  671. csSQL.Format(_T("INSERTINTOTransTbVALUES('%s','%s','%s','%s','%s','%s','%s');"),
  672. wcTraceNum,
  673. wcMsgType,
  674. wcTransAmount,
  675. wcCashierID,
  676. wcLTDate,
  677. wcLTTime,
  678. wcAcquirerCode);
  680. bRet&=ExecuteSQL(csSQL);
  682. //查找一下，看是否真的已经插入数据库的表
  683. csSQL.Format(_T("SELECT*FROMTransTbWHEREtraceid='%s';"),wcTraceNum);
  685. if(GetRecordCount(csSQL)==0)//记录不存在
  686. {
  687. bRet&=FALSE;
  688. }
  690. returnbRet;
  691. }

分享到：
| 测试ExecuteSQL()函数~ 只要SQLCE语句正确 ...
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    ado.rar_DEMO_donkeyqcb_materialhrs_mysql增删改查_数据库操作demo

    例如，`DBRSD.h` 可能包含了`DBRSD.cpp`的类定义，而`DBManager.h`包含了`DBManager.cpp`的接口声明。 这个DEMO项目对于初学者理解数据库操作原理和实践是非常有价值的，因为它提供了实际的代码示例，涵盖了从连接...

    VC++开发的图书管理系统

    - 数据库连接和操作的类文件（如`DBManager.cpp`, `DBManager.h`） - 用户界面的对话框和窗口类文件（如`AddBookDialog.cpp`, `AddBookDialog.h`） - 业务逻辑处理的函数或类文件（如`BorrowFunction.cpp`, `...

    TYDB:适用于iOS的最简单SQLite管理器

    将DBManager.h导入AppDelegate并在didFinishLaunchingWithOptions中调用以下方法。 [DBManager copyDatabaseIfNeeded ]; 如何使用 建立表格 NSMutableDictionary *data = [[ NSMutableDictionary alloc ] init ]; ...

    sqlite-demo.zip

    - "sqlite3.c"和"sqlite3.h"是SQLite的源代码文件，其中"sqlite3.c"包含了SQLite的核心功能实现，"sqlite3.h"则定义了相关的API接口。 - "main.cpp"可能是整个项目的主程序，它将调用SQLite的API进行数据库操作，...

    Qt5代码慕课信息获取

    3. **DBManager.cpp/h**：这些文件涉及到数据库管理。DBManager可能是一个用于处理数据存储和检索的类，它可能使用QSqlDatabase模块来连接和操作数据库。我们可以在这里实现SQL查询，数据插入、更新和删除等功能。 ...

    c++ mysql 引用包

    例如，可以创建一个DBManager类，包含连接、执行SQL、关闭连接等方法，以及异常处理机制。 总的来说，"c++ mysql 引用包"提供了在C++项目中与MySQL数据库交互的基础，开发者可以通过这些头文件实现对数据库的读写...

    qt 单例模式，模板

    3. **Singleton类**：在提供的描述中提到了`Singleton.h`和`SingletonCallOnce.h`，这是实现单例模式的头文件。通常，单例类包含一个私有的构造函数和一个静态方法，该方法返回单例的实例。这样，用户就不能通过常规...

    Qt开发实战：基于Qt的图书管理系统的实验心得与案例解析

    if (dbManager.addBook(title, author)) { QMessageBox::information(this, "Success", "Book added successfully."); } else { QMessageBox::critical(this, "Error", "Failed to add book."); } } } ``` ##...

    Yii2 RBAC 集成了用户管理模块和自写的权限管理模块，前端页面采用H+框架。-Yii2-Rbac.zip

    2. **Yii2 的RBAC组件**：Yii2内置了`yii\rbac\DbManager`，它使用数据库来存储RBAC数据。这个组件允许动态地创建、分配和管理角色、任务和权限。 3. **创建RBAC结构**：使用`yii\rbac\ManagerInterface`提供的方法...

    实习一远程过程调用中间件及数据访问中间件.pdf

    3. 通过编译IDL文件，生成C语言的头文件和源文件，如`mathservice.h`、`mathservice_s.c`和`mathservice_c.c`。 4. 在服务器端编写实现服务的程序，并将其编译为可执行文件，如`mathservice.exe`。 5. 在客户端编写...

    实习一远程过程调用中间件及数据访问中间件定义.pdf

    首先，使用 mysql-connector-java-5[1].0.8.zip 驱动包，编写 DBmanager 类，访问 mysql 数据库，实现创建表、录入成绩、查询成绩等操作。然后，编写客户端程序，调用服务端提供的数据库操作。 3. 服务器和客户端不...

    iOS sqlite3的使用（増删改查）

    #import &lt;sqlite3.h&gt; ``` 接下来，我们创建一个名为`DBManager`的单例类，用于管理数据库的连接和操作。这个类可以包含以下方法： 1. 初始化数据库： - `+ (void)setupDatabaseWithPath:(NSString *)databasePath...

Magicbox
Global site tag (gtag.js) - Google Analytics