使用occi连接oracle的方法

//by rainfish from https://www.doczj.com/doc/ea17978642.html,/
1. 下载
首先下载occi所需要的库：[url=https://www.doczj.com/doc/ea17978642.html,/technology/tech/oci/occi/occidownloads.html]https://www.doczj.com/doc/ea17978642.html,/technology/tech/oci/occi/occidownloads.html
下载linux版本。
然后下载occi所需要的头文件：即instantclient-sdk
https://www.doczj.com/doc/ea17978642.html,/otn/l ... inux32-11.2.0.1.zip
解压后里面有所需要的头文件，主要是occi.h
2. 将occi所需库拷贝到/usr/local/lib/
然后：
ln -s libocci.so libocci.so.11.1
ln -s libclntsh.so.11.1 libclntsh.so
3.
示例，根据互联网修改的
//oracle2.cpp

#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
using namespace oracle:cci;
class dbAccessor
{
public:
dbAccessor();
~dbAccessor();
int get_dbstat();
bool Connect_DB();
void Disconn_DB();
bool ExecuteUpdate(const char* sql);
ResultSet* ExecuteQuery(const char* sql);
void ClearQuery(ResultSet* set);
void Init(const char* dbName,const char* dbUser,const char* dbPass);
void SetDate(unsigned int paramIndex, time_t timeVal);
private:
Environment* m_env;
Connection* m_conn;
Statement* m_stmt;
const char *m_szUser;
const char *m_szPassword;
const char *m_szDbName;
bool bConnected;
};

using namespace std;
using namespace oracle:cci;
dbAccessor::dbAccessor()
{
bConnected=false;
m_env=0;
m_conn=0;
m_stmt=0;
}

dbAccessor::~dbAccessor()
{
Disconn_DB();
}
void dbAccessor::Init(const char* dbName,const char* dbUser,const char* dbPass)
{
m_szDbName = dbName;
m_szUser = dbUser;
m_szPassword = dbPass;
}
bool dbAccessor::Connect_DB()
{
if(m_env ==0)
m_env = Environment::createEnvironment();
if(m_conn==0){
try {
m_conn=m_env->createConnection(m_szUser,m_szPassword,m_szDbName);
} catch (SQLException& ex) {
m_conn = 0;
cout << "connect to database failed: " << ex.getMessage() << endl;
return false;
}
}
return true;
}
void dbAccessor:isconn_DB()
{
if(m_stmt!=0 && m_conn!=0)
m_conn->terminateStatement(m_stmt);
if(m_conn!=0 && m_env!=0)
m_env->terminateConnection(m_conn);
}
// 执行数据库更新操作，包括insert、update、delete操作
bool dbAccessor::ExecuteUpdate(const char* sql)
{
bool update_OK = true;
if(sql==0){
exit(1);
}
if(m_conn==0&&m_env==0){
exit(1);
}
try {
m_stmt=m_conn->createStatement(sql);
} catch (SQLException& ex) {
m_stmt = NULL;
cout << "ExecuteUpdate failed: " << ex.getMessage() << endl;
exit(1);
}
update_OK = m_stmt->executeUpdate();

return update_OK;
}
//执行数据库查询操作，即select操作
ResultSet* dbAccessor::ExecuteQuery(const char* sql)
{
ResultSet* set=0;
if(sql==0){
exit(1);
}
if(m_conn==0&&m_env==0){
exit(1);
}
try {
m_stmt=m_conn->createStatement(sql);
} catch (SQLException& ex) {
m_stmt

= NULL;
cout << "ExecuteQuery failed: " << ex.getMessage() << endl;
exit(1);
}
set=m_stmt->executeQuery();
return set;
}

void dbAccessor::ClearQuery(ResultSet* set)
{
if(m_stmt==0){
exit(1);
}
if(set==0){
exit(1);
}
m_stmt->closeResultSet(set);
}
void dbAccessor::SetDate(unsigned int paramIndex, time_t timeVal)
{
cout<m_stmt = m_conn->createStatement();
assert(m_stmt != NULL);
tm* timeStruct = localtime(&timeVal);
Date date(m_env,
timeStruct->tm_year + 1900,
timeStruct->tm_mon + 1,
timeStruct->tm_mday,
timeStruct->tm_hour,
timeStruct->tm_min,
(timeStruct->tm_sec == 60) ? 0 : timeStruct->tm_sec);

m_stmt->setDate(paramIndex, date);
}

int main(void)
{
dbAccessor obj;
obj.Init("10.1.99.200:1521/orcl","gist","gist";
bool conn = obj.Connect_DB();
if(!conn)
{
perror("obj.Connect_DB()\n";
exit(1);
}
else
{
printf("obj.Connect_DB() OK\n";
}


/*
// 1、插入数据库操作
string sql = "insert into EMAIL0(emailid,checkintime,clientip,clientport,serverip,serverport,capturetime,type,username,password,sendaddress,receiveaddress,subject,ccaddress) ";
sql += "values(1238673850,to_date('04-3-2009','MM-DD-YYYY'),'127.0.0.1',4327,'serverip',110,to_date('04-3-2009','MM-DD-YYYY'),1,'user','pass','sendaddress','receiveaddress','subject','ccaddress')";
obj.ExecuteUpdate(sql.c_str());

// 2、查询数据库操作
sql = "select emailid,to_char(checkintime,'YYYY-MM-DD HH24:MI:SS'),clientip from EMAIL0";
// 第一列emailid：Int型；第二列checkintime：Date类型，转换为字符串类型输出；第三列clientip：string字符串类型
ResultSet* set=obj.ExecuteQuery(sql.c_str());
while(set->next()){
cout << set->getInt(1) << endl; //获取第一列值，int类型
cout << set->getString(2) << endl; //获取第二列值，date类型转换成了字符串类型
cout << set->getString(3) << endl; //获取第三列值，string类型
}
obj.ClearQuery(set);
*/
return 0;
}

//makefile

CC = g++

PROGS = oracle1 oracle2

INCL_PATH = -I/opt/tools/occi/include

CFLAGS = -g -Wall -Wno-deprecated ${INCL_PATH}

LIBS = -locci -lclntsh

CLEANFILES = core core.* *.core *.o temp.* *.out typescript* \
*.lc *.lh *.bsdi *.sparc *.uw

all: ${PROGS}

oracle1: oracle1.o
${CC} ${CFLAGS} -o $@ oracle1.o ${LIBS}

oracle2: oracle2.o
${CC} ${CFLAGS} -o $@ oracle2.o ${LIBS}

.cpp.o:
$(CC) $(CFLAGS) -o $@ -c $<
clean:
rm -f ${PROGS} ${CLEANFILES}