C++ADO连接SQL资源-CSDN文库

共2个文件

cpp：1个

h：1个

4星 · 超过85%的资源需积分: 18 83 浏览量 2013-07-31 09:27:29 上传评论收藏 4KB RAR 举报

在C++编程中，ADO（ActiveX Data Objects）是一种常用的技术，用于与各种数据库系统进行交互，包括SQL Server。ADO是Microsoft开发的组件，它基于OLE DB，提供了一种简单的方式来访问和操作数据。本篇将详细介绍如何使用C++通过ADO连接到SQL数据库。我们需要包含必要的头文件，如`#include <atlbase.h>`，`#include <atlcom.h>`以及`#import`语句来导入ADO库。`#import`通常用于自动生成COM接口的声明，例如： ```cpp #import "msado15.dll" no_namespace rename("EOF", "EndOfFile") ``` 在`AdoConnectDataBase.cpp`和`AdoConnectDataBase.h`文件中，我们可能会定义一个类，比如`ADODatabase`，这个类封装了连接、查询、执行命令等操作。下面是一个简单的类结构示例： ```cpp class ADODatabase { private: _ConnectionPtr conn; // ADO Connection对象 _CommandPtr cmd; // ADO Command对象 public: ADODatabase(const std::wstring& connectionString); ~ADODatabase(); bool Open(); void Close(); bool ExecuteNonQuery(const std::wstring& sql); _RecordsetPtr ExecuteQuery(const std::wstring& sql); }; ``` 在构造函数中，我们可以初始化这些COM对象，并在连接字符串中指定数据库信息。例如： ```cpp ADODatabase::ADODatabase(const std::wstring& connectionString) { HRESULT hr = CoInitialize(NULL); // 初始化COM环境 if (FAILED(hr)) throw std::runtime_error("Failed to initialize COM."); // 创建Connection对象 hr = CoCreateInstance(__uuidof(Connection), NULL, CLSCTX_INPROC_SERVER, __uuidof(_Connection), (LPVOID*)&conn); if (FAILED(hr)) throw std::runtime_error("Failed to create ADO Connection."); // 设置连接字符串 conn->ConnectionString = connectionString.c_str(); } ``` `Open()`方法用于打开数据库连接，`Close()`用于关闭连接。`ExecuteNonQuery()`用于执行不返回结果集的SQL语句，如INSERT、UPDATE或DELETE。`ExecuteQuery()`则用于执行返回结果集的SQL查询，它会返回一个`_RecordsetPtr`，可以遍历查询结果。在`ExecuteNonQuery()`和`ExecuteQuery()`方法中，我们可能需要创建并设置`_CommandPtr`对象，然后调用`Execute()`方法。例如： ```cpp bool ADODatabase::ExecuteNonQuery(const std::wstring& sql) { if (!conn || !cmd) return false; cmd = new _CommandPtr(); cmd->ActiveConnection = conn; cmd->CommandText = sql.c_str(); long rowsAffected = cmd->Execute(NULL, NULL, adCmdText | adExecuteNoRecords); return rowsAffected > 0; } ``` 对于`ExecuteQuery()`，我们需要返回一个记录集，供用户进一步处理： ```cpp _RecordsetPtr ADODatabase::ExecuteQuery(const std::wstring& sql) { if (!conn || !cmd) return NULL; cmd = new _CommandPtr(); cmd->ActiveConnection = conn; cmd->CommandText = sql.c_str(); _RecordsetPtr rs; cmd->Execute(&rs, NULL, adCmdText); return rs; } ``` 这就是一个基础的C++ ADO连接SQL的实现框架。通过这个类，你可以轻松地在C++程序中执行SQL操作，处理数据库事务。注意，使用完ADO对象后，记得释放它们，防止内存泄漏。 C++通过ADO连接SQL提供了强大的数据库操作能力，但需要对COM和ADO的概念有一定理解。在实际项目中，可能还需要考虑错误处理、事务管理、连接池等高级特性，以提高程序的稳定性和性能。

资源推荐

资源详情

资源评论

收起资源包目录

C++ ADO连接SQL.rar （2个子文件）

AdoConnectDataBase.h 11KB

AdoConnectDataBase.cpp 7KB

