ADO接口之_ConnectionPtr

ゝ一世哀愁。 2022-08-13 06:58 35阅读 0赞

ADO中最重要的对象有三个：Connection、Recordset和Command，分别表示连接对象、记录集对象和命令对象。

三个对象对应的[智能指针][Link 1]分别是：\_ConnectionPtr、\_RecordsetPtr、\_CommandPtr。

ADO使用\_ConnectionPtr这个指针来操纵Connection对象，类似地，后面用到的\_CommandPtr和\_RecordsetPtr分别表示命令对象指针和记录集对象指针。

Connection对象是这三个对象的基础，它的主要作用是建立与数据库的连接，建立了与数据库的连接后，才能进行其它有关数据库的访问和操作。也就是说，使用ADO操作数据库，通常先用Connection对象的Open方法打开一个库连接，然后才能进行数据库的操作。操作完成后，要关闭这个库连接。

本文只讲述Connection对象最常用的Open方法和Execute方法。

注意：在使用ADO进行操作之前，必须使用AfxOleInit()函数来进行初始化；

**1. Open()方法**

用于打开一个库连接，而Execute()方法一般用于执行一条SQL语句。

\_ConnectionPtr智能指针的用法：

首先定义一个Connection类型的指针，然后调用CreateInstance()来创建一个连接对象的实例，再调用Open()函数建立与数据源的连接。

在建立连接对象后，可以使用连接对象的Execute()函数来执行SQL命令。

\_ConnectionPtr智能指针Open()方法的原型：

Open(\_bstr\_t ConnectionString,\_bstr\_t UserID,\_bstr\_t Password,long Options)

ConnectionString为连接字串，UserID是用户名，Password是登陆密码

Options是连接选项，可以是如下几个常量：

1> adModeUnknown 缺省，当前的许可权未设置

2> adModeRead 只读

3> adModeWrite 只写

4> adModeReadWrite 可以读写

5> adModeShareDenyRead 阻止其它Connection对象以读权限打开连接

6> adModeShareDenyWrite 阻止其它Connection对象以写权限打开连接

7> adModeShareExclusive 阻止其它Connection对象打开连接

8> adModeShareDenyNone 阻止其它程序或对象以任何权限建立连接

**2. Execute方法**

函数原型：

\_RecordsetPtr Connection::Execute(\_bstr\_t CommandText,VARIANT\* RecordsAffected,long Options)

参数：

CommandText是命令字串，通常是SQL命令，

RecordsAffected是操作完成后所影响的行数

Options表示CommandText中内容的类型，可以取下列值之一：

1> adCmdText 表明CommandText是文本命令

2>adCmdTable 表明CommandText是一个表名

3>adCmdProc 表明CommandText是一个存储过程

4>adCmdUnknown 未知

Execute执行完后返回一个指向记录集的指针(\_ResultsetPtr类型)

3. 异常捕获

出现的异常为：\_com\_error

例程CREATE\_DB\_AND\_TABLE中已经使用了\_ConnectionPtr指针的Open方法和Execute方法，在后面的例程我们将进一步详细说明。

**例程**

ConnPtr\_Open\_Exe

打开VC++ 6.0，新建一个基于对话框的工程ConnPtr\_Open\_Exe。在对话框IDD\_CONNPTR\_OPEN\_EXE\_DIALOG中进行编辑：

使用三个Group Box分成三个部分，第一部分演示使用Execute()函数来执行INSERT INTO命令；第二部分演示使用Execute()函数来执行Update命令；第三部分演示使用Execute()函数来执行SELECT命令。其中，第一部分和第二部分不需要返回记录集，第三部分演示返回记录集显示结果。

该对话框几个控件如下：

控件名称    ID                                            用途

按钮           IDC\_BTN\_INSERT\_INTO  执行INSERT INTO语句

按钮           IDC\_BTN\_UPDATE             执行Update语句

按钮           IDC\_BTN\_SELECT            执行SELECT语句

列表框       IDC\_LIST1                           显示SELECT语句执行结果

使用[ClassWizard][]给列表框IDC\_LIST1创建[CListBox][]变量m\_list1：

双击IDC\_BTN\_INSERT\_INTO按钮，并编辑OnBtnInsertInto()函数如下：

