开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 行业应用 > 百货/超市行业 > 查看源码
ADOConn.cpp
资源名称：chaoshiguanli.rar　[点击查看]
上传用户：jzscgs158
上传日期：2022-05-25
资源大小：8709k
文件大小：21k
源码类别：

百货/超市行业

开发平台：

Visual C++

ADOConn.cpp：源码内容
  1. #include "StdAfx.h"
  2. #include "ADOConn.h"
  3. #include "MyTime.h"
  4. #include "FileOperate.h"
  5. //功能:构造函数
  6. //strData:数据库的名字
  7. CString CADOConn::GetAppPath()
  8. {
  9. char lpFileName[MAX_PATH];
  10. GetModuleFileName(AfxGetInstanceHandle(),lpFileName,MAX_PATH);
  12. CString strFileName = lpFileName;
  13. int nIndex = strFileName.ReverseFind ('\');
  15. CString strPath;
  17. if (nIndex > 0)
  18. strPath = strFileName.Left (nIndex);
  19. else
  20. strPath = "";
  21. return strPath;
  22. }
  23. CADOConn::CADOConn(CString strData)
  24. {
  25. CString strValue;
  26. strData.TrimLeft();
  27. strData.TrimRight();
  28. m_strData=_bstr_t(strData);
  29. strValue=strData.Right(3);
  30. if(strValue=="mdb") m_DataType=1;
  31. if(strValue=="xls") m_DataType=2;
  32. }
  33. CADOConn::CADOConn()
  34. {
  35. m_DataType=1;
  36. m_strData=_bstr_t("Data.mdb");
  37. }
  38. //功能:析构函数
  39. CADOConn::~CADOConn()
  40. {
  42. }
  43. //功能:初始化数据库连接
  44. void  CADOConn::OnInitCADOConn()
  45. {
  46. // 初始化OLE/COM库环境
  47. ::CoInitialize(NULL);
  48.   try
  49. {
  50. //初始化指针
  51. m_pConnection=NULL;
  52. //初始化指针
  53. m_pRecordset=NULL;
  54. // 创建Connection对象
  55. m_pConnection.CreateInstance("ADODB.Connection");
  56. // 设置连接字符串，必须是BSTR型或者_bstr_t类型
  57. _bstr_t strConnect;
  58. switch(m_DataType)
  59. {
  60. case 1://ACCESS
  61. strConnect=_bstr_t("Provider=Microsoft.Jet.OLEDB.4.0;");
  62. strConnect=strConnect+_bstr_t("Data Source=");
  63. strConnect=strConnect+_bstr_t(GetAppPath())+_bstr_t("\data\");
  64. strConnect=strConnect+m_strData;
  65. break;
  66. case 2://EXCEL
  67. strConnect=_bstr_t("Provider=Microsoft.Jet.OLEDB.4.0;");
  68. strConnect=strConnect+_bstr_t("Data Source=");
  69. strConnect=strConnect+_bstr_t(GetAppPath())+_bstr_t("\");
  70. strConnect=strConnect+m_strData;
  71. strConnect=strConnect+";Extended Properties=Excel 8.0";
  72. break;
  73. case 3://SQLSERVER
  74. strConnect=_bstr_t("Provider=Microsoft.Jet.OLEDB.4.0;");
  75. strConnect=strConnect+_bstr_t("Data Source=D:\FECG\");
  76. strConnect=strConnect+";Extended Properties=Excel 8.0";
  77. break;
  78. }
  79. m_pConnection->Open(strConnect,_bstr_t(""),_bstr_t(""),adModeUnknown);
  80. }
  81. // 捕捉异常
  82. catch(_com_error e)
  83. {
  84. // 显示错误信息
  85. AfxMessageBox(e.Description());
  86. }
  87. ASSERT(m_pConnection != NULL);
  88. }
  89. //功能:执行查询
  90. //返回值:字段集的指针
  91. _RecordsetPtr&  CADOConn::GetRecordSet(CString strSQL)
  92. {
  94. try
  95. {
  96. // 连接数据库，如果Connection对象为空，则重新连接数据库
  97. if(m_pConnection==NULL)OnInitCADOConn();
  98. strSQL.TrimLeft();
  99. strSQL.TrimRight();
  100. // 创建记录集对象
  101. m_pRecordset.CreateInstance(__uuidof(Recordset));
  102. // 取得表中的记录
  103. m_pRecordset->Open(_bstr_t(strSQL),m_pConnection.GetInterfacePtr(),adOpenDynamic,adLockOptimistic,adCmdText);
  104. }
  105. // 捕捉异常
  106. catch(_com_error e)
  107. {
  108. // 显示错误信息
  109. AfxMessageBox(e.Description());
  110. }
  111. ASSERT(m_pRecordset!= NULL);
  112. // 返回记录集
  113. return m_pRecordset;
  114. }
  115. //功能:打开字符集
  116. //返回值:TRUE:成功 FALSE:失败
  117. BOOL CADOConn::Open(CString strSQL)
  118. {
  119. try
  120. {
  121. // 连接数据库，如果Connection对象为空，则重新连接数据库
  122. if(m_pConnection==NULL) OnInitCADOConn();
  123. strSQL.TrimLeft();
  124. strSQL.TrimRight();
  125. // 创建记录集对象
  126. m_pRecordset.CreateInstance(__uuidof(Recordset));
  127. // 取得表中的记录
  128. m_pRecordset->Open(_bstr_t(strSQL),m_pConnection.GetInterfacePtr(),adOpenDynamic,adLockOptimistic,adCmdText);
  129. WriteLog(strSQL);
  130. }
  131. // 捕捉异常
  132. catch(_com_error e)
  133. {
  134. // 显示错误信息
  135. AfxMessageBox(e.Description());
  136. return FALSE;
  137. }
  138. // 返回记录集
  139. ASSERT(m_pRecordset!= NULL);
  140. return TRUE;
  141. }
  142. //功能:记录集移向开头
  143. //返回值:TRUE:成功 FALSE:失败
  144. BOOL CADOConn::MoveFirst()
  145. {
  146. if(m_pRecordset==NULL) 
  147. return FALSE;
  148. else
  149. {
  150. m_pRecordset->MoveFirst();
  151. return TRUE;
  152. }
  154. }
  155. //功能:记录集向下移动
  156. //返回值:TRUE:成功 FALSE:失败
  157. BOOL CADOConn::MoveNext()
  158. {
  159. if(m_pRecordset==NULL) 
  160. return FALSE;
  161. else
  162. {
  163. if (!m_pRecordset->adoEOF)
  164. {
  165. m_pRecordset->MoveNext();
  166. return TRUE;
  167. }
  168. else
  169. return FALSE;
  170. }
  172. }
  173. //功能:取得字段中的字符串
  174. //index:字段集中的索引
  175. //strSum:返回的字符的长度(<=实际:代表全部返回,>实际:左补空格)
  176. CString CADOConn::GetValueString(int index,int strSum)
  177. {
  178. _variant_t vValue;//var型返回值
  179. _variant_t vIndex;//索引
  180. CString strValue,strType,str;//strValue:初始返回值 strType:格式化字符串 str:最终返回值
  181. vIndex.vt=VT_I2;
  182. vIndex.iVal=index;
  183. vValue=m_pRecordset->Fields->GetItem(vIndex)->Value;
  184. switch(vValue.vt)
  185. {
  186. case VT_NULL:
  187. str="";
  188. break;
  189. case VT_ERROR:
  190. str="";
  191. break;
  192. case VT_EMPTY:
  193. str="";
  194. break;
  195. default:
  196. str=(LPCSTR)_bstr_t(vValue);
  197. }
  198. strType.Format("%d",strSum);
  199. strType="%"+strType+"s";
  200. strValue.Format(strType,str);
  201. return strValue;
  203. }
  204. //功能:取得字段中的字节型整数
  205. //index:字段集中的索引
  206. byte CADOConn::GetValueByte(int index)
  207. {
  208. _variant_t vValue;//var型返回值
  209. _variant_t vIndex;//索引
  210. byte bValue;//数值返回值
  211. vIndex.vt=VT_I2;
  212. vIndex.iVal=index;
  213. vValue=m_pRecordset->Fields->GetItem(vIndex)->Value;
  214. switch(vValue.vt)
  215. {
  216. case VT_NULL:
  217. bValue=0;
  218. break;
  219. case VT_ERROR:
  220. bValue=0;
  221. break;
  222. case VT_EMPTY:
  223. bValue=0;
  224. break;
  225. default:
  226. bValue=vValue.bVal;
  227. }
  228. return bValue;
  229. }
  230. //功能:取得字段中的字节型整数的字符串形式
  231. //index:字段集中的索引
  232. //strSum:返回的字符的长度(<=实际:代表全部返回,>实际:左补空格)
  233. CString CADOConn::GetValueByteStr (int index,int strSum)
  234. {
  235. _variant_t vValue;//var型返回值
  236. _variant_t vIndex;//索引
  237. byte bValue;//数值返回值
  238. CString strValue,strType;//strValue:字符串返回值 strType:格式化字符串
  239. vIndex.vt=VT_I2;
  240. vIndex.iVal=index;
  241. vValue=m_pRecordset->Fields->GetItem(vIndex)->Value;
  242. switch(vValue.vt)
  243. {
  244. case VT_NULL:
  245. bValue=0;
  246. break;
  247. case VT_ERROR:
  248. bValue=0;
  249. break;
  250. case VT_EMPTY:
  251. bValue=0;
  252. break;
  253. default:
  254. bValue=vValue.bVal;
  255. }
  256. strType.Format("%d",strSum);
  257. strType="%"+strType+"d";
  258. strValue.Format(strType,bValue);
  259. return strValue;
  260. }
  261. //功能:取得字段中的短整型整数
  262. //index:字段集中的索引
  263. int CADOConn::GetValueInt(int index)
  264. {
  265. _variant_t vValue;//var型返回值
  266. _variant_t vIndex;//索引
  267. int iValue;//数值返回值
  268. vIndex.vt=VT_I2;
  269. vIndex.iVal=index;
  270. vValue=m_pRecordset->Fields->GetItem(vIndex)->Value;
  271. switch(vValue.vt)
  272. {
  273. case VT_NULL:
  274. iValue=0;
  275. break;
  276. case VT_ERROR:
  277. iValue=0;
  278. break;
  279. case VT_EMPTY:
  280. iValue=0;
  281. break;
  282. default:
  283. iValue=vValue.iVal;
  284. }
  285. return iValue;
  286. }
  287. //功能:取得字段中的短整型整数的字符串形式
  288. //index:字段集中的索引
  289. //strSum:返回的字符的长度(<=实际:代表全部返回,>实际:左补空格)
  290. CString CADOConn::GetValueIntStr(int index,int strSum)
  291. {
  292. _variant_t vValue;//var型返回值
  293. _variant_t vIndex;//索引
  294. int iValue;//数值返回值
  295. CString strValue,strType;//strValue:字符串返回值 strType:格式化字符串
  296. vIndex.vt=VT_I2;
  297. vIndex.iVal=index;
  298. vValue=m_pRecordset->Fields->GetItem(vIndex)->Value;
  299. switch(vValue.vt)
  300. {
  301. case VT_NULL:
  302. iValue=0;
  303. break;
  304. case VT_ERROR:
  305. iValue=0;
  306. break;
  307. case VT_EMPTY:
  308. iValue=0;
  309. break;
  310. default:
  311. iValue=vValue.iVal;
  312. }
  313. strType.Format("%d",strSum);
  314. strType="%"+strType+"d";
  315. strValue.Format(strType,iValue);
  316. return strValue;
  317. }
  318. //功能:取得字段中的双精度浮点数
  319. //index:字段集中的索引
  320. double CADOConn::GetValueDouble(int index)
  321. {
  322. _variant_t vValue;//var型返回值
  323. _variant_t vIndex;//索引
  324. double dValue;//数值返回值
  325. vIndex.vt=VT_I2;
  326. vIndex.iVal=index;
  327. vValue=m_pRecordset->Fields->GetItem(vIndex)->Value;
  328. switch(vValue.vt)
  329. {
  330. case VT_NULL:
  331. dValue=0;
  332. break;
  333. case VT_ERROR:
  334. dValue=0;
  335. break;
  336. case VT_EMPTY:
  337. dValue=0;
  338. break;
  339. default:
  340. dValue=vValue.dblVal;
  341. }
  342. return dValue;
  343. }
  344. //功能:取得字段中的双精度浮点数的字符串形式
  345. //index:字段集中的索引
  346. //strLSum(整数部分):返回的整数部分的长度(<=实际:代表全部返回,>实际:左补空格)
  347. //strRSum(小数部分):返回的小数部分的长度(<=实际:代表全部返回,>实际:右补空格)
  348. CString CADOConn::GetValueDoubleStr(int index,int strLSum,int strRSum)
  349. {
  350. _variant_t vValue;//var型返回值
  351. _variant_t vIndex;//索引
  352. double dValue;//数值返回值
  353. CString strValue,strType;//strValue:字符串返回值 strType:格式化字符串
  354. vIndex.vt=VT_I2;
  355. vIndex.iVal=index;
  356. vValue=m_pRecordset->Fields->GetItem(vIndex)->Value;
  357. switch(vValue.vt)
  358. {
  359. case VT_NULL:
  360. dValue=0;
  361. break;
  362. case VT_ERROR:
  363. dValue=0;
  364. break;
  365. case VT_EMPTY:
  366. dValue=0;
  367. break;
  368. default:
  369. dValue=vValue.dblVal;
  370. }
  371. strType.Format("%d.%d",strLSum,strRSum);
  372. strType="%"+strType+"f";
  373. strValue.Format(strType,dValue);
  374. return strValue;
  375. }
  376. //功能:取得字段中的单精度浮点数
  377. //index:字段集中的索引
  378. float CADOConn::GetValueFloat(int index)
  379. {
  380. _variant_t vValue;//var型返回值
  381. _variant_t vIndex;//索引
  382. float fValue;//数值返回值
  383. vIndex.vt=VT_I2;
  384. vIndex.iVal=index;
  385. vValue=m_pRecordset->Fields->GetItem(vIndex)->Value;
  386. switch(vValue.vt)
  387. {
  388. case VT_NULL:
  389. fValue=0;
  390. break;
  391. case VT_ERROR:
  392. fValue=0;
  393. break;
  394. case VT_EMPTY:
  395. fValue=0;
  396. break;
  397. default:
  398. fValue=vValue.fltVal;
  399. }
  400. return fValue;
  401. }
  402. //功能:取得字段中的单精度浮点数的字符串形式
  403. //index:字段集中的索引
  404. //strLSum(整数部分):返回的整数部分的长度(<=实际:代表全部返回,>实际:左补空格)
  405. //strRSum(小数部分):返回的小数部分的长度(<=实际:代表全部返回,>实际:右补空格)
  406. CString CADOConn::GetValueFloatStr(int index,int strLSum,int strRSum)
  407. {
  408. _variant_t vValue;//var型返回值
  409. _variant_t vIndex;//索引
  410. float fValue;//数值返回值
  411. CString strValue,strType;//strValue:字符串返回值 strType:格式化字符串
  412. vIndex.vt=VT_I2;
  413. vIndex.iVal=index;
  414. vValue=m_pRecordset->Fields->GetItem(vIndex)->Value;
  415. switch(vValue.vt)
  416. {
  417. case VT_NULL:
  418. fValue=0;
  419. break;
  420. case VT_ERROR:
  421. fValue=0;
  422. break;
  423. case VT_EMPTY:
  424. fValue=0;
  425. break;
  426. default:
  427. fValue=vValue.fltVal;
  428. }
  429. strType.Format("%d.%d",strLSum,strRSum);
  430. strType="%"+strType+"f";
  431. strValue.Format(strType,fValue);
  432. return strValue;
  433. }
  434. //功能:取得字段中的长整型整数的字符串
  435. //index:字段集中的索引
  436. long CADOConn::GetValueLong(int index)
  437. {
  438. _variant_t vValue;//var型返回值
  439. _variant_t vIndex;//索引
  440. long lValue;//数值返回值
  441. vIndex.vt=VT_I2;
  442. vIndex.iVal=index;
  443. vValue=m_pRecordset->Fields->GetItem(vIndex)->Value;
  444. switch(vValue.vt)
  445. {
  446. case VT_NULL:
  447. lValue=0;
  448. break;
  449. case VT_ERROR:
  450. lValue=0;
  451. break;
  452. case VT_EMPTY:
  453. lValue=0;
  454. break;
  455. default:
  456. lValue=vValue.lVal;
  457. }
  458. return lValue;
  459. }
  460. //功能:取得字段中的长整型整数的字符串形式
  461. //index:字段集中的索引
  462. //strSum:返回的字符的长度(<=实际:代表全部返回,>实际:左补空格)
  463. CString CADOConn::GetValueLongStr(int index,int strSum)
  464. {
  465. _variant_t vValue;//var型返回值
  466. _variant_t vIndex;//索引
  467. long lValue;//数值返回值
  468. CString strValue,strType;//strValue:字符串返回值 strType:格式化字符串
  469. vIndex.vt=VT_I2;
  470. vIndex.iVal=index;
  471. vValue=m_pRecordset->Fields->GetItem(vIndex)->Value;
  472. switch(vValue.vt)
  473. {
  474. case VT_NULL:
  475. lValue=0;
  476. break;
  477. case VT_ERROR:
  478. lValue=0;
  479. break;
  480. case VT_EMPTY:
  481. lValue=0;
  482. break;
  483. default:
  484. lValue=vValue.lVal;
  485. }
  486. strType.Format("%d",strSum);
  487. strType="%"+strType+"d";
  488. strValue.Format(strType,lValue);
  489. return strValue;
  490. }
  491. //返回时间型值
  492. //数据库中存的格式为字符串(yyyy-mm-dd HH-MM-SS)
  493. CTime CADOConn::GetValueDate(int index)
  494. {
  495. _variant_t vValue;//var型返回值
  496. _variant_t vIndex;//索引
  497. CString strValue;//数值返回值
  498. vIndex.vt=VT_I2;
  499. vIndex.iVal=index;
  500. vValue=m_pRecordset->Fields->GetItem(vIndex)->Value;
  501. switch(vValue.vt)
  502. {
  503. case VT_NULL:
  504. strValue="1980-08-08";
  505. break;
  506. case VT_ERROR:
  507. strValue="1980-08-08";
  508. break;
  509. case VT_EMPTY:
  510. strValue="1980-08-08";
  511. break;
  512. default:
  513. strValue=(LPCSTR)_bstr_t(vValue);
  514. break;
  515. }
  516. CString strYear,strMonth,strDay,strHour,strMin,strSec;
  517. strYear=strValue.Mid(0,4);
  518. strMonth=strValue.Mid(5,2);
  519. strDay=strValue.Mid(8,2);
  520. if(strValue.GetLength()>10)
  521. {
  522. strHour=strValue.Mid(11,2);
  523. strMin=strValue.Mid(14,2);
  524. strSec=strValue.Mid(17,2);
  525. }
  526. else
  527. {
  528. strHour="0";
  529. strMin="0";
  530. strSec="0";
  531. }
  532. CTime TValue(atoi(strYear),atoi(strMonth),atoi(strDay),atoi(strHour),atoi(strMin),atoi(strSec));
  533. return TValue;
  534. }
  535. //返回时间型值的字符串
  536. //数据库中存的格式为字符串(yyyy-mm-dd HH-MM-SS)
  537. CString CADOConn::GetValueDateStr(int index,CString strType)
  538. {
  539. _variant_t vValue;//var型返回值
  540. _variant_t vIndex;//索引
  541. CString strValue="";//数值返回值
  542. vIndex.vt=VT_I2;
  543. vIndex.iVal=index;
  544. vValue=m_pRecordset->Fields->GetItem(vIndex)->Value;
  545. switch(vValue.vt)
  546. {
  547. case VT_NULL:
  548. strValue="1980-08-08";
  549. break;
  550. case VT_ERROR:
  551. strValue="1980-08-08";
  552. break;
  553. case VT_EMPTY:
  554. strValue="1980-08-08";
  555. break;
  556. default:
  557. strValue=(LPCSTR)_bstr_t(vValue);
  558. break;
  559. }
  560. CString strYear,strMonth,strDay,strHour,strMin,strSec;
  561. strYear=strValue.Mid(0,4);
  562. strMonth=strValue.Mid(5,2);
  563. strDay=strValue.Mid(8,2);
  564. if(strValue.GetLength()>10)
  565. {
  566. strHour=strValue.Mid(11,2);
  567. strMin=strValue.Mid(14,2);
  568. strSec=strValue.Mid(17,2);
  569. }
  570. else
  571. {
  572. strHour="0";
  573. strMin="0";
  574. strSec="0";
  575. }
  576. CTime TValue(atoi(strYear),atoi(strMonth),atoi(strDay),atoi(strHour),atoi(strMin),atoi(strSec));
  577. CString str=TValue.Format(strType);
  578. return str;
  579. }
  580. //功能:执行SQL语句(Insert Update delete)
  581. //strSQL:SQL语句
  582. //返回值:TRUE:成功 FALSE:失败
  583. BOOL CADOConn::ExecuteSQL(CString strSQL)
  584. {
  585. try
  586. {
  587. // 是否已经连接数据库
  588. if(m_pConnection == NULL) OnInitCADOConn();
  589. strSQL.TrimLeft();
  590. strSQL.TrimRight();
  591. m_pConnection->Execute(_bstr_t(strSQL),NULL,adCmdText);
  592. WriteLog(strSQL);
  593. return TRUE;
  594. }
  595. catch(_com_error e)
  596. {
  597. AfxMessageBox(e.Description());
  598. return FALSE;
  599. }
  600. }
  601. //功能:退出连接
  602. void CADOConn::ExitConnect()
  603. {
  604. try
  605. {
  606. if (m_pRecordset !=NULL) m_pRecordset->Close();
  607. if (m_pConnection !=NULL) m_pConnection->Close();
  608. // 释放环境
  609. ::CoUninitialize();
  610. }
  611. catch (_com_error e) 
  612. {
  613. AfxMessageBox(e.Description());
  614. }
  615. }
  616. //功能:向一表中添加一行数据
  617. //strTable:表名
  618. //strSum:表中字段集的数目
  619. //pszText...:strSum个数据字符串
  620. //返回值:TRUE:成功 FALSE:错误
  621. BOOL CADOConn::AddItem(CString strTable,int strSum,LPCTSTR pszText, ... )
  622. {
  623. strTable.TrimLeft();
  624. strTable.TrimRight();
  625. CString strSQL="select * from "+strTable;
  626. CString strFirst=pszText;
  627. LPTSTR* arrpsz = new LPTSTR[strSum];//初始化一列表存放数据
  628. arrpsz[ 0 ] = new TCHAR[ lstrlen( pszText ) + 1 ];
  629. (void)lstrcpy( arrpsz[ 0 ], pszText );
  630.   va_list list;
  631. va_start( list, pszText );//向列表填充数据
  632. Open(strSQL);//字符集类型的查找
  633. strSQL="insert into "+strTable+" values(";
  634. int iType;
  635. iType=GetValueType(0);
  636. if (iType==ado_Field_Str||iType==ado_Field_Text||iType==ado_Field_Date)
  637. strSQL=strSQL+"'"+strFirst+"',";//字符型
  638. else
  639. {
  640. if(strFirst=="") strFirst="0";
  641. strSQL=strSQL+strFirst+",";//数字型
  642. }
  643. for( int iColumn = 1; iColumn <strSum; iColumn++ )
  644. {
  645. pszText = va_arg( list, LPCTSTR );
  646. ASSERT_VALID_STRING( pszText );
  647. iType=GetValueType(iColumn);
  648. if (iType==ado_Field_Str||iType==ado_Field_Text||iType==ado_Field_Date)
  649. strSQL=strSQL+"'"+pszText+"',";
  650. else
  651. {
  652. CString strValue=pszText;
  653. if(strValue=="") strValue="0";
  654. strSQL=strSQL+strValue+",";
  655. }
  656. arrpsz[ iColumn ] = new TCHAR[ lstrlen( pszText ) + 1 ];
  657. (void)lstrcpy( arrpsz[ iColumn ], pszText );
  658. }
  660. va_end( list );
  661. //开始执行
  662. strSQL=strSQL.Left(strSQL.GetLength()-1)+")";
  663. try
  664. {
  665. //执行插入操作
  666. m_pConnection->Execute(_bstr_t(strSQL),NULL,adCmdText);
  667. return TRUE;
  668. }
  669. catch(_com_error e)
  670. {
  671. AfxMessageBox(e.Description());
  672. return FALSE;
  673. }
  674. }
  675. //功能:返回索引为Index时的数据的类型
  676. //返回值:数据类型
  677. int CADOConn::GetValueType(int index)
  678. {
  679. _variant_t vIndex;
  680. int Tpye;
  681. vIndex.vt=VT_I2;
  682. vIndex.iVal=index;
  683. Tpye=m_pRecordset->Fields->GetItem(vIndex)->GetType();
  684. return Tpye;
  685. }
  686. //功能:判断字段集是否结束
  687. //返回值:TRUE:结束 FALSE:未结束
  688. BOOL CADOConn::adoEOF()
  689. {
  690. if(m_pRecordset->adoEOF)
  691. return TRUE;
  692. else
  693. return FALSE;
  694. }
  695. //功能:填充列表
  696. //listMain:列表指针 ColOpenEnd:代表展开多少列
  697. //返回值:TRUE:成功　FALSE:失败
  698. BOOL CADOConn::FillList(CListCtrl *listMain,int ColOpenEnd)
  699. {
  700. int i,iType,iRow=0,listWidth=0;//iType:字段集的数据类型 listWidth:列表中列的宽度
  701. _variant_t vIndex;
  702. long lMax=0;
  703. lMax=m_pRecordset->Fields->Count;
  704. vIndex.vt=VT_I2;
  705. listMain->DeleteAllItems();
  706. if(!m_pRecordset->adoEOF)
  707. {
  708. MoveFirst();
  709. while (!m_pRecordset->adoEOF)
  710. {
  711. for (i=0;i<lMax;i++)
  712. {
  713. CString strValue="";
  714. vIndex.iVal=i;
  715. iType=m_pRecordset->Fields->GetItem(vIndex)->GetType();
  716. switch(iType)
  717. {
  718. case ado_Field_Str:
  719. case ado_Field_Text:
  720. strValue=GetValueString(i,0);
  721. break;
  722. case ado_Field_Long:
  723. strValue=GetValueLongStr(i,0);
  724. break;
  725. case ado_Field_Int:
  726. strValue=GetValueIntStr(i,0);
  727. break;
  728. case ado_Field_Float:
  729. strValue=GetValueFloatStr(i,0,2);
  730. break;
  731. case ado_Field_Double:
  732. strValue=GetValueDoubleStr(i,0,2);
  733. break;
  734. case ado_Field_Byte:
  735. strValue=GetValueByteStr(i,0);
  736. break;
  737. case ado_Field_Date:
  738. strValue=GetValueString(i,0);
  739. break;
  740. default:
  741. strValue="";
  742. break;
  743. }
  744. if(m_DataType==2)
  745. strValue=GetValueString(i,0);
  746. if(i==0)
  747. listMain->InsertItem(iRow,strValue,0);
  748. else
  749. listMain->SetItemText(iRow,i,strValue);
  750. }
  751. m_pRecordset->MoveNext();
  752. iRow=iRow+1;
  753. }
  754. //移向开头
  755. MoveFirst();
  756. }
  757. if(listMain->GetItemCount()>0)
  758. {
  759. if(ColOpenEnd>0)
  760. {
  761. for(int i=0;i<ColOpenEnd;i++)
  762. {
  763. listMain->SetColumnWidth(i,LVSCW_AUTOSIZE);
  764. listWidth=listMain->GetColumnWidth(i);
  765. listMain->SetColumnWidth(i,LVSCW_AUTOSIZE_USEHEADER);
  766. if(listWidth<listMain->GetColumnWidth(i))
  767. listMain->SetColumnWidth(i,LVSCW_AUTOSIZE_USEHEADER);
  768. }
  769. }
  770. else
  771. {
  772. listMain->SetColumnWidth(i,LVSCW_AUTOSIZE_USEHEADER);
  773. }
  775. }
  776. else
  777. {
  778. for(i=0;i<lMax;i++)
  779. {
  780. listMain->SetColumnWidth(i,LVSCW_AUTOSIZE_USEHEADER);
  781. listWidth=listWidth+listMain->GetColumnWidth(i);
  782. }
  783. RECT rectList;
  784. listMain->GetWindowRect(&rectList);
  785. if(listWidth<(rectList.right-rectList.left))
  786. {
  787. listWidth=(rectList.right-rectList.left-listWidth)/11;
  788. listMain->SetColumnWidth(i,listMain->GetColumnWidth(i)+listWidth);
  789. }
  790. }
  791. return TRUE;
  792. }
  793. //功能:初始化自动排列列表
  794. //CListCtrl:列表指针;colSum:列表中已经存在列数
  795. BOOL CADOConn::InitList(CListCtrl *listMain,int colSum)
  796. {
  797. long lMax=0;
  798. _variant_t vIndex;
  799. vIndex.vt=VT_I2;
  800. int i;
  801. lMax=m_pRecordset->Fields->Count;
  802. listMain->SetExtendedStyle(LVS_EX_GRIDLINES|LVS_EX_FULLROWSELECT);
  803. for(i=0;i<lMax;i++)
  804. {
  805. CString strTitle="";
  806. vIndex.iVal=i;
  807. strTitle=(LPCTSTR)m_pRecordset->Fields->GetItem(vIndex)->GetName();
  808. listMain->InsertColumn(i,strTitle,LVCFMT_CENTER,100,0);
  809. }
  810. int intWidth=0;
  811. for(i=0;i<colSum;i++)
  812. {
  813. listMain->SetColumnWidth(i,LVSCW_AUTOSIZE_USEHEADER);
  814. intWidth=intWidth+listMain->GetColumnWidth(i);
  815. }
  816. RECT rectList;
  817. listMain->GetWindowRect(&rectList);
  818. if(intWidth<(rectList.right-rectList.left))
  819. {
  820. intWidth=(rectList.right-rectList.left-intWidth)/colSum;
  821. listMain->SetColumnWidth(i,listMain->GetColumnWidth(i)+intWidth);
  822. }
  823. return TRUE;
  824. }
  825. BOOL CADOConn::FillList(CListCtrl *listMain)
  826. {
  827. int i,iType,iRow=0,listWidth=0;//iType:字段集的数据类型 listWidth:列表中列的宽度
  828. _variant_t vIndex;
  829. long lMax=0;
  830. lMax=m_pRecordset->Fields->Count;
  831. vIndex.vt=VT_I2;
  832. if(!m_pRecordset->adoEOF)
  833. {
  834. MoveFirst();
  835. while (!m_pRecordset->adoEOF)
  836. {
  837. for (i=0;i<lMax;i++)
  838. {
  839. CString strValue="";
  840. vIndex.iVal=i;
  841. iType=m_pRecordset->Fields->GetItem(vIndex)->GetType();
  842. switch(iType)
  843. {
  844. case ado_Field_Str:
  845. case ado_Field_Text:
  846. strValue=GetValueString(i,0);
  847. break;
  848. case ado_Field_Long:
  849. strValue=GetValueLongStr(i,0);
  850. break;
  851. case ado_Field_Int:
  852. strValue=GetValueIntStr(i,0);
  853. break;
  854. case ado_Field_Float:
  855. strValue=GetValueFloatStr(i,0,2);
  856. break;
  857. case ado_Field_Double:
  858. strValue=GetValueDoubleStr(i,0,2);
  859. break;
  860. case ado_Field_Byte:
  861. strValue=GetValueByteStr(i,0);
  862. break;
  863. case ado_Field_Date:
  864. strValue=GetValueString(i,0);
  865. break;
  866. default:
  867. strValue="";
  868. break;
  869. }
  870. if(m_DataType==2)
  871. strValue=GetValueString(i,0);
  872. if(i==0)
  873. iRow=listMain->InsertItem(iRow,strValue,0);
  874. else
  875. listMain->SetItemText(iRow,i,strValue);
  876. }
  877. m_pRecordset->MoveNext();
  878. }
  879. //移向开头
  880. MoveFirst();
  881. }
  882. return TRUE;
  883. }
  884. CString CADOConn::GetFieldsName(int index)
  885. {
  886. _variant_t vIndex;
  887. vIndex.vt=VT_I2;
  888. CString strTitle="";
  889. vIndex.iVal=index;
  890. strTitle=(LPCTSTR)m_pRecordset->Fields->GetItem(vIndex)->GetName();
  891. return strTitle;
  892. }
  893. int CADOConn::GetFeildsCount()
  894. {
  895. int i=m_pRecordset->Fields->Count;
  896. return i;
  897. }
  898. long CADOConn::GetRecordCount()
  899. {
  900. long i;
  901. m_pRecordset->get_RecordCount(&i);
  902. return i;
  903. }
  904. void CADOConn::WriteLog(CString strSql)
  905. {
  906. CFileOperate fileMain;
  907. CMyTime time1;
  908. time1.SetNow();
  909. CString strPath=GetAppPath()+"\data\LOG\"+strfileName+".txt";
  910. CFile file1;
  911. file1.Open(strPath,CFile::modeWrite,NULL);
  912. file1.SeekToEnd();
  913. strPath="rn    "+time1.GetAllString(FALSE)+"    ";
  914. file1.Write(strPath,strPath.GetLength());
  915. file1.Write(strSql,strSql.GetLength());
  916. file1.Close();
  917. }