vc中通过ADO操作数据库

淩亂°似流年 2022-08-05 13:11 170阅读 0赞

## 准备工作 ##

### (1)、引入ADO类 ###

1.  \#import "c:\\program files\\common files\\system\\ado\\msado15.dll" \\
2.   no\_namespace \\
3.   rename ("EOF", "adoEOF")

### (2)、初始化COM ###

在MFC中可以用AfxOleInit();非MFC环境中用:

1.  CoInitialize(NULL);
2.  CoUnInitialize();

### (3)\#import 包含后就可以用3个智能指针了:\_ConnectionPtr、\_RecordsetPtr和\_CommandPtr ###

## 1.连接和关闭数据库 ##

### (1)连接 ###

例子:连接Access数据库

1.  AfxOleInit();//初始化
2.  HRESULT hr;
3.  try
4.  \{ 
5.   hr = m\_pConnection.CreateInstance("ADODB.Connection");///创建Connection对象
6.  if(SUCCEEDED(hr))
7.   \{ 
8.   m\_pConnection->ConnectionTimeout = 0;
9.   hr = m\_pConnection->Open( "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=db.mdb", "", "", adModeUnknown);
10. //m\_pConnection->PutDefaultDatabase ((\_bstr\_t)"DB"); //设置默认数据库
11.  m\_pCommand.CreateInstance(\_\_uuidof(Command));
12.  m\_pCommand->CommandTimeout = 5;
13.  m\_pCommand->ActiveConnection = m\_pConnection;
14.  \}
15. \}
16. catch(\_com\_error e)///捕捉异常
17. \{ 
18.  CString errormessage;
19.  errormessage.Format(" 连接数据库失败! 错误信息:%s",e.ErrorMessage());
20.  AfxMessageBox(errormessage);///显 示错误信息
21. \}

### (2)、关闭 ###

1.  //如果数据库连接有效
2.  if( m\_pConnection->State )
3.   m\_pConnection->Close();
4.  m\_pConnection = NULL;

### (3)、设置连接时间 ###

1.  //设置连接时间 -----------------------------------
2.   pConnection->put\_ConnectionTimeout(long(5));

## 2.打开一个结果集 ##

### (1)打开,首先创建一个\_RecordsetPtr实例,然后调用Open()得到一条SQL语句的执行结果 ###

1.  \_RecordsetPtr m\_pRecordset;
2.  m\_pRecordset.CreateInstance(\_\_uuidof(Recordset));
3.  // 在ADO操作中建议语句中要常用 try...catch()来捕获错误信息，
4.  // 因为它有时会经常出现一些意想不到的错误。jingzhou xu
5.  try
6.  \{ 
7.   m\_pRecordset->Open("SELECT \* FROM DemoTable",// 查询DemoTable表中所有字段
8.   m\_pConnection.GetInterfacePtr(), // 获取库接库的IDispatch指针
9.   adOpenDynamic,
10.  adLockOptimistic,
11.  adCmdText);
12. \}
13. catch(\_com\_error \*e)
14. \{ 
15.  AfxMessageBox(e->ErrorMessage());
16. \}

### (2)关闭结果集 ###

1.  m\_pRecordset->Close();

## 3.操作一个结果集 ##

### (1)、遍历(读取) ###

#### a)、用pRecordset->adoEOF来判断数据库指针是否已经移到结果集的末尾了；m\_pRecordset->BOF判断是否 在第一条记录前面： ####

1.  while(!m\_pRecordset->adoEOF)
2.  \{ 
3.   var = m\_pRecordset->GetCollect("Name");
4.  if(var.vt != VT\_NULL)
5.   strName = (LPCSTR)\_bstr\_t(var);
6.   var = m\_pRecordset->GetCollect("Age");
7.  if(var.vt != VT\_NULL)
8.   strAge = (LPCSTR)\_bstr\_t(var);
9.   m\_AccessList.AddString( strName + " --> "\+strAge );
10.  m\_pRecordset->MoveNext();
11. \}

#### b)、取得一个字段的值的办法有两种办法 ####

##### 一是 #####

