工控编程吧

标题: 上位机通过ADO实现数据库操作完整例程 [打印本页]

---

作者: qq263946146    时间: 2017-6-3 18:48
标题: 上位机通过ADO实现数据库操作完整例程
(, 下载次数: 14)

上传

点击文件名下载附件

数据库在WINCC等一些工控产品上会涉及。
当前例程实现数据库常用功能 ：
动态创建数据源。
添加数据。
修改数据
删除数据
查找数据

下面是例程中关键代码，完整例程项目工程， 可以帖子尾部下载

1. void CMy123View::ShowAll(_bstr_t table)//按条件显示数据
   
2. {
   
3.         CListCtrl*pList = (CListCtrl*)GetDlgItem(IDC_LIST1);
   
4.         _RecordsetPtr record = m_ado.GetRecordset(table);
   
5.         if(NULL == record)
   
6.                 return;
   
7.         pList->DeleteAllItems();
   
8.         if(record->adoBOF)
   
9.                 return;
   
10.         record->MoveFirst();
    
11.         while(!record->adoEOF)
    
12.         {
    
13.                 int i= pList->GetItemCount();
    
14.                 pList->InsertItem(i, (_bstr_t)record->GetCollect("索引"));
    
15.                 pList->SetItemText(i,1,(_bstr_t)record->GetCollect("网站"));
    
16.                 pList->SetItemText(i,2,(_bstr_t)record->GetCollect("网址"));
    
17.                 pList->SetItemText(i,3,(_bstr_t)record->GetCollect("站长"));
    
18.                 record->MoveNext();
    
19.         }
    
20. }
    
21. void CMy123View::OnButton1() //向数据表添加内容
    
22. {
    
23.         CListCtrl*pList = (CListCtrl*)GetDlgItem(IDC_LIST1);
    
24.         CString sIndex,sWebsite,sWebaddr,sWebadmin;
    
25.         int nIndex = pList->GetItemCount();
    
26.         sIndex.Format("%d",nIndex);
    
27.         GetDlgItemText(IDC_EDIT1,sWebsite);
    
28.         GetDlgItemText(IDC_EDIT2,sWebaddr);
    
29.         GetDlgItemText(IDC_EDIT3,sWebadmin);
    
30.         _bstr_t vSQL = "insert into website values('"+sIndex+"','"+sWebsite+"','"+sWebaddr+"','"+sWebadmin+"')";
    
31.         if(!m_ado.ExecuteSQL(vSQL) )
    
32.                 return;
    
33.         ShowAll(_bstr_t("select * from website"));
    
34. }
    
35. 
    
36. void CMy123View::OnButton2()//向数据表删除内容
    
37. {
    
38.         CListCtrl*pList = (CListCtrl*)GetDlgItem(IDC_LIST1);
    
39.         POSITION pos = pList->GetFirstSelectedItemPosition();
    
40.         if(NULL  ==  pos)
    
41.                 return;
    
42.         CString sIndex = pList->GetItemText(pList->GetNextSelectedItem(pos),0);
    
43.         _bstr_t vSQL = "delete from website where 索引="+sIndex+"";
    
44.         if(!m_ado.ExecuteSQL(vSQL) )
    
45.                 return;
    
46.         ShowAll(_bstr_t("select * from website"));
    
47. }
    
48. 
    
49. void CMy123View::OnButton3() //向数据表修改内容
    
50. {
    
51.         CListCtrl*pList = (CListCtrl*)GetDlgItem(IDC_LIST1);
    
52.         POSITION pos = pList->GetFirstSelectedItemPosition();
    
53.         if(NULL  ==  pos)
    
54.                 return;
    
55.         int nIndex = pList->GetNextSelectedItem(pos);
    
56.         CString sWebsite,sWebaddr,sWebadmin,sIndex = pList->GetItemText(nIndex,0);
    
57.         GetDlgItemText(IDC_EDIT1,sWebsite);
    
58.         GetDlgItemText(IDC_EDIT2,sWebaddr);
    
59.         GetDlgItemText(IDC_EDIT3,sWebadmin);
    
60.         _bstr_t vSQL ="Update website SET 网站='"+sWebsite+"',网址='"+sWebaddr+"', 站长='"+sWebadmin+"' where 索引="+sIndex+"";
    
61.         if(!m_ado.ExecuteSQL(vSQL) )
    
62.                 return;
    
63.         ShowAll(_bstr_t("select * from website"));
    
64. }
    
