碼上歡樂
相關內容    簡體    繁體

C++操作oracle數據庫

本文轉載自   查看原文   2016-10-15 14:30   6353    Oracle
數據庫操作方式：可以采用ADO方式，也可以采用oracle本身提供的Proc*C/C++或者是OCCI方式操作數據庫。
 
 連接方式：可以是客戶端連接、也可以是服務器端連接。
 
 數據庫配置：無論是何種連接都需要進行數據庫連接的配置，一般在ORACLE_HOME下面的network/admin/tnsnames.ora文件中進行配置，如果沒有此目錄或者是此文件，需要自己手工添加。內容格式大致如下：

點擊(此處)折疊或打開

  1. BM2D0 =
  2.   (DESCRIPTION =
  3.     (ADDRESS_LIST =
  4.       (ADDRESS = (PROTOCOL = TCP)(HOST = XXX.XXX.XXX.XXX)(PORT = 1521))
  5.     )
  6.     (CONNECT_DATA =
  7.       (SERVICE_NAME = BM2D0)
  8.     )
  9.   )
其中 橄欖色可任意起名，一般在數據庫連接是作為服務和用戶名、密碼一起確定數據庫連接的參數。
    第一個鮮粉色是遠程oracle數據庫所在服務器的IP地址，端口號一般為1521。
    第二個鮮粉色是遠程oracle所在主機的全局數據庫名字，不能隨意更改。
    后兩個搭配起來能夠確定唯一連接對象。
 客戶端連接：
方式一：ADO
main.cpp

點擊(此處)折疊或打開

  1. #include "DBOperation.h"
  2. #include <iostream>
  3. using namespace std;
  5. void main()
  6. {
  7.     CDBOperation dbOper;
  8.     bool bConn = dbOper.ConnToDB("Provider=OraOLEDB.Oracle.1;Persist Security Info=True;Data Source=xxx1", "xxx2", "xxx3");
  9.     if (false == bConn)
  10.     {
  11.         printf("連接數據庫出現錯誤\n");
  12.         system("PAUSE");
  13.         return;
  14.     }
  16.     _RecordsetPtr pRst;
  18.     //執行查詢語句
  19.     //char *sql = "select * from TSTUDENT";
  20.     char sql[255] = {0};
  21.     strcpy(sql, "select * from TSTUDENT");
  22.     pRst = dbOper.ExecuteWithResSQL(sql);
  23.     if (NULL == pRst)
  24.     {
  25.         printf("查詢數據出現錯誤！\n");
  26.         system("PAUSE");
  27.         return;
  28.     }
  29.     if (pRst->adoEOF)
  30.     {
  31.         pRst->Close();
  32.         printf("There is no records in this table\n");
  33.         return;
  34.     }
  35.     _variant_t vSno, vName, v***, vAge, vDno, vDname, vCname;
  36.     while (!pRst->adoEOF)
  37.     {
  38.         //pRst->MoveFirst(); //記錄集指針移動到查詢結果集的前面
  39.         vSno = pRst->GetCollect(_variant_t((long)0));
  40.         vName = pRst->GetCollect(_variant_t("name"));
  41.         v*** = pRst->GetCollect(_variant_t("***"));
  42.         vAge = pRst->GetCollect(_variant_t("age"));
  43.         //vDno = pRst->GetCollect("dno");
  44.         //vDname = pRst->GetCollect("dname");
  45.         //vCname = pRst->GetCollect("cname");
  47.         printf("%s\t%s\t%s\t%d\n", (LPSTR)(LPCSTR)(_bstr_t)vSno, (LPSTR)(LPCSTR)_bstr_t(vName), (LPSTR)(LPCSTR)_bstr_t(v***), vAge.intVal);
  48.         pRst->MoveNext();
  49.     }
  50.     
  51.     //執行插入語句
  52.     //sprintf(sql, "insert into TSTUDENT(sno, name, ***, age) values('%s', '%s', '%s', %d)", "20080016", "全局", "女", 25);
  53.     strcpy(sql, "insert into TSTUDENT(sno, name, ***, age) values('20080001', '全局', '女', 25)");
  54.     pRst = dbOper.ExecuteWithResSQL(sql);
  55.     if (NULL != pRst)
  56.     {
  57.         printf("插入數據成功\n");
  58.     }
  59.     //執行刪除語句
  60.     
  61.     sprintf(sql, "delete from TSTUDENT where sno = '%s'", "20080017");
  62.     pRst = dbOper.ExecuteWithResSQL(sql);
  63.     if (NULL != pRst)
  64.     {
  65.         printf("刪除數據成功\n");
  66.     }
  67.     system("PAUSE");
  68.     //pRst->Close();
  69. }

其中XXX1：是tnsnames.ora中配置的服務名，XXX2是用戶名，XXX3是密碼。
DBOperation.h:
 

