C++操作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;
  4. void main()
  5. {
  6. CDBOperation dbOper;
  7. bool bConn = dbOper.ConnToDB("Provider=OraOLEDB.Oracle.1;Persist Security Info=True;Data Source=xxx1", "xxx2", "xxx3");
  8. if (false == bConn)
  9. {
  10. printf("连接数据库出现错误\n");
  11. system("PAUSE");
  12. return;
  13. }
  14. _RecordsetPtr pRst;
  15. //执行查询语句
  16. //char *sql = "select * from TSTUDENT";
  17. char sql[255] = {0};
  18. strcpy(sql, "select * from TSTUDENT");
  19. pRst = dbOper.ExecuteWithResSQL(sql);
  20. if (NULL == pRst)
  21. {
  22. printf("查询数据出现错误！\n");
  23. system("PAUSE");
  24. return;
  25. }
  26. if (pRst->adoEOF)
  27. {
  28. pRst->Close();
  29. printf("There is no records in this table\n");
  30. return;
  31. }
  32. _variant_t vSno, vName, v***, vAge, vDno, vDname, vCname;
  33. while (!pRst->adoEOF)
  34. {
  35. //pRst->MoveFirst(); //记录集指针移动到查询结果集的前面
  36. vSno = pRst->GetCollect(_variant_t((long)0));
  37. vName = pRst->GetCollect(_variant_t("name"));
  38. v*** = pRst->GetCollect(_variant_t("***"));
  39. vAge = pRst->GetCollect(_variant_t("age"));
  40. //vDno = pRst->GetCollect("dno");
  41. //vDname = pRst->GetCollect("dname");
  42. //vCname = pRst->GetCollect("cname");
  43. 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);
  44. pRst->MoveNext();
  45. }
  46. //执行插入语句
  47. //sprintf(sql, "insert into TSTUDENT(sno, name, ***, age) values(‘%s‘, ‘%s‘, ‘%s‘, %d)", "20080016", "全局", "女", 25);
  48. strcpy(sql, "insert into TSTUDENT(sno, name, ***, age) values(‘20080001‘, ‘全局‘, ‘女‘, 25)");
  49. pRst = dbOper.ExecuteWithResSQL(sql);
  50. if (NULL != pRst)
  51. {
  52. printf("插入数据成功\n");
  53. }
  54. //执行删除语句
  55. sprintf(sql, "delete from TSTUDENT where sno = ‘%s‘", "20080017");
  56. pRst = dbOper.ExecuteWithResSQL(sql);
  57. if (NULL != pRst)
  58. {
  59. printf("删除数据成功\n");
  60. }
  61. system("PAUSE");
  62. //pRst->Close();
  63. }

其中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);
  11. //数据库操作函数
  12. //查询操作 删除以及添加
  13. _RecordsetPtr ExecuteWithResSQL(const char *);
  14. //bool ExecuteNoResSQL(const char *);//delete and add
  15. private:
  16. void PrintErrorInfo(_com_error &);
  17. private:
  18. //初始化数据库连接、命令、记录集
  19. _ConnectionPtr CreateConnPtr();
  20. _CommandPtr CreateCommPtr();
  21. _RecordsetPtr CreateRecsetPtr();
  22. private:
  23. //数据库连接需要的连接、命令操作对象
  24. _ConnectionPtr m_pConnection;
  25. _CommandPtr m_pCommand;
  26. };

DBOperation.cpp

点击(此处)折叠或打开

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

方式二：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";
  14. try
  15. {
  16. Connection *conn = env->createConnection("bsm3", "bsm3", "BSM3");
  17. cout<<"conn success"<<endl;
  18. env->terminateConnection(conn);
  19. }
  20. catch(SQLException e)
  21. {
  22. cout<<e.what()<<endl;
  23. system("pause");
  24. return -1;
  25. }
  26. Environment::terminateEnvironment(env);
  27. cout<<"end!"<<endl;
  28. system("pause");
  29. return 0;
  30. }

