`

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语句正确 ...
评论
发表评论

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

相关推荐

    DBManager.java

    DBManager.java

    DBManager.exe

    数据库操作工具，针对多种弄数据库进行操作。查看各种数据。

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

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

    C#基础全接触

    { //创建指向具体处理函数的代表实例（新建一个代表，让它指向具体的处理函数） DBManager.EmnuConnectionCallback myCallback = new DBManager.EmnuConnectionCallback(ActiveConncetionCallback);...

    Java简单模拟ATM机项目

    DbManager.class mysql-connector-java-5.1.18-bin.jar db mysql_bank.sql sqlserver_bank.sql lib mysql-connector-java-5.1.18-bin.jar MANIFEST.MF pics a11.jpg a12.jpg a13.jpg a16.jpg a18.jpg ...

    WP-DBManager2.50 简体中文包插件 for WordPress.zip

    WP-DBManager2.50 简体中文包插件 插件使用方法： 1.上传到插件目录，在WordPress控制面板激活插件。 2.插件激活之后，会在wp-content目录生成一个backup-db的目录，目录的默认需要的权限是：777。   ...

    java dbmanager

    java dbmanager

    Java简单模拟ATM机

    java语言编写的简单模拟ATM机功能案例，有美观的UI界面，和比较完善的功能模块，业务分层，编码格式规范。可供初学者参考。 另在db文件夹中附带两种数据库（mysql、sqlserver）表结构。... DbManager.java Thumbs.db

    sqlite数据库操作工具类(含jsqlite.jar包)

    sqlite数据库操作工具类(含jsqlite.jar包),DBManager.java工具类可复制到项目中直接使用

    数衡电子秤传秤软件(电子秤管理系统).rar

    数衡电子秤传称软件主程序：DBManager.exe本软件采用“多线程技术”实现与数衡电子秤通讯，够实现对数衡全系列联网电子秤的集中管理，提供商品管理、网络测试、预设键、标设计、店名及文本、用户及权限等一系列管理...

    数据库备份插件WP-DBManager

    WP-DBManager插件介绍： WP-DBManager是wordpress的数据备份插件，目前最新版本为2.40，其主要用途是对WordPress 的数据库进行管理，从而省去了用户必须使用类似PhpMyadmin登录数据库进行备份、修复、导入等操作，...

    Android代码-android

    android write some code about android some tools about android 1 DBManager.java help you to manage the SQLiteDatabase of sqlLite , support multithreaded access.

    jsp所做点卡销售系统

    环境:myeclipse,sqlserver 2005,tomcat,里面附带的jar包是08数据库所用，可以换掉，DBManager.jar中可以修改数据库密码

    用jsp做的简单blog(博客)

    是用myEclipse开发的,tomcat服务器，sqlServer2005数据库，里面jar包是08数据库的，可以换掉，DBManager.java中可以修改数据库密码

    DbManager:用于新系统的数据库Maganer-开源

    该软件实现了一个数据库内容管理器系统，该系统适用于使用ORM框架系统FRESHHH https://sourceforge.net/p/hierarnodesys/的mysql数据库。... 演示：https：//freshhh-dbmanager.sourceforge.io/sample/

    C3P0连接池管理类

    C3P0 数据库连接池 管理类 驱动包 只要在DBManager.java内加上自己的oracle地址和用户名密码即可，如果是用别的数据库，则把相应的数据库连接地址改改就成

    飘云论坛系统 1.0.rar

    飘云论坛系统功能比较简单，实现了用户注册...适合初学者使用。注意：开发环境为Visual Studio 2008,数据库为SQL Server 2008用户名密码是:admin数据库连接文件：master.master.cs、login.aspx、App_Code/DbManager.cs

    DBManager Professional 3.4.6

    DBManager Professional 3.4.6,专业版，功能比免费版强大很多，虽然只有20天试用，但使用比较少，影响不大

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