C++操作oracle数据库

数据库操作方式：可以采用ADO方式，也可以采用oracle本身提供的Proc*C/C++或者是OCCI方式操作数据库。

连接方式：可以是客户端连接、也可以是服务器端连接。

数据库配置：无论是何种连接都需要进行数据库连接的配置，一般在ORACLE_HOME下面的network/admin/tnsnames.ora文件中进行配置，如果没有此目录或者是此文件，需要自己手工添加。内容格式大致如下：

点击(此处)折叠或打开

BM2D0 =

(DESCRIPTION =

(ADDRESS_LIST =

(ADDRESS = (PROTOCOL = TCP)(HOST = XXX.XXX.XXX.XXX)(PORT = 1521))

)

(CONNECT_DATA =

(SERVICE_NAME = BM2D0)

)

)

其中橄榄色可任意起名，一般在数据库连接是作为服务和用户名、密码一起确定数据库连接的参数。
第一个鲜粉色是远程oracle数据库所在服务器的IP地址，端口号一般为1521。
第二个鲜粉色是远程oracle所在主机的全局数据库名字，不能随意更改。
后两个搭配起来能够确定唯一连接对象。

客户端连接：
方式一：ADO
main.cpp

点击(此处)折叠或打开

#include "DBOperation.h"

#include <iostream>

using namespace std;

void main()

