工控编程吧

标题: 上位机MFC如何使用ADO执行SQL命令 [打印本页]

---

作者: qq263946146    时间: 2019-8-9 11:20
标题: 上位机MFC如何使用ADO执行SQL命令
(, 下载次数: 1)

上传

点击文件名下载附件

当前这里准备一个例程。
首先是自定义 一些变量与函数，再如界面准备一些控件。

1. _ConnectionPtr m_pConnection;
   
2.         _RecordsetPtr m_pRecordset;
   
3.                 _CommandPtr m_pCommand;
   
4. BOOL OpenDatabase(LPCTSTR lpszConnect, long nOptions=adConnectUnspecified);
   
5. BOOL CloseDatabase();
   
6.         BOOL OpenRecordset(LPCTSTR lpszSource, long nCursorType=adOpenDynamic,
   
7.                 long nLockType=adLockOptimistic, long nOptions=adCmdText);
   
8.         BOOL CloseRecordset();

复制代码

然后初始化这些变量与控件，与实现函数体。

1. if (!SUCCEEDED(m_pConnection.CreateInstance(__uuidof(Connection))))
   
2.         {
   
3.                 m_pConnection = NULL;
   
4.                 TRACE(_T("Database CreateInstance failed"));
   
5.         }
   
6.         if (!SUCCEEDED(m_pRecordset.CreateInstance(__uuidof(Recordset))))
   
7.         {
   
8.                 m_pRecordset = NULL;
   
9.                 TRACE(_T("Recordset CreateInstance Failed!"));
   
10.         }
    
11.         if (!SUCCEEDED(m_pCommand.CreateInstance(__uuidof(Command))))
    
12.         {
    
13.                 m_pCommand = NULL;
    
14.                 TRACE(_T("Command CreateInstance Failed!"));
    
15.         }
    
16.         //打开数据库
    
17.         CString strConnect = _T("Provider=Microsoft.Jet.OLEDB.4.0;Data Source= Demo.mdb");
    
18.         if (!OpenDatabase(strConnect))
    
19.         {
    
20.                 AfxMessageBox(_T("数据库打开失败。"));
    
21.         }
    
22.         m_pCommand->ActiveConnection = m_pConnection;
    
23.        
    
24.                 //初始化ListCtrl
    
25.         CListCtrl* pListCtrl = (CListCtrl*)GetDlgItem(IDC_LIST1);
    
26.         pListCtrl->SetExtendedStyle(LVS_EX_FULLROWSELECT | LVS_EX_GRIDLINES);
    
27.         pListCtrl->InsertColumn(1, _T("序号"), LVCFMT_CENTER, 80);
    
28.         pListCtrl->InsertColumn(2, _T("姓名"), LVCFMT_CENTER, 100);
    
29.         pListCtrl->InsertColumn(3, _T("年龄"), LVCFMT_CENTER, 100);
    
30. 
    
31.         SetDlgItemText(IDC_COMMAND, _T("SELECT * FROM DemoTable"));

复制代码

1. 
   
2. BOOL CGkbc8Dlg::OpenDatabase(LPCTSTR lpszConnect, long nOptions)
   
3. {
   
4.         ASSERT(m_pConnection != NULL);
   
5.         ASSERT(lpszConnect != NULL);
   
6.         ASSERT(AfxIsValidString(lpszConnect));
   
7.        
   
8.         //打开数据库连接
   
9.         try
   
10.         {
    
11.                 return SUCCEEDED(m_pConnection->Open(_bstr_t(lpszConnect),
    
12.                         _T(""), _T(""), nOptions));
    
13.         }
    
14.         catch (_com_error& e)
    
15.         {
    
16.                 TRACE(_T("%s\n"), e.ErrorMessage());
    
17.                 return FALSE;
    
18.         }
    
19. }
    
20. BOOL CGkbc8Dlg::CloseDatabase()
    
21. {
    
22.         ASSERT(m_pConnection != NULL);
    
23. 
    
24.         //关闭数据库连接
    
25.         try
    
26.         {
    
27.                 if (m_pConnection->State & adStateOpen)
    
28.                 {
    
29.                         return SUCCEEDED(m_pConnection->Close());
    
30.                 }
    
31.                 else
    
32.                 {
    
33.                         return TRUE;
    
34.                 }
    
35.         }
    
36.         catch (_com_error& e)
    
37.         {
    
38.                 TRACE(_T("%s\n"), e.ErrorMessage());
    
39.                 return FALSE;
    
40.         }
    
41. }
    
42. 
    
43. BOOL CGkbc8Dlg::OpenRecordset(LPCTSTR lpszSource, long nCursorType,
    
44.                                                          long nLockType, long nOptions)
    
