1 OCCI使用

// 頭文件
#include <occi.h>
// occi的接口類在對應(yīng)的命名空間中
using namespace oracle::occi;

// 使用
1. 初始化一個環(huán)境->對應(yīng)的類: Environment
2. 使用初始化完成的環(huán)境對象創(chuàng)建一個連接, 得到一個連接對象: Connection, 通過這個對象可用連接并操作服務(wù)器
3. 對數(shù)據(jù)庫的操作: 添刪查改(對應(yīng)相關(guān)的sql語句)
        - 通過得到的連接數(shù)據(jù)庫的實例對象, 創(chuàng)建一個可以對象數(shù)據(jù)進行sql操作的一個對象: Statement
4. 如果對數(shù)據(jù)進行是查詢操作, 會得到一個結(jié)果集, 這個結(jié)果集對應(yīng)的也是一個類: ResultSet
5. 釋放資源
    - 結(jié)果集資源->ResultSet
    - 對數(shù)據(jù)進行sql操作的對象->Statement
    - 銷毀連接對象->Connection
    - 數(shù)據(jù)連接環(huán)境->Environment

1.1 初始化 - Environment 類

OCCI通過創(chuàng)建一個Environment的對象完成初始化工作。

可以通過Environment創(chuàng)建數(shù)據(jù)庫連接，從而進行其它的操作

要創(chuàng)建Environment，應(yīng)該調(diào)用Environment類的靜態(tài)方法createEnvironment()

// 環(huán)境初始化
Environment* env = Environment::createEnvironment();
// 關(guān)閉, 釋放資源
Environment::terminateEnvironment(env);

1.2 連接數(shù)據(jù)庫 - Connection 類

連接數(shù)據(jù)庫通過Connection類的對象實例實現(xiàn)

調(diào)用Environment類的**createConnection()**方法可以創(chuàng)建一個Connection對象；

// 函數(shù)原型: 
// 連接串格式: IP:端口/數(shù)據(jù)庫實例名
Connection *Environment::createConnection( 
    const string &userName,const string &password, const string &connectString );

// 函數(shù)調(diào)用
const string userName = "scott";    // 用戶名
const string passwd = "tiger";    // 密碼
const string connstr = "192.168.247.129:1521/orcl";    // 數(shù)據(jù)庫連接串
Connection* conn = env->createConnection(userName, passwd, connstr);

使用**Environment::terminateConnection()**斷開連接

// 斷開連接
env->terminateConnection(conn);

1.3 執(zhí)行SQL

Statement 類用于執(zhí)行SQL語句,并獲取返回結(jié)果。

ResultSet 類用于處理SELECT 查詢的結(jié)果。

對于所有類型的數(shù)據(jù)的綁定或者獲取，OCCI都提供了統(tǒng)一的方法

• setXXX 方法用于Statement
• getXXX 方法用于Statement & ResultSet

OCCI會自動處理類型之間的轉(zhuǎn)換。

使用方法：

使用Connection:??*createStatement()**創(chuàng)建Statement對象, 指定 SQL 命令(DDL/DML/query)作為參數(shù)

// 操作函數(shù)
Connection::createStatement(string &sql);

Statement::setSQL(string &sql);

Statement::execute(string &sql);       // can be used for any SQL, returns status
// 執(zhí)行一個insert/update/delete
Statement::executeUpdate(string &sql); // returns Insert/Update/Delete count
// 執(zhí)行一個select語句
Statement::executeQuery(string &sql);  // returns ResultSet（結(jié)果集）

使用 setXXX 方法傳遞要綁定用于輸入的值

使用合適的execute方法執(zhí)行SQL

對于SELECT 查詢, 使用ResultSet 對象處理返回結(jié)果