{

CDBOperation dbOper;

bool bConn = dbOper.ConnToDB("Provider=OraOLEDB.Oracle.1;Persist
Security Info=True;Data Source=xxx1", "xxx2", "xxx3");

if (false == bConn)

{

printf("连接数据库出现错误\n");

system("PAUSE");

return;

}

_RecordsetPtr pRst;

//执行查询语句

//char *sql = "select
* from TSTUDENT";

char sql[255] = {0};

strcpy(sql, "select * from TSTUDENT");

pRst = dbOper.ExecuteWithResSQL(sql);

if (NULL == pRst)

{

printf("查询数据出现错误！\n");

system("PAUSE");

return;

}

if (pRst->adoEOF)

{

pRst->Close();

printf("There is no records in this table\n");

return;

}

_variant_t vSno, vName, v***, vAge, vDno, vDname, vCname;

while (!pRst->adoEOF)

{

//pRst->MoveFirst(); //记录集指针移动到查询结果集的前面

vSno = pRst->GetCollect(_variant_t((long)0));

vName = pRst->GetCollect(_variant_t("name"));

v*** = pRst->GetCollect(_variant_t("***"));

vAge = pRst->GetCollect(_variant_t("age"));

//vDno = pRst->GetCollect("dno");

//vDname = pRst->GetCollect("dname");

//vCname = pRst->GetCollect("cname");

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

pRst->MoveNext();

}

//执行插入语句

//sprintf(sql, "insert
into TSTUDENT(sno, name, ***, age) values('%s', '%s', '%s', %d)", "20080016", "全局", "女", 25);

strcpy(sql, "insert into TSTUDENT(sno, name, ***, age) values('20080001',
'全局', '女', 25)");

pRst = dbOper.ExecuteWithResSQL(sql);

if (NULL != pRst)

{

printf("插入数据成功\n");

}

//执行删除语句

sprintf(sql, "delete from TSTUDENT where sno = '%s'", "20080017");

pRst = dbOper.ExecuteWithResSQL(sql);

if (NULL != pRst)

{

printf("删除数据成功\n");

}

system("PAUSE");

//pRst->Close();

}

其中XXX1：是tnsnames.ora中配置的服务名，XXX2是用户名，XXX3是密码。
DBOperation.h:

点击(此处)折叠或打开

#pragma once

#import "c:\program files\common files\system\ado\msado15.dll" no_namespace rename("EOF", "adoEOF")

class CDBOperation

{

public:

//初始化数据库操作需要的对象

CDBOperation(void);

~CDBOperation(void);

//连接至数据库

bool ConnToDB(char *ConnectionString, char *UserID, char *Password);

//数据库操作函数

//查询操作 删除以及添加

_RecordsetPtr ExecuteWithResSQL(const char *);

//bool ExecuteNoResSQL(const char *);//delete and add

private:

void PrintErrorInfo(_com_error &);

private:

//初始化数据库连接、命令、记录集

_ConnectionPtr CreateConnPtr();

_CommandPtr CreateCommPtr();

_RecordsetPtr CreateRecsetPtr();

private:

//数据库连接需要的连接、命令操作对象

_ConnectionPtr m_pConnection;

_CommandPtr m_pCommand;

};

DBOperation.cpp

点击(此处)折叠或打开

#include "DBOperation.h"

CDBOperation::CDBOperation(void)

{

CoInitialize(NULL);

m_pConnection = CreateConnPtr();

m_pCommand = CreateCommPtr();

}

CDBOperation::~CDBOperation(void)

{

//m_pCommand->Close();

m_pConnection->Close();

}

bool CDBOperation::ConnToDB(char *ConnectionString, char *UserID, char *Password)

{

if (NULL == m_pConnection)

{

printf("Failed to create connection\n");

return false;

}

try

{

HRESULT hr = m_pConnection->Open(ConnectionString, UserID, Password, NULL);

if (TRUE == FAILED(hr))

{

return false;

}

m_pCommand->ActiveConnection = m_pConnection;

return true;

}

catch(_com_error &e)

{

PrintErrorInfo(e);

return false;

}

}

_RecordsetPtr CDBOperation::ExecuteWithResSQL(const char *sql)

{

//已经在连接至数据库的时候进行判断了

//if (NULL == m_pCommand || 0 == m_pConnection->State)

//{

// printf("Failed
to create command OR the state of connection is zero\n");

// return NULL;

//}

//char *query = new
char;

//strcpy(query, sql);

try

{

m_pCommand->CommandText = _bstr_t(sql);

_RecordsetPtr pRst = m_pCommand->Execute(NULL, NULL, adCmdText);

return pRst;

//_variant_t ra;

//_RecordsetPtr pRst = m_pConnection->Execute((_bstr_t)query, &ra, adCmdText);

}

catch(_com_error &e)

{

PrintErrorInfo(e);

return NULL;

}

}

//bool CDBOperation::ExecuteNoResSQL(const char *sql)

//{

// //if (NULL == m_pCommand || 0 == m_pConnection->State)

// //{

// // printf();

// //}

// try

// {

// char *query = NULL;

// strcpy(query, sql);

// m_pCommand->CommandText = (_bstr_t)query;

//

// }

//}

void CDBOperation::PrintErrorInfo(_com_error &e)

{

printf("Error infomation are as follows\n");

printf("ErrorNo: %d\nError Message:%s\nError Source:%s\nError Description:%s\n", e.Error(), e.ErrorMessage(), (LPCTSTR)e.Source(),(LPCTSTR)e.Description());

}

_ConnectionPtr CDBOperation::CreateConnPtr()

{

HRESULT hr;

_ConnectionPtr connPtr;

hr = connPtr.CreateInstance(__uuidof(Connection));

if (FAILED(hr) == TRUE)

{

return NULL;

}

return connPtr;

}

_CommandPtr CDBOperation::CreateCommPtr()

{

HRESULT hr;

_CommandPtr commPtr;

hr = commPtr.CreateInstance(__uuidof(Command));

if (FAILED(hr) == TRUE)

{

return NULL;

}

return commPtr;

}

_RecordsetPtr CDBOperation::CreateRecsetPtr()

{

HRESULT hr;

_RecordsetPtr recsetPtr;

hr = recsetPtr.CreateInstance(__uuidof( Command));

if (FAILED(hr) ==TRUE)

{

return NULL;

}

return recsetPtr;

}

方式二：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
应用程序：

点击(此处)折叠或打开

//代码的目的就是验证makefile中oracle的头文件和lib文件路径是否正确了

#include <iostream>

#define WIN32COMMON //避免函数重定义错误

#include <occi.h>

using namespace std;

using namespace oracle::occi;

int main()

{

Environment *env=Environment::createEnvironment();

cout<<"success"<<endl;

string name = "xxx";

string pass = "xxx";

string srvName = "xxx";

try

{

Connection *conn = env->createConnection("bsm3", "bsm3", "BSM3");

cout<<"conn success"<<endl;

env->terminateConnection(conn);

}

catch(SQLException e)

{

cout<<e.what()<<endl;

system("pause");

return -1;

}

Environment::terminateEnvironment(env);

cout<<"end!"<<endl;

system("pause");

return 0;

}

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

点击(此处)折叠或打开

//代码的目的就是验证makefile中oracle的头文件和lib文件路径是否正确了

#include <iostream>

#include <occi.h>

using namespace std;

using namespace oracle::occi;

main()

{

Environment *env=Environment::createEnvironment();

cout<<"success"<<endl;

string name = "xxx";

string pass = "xxx";

string srvName = "xxx";

try

{

Connection *conn = env->createConnection(name, pass, srvName);

cout<<"conn success"<<endl;

env->terminateConnection(conn);

}

catch(SQLException e)

{

cout<<e.what()<<endl;

}

Environment::terminateEnvironment(env);

cout<<"end!"<<endl;

}

Makefile:

点击(此处)折叠或打开

###########################################

#Makefile for the OCCI demo programs

###########################################

INC=-I${ORACLE_HOME}/precomp/public -I${ORACLE_HOME}/rdbms/public

LIB=-L${ORACLE_HOME}/lib -locci
#-bnoquiet #-bloadmap

FLAGS=-q64 -g

#为方便取下面三个变量，目标为helloworld，源文件是helloworld.cpp，编译后文件helloworld.o

PRG=helloworld

SRC=helloworld.cpp

OBJ=helloworld.o

#下面是常规的makefile内容，$@表示依次取目标执行，这里只有helloworld一个目标。实际等价于

#CC -o helloworld helloworld.o 不过加入了include和lib文件。而helloworld.o需要后续完成

$(PRG):$(OBJ)

@echo "begin link......"

${CC} ${FLAGS} ${INC} ${LIB} -o
$@ $(OBJ)

#helloworld目标依赖helloworld.o生成，所以该句就是编译.c生成.o文件。只不过加入了include和lib文件

$(OBJ):$(SRC)

@echo "begin compile......"

${CC} ${FLAGS} ${INC} ${LIB} -c
$(SRC)

#后面的内容不是make的内容了，而是make clean内容。比如想重新make之前，清除.o等文件，执行make clean语句

#.PRNOY语句表明 clean关键词是个伪目标。make不自动执行。

.PRONY:clean

clean:

@echo "Removing linked and compiled files....."

rm -f $(OBJ) $(PRG)

关于客户端以及服务器端采用PROC*C/C++连接方式待续。。。。