Openssl数据安全传输平台015:OCCI的使用方法+在项目中的设计与实现

文章目录

  • 1 OCCI使用
    • 1.1 初始化 - Environment 类
    • 1.2 连接数据库 - Connection 类
    • 1.3 执行SQL
  • 2 OCCI在项目中的使用
    • 2.1 OCCI单独封装为一个类文件OCCIOP
    • 2.2 在ServerOP中作为私有成员
    • 2.3 ServerOP::ServerOP(string json)中实例化进行使用
    • 2.4 秘钥协商过程中进行读写操作

1 OCCI使用

// 头文件
#include <occi.h>
// occi的接口类在对应的命名空间中
using namespace oracle::occi;// 使用
1. 初始化一个环境->对应的类: Environment
2. 使用初始化完成的环境对象创建一个连接, 得到一个连接对象: Connection, 通过这个对象可用连接并操作服务器
3. 对数据库的操作: 添删查改(对应相关的sql语句)- 通过得到的连接数据库的实例对象, 创建一个可以对象数据进行sql操作的一个对象: Statement
4. 如果对数据进行是查询操作, 会得到一个结果集, 这个结果集对应的也是一个类: ResultSet
5. 释放资源- 结果集资源->ResultSet- 对数据进行sql操作的对象->Statement- 销毁连接对象->Connection- 数据连接环境->Environment

1.1 初始化 - Environment 类

OCCI通过创建一个Environment的对象完成初始化工作。

可以通过Environment创建数据库连接,从而进行其它的操作

要创建Environment,应该调用Environment类的静态方法createEnvironment()

// 环境初始化
Environment* env = Environment::createEnvironment();
// 关闭, 释放资源
Environment::terminateEnvironment(env);

1.2 连接数据库 - Connection 类

连接数据库通过Connection类的对象实例实现

调用Environment类的**createConnection()**方法可以创建一个Connection对象;

// 函数原型: 
// 连接串格式: IP:端口/数据库实例名
Connection *Environment::createConnection( const string &userName,const string &password, const string &connectString );
// 函数调用
const string userName = "scott";    // 用户名
const string passwd = "tiger";    // 密码
const string connstr = "192.168.247.129:1521/orcl";    // 数据库连接串
Connection* conn = env->createConnection(userName, passwd, connstr);

使用**Environment::terminateConnection()**断开连接

// 断开连接
env->terminateConnection(conn);

1.3 执行SQL

Statement 类用于执行SQL语句,并获取返回结果。

ResultSet 类用于处理SELECT 查询的结果。

对于所有类型的数据的绑定或者获取,OCCI都提供了统一的方法

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

OCCI会自动处理类型之间的转换。

使用方法:

使用Connection:😗*createStatement()**创建Statement对象, 指定 SQL 命令(DDL/DML/query)作为参数

// 操作函数
Connection::createStatement(string &sql);Statement::setSQL(string &sql);Statement::execute(string &sql);       // can be used for any SQL, returns status
// 执行一个insert/update/delete
Statement::executeUpdate(string &sql); // returns Insert/Update/Delete count
// 执行一个select语句
Statement::executeQuery(string &sql);  // returns ResultSet(结果集)

使用 setXXX 方法传递要绑定用于输入的值

使用合适的execute方法执行SQL

对于SELECT 查询, 使用ResultSet 对象处理返回结果

// 插入操作
Statement *stmt = conn->createStatement(“ insert into Dept(Deptno,Dname, Loc) values (1, ‘ACCOUNTS’, ‘ZONE1’ ”);
stmt->executeUpdate();  
conn->terminateStatement(stmt);       // 关闭查询, 释放资源

使用绑定参数的DML(数据操作语句)示例:

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

执行SELECT查询并处理结果:

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();// 初始化环境连接数据库bool connectDB(string user, string passwd, string connstr);// 得到keyID -> 根据实际业务需求封装的小函数int getKeyID();bool updataKeyID(int keyID);bool writeSecKey(NodeSecKeyInfo *pNode);void closeDB();private:// 获取当前时间, 并格式化为字符串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;// 创建数据库实例对象,因为在多处进行了使用,因此设置为成员OCCIOP m_occi;SecKeyShm* m_shm;
};

2.3 ServerOP::ServerOP(string json)中实例化进行使用

