1. 程式人生 > >使用C++連線sql server 單例模式

使用C++連線sql server 單例模式

直接上程式碼

使用方法:

CADO& m_sqlAdo=CADO::getCADOInstance();
    if (!m_sqlAdo.IsOpen())
    {   
        bool success = m_sqlAdo.InitializeAdo("139.199.xxx.xxx,1433", "sa", "xxxx", "Persist Security Info=False;Initial Catalog=xxx");//Initial Catalog為資料庫名,更多引數百度
        if (!success)
            return
; } m_sqlAdo.ExecuteSql("insert into dbo.test values ('c++','c++')"); _RecordsetPtr result = m_sqlAdo.ExecuteSql("SELECT * FROM dbo.test3"); while (!result->rsEOF) { _variant_t var = result->GetCollect("host");//獲取列中指定欄位的內容 if (var.vt != VT_NULL) std::cout
<< (LPCSTR)_bstr_t(var) << "\t"; result->MoveNext(); } result->Close(); //更多用法請百度_RecordsetPtr

標頭檔案

#pragma once

#ifndef IMPORT_MSADO15_DLL
#define IMPORT_MSADO15_DLL
#if defined(_WIN64) //新增對64位環境的支援 未經過測試
#import "C:\Program Files (x86)\Common Files\System\ado\msado15.dll" no_namespace rename("EOF", "rsEOF")
#else #import "C:\Program Files \Common Files\System\ado\msado15.dll" no_namespace rename("EOF","rsEOF") #endif #endif class CADO { public: static CADO &getCADOInstance() { //靜態變數初始化一次的特點 static CADO mCDevice; return mCDevice; } public: bool InitializeAdo(const char* host,const char* id,const char* password,const char* option); _RecordsetPtr ExecuteSql(const char* strSql); long GetTableCount(const char* SQL); inline bool IsOpen(){return b_Initialize;}; private: CADO(); CADO(const CADO&) {}; CADO& operator=(const CADO&) {}; virtual ~CADO(); _ConnectionPtr m_pCon; //ADO連線物件 _CommandPtr m_pCommand; //命令執行連線物件 bool b_Initialize; };

類檔案

#include "stdafx.h"
#include "ADO.h"
#include <iostream>
#include <assert.h>
CADO::CADO()
{
    b_Initialize=false;
};

CADO::~CADO()
{
    if(m_pCon->State)
        m_pCon->Close();      //關閉資料連線
    m_pCon = nullptr;
#if !defined(_AFXDLL)
    CoUninitialize();
#endif
}

bool    CADO::InitializeAdo(const char* host,const char* id,const char* password,const char* option)
{
    if(b_Initialize)
        return false;
#if defined(_AFXDLL)
    AfxOleInit();
#else 
    CoInitialize(NULL);
#endif
    try
    {           
        std::string strAdoConn; 
        strAdoConn="Provider=SQLOLEDB.1;Password=";
        strAdoConn.append(password);
        strAdoConn+=";User ID=";
        strAdoConn.append(id);
        strAdoConn+=";Data Source=";
        strAdoConn.append(host);
        strAdoConn+=";";
        strAdoConn.append(option);
        HRESULT ok=m_pCon.CreateInstance(_uuidof(Connection)); //SQLOLEDB.1
        m_pCon->ConnectionString = (_bstr_t)strAdoConn.c_str();
        m_pCon->ConnectionTimeout = 5;
        m_pCon->Open("","","",NULL);        
        b_Initialize=true;
    }
    catch(_com_error &ex)
    {
        std::cout<<ex.Description()<<std::endl;
        b_Initialize=false;
    }
    catch(...)
    {   
        std::cout<<"init failed  unknow error";
        b_Initialize=false;
    }
    return b_Initialize;
}

_RecordsetPtr   CADO::ExecuteSql(const char* strSql)
{
    assert(b_Initialize);
    _RecordsetPtr result;
    try {
        result=m_pCon->Execute(strSql, NULL, adCmdText);
    }
    catch (_com_error &ex)
    {
        std::cout << ex.Description()<<std::endl;
        return nullptr;
    }
    return  result;
}

long CADO::GetTableCount(const char* tableName)
{
    _bstr_t vSQL("select count(*) from");
    vSQL += tableName;
    _RecordsetPtr  m_ReWell_d;
    m_ReWell_d=ExecuteSql(vSQL);
    if (!m_ReWell_d)
        return 0;
    _variant_t count = m_ReWell_d->GetCollect((_variant_t)(long)0L);
    m_ReWell_d->Close();
    return count;
}

如果資料庫出現異常 使用catch (_com_error &ex){std::cout << ex.Description()<