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

god

<TABLE cellPadding=0 cellSpacing=0 height=325 style="TABLE-LAYOUT: fixed" width="100%">

<TR>
$ v$ k+ z* J2 }) u+ M' L. L<TD vAlign=top width=32></TD>
0 `, G/ O% j* b. ?9 v<TD  vAlign=top>5. 记录集的遍历、更新
( R7 m3 E7 D9 r9 \  e
, A. {3 `0 `  @& T, I     根据我们刚才通过执行SQL命令建立好的users表，它包含四个字段:ID,username,old,birthday
以下的代码实现：打开记录集，遍历所有记录，删除第一条记录，添加三条记录，移动光标到第二条记录，
更改其年龄，保存到数据库。
/ q, S6 ~& ^: z7 Z_variant_t vUsername,vBirthday,vID,vOld;
& _8 T9 F+ J2 ], M1 d_RecordsetPtr m_pRecordset;
5 v6 u. g, P$ c' |$ `& Am_pRecordset.CreateInstance("ADODB.Recordset");
$ q7 u0 @! t, z% h* K6 J( hm_pRecordset-&gt;Open("SELECT * FROM users",
' w% y, G' ^  n  \ _variant_t((IDispatch*)m_pConnection,true),
& V0 J* B& y' X adOpenStatic,
adLockOptimistic,
adCmdText);
while(!m_pRecordset-&gt;adoEOF)
: P% h5 M3 ~/ B" G4 p( j7 F{
  K( y+ w1 r+ W5 m% y, x   vID = m_pRecordset-&gt;GetCollect(_variant_t((long)0));///取得第1列的值,从0开始计数，
  }, w; l: f7 Y1 R( |! I   ///你也可以直接给出列的名称，如下一行
9 L3 a+ H! U8 u3 q   vUsername = m_pRecordset-&gt;GetCollect("username");///取得username字段的值
   vOld = m_pRecordset-&gt;GetCollect("old");
   vBirthday = m_pRecordset-&gt;GetCollect("birthday");
. U+ ~4 Y5 b) o5 x* S  I" Y. Z  z1 ~+ v   ///在DEBUG方式下的OUTPUT窗口输出记录集中的记录
   if(vID.vt != VT_NULL &amp;&amp; vUsername.vt != VT_NULL &amp;&amp; vOld.vt != VT_NULL &amp;&amp; vBirthday.vt != VT_NULL)
4 ]3 K9 x( c1 h3 ~/ t       TRACE("id:%d,姓名:%s,年龄:%d,生日:%s\r\n",
* d+ f8 F: S) r5 G/ C5 G* l vID.lVal,
(LPCTSTR)(_bstr_t)vUsername,
0 a( c2 n3 w* O( P vOld.lVal,
(LPCTSTR)(_bstr_t)vBirthday);
: R( z$ S+ |. A3 l   m_pRecordset-&gt;MoveNext();///移到下一条记录
; z" E+ Q- e8 J+ V; ^}
- `2 H% p1 n- Q. p4 {6 Y' W/ Em_pRecordset-&gt;MoveFirst();///移到首条记录
m_pRecordset-&gt;Delete(adAffectCurrent);///删除当前记录
///添加三条新记录并赋值
for(int i=0;i&lt;3;i++)
' D" J" H9 |8 |3 ^: v+ E{
1 d9 N' \: h( e& e9 T   m_pRecordset-&gt;AddNew();///添加新记录
; C6 F, i2 e/ R( I   m_pRecordset-&gtutCollect("ID",_variant_t((long)(i+10)));
   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));///从第一条记录往下移动一条记录,即移动到第二条记录处
m_pRecordset-&gtutCollect(_variant_t("old"),_variant_t((long)45));///修改其年龄
9 K- N. m9 G  ?' Dm_pRecordset-&gt;Update();///保存到库中   
备注：多次查询可把查询过程做成一个函数ExecuteSQL让m_pRecordset获得连接指针m_pConnection查询结果
void ExecuteSQL(_ConnectionPtr  m_pConnection, _RecordsetPtr  m_pRecordset,CString strSql)
{
' V& Y* u, k! s0 ^' ]! E) ]   //执行Select 语句
' C4 n& H/ e/ }   BSTR bstrSQL = strSql.AllocSysString();           
2 x+ [& Q3 q7 b+ \7 R    try
9 l; p" o7 I9 x7 B0 \" V1 [    {
       m_pRecordset-&gt;Open(bstrSQL,(IDispatch*)m_pConnection,adOpenDynamic,adLockOptimistic,adCmdText);
: k5 p1 _8 v9 a           //adOpenDynamic：动态  adLockOptimistic乐观封锁法  adCmdText：文本查询语句
! l5 b. U- E, I8 M) K8 P7 d& e: N    }
- z- h: b8 m  q3 p1 `. X% p6 R" ~$ j    catch(_com_error error)
4 D) n0 s: e/ `2 F& z    {
       CString errorMessage;
+ k+ {1 ]: E. d4 m) h+ m2 R+ b* s       errorMessage.format("%s",(LPTSTR)error.Description());
$ k# K: m; {& F       AfxMessageBox(errorMessage);
    }
! S6 i8 w/ y  a9 W$ ~7 a}        
//出错处理：
3127——没有找到目标表
! n* ~# \% c& }& g3092——目标表已经存在
例如：
catch(const _com_error e)
" @7 \) y4 U8 u+ l{
    AfxMessageBox(e.Description());
    long errorCode=e.WCode();
5 }" i% Q7 W( E# a    if(3127==errorCode) AfxMessageBox("表不存在");
$ {; O8 A; C+ i* K2 i; x2 j: x8 i    if(3092==errorCode) AfxMessageBox("表已经存在");
    return FALSE;
}

) |* w- `% z- h+ d, P% C# M" g</TD></TR></TABLE>

wangyu249

<p>不错</p>