//////////////////////////////////////////////////////////////////////
// 构造函数
/**///////////////////////////////////////////////////////////////////////
//默认的构造函数
#include "stdafx.h"
#include "ADODB.h"
#include <iostream>
#include <fstream>
using namespace std;
ADOLib::ADOLib()
{
//初始化
m_nResultRow = 0;
m_nResultCol=0;
m_pConnection = NULL;
//创建对象
m_pRecordset.CreateInstance(_uuidof(Recordset));
m_pCommand.CreateInstance(_uuidof(Command));
}
//传入参数的构造函数
ADOLib::ADOLib(_ConnectionPtr pConnection)
{
m_pConnection = pConnection;
m_nResultRow = 0;
m_nResultCol=0;
//创建对象
m_pRecordset.CreateInstance(_uuidof(Recordset));
m_pCommand.CreateInstance(_uuidof(Command));
}
/**///////////////////////////////////////////////////////////////////////
// 析构函数
/**///////////////////////////////////////////////////////////////////////
ADOLib::~ADOLib()
{
if (m_pRecordset)
{
if(m_pRecordset->State!=adStateClosed)
{
m_pRecordset->Close();
}
m_pRecordset = NULL;
}
if (m_pCommand)
{
if(m_pCommand->State!=adStateClosed)
{
m_pCommand->Release();
}
m_pCommand = NULL;
}
if (m_pConnection)
{
if(m_pConnection->State!=adStateClosed)
{
m_pConnection->Close();
}
m_pConnection = NULL;
}
}
/**//////////////////////////////////////////////////////////////////////
///简单操作函数
////////////////////////////////////////////////////////////////////
//得到操作结果的行数
long ADOLib::GetResultRow()
{
return this->m_nResultRow;
}
//得到操作结果的列数
long ADOLib::GetResultCol()
{
return this->m_nResultCol;
}
//得到操作结果
_RecordsetPtr ADOLib::GetResult()
{
return this->m_pRecordset;
}
/**////////////////////////////////////////////////////////////////////////
///连接操作
///////////////////////////////////////////////////////////////////////
//连接到数据库
//1.连接字符串可以自己构造,也可以从文件中读出
BOOL ADOLib::Connect(CString strUser,CString strPassword,CString strFileName,int nOptions,CString strConStr)
{
try{
m_pConnection.CreateInstance(__uuidof(Connection));
HRESULT hr;
//如果用文件方式配置数据源,进行配置
if(strFileName.Compare("")!=0)
{
CString con = "File Name="+strFileName;
m_pConnection->ConnectionString =(_bstr_t)con;
hr=m_pConnection->Open("",_bstr_t(strUser),_bstr_t(strPassword),nOptions);
}
else
{
//自己配置连接字符串
m_pConnection->ConnectionString = (_bstr_t)strConStr;
hr=m_pConnection->Open("",_bstr_t(strUser),_bstr_t(strPassword),nOptions);
}
//进行连接
//连接失败
if(FAILED(hr))
{
AfxMessageBox("连接失败!");
return FALSE;
}
}
catch(_com_error&e)
{
AfxMessageBox(e.Description()+"B");
return FALSE;
}
return TRUE;
}
//断开连接
void ADOLib::DisConnect()
{
if (m_pConnection)
{
if(m_pConnection->State!=adStateClosed)
m_pConnection->Close();
}
}
/**////////////////////////////////////////////////////////////////////////
///更新操作
///////////////////////////////////////////////////////////////////////
BOOL ADOLib::Execute(CString strSql)
{
try
{
_variant_t vNULL;
vNULL.vt = VT_ERROR;
/**////定义为无参数
vNULL.scode = DISP_E_PARAMNOTFOUND;
/**////非常关键的一句，将建立的连接赋值给它
m_pCommand->ActiveConnection = m_pConnection;
/**////命令字串
m_pCommand->CommandText = (_bstr_t)strSql;
/**////执行命令，取得记录集
m_pRecordset = m_pCommand->Execute(&vNULL,&vNULL,adCmdText);
//确实，vNULL中的intVal是执行操作所影响的行数
m_nResultRow = 0;
m_nResultRow = vNULL.intVal;
}
catch(_com_error &e)
{
m_nResultRow = 0;
return FALSE;
}
return TRUE;
}
/**////////////////////////////////////////////////////////////////////////
///查询操作
///////////////////////////////////////////////////////////////////////
BOOL ADOLib::Select(CString strSql)
{
try
{
m_nResultCol=0;
m_nResultRow=0;
m_pRecordset->CursorLocation=adUseClient; //设置游标位置,设置为客户端形式,否则GetRecordCount()返回值不对
m_pRecordset->Open(_variant_t(strSql),_variant_t((IDispatch *)m_pConnection,true),adOpenDynamic,adLockOptimistic,adCmdText);
m_nResultCol = m_pRecordset->Fields->GetCount();//得到查询结果的列数
m_nResultRow = m_pRecordset->GetRecordCount(); //得到查询结果的行数
}
catch(_com_error&e)
{
AfxMessageBox(e.Description()+"D");
return FALSE;
}
return TRUE;
}
//查询语句，负责对仅仅查询一个字段的情况进行处理
//结果存放在CStringArray类型的变量pResult中
BOOL ADOLib::Select(CString strSql,CStringArray& Result)
{
if(Select(strSql)!=0)
{
Result.RemoveAll();
for(int i=0;i<m_nResultRow;i++)
{
_variant_t value;
value=m_pRecordset->Fields->Item[(long)0]->Value;
if(value.vt==3||value.vt==14)
{
CString strTrans;
strTrans.Format("%ld",value.intVal);
Result.Add(strTrans);
}
else
{
CString strTrans(value.bstrVal);
Result.Add(strTrans);//
}
m_pRecordset->MoveNext();
}
m_pRecordset->Close();
return TRUE;
}
else
{
m_pRecordset->Close();
return FALSE;
}
}
BOOL ADOLib::SelectMulitCol(CString strSql,CStringArray& Result)
{
if(Select(strSql)!=0)
{
Result.RemoveAll();
_variant_t value;
for(int i=0;i<m_nResultRow;i++)
{
for(int j=0;j<m_nResultCol;j++)
{
value=m_pRecordset->Fields->Item[(long)(/**//*i*m_nResultCol+*/j)]->Value;
if(value.vt==3)
{
CString strTrans;
strTrans.Format("%ld",value.intVal);
Result.Add(strTrans);
}
if(value.vt==14)
{
CString strTrans;
strTrans.Format("%ld",value.ullVal);
Result.Add(strTrans);
}
else
if(value.vt==7)
{
COleDateTime time = value.date;
CString strTemp;
strTemp.Format("%d-%d-%d %s",time.GetYear(),time.GetMonth(),time.GetDay(),time.Format("%H:%M:%S"));
Result.Add(strTemp);
}
else
{
CString str;
str=value.bstrVal;
Result.Add(str);//
}
}
m_pRecordset->MoveNext();
}
m_pRecordset->Close();
return TRUE;
}
else
{
m_pRecordset->Close();
return FALSE;
}
}
//保存查询结果到文件
BOOL ADOLib::SelectToFile(CString strSql,CString filename)
{
ofstream sfile(filename,ios::app);
CString aa;
//sfile.open(filename,ios::app);
if(sfile.is_open()==false)
{
//MessageBox("打开文件失败");
return FALSE;
}
if(Select(strSql)!=0)
{
//Result.RemoveAll();
_variant_t value;
for(int i=0;i<m_nResultRow;i++)
{
for(int j=0;j<m_nResultCol-1;j++)
{
value=m_pRecordset->Fields->Item[(long)(/**//*i*m_nResultCol+*/j)]->Value;
if(value.vt==3)
{
CString strTrans;
strTrans.Format("%ld",value.intVal);
//Result.Add(strTrans);
sfile<<value.intVal<<",";
}
if(value.vt==14)
sfile<<value.ullVal<<","