點擊(此處)折疊或打開

  1. #pragma once
  2. #import "c:\program files\common files\system\ado\msado15.dll" no_namespace rename("EOF", "adoEOF")
  3. class CDBOperation
  4. {
  5. public:
  6.     //初始化數據庫操作需要的對象
  7.     CDBOperation(void);
  8.     ~CDBOperation(void);
  9.     //連接至數據庫
  10.     bool ConnToDB(char *ConnectionString, char *UserID, char *Password);
  12.     //數據庫操作函數
  13.     //查詢操作 刪除以及添加
  14.     _RecordsetPtr ExecuteWithResSQL(const char *);
  15.     //bool ExecuteNoResSQL(const char *);//delete and add
  17. private:
  18.     void PrintErrorInfo(_com_error &);
  20. private:
  21.     //初始化數據庫連接、命令、記錄集
  22.     _ConnectionPtr CreateConnPtr();
  23.     _CommandPtr CreateCommPtr();
  24.     _RecordsetPtr CreateRecsetPtr();
  26. private:
  27.     //數據庫連接需要的連接、命令操作對象
  28.     _ConnectionPtr m_pConnection;
  29.     _CommandPtr m_pCommand;
  30. };

DBOperation.cpp

點擊(此處)折疊或打開

  1. #include "DBOperation.h"
  3. CDBOperation::CDBOperation(void)
  4. {
  5.     CoInitialize(NULL);
  6.     m_pConnection = CreateConnPtr();
  7.     m_pCommand = CreateCommPtr();
  8. }
  10. CDBOperation::~CDBOperation(void)
  11. {
  12.     //m_pCommand->Close();
  13.     m_pConnection->Close();
  14. }
  16. bool CDBOperation::ConnToDB(char *ConnectionString, char *UserID, char *Password)
  17. {
  18.     if (NULL == m_pConnection)
  19.     {
  20.         printf("Failed to create connection\n");
  21.         return false;
  22.     }
  24.     try
  25.     {
  26.         HRESULT hr = m_pConnection->Open(ConnectionString, UserID, Password, NULL);
  27.         if (TRUE == FAILED(hr))
  28.         {
  29.             return false;
  30.         }
  31.         m_pCommand->ActiveConnection = m_pConnection;
  32.         return true;
  33.     }
  34.     catch(_com_error &e)
  35.     {
  36.         PrintErrorInfo(e);
  37.         return false;
  38.     }
  39. }
  41. _RecordsetPtr CDBOperation::ExecuteWithResSQL(const char *sql)
  42. {
  43.     //已經在連接至數據庫的時候進行判斷了
  44.     //if (NULL == m_pCommand || 0 == m_pConnection->State)
  45.     //{
  46.     //    printf("Failed to create command OR the state of connection is zero\n");
  47.     //    return NULL;
  48.     //}
  50.     //char *query = new char;
  51.     //strcpy(query, sql);
  52.     try
  53.     {
  54.         m_pCommand->CommandText = _bstr_t(sql);
  55.         _RecordsetPtr pRst = m_pCommand->Execute(NULL, NULL, adCmdText);
  56.         return pRst;
  57.         //_variant_t ra;
  58.         //_RecordsetPtr pRst = m_pConnection->Execute((_bstr_t)query, &ra, adCmdText);
  59.     }
  60.     catch(_com_error &e)
  61.     {
  62.         PrintErrorInfo(e);
  63.         return NULL;
  64.     }
  65. }
  67. //bool CDBOperation::ExecuteNoResSQL(const char *sql)
  68. //{
  69. //    //if (NULL == m_pCommand || 0 == m_pConnection->State)
  70. //    //{
  71. //    //    printf();
  72. //    //}
  73. //    try
  74. //    {
  75. //        char *query = NULL;
  76. //        strcpy(query, sql);
  77. //        m_pCommand->CommandText = (_bstr_t)query;
  78. //
  79. //    }
  80. //}
  82. void CDBOperation::PrintErrorInfo(_com_error &e)
  83. {
  84.     printf("Error infomation are as follows\n");
  85.     printf("ErrorNo: %d\nError Message:%s\nError Source:%s\nError Description:%s\n", e.Error(), e.ErrorMessage(), (LPCTSTR)e.Source(), (LPCTSTR)e.Description());
  86. }
  88. _ConnectionPtr CDBOperation::CreateConnPtr()
  89. {
  90.     HRESULT hr;
  91.     _ConnectionPtr connPtr;
  92.     hr = connPtr.CreateInstance(__uuidof(Connection));
  93.     if (FAILED(hr) == TRUE)
  94.     {
  95.         return NULL;
  96.     }
  97.     return connPtr;
  98. }
  100. _CommandPtr CDBOperation::CreateCommPtr()
  101. {
  102.     HRESULT hr;
  103.     _CommandPtr commPtr;
  104.     hr = commPtr.CreateInstance(__uuidof(Command));
  105.     if (FAILED(hr) == TRUE)
  106.     {
  107.         return NULL;
  108.     }
  109.     return commPtr;
  110. }
  112. _RecordsetPtr CDBOperation::CreateRecsetPtr()
  113. {
  114.     HRESULT hr;
  115.     _RecordsetPtr recsetPtr;
  116.     hr = recsetPtr.CreateInstance(__uuidof(    Command));
  117.     if (FAILED(hr) ==TRUE)
  118.     {
  119.         return NULL;
  120.     }
  121.     return recsetPtr;
  122. }

