C++操作oracle数据库

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了C++操作oracle数据库，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含9712字，纯文字阅读大概需要14分钟。

内容图文

点击(此处)折叠或打开

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

点击(此处)折叠或打开

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. }

点击(此处)折叠或打开

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. };

点击(此处)折叠或打开

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. }

点击(此处)折叠或打开

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. }

点击(此处)折叠或打开

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. }

点击(此处)折叠或打开

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)

C++操作oracle数据库

标签：

本文系统来源：http://www.cnblogs.com/aabbcc/p/5964366.html

内容总结

以上是互联网集市为您收集整理的C++操作oracle数据库全部内容，希望文章能够帮你解决C++操作oracle数据库所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端