65. 
    
66. void CMy123View::OnButton4() //按条件查找
    
67. {
    
68.         CString sContent;
    
69.         GetDlgItemText(IDC_EDIT4,sContent);
    
70.         if(sContent.IsEmpty())
    
71.                 return;
    
72.         CComboBox*pCom = (CComboBox*)GetDlgItem(IDC_COMBO1);
    
73.         CString sText;
    
74.         pCom->GetLBText(pCom->GetCurSel(),sText);
    
75.         _bstr_t vSQL;
    
76.         if("索引" == sText)
    
77.                 vSQL = "select * from website where "+sText+" = "+sContent+"";
    
78.         else
    
79.                 vSQL = "select * from website where "+sText+" = '"+sContent+"'";
    
80.         ShowAll(vSQL);
    
81. }
    
82. 
    
83. void CMy123View::OnSelchangeCombo1() //查找组合框更改内容时
    
84. {       
    
85.         ShowAll(_bstr_t("select * from website"));
    
86. }
    
87. void CMy123View::OnClickList1(NMHDR* pNMHDR, LRESULT* pResult)
    
88. {
    
89.         CListCtrl*pList = (CListCtrl*)GetDlgItem(IDC_LIST1);
    
90.         POSITION pos = pList->GetFirstSelectedItemPosition();
    
91.         if(NULL  ==  pos)
    
92.                 return;
    
93.         int nInext = pList->GetNextSelectedItem(pos);
    
94.         SetDlgItemText(IDC_EDIT1,pList->GetItemText(nInext,1));
    
95.         SetDlgItemText(IDC_EDIT2,pList->GetItemText(nInext,2));
    
96.         SetDlgItemText(IDC_EDIT3,pList->GetItemText(nInext,3));
    
97.         *pResult = 0;
    
98. }
    

复制代码

下面是集成类代码

1. #if !defined(AFX_ADO_H__41E97289_18A5_48A9_9016_6C604EA024E0__INCLUDED_)
   
2. #define AFX_ADO_H__41E97289_18A5_48A9_9016_6C604EA024E0__INCLUDED_
   
3. 
   
4. #if _MSC_VER > 1000
   
5. #pragma once
   
6. #endif // _MSC_VER > 1000
   
7. 
   
8. #import "C:\\Program Files\\Common Files\\System\\ado\\msadox.dll" \
   
9. rename("EOF","adoEOF") rename("BOF","adoBOF")
   
10. #import "C:\\Program Files\\Common Files\\System\\ado\\msado15.dll"no_namespace \
    
11. rename("EOF","adoEOF") rename("BOF","adoBOF")
    
12. #include <io.h>
    
13. 
    
14. class CADO : public CObject  
    
15. {
    
16. private:
    
17.         _ConnectionPtr m_pConnect;
    
18.         _RecordsetPtr  m_pRecord;
    
19. 
    
20. private:
    
21.         void Connect();
    
22.         void DisConnect();
    
23. public:
    
24.         BOOL ExecuteSQL(_bstr_t bstrSQL);
    
25.         _RecordsetPtr GetRecordset(_bstr_t bstrSQL);
    
26. public:
    
27.         CADO();
    
28.         virtual ~CADO();
    
29. 
    
30. };
    
31. 
    
32. #endif // !defined(AFX_ADO_H__41E97289_18A5_48A9_9016_6C604EA024E0__INCLUDED_)
    

复制代码

1. // ADO.cpp: implementation of the CADO class.
   
2. //
   
3. //////////////////////////////////////////////////////////////////////
   
4. 
   
5. #include "stdafx.h"
   
6. #include "123.h"
   
7. #include "ADO.h"
   
8. 
   
9. #ifdef _DEBUG
   
10. #undef THIS_FILE
    
11. static char THIS_FILE[]=__FILE__;
    
12. #define new DEBUG_NEW
    
13. #endif
    
14. 
    
15. 
    
16. 
    
17. void CADO::Connect()
    
