該樓層疑似違規已被系統折疊?隱藏此樓查看此樓

源文件：

#pragma once

#ifndef __ADOConn_cpp__

#define __AODCOnn_cpp__

#include "ADOConn.h"

#include

using namespace std;

ADOConn::ADOConn()

{

}

ADOConn::~ADOConn()

{

}

// 初始化—連接數據庫

void ADOConn::createLine()

{

// 初始化OLE/COM庫環境

::CoInitialize(NULL);

try

{

// 創建Connection對象

m_pConnection.CreateInstance("ADODB.Connection");

// 設置連接字符串，必須是BSTR型或者_bstr_t類型

_bstr_t strConnect = "Provider=SQL Server Native Client 11.0; Server=127.0.0.1;Database=stock2; uid=zzh; pwd=liuyi7181314;";

m_pConnection->Open(strConnect,"","",adModeUnknown);

}

// 捕捉異常

catch(_com_error e)

{

cout << "數據庫連接失敗！";

cout << e.Description();

//printf("%s\n",e.ErrorMessage());

}

}

// 執行查詢

_RecordsetPtr& ADOConn::GetRecordSet(char* SQL)

{

_bstr_t bstrSQL(SQL);

try

{

// 連接數據庫，如果Connection對象為空，則重新連接數據庫

if(m_pConnection==NULL)

createLine();

// 創建記錄集對象

m_pRecordset.CreateInstance(__uuidof(Recordset));

// 取得表中的記錄

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

}

// 捕捉異常

catch(_com_error e)

{

// 顯示錯誤信息

printf("查詢失敗：");

cout << e.Description();

cout << ":" << SQL <

}

// 返回記錄集

return m_pRecordset;

}

// 執行SQL語句，Insert Update _variant_t

BOOL ADOConn::ExecuteSQL(char* SQL)

{

_bstr_t bstrSQL(SQL);

// _variant_t RecordsAffected;

try

{

// 是否已經連接數據庫

if(m_pConnection == NULL)

createLine();

// 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)

{

printf("執行失敗：");

cout << e.Description();

cout << ":" << SQL <

return false;

}

}

void ADOConn::Close()

{

// 關閉記錄集和連接

if (m_pRecordset != NULL)

m_pRecordset->Close();

m_pConnection->Close();

// 釋放環境

::CoUninitialize();

}

//格式轉換

char* ADOConn::VariantToChar(_variant_t& var)

{

char strValue[200];

_bstr_t bst_t;

switch(var.vt)

{

case VT_EMPTY:

strcpy_s(strValue,"\0");

break;

case 3:

case VT_INT:

sprintf_s(strValue,"%d",var.intVal);

break;

case VT_R4:

sprintf_s(strValue,"%f",var.fltVal);

break;

case VT_R8:

sprintf_s(strValue,"%lf",var.dblVal);

case VT_BSTR:

bst_t = var;

sprintf_s(strValue,"%s",(const char* )bst_t);

break;

case VT_BOOL:

sprintf_s(strValue,"%d",var.boolVal);

break;

default:

strcpy_s(strValue,"\0");

break;

}

return strValue;

}

#endif

總結

以上是生活随笔為你收集整理的vs2008创建mysql数据库_求教VS2008 C++连接MySQL数据库的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。