com组件的数据库连接文件

      //////////////////////////////////////////////////////////////////////
// 构造函数
/**///////////////////////////////////////////////////////////////////////
//默认的构造函数
#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<<","