vc6.0 通过ado连接mysql 含odbc工具

// mysql_test.cpp : Defines the entry point for the console application. // #include "stdafx.h" #include "mysql_test.h" #ifdef _DEBUG #define new DEBUG_NEW #undef THIS_FILE static char THIS_FILE[] = __FILE__; #endif ///////////////////////////////////////////////////////////////////////////// // The one and only application object CWinApp theApp; _ConnectionPtr m_pConnection; _RecordsetPtr m_pRecordset; using namespace std; BOOL Connect_MySQL_DataBase(CString& strConn); void Test(); int _tmain(int argc, TCHAR* argv[], TCHAR* envp[]) { CoInitialize(NULL); int nRetCode = 0; if (!AfxWinInit(::GetModuleHandle(NULL), NULL, ::GetCommandLine(), 0)) { cerr << _T("Fatal Error: MFC initialization failed") << endl; nRetCode = 1; } else { CString strHello; strHello.LoadString(IDS_HELLO); cout << (LPCTSTR)strHello << endl; CString strConn( //采用myodbc 连接mysql "Provider=MSDASQL.1;Password=zcc123;Persist Security Info=True;\ User ID=root;Data Source=test"); //也可以采用myole连接mysql，其测试方法下载myole后，建立一个udl文件自行连接到 //mysql中，test后生成字符串后替换myodbc的字符串才行(通过文本文件打开udl文件拷贝即可)。 if (Connect_MySQL_DataBase(strConn)) { cout<<"test connect ok"<<endl; Test(); } else cout<<"test connect mysql failure" << endl; } getchar(); return nRetCode; } //测试打开数据集合 void Test() { _bstr_t strSql("select * from t_mov1"); HRESULT hr = m_pRecordset.CreateInstance(__uuidof(Recordset)); m_pRecordset->Open(strSql, _variant_t((IDispatch*)m_pConnection,true), adOpenDynamic, adLockOptimistic, adCmdText); while(!m_pRecordset->adoEOF) { variant_t ret = m_pRecordset->GetCollect("id"); int i = ret.lVal; cout<<i <<endl; m_pRecordset->MoveNext(); } } /* 连接mysql数据库 */ BOOL Connect_MySQL_DataBase(CString& strConn) { try { HRESULT hr = m_pConnection.CreateInstance(_T("ADODB.Connection")); if (SUCCEEDED(hr)) { m_pConnection->CursorLocation = adUseClient; m_pConnection->Open((_bstr_t)strConn, "", "", adConnectUnspecified); } else return FALSE; } catch(_com_error &e) { //MessageBox(e.ErrorMessage()); return FALSE; } return TRUE; }