1.  //表示取得第0个字 段的值
2.  rdset->GetCollect("Name");
3.  // 或者
4.  rdset->GetCollect(\_variant\_t(long(0));

##### 二是 #####

1.  pRecordset->get\_Collect("COLUMN\_NAME");
2.  //或者 
3.  pRecordset->get\_Collect(long(index));

### (2)、添加 ###

1.  调用m\_pRecordset->AddNew();
2.  调用m\_pRecordset->PutCollect();给每个字段赋值
3.  调用m\_pRecordset->Update();确认

### (3)、修改 ###

### (4)、删除 ###

#### a)、把记录指针移动到要删除的记录上,然后调用 ####

1.  Delete(adAffectCurrent)
2.  try
3.  \{ 
4.  // 假设删除第二条记录
5.   m\_pRecordset->MoveFirst();
6.   m\_pRecordset->Move(1); 
7.  // 从0开始
8.   m\_pRecordset->Delete(adAffectCurrent); 
9.  // 参数adAffectCurrent 为删除当前记录
10.  m\_pRecordset->Update();
11. \}
12. catch(\_com\_error \*e)
13. \{ 
14.  AfxMessageBox(e->ErrorMessage());
15. \}

## 4.直接执行SQL语句,除了要用到结果集其余的大部分功能都可以直接用SQL语言实现 ##

### (1)、用\_CommandPtr和\_RecordsetPtr配合 ###

1.  \_CommandPtr m\_pCommand;
2.  m\_pCommand.CreateInstance(\_\_uuidof(Command));
3.  // 将库连接赋于它
4.  m\_pCommand->ActiveConnection = m\_pConnection; 
5.  // SQL语句
6.  m\_pCommand->CommandText = "SELECT \* FROM DemoTable"; 
7.  // 执行SQL语句，返回记录集
8.  m\_pRecordset = m\_pCommand->Execute(NULL, NULL,adCmdText);

### (2)、直接用\_ConnectionPtr执行SQL语句 ###

1.  \_RecordsetPtr Connection15::Execute ( \_bstr\_t CommandText,
2.   VARIANT \* RecordsAffected,
3.  long Options )

其中CommandText是命令字串，通常是SQL命令。  
参数RecordsAffected是操作完成后所影响的行数,  
参数Options表示CommandText中内容的类型，Options可以取如下值之一：

*  adCmdText:表明CommandText是文本命令
 *  adCmdTable:表明CommandText是一个表名
 *  adCmdProc:表明CommandText是一个存储过程
 *  adCmdUnknown:未知

例子:

1.  \_variant\_t RecordsAffected;
2.  m\_pConnection->Execute("UPDATE users SET old = old+1",&RecordsAffected,adCmdText);

## 5.调用存储过程 ##

### (1)、利用\_CommandPtr ###

1.  \_CommandPtrm\_pCommand;
2.  m\_pCommand.CreateInstance(\_\_uuidof(Command));
3.  m\_pCommand->ActiveConnection = m\_pConnection; // 将库连接赋于它
4.  m\_pCommand->CommandText = "Demo"; 
5.  m\_pCommand->Execute(NULL,NULL, adCmdStoredProc);

### (2)、直接用\_ConnectionPtr直接调用(见4.(2)) ###

## 6.遍历数据库中的所有表名 ##

1.  \_ConnectionPtr m\_pConnect;
2.  
3.  \_RecordsetPtr pSet;
4.  HRESULT hr;
5.  try
6.  \{ 
7.   hr = m\_pConnect.CreateInstance("ADODB.Connection"); 
8.  if(SUCCEEDED(hr)) 
9.   \{ 
10.  CString dd; 
11.  dd.Format("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=%s",file); 
12.  hr = m\_pConnect->Open((\_bstr\_t)dd,"","",adModeUnknown); 
13.  pSet = m\_pConnect->OpenSchema(adSchemaTables); 
14. while(!(pSet->adoEOF)) 
15.  \{ 
16. //获取表格 
17.  \_bstr\_t table\_name = pSet->Fields->GetItem("TABLE\_NAME")->Value;
18. //获取表格类型 
19.  \_bstr\_t table\_type = pSet->Fields->GetItem("TABLE\_TYPE")->Value;
20. //过滤一下，只输出表格名称，其他的省略
21. if ( strcmp(((LPCSTR)table\_type),"TABLE")==0)\{ 
22.  CString tt;
23.  tt.Format("%s",(LPCSTR)table\_name); 
24.  AfxMessageBox(tt); 
25.  \} 
26.  pSet->MoveNext(); 
27.  \} 
28.  pSet->Close(); 
29.  \} 
30.  m\_pConnect->Close(); 
31. \}catch(\_com\_error e)///捕捉异常
32. \{ 
33.  CString errormessage; 
34.  errormessage.Format("连接数据库失败!rn错误 信息:%s",e.ErrorMessage());
35.  AfxMessageBox(errormessage);
36. return \-1;
37. \}

## 7.遍历一个表中的所有字段 ##

1.  Field \* field = NULL;
2.  HRESULT hr;
3.  Fields \* fields = NULL;
4.  hr = m\_pRecordset->get\_Fields (&fields);//得到记录集的字段集和
5.  
6.  if(SUCCEEDED(hr))
7.   fields->get\_Count(&ColCount);
8.  //得到记录集的字段集合中的字段的总个数
9.  for(i=0;i ...
10.  Item\[i\]->get\_Name(&bstrColName);//得到记录集//中的字段名
11.  strColName=bstrColName;
12.  nameField = strColName;
13.  m\_FieldsList.AddString(nameField);
14. \}
15. if(SUCCEEDED(hr))
16.  fields->Release();//释放指针

## 附: ##

### 1、\_variant\_t ###

(1)、一般传给这3个指针的值都不是MFC直接支持的数据类型,而要用\_variant\_t转换一下  
\_variant\_t(XX)可以把大多数类型的变量转换成适合的类型传入  
(2)、\_variant\_t var;  
\_variant\_t -> long: (long)var;  
\_variant\_t -> CString: CString strValue = (LPCSTR)\_bstr\_t(var);  
CString -> \_variant\_t: \_variant\_t(strSql);

### 2、BSTR宽字符串与CString相互转换 ###

BSTR bstr;  
CString strSql;  
CString -> BSTR: bstr = strSql.AllocSysString();  
BSTR -> CString: strSql = (LPCSTR)bstr;

### 3、\_bstr\_t与CString相互转换 ###

\_bstr\_t bstr;  
CString strSql;  
CString -> \_bstr\_t: bstr = (\_bstr\_t)strSql;  
\_bstr\_t -> CString: strSql = (LPCSTR)bstr;

### 4、关于时间 ###

Access:表示时间的字符串\#2004-4-5\#  
Sql:表示时间的字符串''2004-4-5''  
DateField(时间字段)  
select \* from my\_table where DateField > \#2004-4-10\#  
try  
\{  
m\_pCommand->CommandText = "INSERT INTO tTest(age) VALUES('23f2') ";  
m\_pRecordset = m\_pCommand->Execute(NULL,NULL, adCmdText);  
\}  
catch(\_com\_error e)///捕捉异常  
\{  
CString errormessage;  
errormessage.Format("连接数据库失败! 错误信息:%s",e.ErrorMessage());  
AfxMessageBox(errormessage);///显示错误信息  
\}