使用C++連線sql server 單例模式
阿新 • • 發佈:2019-01-23
直接上程式碼
使用方法:
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()<