45. {
    
46.         ASSERT(m_pConnection != NULL);
    
47.         ASSERT(m_pRecordset != NULL);
    
48.         ASSERT(lpszSource != NULL);
    
49.         ASSERT(AfxIsValidString(lpszSource));
    
50. 
    
51.         //打开记录集
    
52.         try
    
53.         {
    
54.                 return (SUCCEEDED(m_pRecordset->Open(_variant_t(lpszSource),
    
55.                                                                                 m_pConnection.GetInterfacePtr(),
    
56.                                                                                 (CursorTypeEnum)nCursorType,
    
57.                                                                                 (LockTypeEnum)nLockType,
    
58.                                                                                 nOptions)));
    
59.         }
    
60.         catch(_com_error e)
    
61.         {
    
62.                 TRACE(_T("%s\n"), e.ErrorMessage());
    
63.                 return FALSE;
    
64.         }
    
65. }
    
66. 
    
67. BOOL CGkbc8Dlg::CloseRecordset()
    
68. {
    
69.         ASSERT(m_pRecordset != NULL);
    
70. 
    
71.         //关闭记录集
    
72.         try
    
73.         {
    
74.                 if (m_pRecordset->State & adStateOpen)
    
75.                 {
    
76.                         return SUCCEEDED(m_pRecordset->Close());
    
77.                 }
    
78.                 else
    
79.                 {
    
80.                         return TRUE;
    
81.                 }
    
82.         }
    
83.         catch (_com_error e)
    
84.         {
    
85.                 TRACE(_T("%s\n"), e.ErrorMessage());
    
86.                 return FALSE;
    
87.         }
    
88. }

复制代码

记得列表控件设置属性为报表
(, 下载次数: 1)

上传

点击文件名下载附件
最后就是调用按钮执行SQL命令。

1. void CGkbc8Dlg::OnButton3()
   
2. {
   
3.         CString strCommand = _T("");
   
4.         GetDlgItemText(IDC_COMMAND, strCommand);
   
5. 
   
6.         //执行SQL命令
   
7.         m_pCommand->CommandText = _bstr_t(strCommand);
   
8.         _variant_t vNULL;
   
9.         vNULL.vt = VT_ERROR;
   
10.         vNULL.scode = DISP_E_PARAMNOTFOUND;
    
11.         try
    
12.         {
    
13.                 m_pRecordset = m_pCommand->Execute(&vNULL, &vNULL, adCmdText);
    
14.         }
    
15.         catch (_com_error& e)
    
16.         {
    
17.                 TRACE(_T("%s\n"), e.ErrorMessage());
    
18.                 return;
    
19.         }
    
20. 
    
21.         //读取记录集
    
22.         if (m_pRecordset->BOF && m_pRecordset->adoEOF)
    
23.         {
    
24.                 return;
    
25.         }
    
26.         m_pRecordset->MoveFirst();
    
27.         int n = 0;
    
28.         while (!m_pRecordset->adoEOF)
    
29.         {
    
30.                 _variant_t varValue;
    
31.                 CString strName = _T("");
    
32.                 int nAge = 0;
    
33. 
    
34.                 varValue = m_pRecordset->GetCollect(_variant_t(_T("NAME")));
    
35.                 if (varValue.vt != VT_NULL)
    
36.                 {
    
37.                         strName = varValue.bstrVal;
    
38.                 }
    
39.                 else
    
40.                 {
    
41.                         strName = _T("");
    
42.                 }
    
43. 
    
44.                 varValue = m_pRecordset->GetCollect(_variant_t(_T("AGE")));
    
45.                 if (varValue.vt != VT_NULL)
    
46.                 {
    
47.                         nAge = varValue.intVal;
    
48.                 }
    
49.                 else
    
50.                 {
    
51.                         nAge = 0;
    
52.                 }
    
53. 
    
54.                 //刷新ListCtrl
    
55.                 CListCtrl* pListCtrl = (CListCtrl*)GetDlgItem(IDC_LIST1);
    
56.                 CString strText = _T("");
    
57.                 strText.Format(_T("%d"), n + 1);
    
58.                 pListCtrl->InsertItem(n, strText);
    
59.                 strText.Format(_T("%s"), strName);
    
60.                 pListCtrl->SetItemText(n, 1, strText);
    
61.                 strText.Format(_T("%d"), nAge);
    
62.                 pListCtrl->SetItemText(n, 2, strText);
    
63.                 n++;
    
64. 
    
65.                 m_pRecordset->MoveNext();
    
66.         }       
    
67. }

复制代码

(, 下载次数: 0)

上传

点击文件名下载附件
[MFC408]1[/MFC408]
[weixinlianxi]1[/weixinlianxi]

---

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

Powered by Discuz! X3.4