准备：6 A: Z( W1 i6 N
(1)、引入ADO类' U& I' R# x; U
#import "c:\program files\common files\system\ado\msado15.dll" \6 ^# ~ S2 d1 _
no_namespace \4 e; r8 m3 ~4 ~* o b m1 _
rename ("EOF", "adoEOF")
% ?& N4 |6 w) _) a(2)、初始化COM
7 K& p2 @' B ?+ F4 O% T3 s在MFC中可以用AfxOleInit();非MFC环境中用:
+ S2 w+ s9 I, V3 q HCoInitialize(NULL);
# }: M+ t" S# W* [. N# y4 j/ _CoUnInitialize();1 [' \0 ^7 j+ ]
(3)#import 包含后就可以用3个智能指针了:_ConnectionPtr、_RecordsetPtr和_CommandPtr
% U/ Q+ o1 S9 u6 W1.连接和关闭数据库 (1)连接 # V* u" `$ _% \! P h$ K) ^
例子:连接Access数据库4 c/ U6 g4 E8 B. a( X
AfxOleInit();//初始化/ y6 a+ e T* O. f7 T5 \
HRESULT hr;7 _; e, {- @' p' P: @
try
& Z" N; c5 G( K( k{
1 W' |4 S* m6 `/ I5 thr = m_pConnection.CreateInstance("ADODB.Connection");///创建Connection对象
' U( C# A& Z gif(SUCCEEDED(hr))0 ^* P8 d4 w0 V U6 u
{' o$ V! A! P) q& B+ w
m_pConnection->ConnectionTimeout = 0;: [ U5 p9 _& D/ b
hr = m_pConnection->Open( "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=db.mdb", "", "", adModeUnknown);, _( x- U- K+ L( P; g* v
//m_pConnection->PutDefaultDatabase ((_bstr_t)"DB");//设置默认数据库
. k" J/ g w7 M0 v- v7 q" g/ n& d3 Bm_pCommand.CreateInstance(__uuidof(Command));/ v' P7 g6 b: v* |& k
m_pCommand->CommandTimeout = 5;) ^7 K% p9 }; \2 O! q+ x2 c
m_pCommand->ActiveConnection = m_pConnection;
/ p, j$ y9 A# M# J9 D" m}( k, {" I4 p" a7 C+ D
}
" X: ^9 t2 M! x7 fcatch(_com_error e)///捕捉异常) X: n* ` S7 ?) U; Y y
{
5 h+ r' l" b0 w+ O+ t) RCString errormessage;! t3 @* u" d/ P7 k
errormessage.Format("连接数据库失败!\r\n错误信息:%s",e.ErrorMessage());
* ^! Y7 Y8 M: m; Q5 ]AfxMessageBox(errormessage);///显示错误信息, z5 w( o$ k7 {, W: a; K
}6 D W. F$ x( q. D( G1 e7 d+ y
6 ^6 {! U0 b }" p
(2)、关闭* Y0 |) j& c: z+ Y+ R4 i4 J# [9 F& B( Q
//如果数据库连接有效
& S* `) k y, j3 C" ?* Oif( m_pConnection->State )9 D# p( q% i0 x$ J1 Y6 S
m_pConnection->Close();1 E" e0 P1 _* l" f
m_pConnection = NULL;: w8 E! D( T2 E+ O: f' k7 x
(3)、设置连接时间 //设置连接时间-----------------------------------
4 y( p @5 L* |: opConnection->put_ConnectionTimeout(long(5));0 f, W2 A3 F) k# Z" N
2.打开一个结果集) ^7 I9 I' y g$ s0 K9 I7 R
(1)打开,首先创建一个_RecordsetPtr实例,然后调用Open()得到一条SQL语句的执行结果
9 X% X/ p, V& K0 y3 F_RecordsetPtrm_pRecordset;- M1 Q; G0 d" y
m_pRecordset.CreateInstance(__uuidof(Recordset));
! }# G+ z& _% r2 y// 在ADO操作中建议语句中要常用try...catch()来捕获错误信息，
8 A& ^ I* n8 G// 因为它有时会经常出现一些意想不到的错误。jingzhou xu- ?, H$ V0 l1 v7 e3 Y4 n
try& ~4 q' s& b. e; H; G# Z9 ^
{
6 M- v8 {; ]& tm_pRecordset->Open("SELECT * FROM DemoTable",// 查询DemoTable表中所有字段
% X0 x* R9 ?6 n) }; T) im_pConnection.GetInterfacePtr(), // 获取库接库的IDispatch指针
! g1 m7 I3 Q1 N6 ladOpenDynamic,
4 {, |0 l+ \" ~, R( vadLockOptimistic, V) T* v: d5 T5 F0 a
adCmdText);! ?. a; F/ D3 C5 Y4 r% n- Q
}! s; m7 i3 j# ~2 U/ z, g, V8 Y
catch(_com_error *e)
+ _ Y$ r' B0 E{, A p1 ]# }$ ^7 ~+ [. m) Z5 \
AfxMessageBox(e->ErrorMessage());
E# V+ G$ V$ Z6 K+ {}, O1 k! w0 y3 P( W
(2)关闭结果集
! y& Q1 B( c/ i' {+ m- s Vm_pRecordset->Close(); O _+ ]% b2 |. r8 X6 Y
3.操作一个结果集+ u" V# w' T8 I$ n- N6 M
(1)、遍历(读取)
, M9 \3 @$ `2 ]5 E2 Z3 Ta)、用pRecordset->adoEOF来判断数据库指针是否已经移到结果集的末尾了；m_pRecordset->BOF判断是否 在第一条记录前面：8 e. z' d5 P! K6 c0 Z
while(!m_pRecordset->adoEOF)) E: c) C0 ?: |
{; S0 d# `4 Z5 b2 O
var = m_pRecordset->GetCollect("Name");
8 h/ P, p* U; f& \if(var.vt != VT_NULL). }: j9 a7 h% n6 S: j# u" D) Y
strName = (LPCSTR)_bstr_t(var);
+ h {: K. t6 x+ j/ G& Avar = m_pRecordset->GetCollect("Age");
7 [( i! r. r6 c' ~ uif(var.vt != VT_NULL); Z, H: w: {/ W2 g0 x, a
strAge = (LPCSTR)_bstr_t(var);5 s7 o5 O! n% k# @# ^
m_AccessList.AddString( strName + " --> "+strAge );0 n2 q/ l$ b7 G; z
m_pRecordset->MoveNext();
5 e% T" r e" a) n* F- S7 a}- v- y, P( F9 C6 T( z- f
b)、取得一个字段的值的办法有两种办法
5 l" S& d- P, ^一是: ?! u, h6 T* Q: L, a
//表示取得第0个字段的值 m_pRecordset->GetCollect("Name");; \* L5 Z6 K+ `' _* t- z! [
或者 m_pRecordset->GetCollect(_variant_t(long(0));
9 Z- D& u- ?6 C( r) c& Z7 p二是; k& s: f! b% b% e
pRecordset->get_Collect("COLUMN_NAME");
' `6 o$ _6 b! G( K2 D3 C2 ]或者 pRecordset->get_Collect(long(index));
6 V) U8 x% F1 ?+ [0 s, B(2)、添加# `% P5 e& i$ c; D: F
a)、调用m_pRecordset->AddNew();
( Z1 L; L6 G" fb)、调用m_pRecordset->PutCollect();给每个字段赋值
9 U) M5 i X% r' D" i; Jc)、调用m_pRecordset->Update();确认 K6 l5 C9 R. r6 u* |
(3)、修改
# ]7 a: E" t8 }* x(4)、删除
$ A' F; \" a+ h) Y. K& ~a)、把记录指针移动到要删除的记录上,然后调用
2 v3 a4 ]$ g! B K* ADelete(adAffectCurrent) try
2 W, u- [; k& Y/ n1 l3 \{
$ x8 l- I' U% x6 O) R, G// 假设删除第二条记录
% s# N) l/ U! K+ F; ~m_pRecordset->MoveFirst();
# j8 [; v) n8 e3 jm_pRecordset->Move(1);
" U' C2 S! D, H$ k; H( m2 o) b// 从0开始
8 g6 |/ }/ Y% j( Vm_pRecordset->Delete(adAffectCurrent);
5 X, j# B# L. \+ y6 _8 _// 参数adAffectCurrent为删除当前记录/ P/ s/ C. x# i1 g0 F
m_pRecordset->Update();
& k, V$ t8 j% [$ Y) v* x' O8 S' Z}; W$ o; }' S$ Y
catch(_com_error *e)' G ?2 x$ s6 m4 }: z
{; N( z( Y8 c0 Q+ P! p( }
AfxMessageBox(e->ErrorMessage());
J1 X4 J' B! t, c: ?}
* y; l4 h5 P9 S7 C/ O4.直接执行SQL语句,除了要用到结果集其余的大部分功能都可以直接用SQL语言实现
8 j. y: s, Z* o: w- f8 Q(1)、用_CommandPtr和_RecordsetPtr配合
/ X# W4 w# U: L% o, L5 @2 ?_CommandPtrm_pCommand;
/ r6 T' J6 t: Q4 ~/ j& am_pCommand.CreateInstance(__uuidof(Command));: d5 D1 ?0 `5 |8 z* {
// 将库连接赋于它
* N( d: r" _9 s: h4 u$ n7 ~m_pCommand->ActiveConnection = m_pConnection;
+ W) P) K0 T: \+ p/ ]. B9 R# S) b// SQL语句
3 a2 w. p2 A- o! _% v& A$ M% ^8 Pm_pCommand->CommandText = "SELECT * FROM DemoTable";
8 {8 V G$ Q) T2 U, i2 o// 执行SQL语句，返回记录集- S3 v$ X5 G3 Z- e6 |4 z* M" L
m_pRecordset = m_pCommand->Execute(NULL, NULL,adCmdText);- ]" s- A$ `8 Z
" [6 D6 T, _( j* J- W) F9 p, l0 }(2)、直接用_ConnectionPtr执行SQL语句
$ o& l& _; t. a! H6 }; d2 ~, J_RecordsetPtr Connection15::Execute ( _bstr_t CommandText, U8 k7 `) o9 b7 @/ F
VARIANT * RecordsAffected, 0 v. z" R7 `: }# {4 w! A: o) F2 n
long Options )
7 @) K, S* i- G! A) K* d& T其中CommandText是命令字串，通常是SQL命令。 2 m" l( E4 N: K# \( y6 S5 G
参数RecordsAffected是操作完成后所影响的行数, 5 O' ~- \& o5 c& ?: ]: t+ a
参数Options表示CommandText中内容的类型，Options可以取如下值之一：
- T, a% b4 U' y, a' j2 y* _adCmdText:表明CommandText是文本命令
- m* w- }/ B, ?2 V) @2 badCmdTable:表明CommandText是一个表名 ) O/ S5 F3 G+ v' l* t
adCmdProc:表明CommandText是一个存储过程 4 T1 ^7 V& E, ?* ~. ^. T2 l" V/ ~
adCmdUnknown:未知
$ y X/ J6 t; A9 C; Y j( E/ M例子:* {# L5 ?2 G' G/ J
_variant_t RecordsAffected;
- M' y: a. \$ e& Y T8 Vm_pConnection->Execute("UPDATE users SET old = old+1",&RecordsAffected,adCmdText); . i9 Y6 k0 U8 q
5.调用存储过程1 C' k$ e0 p/ z& Q9 U$ e/ }4 Q! Q
(1)、利用_CommandPtr
3 j7 @( T Q& J u/ I( W_CommandPtrm_pCommand;# w/ u* m3 b" R) i/ A% G
m_pCommand.CreateInstance(__uuidof(Command));
$ o6 d7 ?* \$ N3 z3 l2 T7 Am_pCommand->ActiveConnection = m_pConnection; // 将库连接赋于它
8 x4 o5 I5 n/ T+ D4 A, u8 R0 Vm_pCommand->CommandText = "Demo"; 2 i, _$ k9 @2 l6 B& J
m_pCommand->Execute(NULL,NULL, adCmdStoredProc);6 t9 T$ e- Q1 p. P. M$ q; U
+ D& X% s. s1 x! p+ f+ A; Y% C1 b(2)、直接用_ConnectionPtr直接调用
0 \" o$ i; w m* X6.遍历数据库中的所有表名
/ \; p2 l' O3 {+ I_RecordsetPtr pSet;
3 x" H1 ~- f* q+ d7 q" r" @' \$ _HRESULT hr;
' U7 m# p8 |* Rtry 8 u- r$ m, y/ O- _* `
{ 9 t/ _( A4 w; c d6 x
hr = m_pConnect.CreateInstance("ADODB.Connection"); / L! g3 ~. D1 Y! Y) S& Y
if(SUCCEEDED(hr)) 9 A8 P% x, I# Y+ ]: n @3 _
{ # d0 D! b3 \; \; c% P
CString dd; 4 g! V' |6 u- _- I' v
dd.Format("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=%s",file); ! H% O4 s# D4 Y& A( G/ k; k
hr = m_pConnect->Open((_bstr_t)dd,"","",adModeUnknown);
8 T5 V9 s/ Z9 n# V1 J- `# }' ipSet = m_pConnect->OpenSchema(adSchemaTables);
- H3 p. |- W7 c% j4 V% V, H: wwhile(!(pSet->adoEOF)) $ V2 s! @( w* f0 l* V6 J% D
{
" {! G: r# c# q+ h0 C//获取表格
8 A+ ]/ R2 ?/ I: n" g7 V# T1 q_bstr_t table_name = pSet->Fields->GetItem("TABLE_NAME")->Value;
* c- R7 g. X1 n* M1 p Y$ G3 K0 m//获取表格类型
7 H( x+ R. a3 }; Y! Z_bstr_t table_type = pSet->Fields->GetItem("TABLE_TYPE")->Value;
$ \( h$ H8 |% o6 `//过滤一下，只输出表格名称，其他的省略. i* l8 x) n3 ~" a) u
if ( strcmp(((LPCSTR)table_type),"TABLE")==0){
0 u9 x: s8 y, ?0 C* OCString tt;
% W9 ^! r; `6 B5 itt.Format("%s",(LPCSTR)table_name); # _+ ^0 y J' T& {
AfxMessageBox(tt); ' g4 O0 H7 t- e/ ~7 e/ k. J8 I
} - {+ b6 T( N- d/ v& _+ Y$ O
pSet->MoveNext(); & i" M$ L% H! m. s2 W( R+ r
}
' v8 x- O8 g2 ^2 ]& F, ?; upSet->Close(); 7 G. J/ y: ^3 Y5 J" `% I: F8 M
}
# O; j0 n, `, O$ q: H- J' om_pConnect->Close(); 4 R; N: s1 ^1 |; H# t9 e% z2 g4 l
}catch(_com_error e)///捕捉异常 . Y" t! x- `1 t! g& `" z( c/ J1 |
{
9 V, C" w1 R7 B& dCString errormessage; : E, v! q, M0 ~
errormessage.Format("连接数据库失败!rn错误信息:%s",e.ErrorMessage());
& J, C7 j& A' {" W! y6 R2 q7 oAfxMessageBox(errormessage);
+ E/ E# x% w$ f; T5 [return -1;
- R% n' p; j& E% S: |, G+ Y% @}
) r% m/ X6 G0 \% C0 T' a$ g, G @7.遍历一个表中的所有字段* S7 |8 a1 _7 {, J, H9 {) i1 R
Field * field = NULL;4 j3 Q( n1 j( r" [* c N
HRESULT hr;- d, Y5 O6 q; }; l
Fields * fields = NULL;
c0 C! ~ g& _hr = m_pRecordset->get_Fields (&fields);//得到记录集的字段集和
1 g; Z* x3 N }! p# {
% S( o% `% U% K( B7 cif(SUCCEEDED(hr))
6 ]; s* X% m0 L2 ~, X fields->get_Count(&ColCount); ) v4 g# V2 a/ Z, l8 m
//得到记录集的字段集合中的字段的总个数
+ g8 \2 o6 C! x: @4 E) [0 nfor(i=0;iItem[i]->get_Name(&bstrColName);//得到记录集//中的字段名* ?7 L& h( F" @$ L9 S% u
strColName=bstrColName;
+ }9 w. k/ I9 w) ?7 a$ N9 {* \nameField = strColName; B+ x% L9 |0 k. `
m_FieldsList.AddString(nameField);+ o) s5 u& } v' k
}8 A" B8 T3 o2 x5 ~9 q" j, v
if(SUCCEEDED(hr))# b4 |( s6 P- J. v
fields->Release();//释放指针1 X7 m) a2 c- Z- g I5 {8 K
附:
5 A- y$ M# a% I- U7 p6 |9 V1、_variant_t3 ]% z$ t" M4 `: }; U0 v
(1)、一般传给这3个指针的值都不是MFC直接支持的数据类型,而要用_variant_t转换一下
: M2 u7 f9 z+ G# U X, y7 G- D1 Z_variant_t(XX)可以把大多数类型的变量转换成适合的类型传入：! _( ^3 o Q3 R' w" x( c2 d2 a
(2)、_variant_t var;_variant_t -> long: (long)var;" W% g) [" A' L
_variant_t -> CString: CString strValue = (LPCSTR)_bstr_t(var);( [4 C1 K" `6 s; k4 S# J; b8 h) h
CString -> _variant_t: _variant_t(strSql);
5 y$ W& n6 d/ V s/ l* K2、BSTR宽字符串与CString相互转换+ o2 v; m6 ^: Q. o3 B7 y
BSTR bstr;& X% ^, T6 K. j( z& f
CString strSql;
. T- ?7 j) d, Y2 nCString -> BSTR: bstr = strSql.AllocSysString();. [6 P9 B) A' Q- T4 |
BSTR -> CString: strSql = (LPCSTR)bstr;
( Z/ Y. M" k1 @3、_bstr_t与CString相互转换/ s5 f; p4 Q3 U/ _4 J
_bstr_t bstr;
' k8 l0 u& A2 G6 l/ ~# N8 xCString strSql;1 u F( G# W! s2 O
CString -> _bstr_t: bstr = (_bstr_t)strSql;
2 e( C+ d6 B, }- F1 h6 |_bstr_t -> CString: strSql = (LPCSTR)bstr;
8 C) f9 b: \9 ~; ?, V) P4、关于时间
% x% L9 k B9 k7 Z$ QAccess:表示时间的字符串#2004-4-5#$ L4 y+ ~, ^, F/ H& `
Sql:表示时间的字符串@#@#2004-4-5@#@#; F9 K: o1 D0 S, U8 o
DateField(时间字段) select * from my_table where DateField > #2004-4-10# " E0 G- l3 [& J/ L% k
try# l) x; g4 ]& O8 U5 a
{0 U; d- ~* p+ X2 z( c1 ~, }0 `# z
m_pCommand->CommandText = "INSERT INTO tTest(age) VALUES(@#23f2@#) ";
4 f4 |8 C) ~$ e6 l, D4 F& Hm_pRecordset = m_pCommand->Execute(NULL,NULL, adCmdText); 8 w6 Z; I. H# T/ f0 s2 r1 Z7 G( W
}
3 x6 f+ v; \6 C* ~: z' Lcatch(_com_error e)///捕捉异常3 R8 n2 w& Q. s9 r0 w" g1 G6 B
{: I; N5 e3 |6 m; E5 K8 a
CString errormessage;& A: M5 F7 H H' b* T. T! J/ p
errormessage.Format("连接数据库失败!\r\n错误信息:%s",e.ErrorMessage());
, _& R8 V$ u' \0 oAfxMessageBox(errormessage);///显示错误信息' o8 X# o- W5 y
阅读(153) | 评论(0) | 转发(0) |
