1 #pragma once
 2 #import "C:\Program Files (x86)\Common Files\System\ado\msado15.dll" no_namespace rename("EOF", "adoEOF")
 3 #include <icrsint.h>
 4 class CADO
 5 {
 6 public:
 7     CADO(void);
 8     ~CADO(void);
 9     _ConnectionPtr m_pConnection;
10     _RecordsetPtr m_pRecordset;
11     void Connect(void);
12     void ExitConnect(void);
13     _RecordsetPtr& GetRecordset(_bstr_t SQL);
14 };

 1 #include "ADO.h"
 2 #include<iostream>
 3 using namespace std;
 4 
 5 CADO::CADO(void)
 6 {
 7 }
 8 
 9 
10 CADO::~CADO(void)
11 {
12 }
13 
14 void CADO::Connect(void)
15 { 
16     try{
17         CoInitialize(NULL);  //初始化COM环境
18         m_pConnection.CreateInstance("ADODB.Connection");  //创建连接对象
19         m_pConnection->ConnectionString="Provider=SQLOLEDB.1;Integrated Security=SSPI;Persist Security Info=False;User ID=test;Initial Catalog=UserInfo1;Data Source=Disturbance-PC\\SQLEXPRESS"; 
20         HRESULT hr=m_pConnection->Open("", "", "", adModeUnknown);
21         if(hr!=S_OK)
22             cout<<"Can not connect to the specified database!"<<endl;
23     }
24     catch(_com_error e){
25         cout<<e.Description()<<endl;
26     }
27 }
28 void CADO::ExitConnect(void)
29 {
30     if(m_pRecordset!=NULL){
31         m_pRecordset->Close();
32         m_pConnection->Close();
33     }
34     ::CoUninitialize();  //释放环境
35 }
36 
37 _RecordsetPtr& CADO::GetRecordset(_bstr_t SQL)
38 {
39     m_pRecordset=NULL;
40     CADO link;
41     try{
42         if(m_pConnection==NULL)
43             Connect();
44         m_pRecordset.CreateInstance(__uuidof(Recordset));
45         m_pRecordset->Open((_bstr_t)SQL, m_pConnection.GetInterfacePtr(), adOpenDynamic, adLockOptimistic, adCmdText);
46     }
47     catch(_com_error e){
48         cout<<e.Description()<<endl;
49         m_pRecordset=NULL;
50         return m_pRecordset;
51     }
52     return m_pRecordset;
53 }

 1 #include<afxwin.h>
 2 #include <iostream>
 3 #include "ADO.h"
 4 #include<string>
 5 using namespace std;
 6 
 7 void main()
 8 {
 9 
10     string sql;
11     CADO record;
12     record.Connect();
13     _RecordsetPtr m_pRecordset;
14     sql="select * from UserInfo";//这句话代表找到数据库中表UserInfo的位置
15     _bstr_t bstr_t(sql.c_str());
16     m_pRecordset=record.GetRecordset(bstr_t);//返回的可以假设是一个指针，它指向该表的第一行
17     
18     //m_pRecordset->MoveFirst();    //移到首条记录
19     while(!m_pRecordset->adoEOF){
20         m_pRecordset->Delete(adAffectCurrent);    //删除当前记录
21         m_pRecordset->MoveNext();//移动到下一行
22     }
23 
24     _variant_t vUsername,vBirthday,vID,vOld;
25     for(int i=0;i<3;i++)    //添加三条新记录并赋值
26     {
27         m_pRecordset->AddNew();    //添加新记录
28         m_pRecordset->PutCollect("学号",_variant_t((int)(i+10)));
29         m_pRecordset->PutCollect("姓名",_variant_t("ADASA"));
30         m_pRecordset->PutCollect("年龄",_variant_t((int)21));
31         m_pRecordset->PutCollect("生日",_variant_t("1930-3-15"));
32     }
33     m_pRecordset->Update();    //保存到库中，和AddNew对应
34 
35     m_pRecordset=record.GetRecordset(bstr_t);//再次获得第一行的指针
36     while(!m_pRecordset->adoEOF)
37     {
38         vID = m_pRecordset->GetCollect(_variant_t((long)0));//取得第1列的值,从0开始计数，你也可以直接给出列的名称，如下一行
39         vUsername = m_pRecordset->GetCollect("姓名");//取得姓名字段的值
40         vOld = m_pRecordset->GetCollect("年龄");
41         vBirthday = m_pRecordset->GetCollect("生日");
42         printf("id:%d,姓名:%s,年龄:%d,生日:%s\r\n",
43             vID.lVal,
44             CString(vUsername.bstrVal),
45             vOld.lVal,
46             CString(vBirthday.bstrVal));  //在DEBUG方式下的OUTPUT窗口输出记录集中的记录
47         m_pRecordset->MoveNext();    //移到下一条记录
48     }
49     record.ExitConnect();
50 }