18. {
    
19.         DisConnect();
    
20.         char cPath[MAX_PATH];
    
21.         GetModuleFileName(NULL,cPath,MAX_PATH);
    
22.         CString sPath(cPath);
    
23.         sPath=sPath.Left(sPath.ReverseFind('\\'));
    
24.         sPath +="\\data\\Test.mdb";
    
25.         if(-1 == _access(sPath,0))//数据源文件不存在
    
26.         {
    
27.                 //创建MDB文件
    
28.                 strcpy(cPath,sPath);
    
29.                 sPath.Format("Provider=Microsoft.JET.OLEDB.4.0;Data Source=%s",cPath);
    
30.                 _bstr_t strcnn = sPath;
    
31.                 ADOX::_CatalogPtr pCat;
    
32.                 pCat.CreateInstance(__uuidof(ADOX::Catalog));
    
33.                 pCat->Create(strcnn);       
    
34.                 ////在MDB文件内创建表格
    
35.                 ADOX::_TablePtr pTable;
    
36.                 pTable.CreateInstance(__uuidof(ADOX::Table));
    
37.                 pTable->PutName("website");
    
38.                 pTable->Columns->Append("索引",ADOX::adInteger,0);
    
39.                 pTable->Columns->Append("网站",ADOX::adVarWChar,50);
    
40.                 pTable->Columns->Append("网址",ADOX::adVarWChar,50);
    
41.                 pTable->Columns->Append("站长",ADOX::adVarWChar,20);
    
42.                 pCat->Tables->Append( pTable.GetInterfacePtr() );               
    
43.                 pTable =NULL;
    
44.                 pCat   =NULL;
    
45.         }
    
46.         strcpy(cPath,sPath);
    
47.         sPath.Format("Provider=Microsoft.JET.OLEDB.4.0;Data Source=%s",cPath);
    
48.         try        {
    
49.                 m_pConnect.CreateInstance(__uuidof(Connection));
    
50.                 m_pConnect->Open(_bstr_t(sPath),"","",adModeUnknown);
    
51.                 m_pRecord.CreateInstance(__uuidof(Recordset));
    
52.         }
    
53.         catch (_com_error e){
    
54.                 AfxMessageBox(e.ErrorMessage());               
    
55.         }
    
56. }
    
57. void CADO::DisConnect()
    
58. {
    
59.         if(NULL!=m_pRecord&&m_pRecord->State)
    
60.                 m_pRecord->Close();
    
61.         m_pRecord = NULL;
    
62.         if(NULL!=m_pConnect&&m_pConnect->State)
    
63.                 m_pConnect->Close();
    
64.         m_pConnect= NULL;
    
65. }
    
66. CADO::CADO()
    
67. {
    
68.         ::CoInitialize(NULL);
    
69.         m_pConnect = NULL;
    
70.         m_pRecord  = NULL;
    
71.         Connect();
    
72. }
    
73. CADO::~CADO()
    
74. {
    
75.         DisConnect();
    
76.         ::CoUninitialize();
    
77. }
    
78. 
    
79. BOOL CADO::ExecuteSQL(_bstr_t bstrSQL)
    
80. {
    
81.         try
    
82.         {        m_pConnect->Execute(bstrSQL,NULL,adCmdText);
    
83.         return true;
    
84.         }
    
85.         catch(_com_error e){
    
86.                 AfxMessageBox(e.ErrorMessage());
    
87.                 return false;
    
88.         }
    
89. }
    
90. _RecordsetPtr CADO::GetRecordset(_bstr_t bstrSQL)
    
91. {
    
92.         if(NULL!=m_pRecord&&m_pRecord->State)
    
93.                 m_pRecord->Close();
    
94.         try{
    
95.                 m_pRecord->Open(bstrSQL,m_pConnect.GetInterfacePtr(),adOpenDynamic,adLockOptimistic,adCmdText);
    
96.         }
    
97.         catch(_com_error e){
    
98.                 AfxMessageBox(e.ErrorMessage());
    
99.                 return NULL;
    
100.         }
     
101.         return m_pRecord;
     
102. }

复制代码

[weixinlianxi]1[/weixinlianxi]

---

欢迎光临 工控编程吧 (https://www.gkbc8.com/)

Powered by Discuz! X3.4