天天看點

c ado mysql_C++ ADO操作mysql資料庫

1、安裝mysql5.5 和mysql連接配接驅動mysql-connector-odbc-5.1.12-win32.msi

2、給mysql添加資料源,方法可百度windows下mysql如何在odbc添加資料源

3、如果在添加資料源的時候無法找到MySQL ODBC 5.1 Driver,則需要進行如下步驟:

進入dos指令行,輸入: C:\Users\Administrator>cd\windows\SysWOW64 C:\windows\SysWOW64>odbcad32

詳細步驟位址:http://bbs.csdn.net/topics/391986934

4、下面在vs2013下進行C++ ADO操作mysql資料庫

ADOConn.h

#pragma once

//導入ADO庫,位置在計算機c盤

#import "c:\Program Files\Common Files\System\ado\msado15.dll" no_namespace rename("EOF","adoEOF") rename("BOF","adoBOF") //32位系統加上這個

//#import "c:\Program Files (x86)\Common Files\System\ado\msado15.dll" no_namespace rename("EOF", "adoEOF") rename("BOF","adoBOF") //64位系統加上這個

class CADOConn

{

public:

CADOConn(void);

~CADOConn(void);

public:

//添加一個指向Connection對象的指針:

_ConnectionPtr m_pConnection;

//添加一個指向Recordset對象的指針:

_RecordsetPtr m_pRecordset;

// 定義方法

public:

// 初始化—連接配接資料庫

void OnInitADOConn();

// 執行查詢

_RecordsetPtr& GetRecordSet(_bstr_t bstrSQL);

// 執行SQL語句,Insert Update _variant_t

BOOL ExecuteSQL(_bstr_t bstrSQL);

void ExitConnect();

};

ADOConn.cpp

#include "ADOConn.h"

CADOConn::CADOConn(void)

{

}

CADOConn::~CADOConn(void)

{

}

void CADOConn::OnInitADOConn()

{

// 初始化OLE/COM庫環境

::CoInitialize(NULL);

HRESULT hr;

try

{

// 建立Connection對象,可以通過配置檔案擷取連接配接資訊

hr = m_pConnection.CreateInstance("ADODB.Connection");

if (SUCCEEDED(hr))

{

m_pConnection->ConnectionTimeout = 600;//設定連接配接逾時時間

m_pConnection->CommandTimeout = 120;//設定執行指令逾時時間

m_pConnection->Open("DSN=mysql;Server= localhost;Database=home", "root", "123456", adModeUnknown);

//mysql是設定好的Data Soure Name

//Server= localhost 本機

//Database=home,home是用mysql建立的資料庫

//root和123456分别是登入mysql資料庫的使用者名和密碼

}

}

// 捕捉異常

catch (_com_error e)

{

// 顯示錯誤資訊

//AfxMessageBox(e.Description());//需要建立MFC工程,但我這裡是控制台工程,就把它注釋掉了,下同

}

}

_RecordsetPtr& CADOConn::GetRecordSet(_bstr_t bstrSQL)

{

try

{

// 連接配接資料庫,如果Connection對象為空,則重新連接配接資料庫

if (m_pConnection == NULL)

OnInitADOConn();

// 建立記錄集對象

m_pRecordset.CreateInstance(__uuidof(Recordset));

// 取得表中的記錄

m_pRecordset->Open(bstrSQL, m_pConnection.GetInterfacePtr(), adOpenDynamic, adLockOptimistic, adCmdText);

}

// 捕捉異常

catch (_com_error e)

{

// 顯示錯誤資訊

//AfxMessageBox(e.Description());

}

// 傳回記錄集

return m_pRecordset;

}

BOOL CADOConn::ExecuteSQL(_bstr_t bstrSQL)

{

// _variant_t RecordsAffected;

try

{

// 是否已經連接配接資料庫

if (m_pConnection == NULL)

OnInitADOConn();

// Connection對象的Execute方法:(_bstr_t CommandText,

// VARIANT * RecordsAffected, long Options )

// 其中CommandText是指令字串,通常是SQL指令。

// 參數RecordsAffected是操作完成後所影響的行數,

// 參數Options表示CommandText的類型:adCmdText-文本指令;adCmdTable-表名

// adCmdProc-存儲過程;adCmdUnknown-未知

m_pConnection->Execute(bstrSQL, NULL, adCmdText);

return true;

}

catch (_com_error e)

{

//AfxMessageBox(e.Description());

return false;

}

}

void CADOConn::ExitConnect()

{

// 關閉記錄集和連接配接

if (m_pRecordset != NULL)

{

m_pRecordset->Close();

//m_pRecordset->Release();

}

m_pConnection->Close();

//m_pConnection->Release();

// 釋放環境

::CoUninitialize();

}

main.cpp

#include "ADOConn.h"

int main()

{

CADOConn m_ADO;

m_ADO.OnInitADOConn();

//在進行sql語句之前,先要用mysql建立資料庫home,然後建立一張teacher表,包含id和name兩個字段

//設定SELECT語句

_bstr_t vSQL, vInserSQL;

vSQL = "select name from teacher";

//設定INSERT語句

vInserSQL = "insert into teacher values(2, '張')";

///執行INSERT語句

if (m_ADO.ExecuteSQL(vInserSQL))

{

printf("Insert Data Successful!!!\n");

}

//執行SELETE語句

_RecordsetPtr m_pRecordset;

m_pRecordset = m_ADO.GetRecordSet(vSQL);

LPCTSTR name; //LPCTSTR等價于const TCHAR *

//const TCHAR * name;

//傳回各列的值

while (!m_pRecordset->adoEOF)

{

name = (LPCTSTR)(_bstr_t)m_pRecordset->GetCollect("name");

printf("name : %s\n", name);

m_pRecordset->MoveNext();

}

//斷開與資料庫的連接配接

m_ADO.ExitConnect();

return 0;

}