登 录
最近做了一个数据诊断的项目，里面自己写了一个数据库的操作类，包含：连接数据库、读数据表、执行SQL操作，释放数据库等组成，希望对大家有用，由于水平有限，若有错误或者代码不足地方欢迎指正，谢谢。
ADOOperate.H
//////////////////////////////////////////////////////////////////////<br /> // 类功能：用于数据库的操作 主要实现 连接数据库 读数据表 检查数据表 执行SQL语句<br /> //<br /> // 孙高朝 2010.03.25<br /> //////////////////////////////////////////////////////////////////////<br /> #if !defined(AFX_ADOOPERATE_H__EB4AC016_15D4_46E9_A754_E1C1A036DAAE__INCLUDED_)<br /> #define AFX_ADOOPERATE_H__EB4AC016_15D4_46E9_A754_E1C1A036DAAE__INCLUDED_<br /> #if _MSC_VER > 1000<br /> #pragma once<br /> #endif // _MSC_VER > 1000<br /> #include "stdafx.h"<br /> class CADOOperate<br /> {<br /> public:<br /> CString m_DataSource; // 数据源<br /> CString m_PassWord; // 密码<br /> CString m_UserName; // 数据库名<br /> _ConnectionPtr m_pConn; // ADO连接<br /> CString strTableName; // 表名 外边传入<br /> _RecordsetPtr m_pRst; // 记录集<br /> public:<br /> BOOL funCheckTable(CString strName,CString strDBType);<br /> BOOL ExecuteSQL(CString strSQL,LPCSTR strDBType = ORACLE);<br /> _RecordsetPtr& ReadTable(LPCSTR strSQL1 = NULL,LPCSTR strDBType = ORACLE); // 读表 返回记录集<br /> BOOL OpenDataBase(CString lpDBType); // 连接数据库<br /> void ExitADO();<br /> CADOOperate();<br /> virtual ~CADOOperate();<br /> };<br /> #endif // !defined(AFX_ADOOPERATE_H__EB4AC016_15D4_46E9_A754_E1C1A036DAAE__INCLUDED_)<br />
ADOOperate.C
// ADOOperate.cpp: implementation of the CADOOperate class.<br /> //<br /> //////////////////////////////////////////////////////////////////////<br /> #include "stdafx.h"<br /> #include "ADOOperate.h"<br /> #include "h_Const.h"<br /> #include "ShareFun.h"<br /> #include "FileLog.h"<br /> //////////////////////////////////////////////////////////////////////<br /> // Construction/Destruction<br /> //////////////////////////////////////////////////////////////////////<br /> CADOOperate::CADOOperate()<br /> {<br /> strTableName = " "; // 初始化表名<br /> m_DataSource = " "; // 数据源<br /> m_PassWord = " "; // 密码<br /> m_UserName = " "; // 数据库名<br /> }<br /> CADOOperate::~CADOOperate()<br /> {<br /> }<br /> //*********************************************<br /> //<br /> // 函数功能: 连接数据库<br /> // 参数： CString 字符串<br /> // 返回值： TRUE: 连接成功 FALSE：连接失败<br /> // 作者： 孙高朝 2010.03.24<br /> //<br /> //*********************************************<br /> BOOL CADOOperate::OpenDataBase(CString strDBType)<br /> {<br /> CString strSQL;<br /> CShareFun myFun;<br /> // 选择数据库连接语句<br /> if (strDBType == ACCESS) // ACCESS<br /> {<br /> CString strPath;<br /> strPath = myFun.funGetPath();<br /> strSQL = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + strPath + "MobileDB.mdb;Persist Security Info=False";<br /> }<br /> else if (strDBType == SQLSERVER) // SQL SERVER<br /> {<br /> strSQL = "Provider=SQLOLEDB.1;Integrated Security=SSPI;Persist Security Info=False;Initial Catalog=BookManage" ;<br /> }<br /> else if (strDBType == ORACLE) // 默认为ORACLE<br /> {<br /> // 读取ADO.INI的文件<br /> m_DataSource = myFun.funReadini(DATASOURCE);<br /> m_UserName = myFun.funReadini(USERNAME);<br /> m_PassWord = myFun.funReadini(PASSWORD);<br /> strSQL = "Provider=MSDAORA.1;Password=" + (CString)m_PassWord + ";User ID=" + (CString)m_UserName<br /> + ";Data Source=" + (CString)m_DataSource + ";Persist Security Info=True"; // 数据库连接语句<br /> }</p> <p> CoInitialize(NULL); // 初始化COM库</p> <p> try<br /> {<br /> m_pConn.CreateInstance(__uuidof(Connection)); // 连接指针<br /> m_pConn->ConnectionString = (_bstr_t)strSQL;<br /> m_pConn->Open("","","",NULL);<br /> }<br /> catch (_com_error) // 连接出错处理<br /> {<br /> MessageBox(0,strDBType + "连接数据库错误","提示",MB_OK|MB_ICONINFORMATION);<br /> return false;<br /> }<br /> catch (...)<br /> {<br /> AfxMessageBox("SYS Error");<br /> return false;<br /> }<br /> return true;<br /> }<br /> //*********************************************<br /> //<br /> // 函数功能: 读取数据库表<br /> // 参数： CString 字符串<br /> // 返回值： 返回记录集数<br /> // 作者： 孙高朝 2010.03.24<br /> //<br /> //*********************************************<br /> _RecordsetPtr& CADOOperate::ReadTable(LPCSTR strSQL1,LPCSTR strDBType)<br /> {<br /> CString strSQL;<br /> CString strSQL2;<br /> CFileLog myFile;<br /> strSQL2 = strSQL1;<br /> strSQL = "SELECT * FROM " + strTableName ;</p> <p> if(strSQL2.GetLength() > 0)<br /> {<br /> strSQL = "SELECT * FROM " + strTableName + " WHERE " + strSQL1;<br /> }</p> <p> try<br /> {<br /> if(m_pConn==NULL) // 判断连接是否断开<br /> OpenDataBase(strDBType); // 重新连接<br /> m_pRst.CreateInstance(__uuidof(Recordset)); // 数据集指针<br /> m_pRst->raw_Close(); // 关闭记录集<br /> m_pRst->Open((_bstr_t)strSQL,m_pConn.GetInterfacePtr(),adOpenDynamic,adLockOptimistic,adCmdText);<br /> }<br /> catch(_com_error e)<br /> {<br /> myFile.WriteToLog(ErrorFileName,"CADOOperate ReadTable()",(LPCSTR)e.Description());<br /> }<br /> return m_pRst; // 返回记录集<br /> }<br /> //*********************************************<br /> //<br /> // 函数功能: ADO释放函数<br /> // 参数：<br /> // 返回值：<br /> // 作者： 孙高朝 2010.03.29<br /> //<br /> //*********************************************<br /> void CADOOperate::ExitADO()<br /> {<br /> if(m_pRst->State)<br /> {<br /> m_pRst->Close();<br /> }<br /> m_pRst = NULL;<br /> if (m_pConn->State)<br /> {<br /> m_pConn->Close();<br /> }<br /> m_pConn = NULL;<br /> // 错误说明：智能指针_RecordsetPtr和_ConnectionPtr在超出作用域是会自动释放的，<br /> // 也就是说指针在CreateInstance()的时候分配内存，在作用域外释放，<br /> // 所以自己调用Release()并不是必需的，不过调用有可能出错，而设为NULL是完全可以不用的。<br /> // m_pConn->Release();<br /> CoUninitialize(); // 卸载COM库<br /> }<br /> //*********************************************<br /> //<br /> // 函数功能: 执行数据库操作<br /> // 参数： LPCSTR 字符串指针<br /> // 返回值： 返回记录集数<br /> // 作者： 孙高朝 2010.03.29<br /> //<br /> //*********************************************<br /> BOOL CADOOperate::ExecuteSQL(CString strSQL,LPCSTR strDBType)<br /> {<br /> try<br /> {<br /> if(m_pConn==NULL) // 判断连接是否断开<br /> OpenDataBase(strDBType); // 重新连接</p> <p> m_pRst.CreateInstance(__uuidof(Recordset)); // 数据集指针<br /> m_pRst->raw_Close(); // 关闭记录集<br /> m_pRst->Open((_bstr_t)strSQL,m_pConn.GetInterfacePtr(),adOpenDynamic,adLockOptimistic,adCmdText);<br /> }<br /> catch(_com_error e)<br /> {<br /> e.Description();<br /> return FALSE;<br /> }</p> <p> return TRUE; // 返回记录集<br /> }<br /> //*********************************************<br /> //<br /> // 函数功能: 检查数据库是否存在该表<br /> // 参数： LPCSTR 字符串指针<br /> // 返回值： 返回TRUE OR FALSE<br /> // 作者： 孙高朝 2010.03.29<br /> //<br /> //*********************************************<br /> BOOL CADOOperate::funCheckTable(CString strName,CString strDBType)<br /> {<br /> CString strSQL;<br /> // 选择数据库连接语句<br /> if (strDBType == ACCESS) // ACCESS<br /> {<br /> strSQL = "SELECT * FROM MSysObjects WHERE Name = '" + strName + "'"; // 表名强制为大写, 判断是否存在<br /> }<br /> else if (strDBType == SQLSERVER) // SQL SERVER<br /> {<br /> strSQL = " " ;<br /> }<br /> else if (strDBType == ORACLE) // ORACLE<br /> {<br /> strSQL = "SELECT Table_Name FROM Tabs WHERE Table_Name='" + strName + "'"; // 表名强制为大写, 判断是否存在<br /> }<br /> try<br /> {<br /> if(m_pConn==NULL) // 判断连接是否断开<br /> OpenDataBase(ORACLE); // 重新连接</p> <p> m_pRst.CreateInstance(__uuidof(Recordset)); // 数据集指针<br /> m_pRst->raw_Close(); // 关闭记录集<br /> m_pRst->Open((_bstr_t)strSQL,m_pConn.GetInterfacePtr(),adOpenDynamic,adLockOptimistic,adCmdText);<br /> }<br /> catch(_com_error e)<br /> {<br /> e.Description();<br /> return FALSE;<br /> }<br /> // 存在表否<br /> if (m_pRst->adoEOF)<br /> {<br /> return FALSE;<br /> }<br /> return TRUE;<br /> }<br />
抱歉!评论已关闭.