**\[cpp\]**  [view plain][] [copy][view plain]

1.  **void** CConnPtr\_Open\_ExeDlg::OnBtnInsertInto()   
2.  \{  
3.      \_ConnectionPtr m\_pConnection;  
4.      \_variant\_t RecordsAffected;  
5.      **try**  
6.      \{  
7.          m\_pConnection.CreateInstance(\_\_uuidof(Connection));  
8.          m\_pConnection->Open("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=Northwind.mdb","","",adModeUnknown);  
9.      \}  
10.     **catch**(\_com\_error e)  
11.     \{  
12.         CString errormessage;  
13.         errormessage.Format("连接数据库失败!\\r错误信息:%s",e.ErrorMessage());  
14.         AfxMessageBox(errormessage);  
15.         **return**;  
16.     \}  
17.   
18.     **try**  
19.     \{  
20.         \_bstr\_t strCmd="INSERT INTO Employees(EmployeeID,FirstName,LastName,HireDate,City,Country) VALUES(10,'Mary','Williams','15/4/1993 12:00:00','New York','USA')";  
21.         m\_pConnection->Execute(strCmd,&RecordsAffected,adCmdText);  
22.     \}  
23.     **catch**(\_com\_error &e)  
24.     \{  
25.         AfxMessageBox(e.Description());  
26.     \}  
27.     **if**(m\_pConnection->State)  
28.     \{  
29.         m\_pConnection->Close();  
30.     \}  
31. \}

双击IDC\_BTN\_UPDATE按钮，并编辑OnBtnUpdate()函数如下：

**\[cpp\]**  [view plain][] [copy][view plain]

1.  **void** CConnPtr\_Open\_ExeDlg::OnBtnUpdate()   
2.  \{  
3.      \_ConnectionPtr m\_pConnection;  
4.      \_variant\_t RecordsAffected;  
5.      **try**  
6.      \{  
7.          m\_pConnection.CreateInstance(\_\_uuidof(Connection));  
8.          m\_pConnection->Open("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=Northwind.mdb","","",adModeUnknown);  
9.      \}  
10.     **catch**(\_com\_error e)  
11.     \{  
12.         CString errormessage;  
13.         errormessage.Format("连接数据库失败!\\r错误信息:%s",e.ErrorMessage());  
14.         AfxMessageBox(errormessage);  
15.         **return**;  
16.     \}  
17.   
18.     **try**  
19.     \{  
20.         \_bstr\_t strCmd="UPDATE Employees SET FirstName='Bill',LastName='Clinton',HireDate='25/11/1994 12:00:00',City='Los Angeles' WHERE EmployeeID=10";  
21.         m\_pConnection->Execute(strCmd,&RecordsAffected,adCmdText);  
22.     \}  
23.     **catch**(\_com\_error &e)  
24.     \{  
25.         AfxMessageBox(e.Description());  
26.     \}  
27.   
28.     **if**(m\_pConnection->State)  
29.     \{  
30.         m\_pConnection->Close();   
31.     \}  
32. \}

双击IDC\_BTN\_SELECT按钮，并编辑OnBtnSelect()函数如下：

**\[cpp\]**  [view plain][] [copy][view plain]