方式二：OCCI
默認oracle安裝了occi庫，但是只是安裝了release版本的資源，因此需要將程序配置為release模式，或者是參看http://www.189works.com/article-42057-1.html為debug模式獲取必備的頭文件以及庫文件，本文采用的是release模式，使用默認安裝的庫文件以及頭文件。
1.修改配置屬性
    改為Rlease模式
2.添加庫文件目錄
    $(ORACLE_HOME)\oci\include
3.添加頭文件目錄
    $(ORACLE_HOME)\oci\lib
4.添加庫文件:oraocci10.lib
應用程序：

點擊(此處)折疊或打開

  1. //代碼的目的就是驗證makefile中oracle的頭文件和lib文件路徑是否正確了
  2. #include <iostream>
  3. #define WIN32COMMON //避免函數重定義錯誤
  4. #include <occi.h>
  5. using namespace std;
  6. using namespace oracle::occi;
  7. int main()
  8. {
  9.   Environment *env=Environment::createEnvironment();
  10.   cout<<"success"<<endl;
  11.   string name = "xxx";
  12.   string pass = "xxx";
  13.   string srvName = "xxx";
  15.   try
  16.   {
  17.     Connection *conn = env->createConnection("bsm3", "bsm3", "BSM3");
  18.     cout<<"conn success"<<endl;
  19.     env->terminateConnection(conn);
  20.   }
  21.   catch(SQLException e)
  22.   {
  23.     cout<<e.what()<<endl;
  24.     system("pause");
  25.     return -1;
  26.   }
  28.   Environment::terminateEnvironment(env);
  29.   cout<<"end!"<<endl;
  30.   system("pause");
  31.   return 0;
  32. }

服務器端：AIX服務器
方式一：OCCI
helloworld.cpp

點擊(此處)折疊或打開

  1. //代碼的目的就是驗證makefile中oracle的頭文件和lib文件路徑是否正確了
  2. #include <iostream>
  3. #include <occi.h>
  4. using namespace std;
  5. using namespace oracle::occi;
  6. main()
  7. {
  8.   Environment *env=Environment::createEnvironment();
  9.   cout<<"success"<<endl;
  10.   string name = "xxx";
  11.   string pass = "xxx";
  12.   string srvName = "xxx";
  14.   try
  15.   {
  16.     Connection *conn = env->createConnection(name, pass, srvName);
  17.     cout<<"conn success"<<endl;
  18.     env->terminateConnection(conn);
  19.   }
  20.   catch(SQLException e)
  21.   {
  22.     cout<<e.what()<<endl;
  23.   }
  25.   Environment::terminateEnvironment(env);
  26.   cout<<"end!"<<endl;
  27. }

Makefile:

點擊(此處)折疊或打開

  1. ###########################################
  2. #Makefile for the OCCI demo programs
  3. ###########################################
  4. INC=-I${ORACLE_HOME}/precomp/public -I${ORACLE_HOME}/rdbms/public
  5. LIB=-L${ORACLE_HOME}/lib -locci #-bnoquiet #-bloadmap
  6. FLAGS=-q64 -g
  7. #為方便取下面三個變量，目標為helloworld，源文件是helloworld.cpp，編譯后文件helloworld.o
  8. PRG=helloworld
  9. SRC=helloworld.cpp
  10. OBJ=helloworld.o
  11. #下面是常規的makefile內容，$@表示依次取目標執行，這里只有helloworld一個目標。實際等價於
  12. #CC -o helloworld helloworld.o 不過加入了include和lib文件。而helloworld.o需要后續完成
  13. $(PRG):$(OBJ)
  14.         @echo "begin link......"
  15.         ${CC} ${FLAGS} ${INC} ${LIB} -o $@ $(OBJ)
  16. #helloworld目標依賴helloworld.o生成，所以該句就是編譯.c生成.o文件。只不過加入了include和lib文件
  17. $(OBJ):$(SRC)
  18.         @echo "begin compile......"
  19.         ${CC} ${FLAGS} ${INC} ${LIB} -c $(SRC)
  20. #后面的內容不是make的內容了，而是make clean內容。比如想重新make之前，清除.o等文件，執行make clean語句
  21. #.PRNOY語句表明 clean關鍵詞是個偽目標。make不自動執行。
  22. .PRONY:clean
  23. clean:
  24.         @echo "Removing linked and compiled files....."
  25.         rm -f $(OBJ) $(PRG)
關於客戶端以及服務器端采用PROC*C/C++連接方式待續。。。。


免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。



猜您在找 [C++] 通過OCCI操作Oracle數據庫詳解 C++ 連接oracle數據庫 C++操作MySQL數據庫 C++操作mysql數據庫 C++操作MySQL數據庫 C++ 通過ADO連接Oracle數據庫 Oracle數據庫操作 redis數據庫操作的C++簡單封裝 c++操作數據庫 C++ 的數據庫操作類ListControl顯示
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM