|
>1.VC连接SQL Server数据库时步骤 -------------------------------------------------- --- (1)初始化COM库，引入ADO库定义文件。 在MFC中可以用AfxOleInit();非MFC环境中用:CoInitialize(NULL); CoUnInitialize(); (2)用Connection对象连接数据库 (3)利用建立好的连接，通过Connection、Command对象执行SQL命令，或利用Recordset对象取得结果记录集进行查询、处理。 (4)使用完毕后关闭连接释放对象。 >2.连接数据库的方式 -------------------------------------------------- --- OLEDB 是一种基于组件对象的数据库连接方式. ADO 是建立在OLEDB基础之上的一种简单快速的OLEDB连接方式. ODBC 各数据库厂商基于Microsoft开发给他们的数据库公共接口而开发的连接方式. DAO 是微软开发的更简单的数据连接方式, 早期使用得比较多. >3. ODBC链接 -------------------------------------------------- --- 适合数据库类型 链接方式 access "Driver={microsoft access driver(*.mdb)};dbq=*.mdb;uid=admin;pwd=pass;" dBase "Driver={microsoft dbase driver(*.dbf)};driverid=277;dbq=------------;" Oracle "Driver={microsoft odbc for oracle};server=oraclesever.world;uid=admin;pwd=pas s;" MSSQL server "Driver={sql server};server=servername;database=dbname;uid=sa;p wd=pass;" MS text "Driver={microsoft text driver(*.txt; *.csv)};dbq=-----;extensions=asc,csv,tab,txt;Persi st SecurityInfo=false;" Visual Foxpro "Driver={microsoft Visual Foxpro driver};sourcetype=DBC;sourceDB=*.dbc;Exclusive=No ;" MySQL "Driver={mysql};database=yourdatabase;uid=username ;pwd=yourpassword;option=;" >4. OLEDB链接 -------------------------------------------------- --- 适合的数据库类型 链接方式 access "Provider=microsoft.jet.oledb.4.0;data source=your_database_path;user id=admin;password=pass;" Oracle "Provider=OraOLEDB.Oracle;data source=dbname;user id=admin;password=pass;" MS SQL Server "Provider=SQLOLEDB;data source=machinename;initial catalog=dbname;userid=sa;password=pass;" >5. 基本数据库操作 -------------------------------------------------- --- 添加 a)、调用m_pRecordset->AddNew(); b)、调用m_pRecordset->PutCollect();给每个字段赋值 c)、调用m_pRecordset->Update();确认 删除 a)、把记录指针移动到要删除的记录上,然后调用Delete(adAffectCurrent) try { // 假设删除第二条记录} catch(_com_error *e) { AfxMessageBox(e->ErrorMessage()); } >6. 直接执行SQL语句实现 -------------------------------------------------- --- 除了要用到结果集其余的大部分功能都可以直接用SQL语言实现 (1)、用_CommandPtr和_RecordsetPtr配合 _CommandPtr m_pCommand; m_pCommand.CreateInstance(__uuidof(Command));// 将库连接赋于它 m_pCommand->ActiveConnection = m_pConnection; // SQL语句 m_pCommand->CommandText = "SELECT * FROM DemoTable"; // 执行SQL语句，返回记录集 m_pRecordset = m_pCommand->Execute(NULL, NULL,adCmdText); (2)、直接用_ConnectionPtr执行SQL语句 _RecordsetPtr Connection15::Execute ( _bstr_t CommandText, VARIANT * RecordsAffected, long Options ) 其中CommandText是命令字串，通常是SQL命令。 参数RecordsAffected是操作完成后所影响的行数, 参数Options表示CommandText中内容的类型，Options可以取如下值之一： adCmdText:表明CommandText是文本命令 adCmdTable:表明CommandText是一个表名 adCmdProc:表明CommandText是一个存储过程 adCmdUnknown:未知 例子: _variant_t RecordsAffected; m_pConnection->Execute("UPDATE users SET old = old+1",&RecordsAffected,adCmdText); >7. 调用存储过程 -------------------------------------------------- --- (1)利用_CommandPtr _CommandPtr m_pCommand; m_pCommand.CreateInstance(__uuidof(Command)); m_pCommand->ActiveConnection = m_pConnection; // 将库连接赋于它 m_pCommand->CommandText = "Demo"; m_pCommand->Execute(NULL,NULL, adCmdStoredProc); (2)直接用_ConnectionPtr直接调用(见4.(2)) 6.遍历数据库中的所有表名_ConnectionPtr m_pConnect; _RecordsetPtr pSet; HRESULT hr; try {
}catch(_com_error e)///捕捉异常 {
} >8. 遍历一个表中的所有字段 -------------------------------------------------- --- Field * field = NULL; HRESULT hr; Fields * fields = NULL; hr = m_pRecordset->get_Fields (&fields); //得到记录集的字段集和 if(SUCCEEDED(hr)) fields->get_Count(&ColCount); //得到记录集的字段集合中的字段的总个数 for(i=0;iItem[i]->get_Name(&bstrColName); //得到记录集//中的字段名
} if(SUCCEEDED(hr)) fields->Release();//释放指针 >9. 几个特殊字段 -------------------------------------------------- --- 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# >10. Connection对象的Open方法 -------------------------------------------------- --- 原型HRESULT Connection15::Open ( _bstr_t ConnectionString, _bstr_t UserID, _bstr_t Password, long Options ) ConnectionString为连接字串,UserID是用户名, Password是登陆密码,Options是连接选项,用于指定Connection对象对数据的更新许可权, Options可以是如下几个常量: adModeUnknown:缺省。当前的许可权未设置 adModeRead:只读 adModeWrite:只写 adModeReadWrite:可以读写 adModeShareDenyRead:阻止其它Connection对象以读权限打开连接 adModeShareDenyWrite:阻止其它Connection对象以写权限打开连接 adModeShareExclusive:阻止其它Connection对象以读写权限打开连接 adModeShareDenyNone:阻止其它Connection对象以任何权限打开连接 >11. Connection对象除Open方法中常用的连接方式 -------------------------------------------------- --- (1)通过JET数据库引擎对ACCESS2000数据库的连接 m_pConnection->Open("Provider=Microsoft.Jet.OLEDB.4 .0;Data Source=C:\\test.mdb","","",adModeUnknown); (2)通过DSN数据源对任何支持ODBC的数据库进行连接: m_pConnection->Open("Data Source=adotest;UID=sa;PWD=;","","",adModeUnknown); (3)不通过DSN对SQL SERVER数据库进行连接： m_pConnection->Open("driver={SQL Server};Server=127.0.0.1;DATABASE=vckbase;UID=sa;P WD=139","","",adModeUnknown); 其中Server是SQL服务器的名称，DATABASE是库的名称 >12. Connection对象中两个有用的属性ConnectionTimeOut与State -------------------------------------------------- --- ConnectionTimeOut用来设置连接的超时时间，需要在Open之前调用，例如: m_pConnection->ConnectionTimeout = 5;///设置超时时间为5秒 m_pConnection->Open("Data Source=adotest;","","",adModeUnknown); State属性指明当前Connection对象的状态，0表示关闭，1表示已经打开，我们可以通过读取这个属性来作相应的处理，例如: if(m_pConnection->State) m_pConnection->Close(); ///如果已经打开了连接则关闭它 >13.利用Connection对象的Execute方法 -------------------------------------------------- --- _RecordsetPtr Connection15::Execute ( _bstr_t CommandText, VARIANT * RecordsAffected, long Options ) 其中CommandText是命令字串，通常是SQL命令。 参数RecordsAffected是操作完成后所影响的行数, 参数Options表示CommandText中内容的类型，Options可以取如下值之一： adCmdText:表明CommandText是文本命令 adCmdTable:表明CommandText是一个表名 adCmdProc:表明CommandText是一个存储过程 adCmdUnknown:未知 >14. Execute执行及执行之后的结果 -------------------------------------------------- --- _variant_t RecordsAffected; ///执行SQL命令：CREATE TABLE创建表格users,users包含四个字段:整形ID,字符串username,整形old,日期型birthday m_pConnection->Execute("CREATE TABLE users(ID INTEGER,username TEXT,old INTEGER,birthday DATETIME)",&RecordsAffected,adCmdText); ///往表格里面添加记录 m_pConnection->Execute("INSERT INTO users(ID,username,old,birthday) VALUES (1, 'Washington', 25, '1970/1/1')",&RecordsAffected,adCmdText); ///将所有记录old字段的值加一 m_pConnection->Execute("UPDATE users SET old = old+1",&RecordsAffected,adCmdText); ///执行SQL统计命令得到包含记录条数的记录集 m_pRecordset=m_pConnection->Execute("SELECT COUNT(*) FROM users", &RecordsAffected, adCmdText); _variant_t vIndex = (long)0; _variant_t vCount = m_pRecordset->GetCollect(vIndex);///取得第一个字段的值放入vCount变量 m_pRecordset->Close();///关闭记录集 CString message; message.Format("共有%d条记录",vCount.lVal); AfxMessageBox(message);///显示当前记录条数 >15. 利用Command对象来执行SQL命令 -------------------------------------------------- --- _CommandPtr m_pCommand; m_pCommand.CreateInstance("ADODB.Command"); _variant_t vNULL; vNULL.vt = VT_ERROR; vNULL.scode = DISP_E_PARAMNOTFOUND;///定义为无参数 m_pCommand->ActiveConnection = m_pConnection;///非常关键的一句，将建立的连接赋值给它 m_pCommand->CommandText = "SELECT * FROM users";///命令字串 m_pRecordset = m_pCommand->Execute(&vNULL,&vNULL,adCmdText);///执行命令，取得记录集 在这段代码中我们只是用Command对象来执行了SELECT查询语句，Command对象在进行存储过程的调用中能真正体现它的作用。下次我们将详细介绍。 >16. 直接用Recordset对象进行查询取得记录集 -------------------------------------------------- --- m_pRecordset->Open("SELECT * FROM users",_variant_t((IDispatch *)m_pConnection, true), adOpenStatic, adLockOptimistic, adCmdText); Open方法的原型: HRESULT Recordset15::Open ( const _variant_t & Source, const _variant_t & ActiveConnection, enum CursorTypeEnum CursorType, enum LockTypeEnum LockType, long Options ) 其中： ①Source是数据查询字符串 ②ActiveConnection是已经建立好的连接（我们需要用Connection对象指针来构造一个_variant_t对象) ③CursorType光标类型，它可以是以下值之一,这个枚举结构: enum CursorTypeEnum {
}; ④LockType锁定类型，它可以是以下值之一，请看如下枚举结构： enum LockTypeEnum {
}; >17. 查看记录集中记录 -------------------------------------------------- --- while(!m_pRecordset->adoEOF) { var = m_pRecordset->GetCollect("Name"); if(var.vt != VT_NULL) strName = (LPCSTR)_bstr_t(var); var = m_pRecordset->GetCollect("Age"); if(var.vt != VT_NULL) strAge = (LPCSTR)_bstr_t(var); m_AccessList.AddString( strName + " --> "+strAge ); m_pRecordset->MoveNext(); 取得一个字段的值的办法有两种办法 一是 m_pRecordset->GetCollect("Name");//表示取得第0个字段的值 或者m_pRecordset->GetCollect(_variant_t(long(0)); 二是 pRecordset->get_Collect("COLUMN_NAME"); 或者pRecordset->get_Collect(long(index)); >18.VC连接数据库的简要步骤。 -------------------------------------------------- --- 【1】COM库的初始化 我们可以使用AfxOleInit()来初始化COM库，这项工作通常在CWinApp::InitInstance()的重载函数中完成，请看如下代码: BOOL CADOTest1App::InitInstance() { AfxOleInit(); ...... 【2】用#import指令引入ADO类型库 我们在stdafx.h中加入如下语句：(stdafx.h这个文件哪里可以找到?你可以在FileView中的Header Files里找到) #import "c:\program files\common files\system\ado\msado15.dll" no_namespace rename("EOF","adoEOF") 这一语句作用同我们熟悉的#include类似,编译的时候系统会为我们生成msado15.tlh,ado15.tli两个C++头文件来定义ADO库。 说明:(1)环境中msado15.dll不一定在这个目录下，请按实际情况修改(2) 在编译的时候肯能会出现如下警告，对此微软在MSDN中作了说明，并建议我们不要理会这个警告。msado15.tlh(405) : warning C4146: unary minus operator applied to unsigned type, result still unsigned 【3】创建Connection对象并连接数据库 首先我们需要添加一个指向Connection对象的指针: _ConnectionPtr m_pConnection; 下面的代码演示了如何创建Connection对象实例及如何连接数据库并进行异常捕捉。 BOOL CADOTest1Dlg::OnInitDialog() {
【4】执行SQL命令并取得结果记录集 为了取得结果记录集，我们定义一个指向Recordset对象的指针:_RecordsetPtr m_pRecordset; 并为其创建Recordset对象的实例: m_pRecordset.CreateInstance("ADODB.Recordset"); SQL命令的执行可以采用多种形式，下面我们一进行阐述。 【5】记录集的遍历、更新 根据我们刚才通过执行SQL命令建立好的users表，它包含四个字段:ID,username,old,birthday 以下的代码实现：打开记录集，遍历所有记录，删除第一条记录，添加三条记录，移动光标到第二条记录，更改其年龄，保存到数据库。 _variant_t vUsername,vBirthday,vID,vOld; _RecordsetPtr m_pRecordset; m_pRecordset.CreateInstance("ADODB.Recordset"); m_pRecordset->Open("SELECT * FROM users",_variant_t((IDispatch*)m_pConnection,true), adOpenStatic,adLockOptimistic,adCmdText); while(!m_pRecordset->adoEOF)///这里为什么是adoEOF而不是EOF呢?还记得rename("EOF","adoEOF")这一句吗? {
} m_pRecordset->MoveFirst();///移到首条记录 m_pRecordset->Delete(adAffectCurrent);///删除当前记录 ///添加三条新记录并赋值 for(int i=0;i<3;i++) {
} m_pRecordset->Move(1,_variant_t((long)adBookmarkFir st));///从第一条记录往下移动一条记录,即移动到第二条记录处 m_pRecordset->PutCollect(_variant_t("old"),_variant _t((long)45));///修改其年龄 m_pRecordset->Update();///保存到库中 【6】关闭记录集与连接 记录集或连接都可以用Close方法来关闭 m_pRecordset->Close();///关闭记录集 m_pConnection->Close();///关闭连接 void CAdoSTDlg::OnBtnbl() {
} void CAdoSTDlg::OnBtnadd() {
} void CAdoSTDlg::OnBtnmod() { // TODO: Add your control notification handler code here //**************************************************
} void CAdoSTDlg::OnBtndel() { // TODO: Add your control notification handler code here UpdateData(TRUE); ADOConn m_AdoConn; m_AdoConn.OnInitADOConn(); _bstr_t sql; CString strsql; // strsql.Format("delete from st where no = 66%s",m_id); strsql.Format("delete from st where No = %s",m_id); //sql="delete from st where No=66"; m_AdoConn.ExecuteSQL((_bstr_t)strsql); //m_AdoConn.ExecuteSQL(sql); m_AdoConn.ExitConnect(); m_list.DeleteAllItems(); OnBtnbl(); //遍历显示 /*UpdateData(TRUE); ADOConn m_AdoConn; m_AdoConn.OnInitADOConn(); _bstr_t sql; sql="select * from st order by No ASC"; _RecordsetPtr m_pRecordset; m_pRecordset=m_AdoConn.GetRecordSet((_bstr_t)sql); CString m_id; try { m_pRecordset->Move(m_RecNo-1,vtMissing); m_pRecordset->Delete(adAffectCurrent); m_pRecordset->Update(); } catch(...) { MessageBox("操作失败"); return; } MessageBox("删除成功"); m_list.DeleteAllItems(); OnBtnbl(); *///遍历显示 } void CAdoSTDlg::OnClickList1(NMHDR* pNMHDR, LRESULT* pResult) { // TODO: Add your control notification handler code here UpdateData(true); int pos; pos=m_list.GetSelectionMark(); m_id=m_list.GetItemText(pos,0); m_name=m_list.GetItemText(pos,1); m_qita=m_list.GetItemText(pos,2); UpdateData(false); *pResult = 0; }
4.执行SQL命令并取得结果记录集 为了取得结果记录集，我们定义一个指向Recordset对象的指针：_RecordsetPtrm_pRecordset； 并为其创建Recordset对象的实例： m_pRecordset.CreateInstance（”ADODB.Recordset“）； SQL命令的执行可以采用多种形式，下面我们一进行阐述。 （1）利用Connection对象的Execute方法执行SQL命令 Execute方法的原型如下所示： _RecordsetPtr Connection15：：Execute （ _bstr_tCommandText， VARIANT * RecordsAffected， long Options ） 其中CommandText是命令字串，通常是SQL命令。 参数RecordsAffected是操作完成后所影响的行数， 参数Options表示CommandText中内容的类型，Options可以取如下值之一： adCmdText：表明CommandText是文本命令 adCmdTable：表明CommandText是一个表名 adCmdProc：表明CommandText是一个存储过程 adCmdUnknown：未知 Execute执行完后返回一个指向记录集的指针，下面我们给出具体代码并作说明。 _variant_tRecordsAffected； ///执行SQL命令：CREATE TABLE创建表格users，users包含四个字段：整形ID，字符串username， 整形old，日期型birthday m_pConnection->Execute（”CREATE TABLE users（ID INTEGER，usernameTEXT，oldINTEGER，birthday DATETIME）“，&RecordsAffected，adCmdText）；
（1， ''''Washington''''，25，''''1970/1/1''''）“，&RecordsAffected，adCmdText）； ///将所有记录old字段的值加一 m_pConnection->Execute（”UPDATE users SET old = old+1“，&RecordsAffected，adCmdText）； ///执行SQL统计命令得到包含记录条数的记录集 m_pRecordset = m_pConnection->Execute（”SELECT COUNT（*） FROM users“，&RecordsAffected，adCmdText）； _variant_tvIndex = （long）0； _variant_tvCount = m_pRecordset->GetCollect（vIndex）；///取得第一个字段的值放入vCount变量 上两句可以写成- _variant_tvCount = m_pRecordset->GetCollect（（_variant_t）（（long）0））； m_pRecordset->Close（）；///关闭记录集 CString message； message.Format（”共有%d条记录“，vCount.lVal）；
_CommandPtrm_pCommand； m_pCommand.CreateInstance（”ADODB.Command“）； _variant_tvNULL； vNULL.vt = VT_ERROR； vNULL.scode = DISP_E_PARAMNOTFOUND；///定义为无参数 m_pCommand->ActiveConnection = m_pConnection；///非常关键的一句，将建立的连接赋值给它 m_pCommand->CommandText = “SELECT * FROM users”；///命令字串 m_pRecordset = m_pCommand->Execute（&vNULL，&vNULL，adCmdText）；///执行命令，取得记录集 在这段代码中我们只是用Command对象来执行了SELECT查询语句，Command对象在进行存储过程的调用中能真正体现它的作用。下次我们将详细介绍。 （3）直接用Recordset对象进行查询取得记录集 实例-- void CGmsaDlg：：OnDBSelect（） { // TODO： Add your control notification handler code here _RecordsetPtr Rs1； //定义Recordset对象 _bstr_t Connect（“DSN=GMS；UID=sa；PWD=；”）；//定义连接字符串 _bstr_t Source （“SELECT count（*） FROM buaa.mdb010”）； //要执行的SQL语句 ：：CoInitialize（NULL）； //初始化Rs1对象 HRESUL hr = Rs1.CreateInstance（ __uuidof（ Recordset ） ）； //省略对返回值hr的判断 Rs1->Open（ Source， Connect， adOpenForwardOnly， adLockReadOnly， -1 ）；
CStringstrTemp=（char* ）（_bstr_t）temp； MessageBox（“OK！”+strTemp）； }
m_pRecordset->Open（“SELECT * FROM users”， _variant_t（（IDispatch *）m_pConnection，true）， adOpenStatic， adLockOptimistic， adCmdText）； 5.记录集的遍历、更新
以下的代码实现：打开记录集，遍历所有记录，删除第一条记录，添加三条记录，移动光标到第二条记录， 更改其年龄，保存到数据库。 _variant_tvUsername，vBirthday，vID，vOld； _RecordsetPtrm_pRecordset； m_pRecordset.CreateInstance（“ADODB.Recordset”）； m_pRecordset->Open（“SELECT * FROM users”， _variant_t（（IDispatch*）m_pConnection，true）， adOpenStatic， adLockOptimistic， adCmdText）； while（！m_pRecordset->adoEOF） { vID = m_pRecordset->GetCollect（_variant_t（（long）0））；///取得第1列的值，从0开始计数， ///您也可以直接给出列的名称，如下一行 vUsername = m_pRecordset->GetCollect（“username”）；///取得username字段的值 vOld = m_pRecordset->GetCollect（“old”）； vBirthday = m_pRecordset->GetCollect（“birthday”）； ///在DEBUG方式下的OUTPUT窗口输出记录集中的记录 if（vID.vt ！= VT_NULL &&vUsername.vt ！= VT_NULL &&vOld.vt ！= VT_NULL &&vBirthday.vt ！= VT_NULL） TRACE（“id：%d，姓名：%s，年龄：%d，生日：%s “， vID.lVal， （LPCTSTR）（_bstr_t）vUsername， vOld.lVal， （LPCTSTR）（_bstr_t）vBirthday）； m_pRecordset->MoveNext（）；///移到下一条记录 } m_pRecordset->MoveFirst（）；///移到首条记录 m_pRecordset->Delete（adAffectCurrent）；///删除当前记录 ///添加三条新记录并赋值 for（inti=0；i<3；i++） { m_pRecordset->AddNew（）；///添加新记录 m_pRecordset->PutCollect（”ID“，_variant_t（（long）（i+10）））； m_pRecordset->PutCollect（”username“，_variant_t（”叶利钦“））； m_pRecordset->PutCollect（”old“，_variant_t（（long）71））； m_pRecordset->PutCollect（”birthday“，_variant_t（”1930-3-15“））； } m_pRecordset->Move（1，_variant_t（（long）adBookmarkFirst））；///从第一条记录往下移动一条记录，即移动 到第二条记录处 m_pRecordset->PutCollect（_variant_t（”old“），_variant_t（（long）45））；///修改其年龄 m_pRecordset->Update（）；///保存到库中 备注：多次查询可把查询过程做成一个函数ExecuteSQL让m_pRecordset获得连接指针m_pConnection查询结果 void ExecuteSQL（_ConnectionPtrm_pConnection， _RecordsetPtrm_pRecordset，CStringstrSql） { //执行Select 语句 BSTR bstrSQL = strSql.AllocSysString（）； try { m_pRecordset->Open（bstrSQL，（IDispatch*）m_pConnection，adOpenDynamic，adLockOptimistic， adCmdText）； //adOpenDynamic：动态 adLockOptimistic乐观封锁法 adCmdText：文本查询语句 } catch（_com_error error） { CStringerrorMessage； errorMessage.Format（”%s“，（LPTSTR）error.Description（））； AfxMessageBox（errorMessage）； } }
|
|
|