服务器端：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";
  13. try
  14. {
  15. Connection *conn = env->createConnection(name, pass, srvName);
  16. cout<<"conn success"<<endl;
  17. env->terminateConnection(conn);
  18. }
  19. catch(SQLException e)
  20. {
  21. cout<<e.what()<<endl;
  22. }
  23. Environment::terminateEnvironment(env);
  24. cout<<"end!"<<endl;
  25. }

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内容，[email protected]表示依次取目标执行，这里只有helloworld一个目标。实际等价于
  12. #CC -o helloworld helloworld.o 不过加入了include和lib文件。而helloworld.o需要后续完成
  13. $(PRG):$(OBJ)
  14. @echo "begin link......"
  15. ${CC} ${FLAGS} ${INC} ${LIB} -o [email protected] $(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++连接方式待续。。。。

时间： 2024-08-10 21:30:28

C++操作oracle数据库的相关文章

Java操作Oracle数据库以及调用存储过程

操作Oracle数据库 publicclass DBConnection {     //jdbc:oracle:thin:@localhost:1521:orcl     publicstaticfinal String url = "jdbc:oracle:thin:@localhost:1521:ORCL";     publicstatic Connection conn ;         static{         //获取数据库驱动         try {    

JFinal框架操作oracle数据库

JFinal框架操作oracle数据库,需要在configPlugin()方法中配置链接oracle数据库的相关配置 配置JFinal数据库操作插件,configPlugin方法 这里我加载jdbc.properties配置文件实在configConstant加载的 @Override public void configConstant(Constants me) { loadPropertyFile("jdbc.properties");//加载配置文件 me.setDevMode

使用ADO.NET操作Oracle数据库

本文将示例使用C#的ADO.NET技术调用Oralce的存储过程和函数及操作Oracle数据库. 在oracle的hr数据库中建立存储过程 在oralce的hr数据库中建立函数 新建控制台项目,在主函数添加代码: 1 string strConn = "Data Source=jayjay;User ID=hr;Password=oracle;Unicode=True"; 2 3 //调用存储过程 4 using (OracleConnection conn = new OracleC

java PreparedStatement操作oracle数据库

import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; //import java.sql.Statement; import java.sql.PreparedStatement; public class lx02{ public static void main(String[] args) throws SQLException, ClassNotFoundException

Java操作Oracle数据库自建工具库

在学习Java操作Oracle数据库的时候,忽然想到这个可不可以像php那样自己建立一个工具类,这样的话可以大大的减小代码的复杂度.也可以提高工作效率. java如果不能自己建立工具类,那是非常可笑的,但是,在建立的过程中,出现了一些问题,希望在以后不要犯类似的错误. 首先,我们在自建工具类之前必然是先模拟测试的,在这个例子当中,其过程如下: 1:引入Oracle的驱动程序 2:建立OracleTools类,并且定义其成员变量. 3:写OracleTools类的成员方法和构造函数. 4:如果全部

Python使用cx_Oracle模块连接操作Oracle数据库

1. 简介 cx_Oracle 是一个用来连接并操作 Oracle 数据库的 Python 扩展模块, 支持包括 Oracle 9.2 10.2 以及 11.1 等版本 2.安装 最后是去官网http://cx-oracle.sourceforge.net/上下载安装,我自己通过pip和easy install安装都失败了,我是在win8.1的环境下安装的 3.使用 使用就很简单,以下为代码示例 #!/usr/bin/env python #-*- coding:utf-8 -*- import

ASP.NET操作ORACLE数据库之模糊查询

ASP.NET操作ORACLE数据库之模糊查询 一.ASP.NET MVC利用OracleHelper辅助类操作ORACLE数据库 1 //连接Oracle数据库的连接字符串 2 string connectionString = @"Data Source=(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP) 3 (HOST=localhost) (PORT=1521)))(CONNECT_DATA=(SERVICE_NAME=TestDB)))

连接Linux服务器操作Oracle数据库

连接Linux服务器操作Oracle数据库 由于项目已经上线,现场的数据库服务器不允许直接用Oracle的客户端plsqldev.exe来连接,只能通过Linux服务器的命令来操作. 以下是用SecureCRT 5.1客户端连接Linux服务器来操作Oracle数据库: 1.连接到Linux服务器(输入服务器的ip地址) ssh 10.199.94.227 连接成功后会提示输入密码,输入成功会提示. 2.切换到操作Oracle数据库 su - oracle 切换成功会提示相关数据库的实例.例如:

PHP操作Oracle数据库

原文出处 (这是来自“百度文库”中的文章写得很不错) PHP操作Oracle数据库(OCI数据抽象层)OCI(Oracle 8 Call-Interface)是PHP中内置的数据库抽象层函数.下面针对连接Oracle数据库操作数据库的常见任务举例说明:=======================基本查询:无条件查询===================1.数据库连接:函数:oci_connect()函数:resource oci_connect ( string username, strin

操作Oracle数据库，插入数据时显示：ORA-00984列在此处不允许错误

操作Oracle数据库,插入数据时显示:ORA-00984列在此处不允许错误,如下图所示: 出现的原因是由于,在插入字符或字符串型字段时.如果插入的数据是纯数字,则不会有错误:如果出现字符,则会报ORA-00984列在此处不允许异常. 可以创建TestUser表,如下: create table TestUser ( usercode char(5), username varchar2(20) ) 以下例子请注意第一个字段usercode的值 1.正常例子:usercode为纯数字.可以正常插