[转帖]在Visual C++中用ADO进行数据库编程(下)

god

<TABLE cellPadding=0 cellSpacing=0 height=325 style="TABLE-LAYOUT: fixed" width="100%">
2 k% J' R5 O. l( a. V! S8 A! y
<TR>
<TD vAlign=top width=32></TD>
( i: ~& i2 W, t<TD  vAlign=top>5. 记录集的遍历、更新
, u9 R: c/ k2 o) }3 ^
     根据我们刚才通过执行SQL命令建立好的users表，它包含四个字段:ID,username,old,birthday
5 X" }% e1 k. F. Q0 m8 ~以下的代码实现：打开记录集，遍历所有记录，删除第一条记录，添加三条记录，移动光标到第二条记录，
更改其年龄，保存到数据库。
_variant_t vUsername,vBirthday,vID,vOld;
/ R$ g4 h& ^* p) U' A4 N_RecordsetPtr m_pRecordset;
; p9 A+ l' N1 _; I" @m_pRecordset.CreateInstance("ADODB.Recordset");
  z$ Z; v* A  i1 k# Jm_pRecordset-&gt;Open("SELECT * FROM users",
_variant_t((IDispatch*)m_pConnection,true),
adOpenStatic,
% l. `. c4 E2 }* f  a# p# y1 Q& @ adLockOptimistic,
. c1 g2 |* o, y" y; E- G adCmdText);
4 Z( C8 W' c' b: p4 `* zwhile(!m_pRecordset-&gt;adoEOF)
{
0 O3 ~- q3 I9 n: C: A   vID = m_pRecordset-&gt;GetCollect(_variant_t((long)0));///取得第1列的值,从0开始计数，
   ///你也可以直接给出列的名称，如下一行
   vUsername = m_pRecordset-&gt;GetCollect("username");///取得username字段的值
( a+ t8 f. k, U( B3 x7 ~3 O   vOld = m_pRecordset-&gt;GetCollect("old");
  ?7 E2 Q, ^3 M+ a. B; t   vBirthday = m_pRecordset-&gt;GetCollect("birthday");
   ///在DEBUG方式下的OUTPUT窗口输出记录集中的记录
6 c3 _4 t& U, n2 |   if(vID.vt != VT_NULL &amp;&amp; vUsername.vt != VT_NULL &amp;&amp; vOld.vt != VT_NULL &amp;&amp; vBirthday.vt != VT_NULL)
. M! w& k6 p' p       TRACE("id:%d,姓名:%s,年龄:%d,生日:%s\r\n",
vID.lVal,
( w' K1 ?3 u) U) `" g( L+ u* n (LPCTSTR)(_bstr_t)vUsername,
vOld.lVal,
2 t& |/ x" }/ u8 T! G (LPCTSTR)(_bstr_t)vBirthday);
+ k; I3 t( j7 ~" x; \) h0 }; f: R   m_pRecordset-&gt;MoveNext();///移到下一条记录
! w, T/ p; ?% J) V$ l}
m_pRecordset-&gt;MoveFirst();///移到首条记录
0 y/ \: p+ O# N* im_pRecordset-&gt;Delete(adAffectCurrent);///删除当前记录
$ h; S& r5 E! @' B1 ~4 v/ p& v///添加三条新记录并赋值
for(int i=0;i&lt;3;i++)
{
   m_pRecordset-&gt;AddNew();///添加新记录
7 u" o( I9 U, R1 S2 t   m_pRecordset-&gtutCollect("ID",_variant_t((long)(i+10)));
8 x6 t0 |, d$ l0 o5 f; y) S   m_pRecordset-&gtutCollect("username",_variant_t("叶利钦"));
   m_pRecordset-&gtutCollect("old",_variant_t((long)71));
   m_pRecordset-&gtutCollect("birthday",_variant_t("1930-3-15"));
}
m_pRecordset-&gt;Move(1,_variant_t((long)adBookmarkFirst));///从第一条记录往下移动一条记录,即移动到第二条记录处
* s5 p2 k5 V7 ym_pRecordset-&gtutCollect(_variant_t("old"),_variant_t((long)45));///修改其年龄
m_pRecordset-&gt;Update();///保存到库中   
: ]! A4 f3 g0 R5 J. \备注：多次查询可把查询过程做成一个函数ExecuteSQL让m_pRecordset获得连接指针m_pConnection查询结果
void ExecuteSQL(_ConnectionPtr  m_pConnection, _RecordsetPtr  m_pRecordset,CString strSql)
{
   //执行Select 语句
) ?, _  k' r& D8 f/ T2 d  K   BSTR bstrSQL = strSql.AllocSysString();           
, U  G% g1 \( L. |7 C, e$ \4 }4 ^    try
    {
8 ]. z9 c' t/ R2 E       m_pRecordset-&gt;Open(bstrSQL,(IDispatch*)m_pConnection,adOpenDynamic,adLockOptimistic,adCmdText);
           //adOpenDynamic：动态  adLockOptimistic乐观封锁法  adCmdText：文本查询语句
    }
. a9 Z# b" D. V0 ]& ?4 q: Y& ?: ^    catch(_com_error error)
) n2 ^# j6 b! x( A) E! O    {
8 h3 ]: `% L* ^( D       CString errorMessage;
. I4 V! i1 s2 W0 W       errorMessage.format("%s",(LPTSTR)error.Description());
       AfxMessageBox(errorMessage);
6 F0 J1 c: y+ o  b4 `9 j9 F    }
}        
- H1 W- I' a+ |//出错处理：
( U9 {, [7 c  r3127——没有找到目标表
- x8 `4 w- ?! Y* z3092——目标表已经存在
例如：
catch(const _com_error e)
{
. w5 u* N! J! i' B0 x% z# h/ [    AfxMessageBox(e.Description());
    long errorCode=e.WCode();
' x8 G& k) N2 T* }# p( t9 J    if(3127==errorCode) AfxMessageBox("表不存在");
    if(3092==errorCode) AfxMessageBox("表已经存在");
    return FALSE;
$ X; C6 Z* q0 z8 l7 ~$ L}

  u- ~/ o: j+ r" t% M9 I6 G</TD></TR></TABLE>

wangyu249

<p>不错</p>