// 插入操作
Statement *stmt = conn->createStatement(“ insert into Dept(Deptno,Dname, Loc) values (1, ‘ACCOUNTS’, ‘ZONE1’ ”);
stmt->executeUpdate();  
conn->terminateStatement(stmt);       // 關(guān)閉查詢, 釋放資源

使用綁定參數(shù)的DML（數(shù)據(jù)操作語句）示例：

Statement *stmt = conn->createStatement(“ insert into  Emp(EmpNo,Ename) values(:1, :2) ”);  
//1 and 2 are bind placeholders  
int empno = 2;  
string empname = “JOHN W”;  
//first parameter is bind position, second is value  
stmt->setInt(1, empno);   
stmt->setString(2, empname);  
stmt->executeUpdate();  

執(zhí)行SELECT查詢并處理結(jié)果：文章來源地址http://www.zghlxwxcb.cn/news/detail-740232.html

Statement *stmt = conn->createStatement(
    “select Empno, Ename, Sal from Emp where Hiredate >= :1”);  

//automatically converted to Date  
stmt->setString(1, “01-JAN-1987”);  

//executeQuery returns a ResultSet  
ResultSet *rs = stmt->executeQuery();   

//ResultSet::next fetches rows and returns FALSE   
//when no more rows  
while (rs->next() == true)  
{  
   //get values using the getXXX methods of ResultSet  
   empno = rs->getInt(1);  
   empname = rs->getString(2);  
   empsalary = rs->getFloat(3);  
}  
stmt->closeResultSet(rs);//to free resources 

2 OCCI在項目中的使用

2.1 OCCI單獨封裝為一個類文件OCCIOP

#pragma once
#define _GLIBCXX_USE_CXX11_ABI 0
#include <string>
#include <occi.h>
#include "SeckKeyNodeInfo.h"
using namespace std;
using namespace oracle::occi;


class OCCIOP
{
public:
	OCCIOP();
	~OCCIOP();

	// 初始化環(huán)境連接數(shù)據(jù)庫
	bool connectDB(string user, string passwd, string connstr);
	// 得到keyID -> 根據(jù)實際業(yè)務(wù)需求封裝的小函數(shù)
	int getKeyID();
	bool updataKeyID(int keyID);
	bool writeSecKey(NodeSecKeyInfo *pNode);
	void closeDB();

private:
	// 獲取當(dāng)前時間, 并格式化為字符串
	string getCurTime();

private:
	Environment* m_env;
	Connection* m_conn;
};

2.2 在ServerOP中作為私有成員

#pragma once
#include <map>
#include "TcpServer.h"
#include "Message.pb.h"
#include "OCCIOP.h"
#include "SecKeyShm.h"
// 處理客戶端請求
class ServerOP
{
public:
	enum KeyLen {Len16=16, Len24=24, Len32=32};
	ServerOP(string json);
	void startServer();
	static void* working(void* arg);
	friend void* workHard(void* arg);
	string seckeyAgree(RequestMsg* reqMsg);
	~ServerOP();

private:
	string getRandKey(KeyLen len);

private:
	string m_serverID;	
	string m_dbUser;
	string m_dbPwd;
	string m_dbConnStr;
	unsigned short m_port;
	map<pthread_t, TcpSocket*> m_list;
	TcpServer *m_server = NULL;
	
	// 創(chuàng)建數(shù)據(jù)庫實例對象，因為在多處進行了使用，因此設(shè)置為成員
	OCCIOP m_occi;
	
	SecKeyShm* m_shm;
};

2.3 ServerOP::ServerOP(string json)中實例化進行使用

ServerOP::ServerOP(string json)
{
	// 解析json文件, 讀文件 -> Value
	ifstream ifs(json);
	Reader r;
	Value root;
	r.parse(ifs, root);
	m_port = root["Port"].asInt();
	m_serverID = root["ServerID"].asString();
	
	// 數(shù)據(jù)庫相關(guān)的信息
	m_dbUser = root["UserDB"].asString();
	m_dbPwd = root["PwdDB"].asString();
	m_dbConnStr = root["ConnStrDB"].asString();

	// 實例化一個連接oracle數(shù)據(jù)的對象
	m_occi.connectDB(m_dbUser, m_dbPwd, m_dbConnStr);

	string shmKey = root["ShmKey"].asString();
	int maxNode = root["ShmMaxNode"].asInt();
	m_shm = new SecKeyShm(shmKey, maxNode);
}

2.4 秘鑰協(xié)商過程中進行讀寫操作

// 將生成的新秘鑰寫入到數(shù)據(jù)庫中 -> 操作 SECKEYINFO
NodeSecKeyInfo node;
strcpy(node.clientID, reqMsg->clientid().data());
strcpy(node.serverID, reqMsg->serverid().data());
strcpy(node.seckey, key.data());

node.seckeyID = m_occi.getKeyID();	// 秘鑰的ID

info.seckeyID = node.seckeyID;
node.status = 1;

// 初始化node變量
bool bl = m_occi.writeSecKey(&node);

到了這里，關(guān)于Openssl數(shù)據(jù)安全傳輸平臺015：OCCI的使用方法+在項目中的設(shè)計與實現(xiàn)的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！