ServerOP::ServerOP(string json)
{// 解析json文件, 读文件 -> Valueifstream ifs(json);Reader r;Value root;r.parse(ifs, root);m_port = root["Port"].asInt();m_serverID = root["ServerID"].asString();// 数据库相关的信息m_dbUser = root["UserDB"].asString();m_dbPwd = root["PwdDB"].asString();m_dbConnStr = root["ConnStrDB"].asString();// 实例化一个连接oracle数据的对象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 秘钥协商过程中进行读写操作

// 将生成的新秘钥写入到数据库中 -> 操作 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();	// 秘钥的IDinfo.seckeyID = node.seckeyID;
node.status = 1;// 初始化node变量
bool bl = m_occi.writeSecKey(&node);

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/122294.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

关于错误javax.net.ssl.SSLException: Received close_notify during handshake

今天开发的小伙伴遇到一问题&#xff0c;报错内容是&#xff1a; javax.net.ssl.SSLException: Received close_notify during handshake at sun.security.ssl.Alerts.getSSLException(Unknown Source) at sun.security.ssl.SSLSocketImpl.fatal(Unknown Source) at sun.securi…

智能水厂运行与调控3D模拟仿真在线展示提高整个系统的协同效应

水厂在生活中的重要性不可忽视。它们提供清洁、安全的水源&#xff0c;满足人们饮用、洗浴、烹饪等基本需求&#xff0c;保障公共卫生&#xff0c;预防疾病传播;同时&#xff0c;水厂也促进经济发展&#xff0c;为工业生产和农业灌溉提供保障&#xff0c;吸引和支持企业的投资和…

chrome谷歌浏览器取消网页所有剪切板的授权方法步骤

地址栏输入 chrome://settings/content/clipboard选择 不允许网站查看您剪贴板中的文字或图片 ———————————————— 版权声明&#xff1a;本文为CSDN博主「一切V随缘」的原创文章&#xff0c;遵循CC 4.0 BY-SA版权协议&#xff0c;转载请附上原文出处链接及本声明…

MySQL 8 - 处理 NULL 值 - is null、=null、is not null、<> null 、!= null

处理 NULL 值&#xff1a; IS NULL&#xff1a;IS NULL 用于检查一个列是否为 NULL。例如&#xff0c;如果查找一个表中某一列的值为 NULL 的行&#xff0c;可以使用以下语法&#xff1a; SELECT * FROM table_name WHERE column_name IS NULL;IS NOT NULL&#xff1a;IS NOT N…

使用Spring Data Elasticsearch 进行索引的增、删、改、查

一 Spring Data Elasticsearch 项目环境搭建 1.1 修改pom文件添加依赖 目前使用spring-boot-starter-parent版本为2.2.8.RELEASE 对应spring-data-elasticsearch版本为2.2.8.RELEASE&#xff0c;版本对应可以自行百度&#xff0c;如果不行直接用elasticsearch-rest-high-lev…

phar反序列化学习

PHP反序列化常见的是使用unserilize()进行反序列化&#xff0c;除此之外还有其它的反序列化方法&#xff0c;不需要用到unserilize()。就是用到phar反序列化。 Phar phar文件 Phar是将php文件打包而成的一种压缩文档&#xff0c;类似于Java中的jar包。它有一个特性就是phar文…

React Router初学者入门指南(2023版)

React Router&#xff0c;简单来说&#xff0c;是一个帮助处理React应用程序中导航和路由的库。它是用于管理React中路由的最流行的路由工具。如果你对路由的概念不熟悉&#xff0c;可以将其视为在网站的不同部分之间导航的过程。例如&#xff0c;当你进入网站的“联系我们”部…

从AlexNet到chatGPT的演进过程

一、演进 AlexNet&#xff08;2012&#xff09;&#xff1a; AlexNet是深度学习领域的重要突破&#xff0c;包括5个卷积层和3个全连接层。使用ReLU激活函数和Dropout正则化&#xff0c;获得了ImageNet图像分类比赛的胜利。引入了GPU加速训练&#xff0c;大幅提高了深度神经网络…

Android系统的特性

目录 Android系统的特性 1. 显示布局 2. 数据存储 3. 网络 4. 信息 5. 浏览器 6. 编程语言支持 7. 媒体支持 8. 流媒体支持 9. 硬件支持 10. 多点触控 11.蓝牙 12. 多任务处理 13. 语音功能 14.无线共享功能 15. 截图功能 16. 跨平台 17. 应用程序的安全机制…

Flutter笔记:完全基于Flutter绘图技术绘制一个精美的Dash图标(上)

Flutter笔记 完全基于Flutter绘图技术绘制一个精美的Dart语言吉祥物Dash&#xff08;上&#xff09; 作者&#xff1a;李俊才 &#xff08;jcLee95&#xff09;&#xff1a;https://blog.csdn.net/qq_28550263 邮箱 &#xff1a;291148484163.com 本文地址&#xff1a;https://…

No authorization token was found

今天遇到了一个问题&#xff0c;我把前后端逻辑都理了一遍&#xff0c;开始怀疑后端&#xff0c;后端肯定没错了&#xff0c;把前端理了一遍&#xff0c;ok前后端没错&#xff0c;我错。登录哪里需要的token&#xff1f;&#xff1f;&#xff1f;&#xff1f;把我搞懵逼了。 测…

npm start启动的是什么

npm start 命令是在一个 Node.js 项目中执行的一个自定义命令&#xff0c;用于启动该项目。该命令是在 package.json 文件中定义的&#xff0c;通常被用于启动一个 Web 应用程序或服务。 具体来说&#xff0c;当在项目目录下执行 npm start 命令时&#xff0c;npm 将会在该项目…

[红蓝攻防]MDOG(全新UI重制版)为Xss跨站而生,数据共享,表单劫持,URL重定向

说明 功能Cookie窃取表单劫持(钓鱼账密)重定向流量劫持多平台数据推送钉钉数据推送 运行窗口 ./dist目录下已生成exe文件,双击打开 Cookie窃取 点击运行服务,复制以上的payload,payload怎么变形那么你可已去混淆 payload在页面执行 受害者访问存在xss漏洞的页面时受到攻击,…

Capacitor 打包 h5 到 Android 应用,uniapp https http net::ERR_CLEARTEXT_NOT_PERMITTED

Capacitor 打包 h5 到 Android 应用&#xff0c;uniapp https http net::ERR_CLEARTEXT_NOT_PERMITTED capacitor 官网&#xff1a; https://capacitorjs.com/docs/ 项目上需要做一个 app&#xff0c;而这个 app 是用 uniapp 做的&#xff0c;里面用到了一个依赖 dom 的库&…

项目管理概论:什么是项目、项目管理的重要性、成功的标准包含什么以及相关笔记

本文摘要 按照惯例,咱们开篇先介绍一下项目概论中的相关概念,然后记录一下这里面的关键知识点和重点笔记。 这些知识点和笔记源自《信息系统项目管理师教程》(第4版)、往年概念方向的真题甚至题干(有时候题目就是知识点 👻)。 本文会不断的更新和补充,比如一些晦涩的概念…

目标检测YOLO实战应用案例100讲-基于无人机图像的房屋目标检测

目录 前言 国内外研究现状 房屋建筑检测的研究现状 深度学习的研究现状

Android官方ShapeableImageView描边/圆形/圆角图,xml布局实现

Android官方ShapeableImageView描边/圆形/圆角图&#xff0c;xml布局实现 <?xml version"1.0" encoding"utf-8"?> <LinearLayout xmlns:android"http://schemas.android.com/apk/res/android"xmlns:app"http://schemas.android.…

【理论知识:Window Aggregation】flink 窗口聚合功能概述:两种窗口聚合模式的使用例子、功能说明

文章目录 一. Windowing TVFs1. 三种类型聚合的例子2. GROUPING SETS子句语法 ing2.1.ROLLUP2.2. CUBE 3. Selecting Group Window Start and End Timestamps4. 级联窗口聚合&#xff08;Cascading Window Aggregation&#xff09; 二. Group Window Aggregation1. Group Windo…

IDEA新建maven项目,使用mybatis操作数据库完整过程

IDEA新建maven项目&#xff0c;使用mybatis操作数据库完整过程 一、IDEA新建maven项目二、配置mybatis三、创建表对应实体类四、创建mapper接口五、使用mybatis操作数据库 前提&#xff1a; 这个教程是在maven项目中使用mybatis进行数据库操作&#xff0c;不是在spring boot项目…

力扣 88. 合并两个有序数组

目录 1.解题思路2.代码实现 1.解题思路 另开辟一个大小为mn的数组再利用双指针判断两个指针的大小&#xff0c;将小值赋给数组上并给该数组的下标加一和该指针加一&#xff0c;其次&#xff0c;要判断两个数组是否已经被拷贝完&#xff0c;如果其中一个已经到头&#xff0c;那…