/********************************************************************* * CopyRight(C), 2012, MoGuangYan. All Rights Reserved * * Date Created : 2012.4.16 * FileName : AdoConnectDataBase.cpp * Description : The Methods * Mail : moguangyan23@163.com or 1031300437@qq.com * Author : MoGuangYan * Contact : 1031300437(QQ) * Date Modified: 2013.7.19 * * FileVersion : 1.0.0.0 * **********************************************************************/ #include "AdoConnectDataBase.h" void MessageLog_void(char chLog[]); void MessageLog_void(char chLog[]) { FILE *fp; char chFile[100] ="\0"; time_t rawtime; struct tm *timeinfo; time (&rawtime); timeinfo = localtime(&rawtime); sprintf(chFile,"ADO_Log_%4d-%02d-%02d.txt",1900+timeinfo->tm_year, 1+timeinfo->tm_mon,timeinfo->tm_mday); fp = fopen(chFile,"at+"); if(fp == NULL) { return; } else { fprintf(fp,"[ADO Error]%s\n",chLog); fclose(fp); } return; } CAdoConnectDataBase::CAdoConnectDataBase() { try { ::CoInitialize(NULL); //初始化OLE/COM库环境 Connectionstring = ""; m_pConnection = NULL; m_pRecordset = NULL; } catch(_com_error e) { char chLog[300] ="\0"; sprintf(chLog,"构造函数[%s]",(char *)e.Description()); MessageLog_void(chLog); } } CAdoConnectDataBase::~CAdoConnectDataBase() { //关闭记录集和连接 try { if(m_pRecordset != NULL) m_pRecordset->Close(); m_pConnection->Close(); ::CoUninitialize(); //释放程序占用的COM资源 } catch(_com_error e) { char chLog[300] ="\0"; sprintf(chLog,"关闭连接异常[%s]",(char *)e.Description()); MessageLog_void(chLog); } } bool CAdoConnectDataBase::InitAdoConnet() // 连接数据库 { try { m_pConnection.CreateInstance("ADODB.Connection");//创建Connection 对象 m_pConnection->Open(Connectionstring,"","",adModeUnknown); } catch(_com_error e) { char chLog[300] ="\0"; sprintf(chLog,"连接数据库异常[%s]",(char *)e.Description()); MessageLog_void(chLog); return false; } return true; } bool CAdoConnectDataBase::ExecuteSQL(_bstr_t bstrSQL)//执行Insert UpDate Delete { try { //是否已经连接到数据库 if(m_pConnection == NULL) { if(!InitAdoConnet()) { char ch[100] ="重连数据库失败"; MessageLog_void(ch); return false; } } m_pConnection->Execute(bstrSQL,NULL,adCmdText); return true; } catch(_com_error e) { char chLog[300] ="\0"; sprintf(chLog,"增删改操作异常[%s]",(char *)e.Description()); MessageLog_void(chLog); return false; } } _RecordsetPtr& CAdoConnectDataBase::GetRecordSet(_bstr_t bstrSQL) // 执行查询 { try { //连接数据库如果Connection对象为空则重新连接数据库 if(m_pConnection==NULL) { if(!InitAdoConnet()) { char ch[100] ="重连数据库失败"; MessageLog_void(ch); m_pRecordset = NULL; return m_pRecordset; } } //创建记录集对象 m_pRecordset.CreateInstance(__uuidof(Recordset)); //设置静态游标方式 m_pRecordset->CursorType=adOpenStatic; m_pRecordset->CursorLocation=adUseClient; m_pRecordset->Open(bstrSQL,m_pConnection.GetInterfacePtr(),adOpenDynamic,adLockBatchOptimistic,adCmdText); } catch (_com_error e) { char chLog[300] ="\0"; sprintf(chLog,"查询异常[%s]",(char *)e.Description()); MessageLog_void(chLog); } return m_pRecordset; } void CAdoConnectDataBase::ExecuteStoredPro_Para(_CommandPtr &m_pCmd,char *StoreName,char *ReturnValue) // 执行存储过程，有一个返回值(带参数) { try { //连接数据库如果Connection对象为空则重新连接数据库 if(m_pConnection==NULL) { if(!InitAdoConnet()) { char ch[100] ="重连数据库失败"; MessageLog_void(ch); return; } } m_pConnection->CursorLocation =adUseClient; // 设置游标方式 m_pCmd->ActiveConnection = m_pConnection; m_pCmd->CommandText = StoreName; //存储过程名称 m_pCmd->CommandType = adCmdStoredProc; m_pCmd->Execute(NULL,NULL,adCmdStoredProc); _variant_t VretVal = m_pCmd->Parameters->GetItem("@ReturnValues_VarC")->GetValue(); // 获取返回值（输出参数） char ch[300] ="\0"; sprintf(ch,"%s",(char*)(_bstr_t)(VretVal)); strcpy(ReturnValue,ch); } catch (_com_error e) { char chLog[300] ="\0"; sprintf(chLog,"执行存储过程异常[%s]",(char *)e.Description()); MessageLog_void(chLog); strcpy(ReturnValue,chLog); } } _RecordsetPtr & CAdoConnectDataBase::ExecuteStoredProcSet(char *StoreName) { try { _CommandPtr m_pCmd; m_pCmd.CreateInstance(__uuidof(Command)); m_pRecordset = NULL; //连接数据库如果Connection对象为空则重新连接数据库 if(m_pConnection==NULL) { if(!InitAdoConnet()) { char ch[100] ="重连数据库失败"; MessageLog_void(ch); return m_pRecordset; } } m_pConnection->CursorLocation =adUseClient; // 设置游标方式 //创建记录集对象 m_pRecordset.CreateInstance(__uuidof(Recordset)); //设置静态游标方式 m_pRecordset->CursorType=adOpenStatic; m_pRecordset->CursorLocation=adUseClient; m_pCmd->ActiveConnection = m_pConnection; m_pCmd->CommandText = StoreName; //存储过程名称 m_pCmd->CommandType = adCmdStoredProc; m_pRecordset = m_pCmd->Execute(NULL,NULL,adCmdStoredProc); } catch (_com_error e) { char chLog[300] ="\0"; sprintf(chLog,"执行存储过程异常[%s]",(char *)e.Description()); MessageLog_void(chLog); } return m_pRecordset; } void CAdoConnectDataBase::ExecuteStoredProc(char *StoreName,char *ReturnValue) // 执行存储过程，有一个返回值(不带参数) { try { //连接数据库如果Connection对象为空则重新连接数据库 if(m_pConnection==NULL) { if(!InitAdoConnet()) { char ch[100] ="重连数据库失败"; MessageLog_void(ch); return; } } _CommandPtr m_pCmd; m_pCmd.CreateInstance(__uuidof(Command)); m_pConnection->CursorLocation =adUseClient; // 设置游标方式 m_pCmd->ActiveConnection = m_pConnection; m_pCmd->CommandText = StoreName; //存储过程名称 m_pCmd->CommandType = adCmdStoredProc; m_pCmd->Execute(NULL,NULL,adCmdStoredProc); _variant_t VretVal = m_pCmd->Parameters->GetItem("@ReturnValues_VarC")->GetValue(); // 获取返回值（输出参数） char ch[300] ="\0"; sprintf(ch,"%s",(char*)(_bstr_t)(VretVal)); strcpy(ReturnValue,ch); } catch (_com_error e) { char chLog[300] ="\0"; sprintf(chLog,"执行存储过程异常[%s]",(char *)e.Description()); MessageLog_void(chLog); strcpy(ReturnValue,chLog); } } _RecordsetPtr & CAdoConnectDataBase::ExecuteStoredProcSet_Para(_CommandPtr &m_pCmd,char *StoreName) // 执行存储过程，返回记录集(带参数) { try { m_pRecordset = NULL; //连接数据库如果Connection对象为空则重新连接数据库 if(m_pConnection==NULL) { if(!InitAdoConnet()) { char ch[100] ="重连数据库失败"; MessageLog_void(ch); return m_pRecordset; } } m_pConnection->CursorLocation =adUseClient; // 设置游标方式 //创建记录集对象 m_pRecordset.CreateInstance(__uuidof(Recordset)); //设置静态游标方式 m_pRecordset->CursorType=adOpenStatic; m_pRecordset->CursorLocation=adUseClient; m_pCmd->ActiveConnection = m_pConnection; m_pCmd->CommandText = StoreName; //存储过程名称 m_pCmd->CommandType = adCmdStoredProc; m_pRecordset = m_pCmd->Execute(NULL,NULL,adCmdStoredProc); } catch (_com_error e) { char chLog[300] ="\0"; sprintf(chLog,"执行存储过程异常[%s]",(char *)e.Description()); MessageLog_void(chLog); } return m_pRecordset; }

评论收藏

内容反馈