1.  **void** CConnPtr\_Open\_ExeDlg::OnBtnSelect()   
2.  \{  
3.      \_ConnectionPtr m\_pConnection;  
4.      \_variant\_t RecordsAffected;  
5.      \_RecordsetPtr m\_pRecordset;  
6.      **try**  
7.      \{  
8.          m\_pConnection.CreateInstance(\_\_uuidof(Connection));  
9.          m\_pConnection->Open("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=Northwind.mdb","","",adModeUnknown);  
10.     \}  
11.     **catch**(\_com\_error e)  
12.     \{  
13.         CString errormessage;  
14.         errormessage.Format("连接数据库失败!\\r错误信息:%s",e.ErrorMessage());  
15.         AfxMessageBox(errormessage);  
16.         **return**;  
17.     \}  
18.     **try**  
19.     \{  
20.         m\_pRecordset.CreateInstance("ADODB.Recordset"); //为[Recordset对象][Recordset]创建实例  
21.         \_bstr\_t strCmd="SELECT EmployeeID,FirstName,LastName,HireDate,City FROM Employees WHERE City='London'";  
22.         m\_pRecordset=m\_pConnection->Execute(strCmd,&RecordsAffected,adCmdText);  
23.     \}  
24.     **catch**(\_com\_error &e)  
25.     \{  
26.         AfxMessageBox(e.Description());  
27.     \}  
28.     \_variant\_t vEmployeeID,vFirstName,vLastName,vHireDate,vCity;  
29.     **try**  
30.     \{  
31.         **while**(!m\_pRecordset->adoEOF)  
32.         \{  
33.             vEmployeeID=m\_pRecordset->GetCollect(\_variant\_t((**long**)0));  
34.             //取得第1列的值，从0开始计数，你也可以直接列出列的名称，如下一行  
35.             vFirstName=m\_pRecordset->GetCollect("FirstName");  
36.             vLastName=m\_pRecordset->GetCollect("LastName");  
37.             vHireDate=m\_pRecordset->GetCollect("HireDate");  
38.             vCity=m\_pRecordset->GetCollect("City");  
39.             CString strtemp;  
40.             **if**(vEmployeeID.vt!=VT\_NULL)  
41.             \{  
42.                 strtemp.Format("%d",vEmployeeID.lVal);  
43.             \}  
44.             **if**(vFirstName.vt!=VT\_NULL)  
45.             \{  
46.                 strtemp+=" ";  
47.                 strtemp+=(**LPCTSTR**)(\_bstr\_t)vFirstName;  
48.             \}  
49.             **if**(vLastName.vt!=VT\_NULL)  
50.             \{  
51.                 strtemp+=" ";  
52.                 strtemp+=(**LPCTSTR**)(\_bstr\_t)vLastName;  
53.             \}  
54.             **if**(vHireDate.vt!=VT\_NULL)  
55.             \{  
56.                 strtemp+=" ";  
57.                 strtemp+=(**LPCTSTR**)(\_bstr\_t)vHireDate;  
58.             \}  
59.             **if**(vCity.vt!=VT\_NULL)  
60.             \{  
61.                 strtemp+=" ";  
62.                 strtemp+=(**LPCTSTR**)(\_bstr\_t)vCity;  
63.             \}  
64.   
65.             m\_list1.AddString(strtemp);  
66.             m\_list1.AddString("\\n");  
67.   
68.             //移动到下一条记录  
69.             m\_pRecordset->MoveNext();  
70.         \}  
71.     \}  
72.     **catch**(\_com\_error &e)  
73.     \{  
74.         AfxMessageBox(e.Description());  
75.     \}  
76.   
77.     m\_pRecordset->Close();  
78.     m\_pRecordset=NULL;  
79.     m\_pConnection->Close();   
80.     m\_pConnection=NULL;  
81. \}

附加操作（重要）：

1> 在[stdafx.h][]中加入如下语句：

\#import "C:\\Program Files\\Common Files\\system\\ado\\msado15.dll" rename("EOF","adoEOF")

2> 在BOOL CConnPtr\_Open\_ExeApp::InitInstance()函数中加入：

AfxOleInit();

该部分演示了如何使用\_ConnectionPtr接口开发ACCESS数据库：先创建一个Connection对象实例，然后用Open方法打开一个库连接，最后使用Execute方法执行SQL语句进行其它有关数据库的访问和操作。

[Link 1]: http://www.so.com/s?q=%E6%99%BA%E8%83%BD%E6%8C%87%E9%92%88&ie=utf-8&src=se_lighten_f
[ClassWizard]: http://www.so.com/s?q=ClassWizard&ie=utf-8&src=se_lighten_f
[CListBox]: http://www.so.com/s?q=CListBox&ie=utf-8&src=se_lighten_f
[view plain]: http://blog.csdn.net/xiaobai1593/article/details/7449024#
[Recordset]: http://www.so.com/s?q=Recordset%E5%AF%B9%E8%B1%A1&ie=utf-8&src=se_lighten_f
[stdafx.h]: http://www.so.com/s?q=stdafx.h&ie=utf-8&src=se_lighten_f