sqlite - sqlite3_exec - c++回调函数的处理
文章目录
- sqlite - sqlite3_exec - c++回调函数的处理
- 概述
- 笔记
- 回调赋值实现
- 用到的数据结构
- 回调分发函数的实现
- 具体的回调处理
- sqlite3_exe执行完后, 行集的具体处理
- END
sqlite - sqlite3_exec - c++回调函数的处理
概述
以前给客户写了个小程序, 处理sqlite执行sql时, 给定回调, 等sql执行完, 处理返回的行集.
那时候, 时间紧, 回调整的不太好, 只是能用而已.
这次给自己写账单分析程序, 关于用回调处理行集的部分, 想到了比以前好的方法.
可以只使用一个类静态回调函数(回调分发函数), 然后通过参数, 可以将具体干活的普通类成员函数, 赋值给回调参数. 程序简洁实用很多.
试过了, 好使.
笔记
demo就不单独写了, 从现有工程中, 摘取程序片段来说明.
关于回调这块, 因为有语法的细节, 即使知道这回事, 如果重新写一个新回调, 也会试错好多次.
让自己以后看, 能明白就行了.
bool COrderProcBase::db_proc_excel_to_db()
{bool b_rc = false;int ArySize = 0;CStringArray strAry;int i = 0;int id = 0;CString strOrgFile;CString strCpyEnFile;CFileOperation file_opt;CString cs_drive;CString cs_dir;CString cs_name;CString cs_ext;CString csCsvToExcel;CString csTmp;do {// 建立数据库中的表// !! 在建立表之前, 要先检查表是否存在, 如果不存在, 才去建立表// 否则在表存在的情况下, 再建立表, 就会返回错误, 错误原因是表已经存在// 检查表是否存在是一段sql, 返回的行集是2行(列名称, 列值),1列if (!is_db_tbl_exist()) // 这里要执行sql, 就会返回一个行集, 就用到了回调.{if (!db_create_tbl()){break;}}
bool COrderProcJH::is_db_tbl_exist()
{return COrderProcBase::is_db_tbl_exist(_T("TBL_FILE_JH"));
}
回调赋值实现
bool COrderProcBase::is_db_tbl_exist(TCHAR* pszTblName)
{// 表在数据中是否存在?bool b_rc = false;string str_utf8_sql;string str_sql;char* zErrMsg = NULL; //错误信息const char* sql = NULL;int rc = 0;CString csMsg;char szBuf[4096];TAG_PARAM_CALLBACK_FOR_SQLITE3_EXEC param;do {_ASSERT(NULL != pszTblName);if (NULL == pszTblName){break;}memset(szBuf, 0, sizeof(szBuf));sprintf(szBuf, "SELECT EXISTS(SELECT name FROM sqlite_schema WHERE type='table' AND name='%s');", getLogicProxy()->my_W2A(pszTblName).c_str());str_sql = szBuf;str_utf8_sql = getLogicProxy()->UnicodeToUTF8(getLogicProxy()->my_A2W(str_sql));param.pThis = this;param.pFn = &COrderProcBase::callback_for_sqlite3_exec_proc_tbl_exist;param.row_set.clear();// 回调的赋值 为参数3, 参数4// 这样填写回调, 回调分发函数(类静态成员函数)只有一个, 不用变.// 具体的回调处理函数(类普通成员函数), 赋值在参数中. // 如果具体的回调处理函数不是这个类的this, 也可以在参数中指定. 这样就可以用任何类实例的任何普通成员函数来处理回调了, 很方便.// 这个参数中要赋值的类实例指针, 可以是一个基类的指针, 让处理回调的类都是这个基类的子类, 有基类中规定的处理回调的纯虚接口就好.rc = sqlite3_exec(get_db_handle(), str_utf8_sql.c_str(), COrderProcBase::callback_for_sqlite3_exec_dispatch, ¶m, &zErrMsg);if (SQLITE_OK != rc) {csMsg.Format(_T("错误 : %s"), getLogicProxy()->UTF8ToUnicode(zErrMsg).c_str());getLogicProxy()->addTips(csMsg);break;}// 等sql执行完, 只要执行的对, 就可以用另外一个函数来处理返回的结果集// 针对不同类型的sql, 实现不同的结果集处理函数b_rc = procResultSet_isTblExist(param.row_set, pszTblName);} while (false);if (NULL != zErrMsg) {sqlite3_free(zErrMsg);zErrMsg = NULL;}return b_rc;
}
用到的数据结构
// 类成员函数指针类型的定义
class COrderProcBase;
// PFN_CALLBACK_FOR_SQLITE3_EXEC是sqlite3_exec回调要求的函数样式
typedef int (COrderProcBase::* PFN_CALLBACK_FOR_SQLITE3_EXEC)(void* data, int argc, char** argv, char** azColName);
class COrderProcBase
{
public:
// ...// 这个结构在类中直接定义的typedef struct _tag_param_callback_for_sqlite3_exec{COrderProcBase* pThis; // 本类的指针, 用来从回调分发函数(类静态成员函数) 执行到类的普通成员函数PFN_CALLBACK_FOR_SQLITE3_EXEC pFn; // 本类中实际的回调处理函数指针(类的普通成员函数)C_my_row_set row_set; // 执行sql后, 返回的行集 这里是装在返回行集的类}TAG_PARAM_CALLBACK_FOR_SQLITE3_EXEC;
回调分发函数的实现
int COrderProcBase::callback_for_sqlite3_exec_dispatch(void* data, int argc, char** argv, char** azColName)
{int i_rc = 0;TAG_PARAM_CALLBACK_FOR_SQLITE3_EXEC* param;do {if (NULL == data){break;}param = (TAG_PARAM_CALLBACK_FOR_SQLITE3_EXEC*)data;if ((NULL != param->pThis) && (NULL != param->pFn)){// 这里就可以执行sqlite3_exec指定的回调函数了(任意类, 任意类的回调实现(类的普通成员函数))// 这个回调分发函数基本不用再改.i_rc = ((param->pThis)->*(param->pFn))(data, argc, argv, azColName);}} while (false);return i_rc;
}
具体的回调处理
这个根据具体要执行的sql具体处理, 最普通的就是将行集先存起来.
等sqlite3_exec完事了, 再拿存的行集来判断结果.
以判断库中表是否存在为例
如果在回调中, 只是将行集存起来, 那么下面的回调就是一个通用的实现.
int COrderProcBase::callback_for_sqlite3_exec_proc_tbl_exist(void* data, int argc, char** argv, char** azColName)
{int i_rc = 0;TAG_PARAM_CALLBACK_FOR_SQLITE3_EXEC* param;int i = 0;do {if (NULL == data){break;}param = (TAG_PARAM_CALLBACK_FOR_SQLITE3_EXEC*)data;C_my_row row;C_my_key_val key_val;for (i = 0; i < argc; i++){key_val.m_cs_key = azColName[i];key_val.m_cs_val = argv[i];row.m_list.AddTail(key_val);}// 回调进来一次, 就是一行param->row_set.m_list.AddTail(row);} while (false);return i_rc;
}
sqlite3_exe执行完后, 行集的具体处理
以判断库中表是否存在为例
这个实现应该和每种不同的sql相关, 拿回调中存好的行集做不同的判断.
bool COrderProcBase::procResultSet_isTblExist(C_my_row_set& row_set, const TCHAR* pszTblName)
{bool b_rc = false;POSITION pos;POSITION pos1;C_my_row row;C_my_row row1;C_my_key_val key_val;TCHAR szBuf[4096];bool b_stop = false;do {if (NULL == pszTblName){break;}if (1 != row_set.m_list.GetSize()){break;}for (pos = row_set.m_list.GetHeadPosition(); (NULL != pos); row_set.m_list.GetNext(pos)){row = row_set.m_list.GetAt(pos);if (1 != row.m_list.GetSize()){break;}for (pos1 = row.m_list.GetHeadPosition(); (NULL != pos1); row.m_list.GetNext(pos1)){b_stop = true;key_val = row.m_list.GetAt(pos1);memset(szBuf, 0, sizeof(szBuf));_stprintf(szBuf, _T("EXISTS(SELECT name FROM sqlite_schema WHERE type='table' AND name='%s')"), pszTblName);if (key_val.m_cs_key != szBuf){break;}if (key_val.m_cs_val != _T("1")){break;}b_rc = true;break;}if (b_stop){break;}}} while (false);return b_rc;
}
END
相关文章:
sqlite - sqlite3_exec - c++回调函数的处理
文章目录 sqlite - sqlite3_exec - c回调函数的处理概述笔记回调赋值实现用到的数据结构回调分发函数的实现具体的回调处理sqlite3_exe执行完后, 行集的具体处理END sqlite - sqlite3_exec - c回调函数的处理 概述 以前给客户写了个小程序, 处理sqlite执行sql时, 给定回调, 等…...

docker搭建logstash和使用方法
配置logstash 查询下载镜像【固定和elasticsearch一样的版本】 [roothao ~]# docker search logstash NAME DESCRIPTION STARS OFFICIAL AUTOMATED logstash …...

Memory-augmented Deep Autoencoder for Unsupervised Anomaly Detection 论文阅读
Memorizing Normality to Detect Anomaly: Memory-augmented Deep Autoencoder for Unsupervised Anomaly Detection 摘要1.介绍2.相关工作异常检测Memory networks 3. Memory-augmented Autoencoder3.1概述3.2. Encoder and Decoder3.3. Memory Module with Attention-based S…...

Mac端 DevEco Preview 窗口无法展示,提示文件中的node.dir错误
语雀知识库地址:语雀HarmonyOS知识库 飞书知识库地址:飞书HarmonyOS知识库 DevEco版本:Build Version: 3.1.0.501, built on June 20, 2023 环境信息 问题描述 打开 Preview 标签窗口后,提示Preview failed。 Run窗口提示如下 F…...

TIMO后台管理系统 Shiro 反序列化漏洞复现
0x01 产品简介 TIMO 后台管理系统,基于SpringBoot2.0 + Spring Data Jpa + Thymeleaf + Shiro 开发的后台管理系统,采用分模块的方式便于开发和维护,支持前后台模块分别部署,目前支持的功能有:权限管理、部门管理、字典管理、日志记录、文件上传、代码生成等,为快速开发后…...

3.4_1 java自制小工具 - pdf批量转图片
相关链接 目录参考文章:pdf转图片(apache pdfbox)参考文章:GUI界面-awt参考文章:jar包转exe(exe4j)参考文章:IDEA导入GIT项目参考文章:IDEA中使用Gitee管理代码gitee项目链接:pdf_2_image网盘地址…...

vue中实现数字+英文字母组合键盘
完整代码 <template><div class"login"><div click"setFileClick">欢迎使用员工自助终端</div><el-dialog title"初始化设置文件打印消耗品配置密码" :visible.sync"dialogSetFile" width"600px&quo…...

Centos服务器上根据端口号查询jar包,根据jar包查端口号
在开发springboot服务器时,经常会遇到其他人部署的java服务,需要自己维护,留下的信息又非常少。经常面临找不到jar包位置,或者不知道占用端口,不知道启动命令的问题。这里记录一下常用的centos服务器上的命令ÿ…...

数据仓库与数据挖掘复习资料
一、题型与考点[第一种] 1、解释基本概念(中英互译解释简单的含义); 2、简答题(每个10分有两个一定要记住): ① 考时间序列Time series(第六章)的基本概念含义解释作用(序列模式挖掘的作用); ② 考聚类(第五章)重点考…...

限流算法,基于go的gRPC 实现的
目录 一、单机限流 1、令牌桶算法 3、固定窗口限流算法 4、滑动窗口 二、集群限流 1、分布式固定窗口 (基于redis) 2、分布式滑动窗口 一、单机限流 1、令牌桶算法 令牌桶算法是当流量进入系统前需要获取令牌,没有令牌那么就要进行限…...

Shell中HTTP变量和文本处理
在Shell中,HTTP变量和文本处理是常见的任务之一。Shell是一个命令行解释器,可以用来自动化执行各种系统任务。在Shell中,我们可以使用各种命令和工具来处理HTTP变量和文本。 首先,让我们来看看如何在Shell中处理HTTP变量。HTTP变…...

java学习part39map
159-集合框架-Map不同实现类的对比与HashMap中元素的特点_哔哩哔哩_bilibili 1.Map 2.Entry 个人理解是c的pair,代表一个键值对。Map就是entry的叠加 3.常用方法 4.TreeMap 5.Properties...
使用sqoop操作HDFS与MySQL之间的数据互传
一,数据从HDFS中导出至MySQL中 1)开启Hadoop、mysql进程 start-all.sh/etc/init.d/mysqld start/etc/init.d/mysqld status 2)将学生数据stu_data.csv传到HDFS的/local_student目录下 在hdfs中创建目录 hdfs dfs -mkdir /local_student 上…...

Kafka使用指南
Kafka简介架构设计Kafka的架构设计关键概念Kafka的架构设计关键机制 Partition介绍Partition工作机制 应用场景ACK机制介绍ACK机制原理ACK机制对性能的影响ACK控制粒度Kafka分区数对集群性能影响调整分区优化集群性能拓展Kafka数据全局有序 Kafka简介 Kafka是由Apache软件基金…...

HarmonyOS4.0从零开始的开发教程03初识ArkTS开发语言(中)
HarmonyOS(二)初识ArkTS开发语言(中)之TypeScript入门 浅析ArkTS的起源和演进 1 引言 Mozilla创造了JS,Microsoft创建了TS,Huawei进一步推出了ArkTS。 从最初的基础的逻辑交互能力,到具备类…...

西工大计算机学院计算机系统基础实验一(函数编写1~10)
还是那句话,千万不要慌,千万不要着急,耐下性子慢慢来,一步一个脚印,把基础打的牢牢的,一样不比那些人差。回到实验本身,自从按照西工大计算机学院计算机系统基础实验一(…...

VMware 虚拟机 电脑重启后 NAT 模式连不上网络问题修复
问题描述: 昨天 VMware 安装centos7虚拟机,网络模式配置的是NAT模式,配置好后,当时能连上外网,今天电脑重启后,发现连不上外网了 检查下各个配置,都没变动,突然就连不上了 网上查了…...

【桑基图】绘制桑基图
绘制桑基图 一、绘制桑基图(1)方法一:去在线网站直接绘制(2)方法二:写html之后在vscode上运行 二、遇到的问题(1)当导入一些excel的时候,无法绘制出桑基图 一、绘制桑基图…...

ACM32F403/F433 12 位多通道,支持 MPU 存储保护功能,应用于工业控制,智能家居等产品中
ACM32F403/F433 芯片的内核基于 ARMv8-M 架构,支持 Cortex-M33 和 Cortex-M4F 指令集。芯片内核 支持一整套DSP指令用于数字信号处理,支持单精度FPU处理浮点数据,同时还支持Memory Protection Unit (MPU)用于提升应用的…...

7. 从零用Rust编写正反向代理, HTTP及TCP内网穿透原理及运行篇
wmproxy wmproxy是由Rust编写,已实现http/https代理,socks5代理, 反向代理,静态文件服务器,内网穿透,配置热更新等, 后续将实现websocket代理等,同时会将实现过程分享出来ÿ…...
树莓派超全系列教程文档--(62)使用rpicam-app通过网络流式传输视频
使用rpicam-app通过网络流式传输视频 使用 rpicam-app 通过网络流式传输视频UDPTCPRTSPlibavGStreamerRTPlibcamerasrc GStreamer 元素 文章来源: http://raspberry.dns8844.cn/documentation 原文网址 使用 rpicam-app 通过网络流式传输视频 本节介绍来自 rpica…...
React Native 导航系统实战(React Navigation)
导航系统实战(React Navigation) React Navigation 是 React Native 应用中最常用的导航库之一,它提供了多种导航模式,如堆栈导航(Stack Navigator)、标签导航(Tab Navigator)和抽屉…...

JavaScript 中的 ES|QL:利用 Apache Arrow 工具
作者:来自 Elastic Jeffrey Rengifo 学习如何将 ES|QL 与 JavaScript 的 Apache Arrow 客户端工具一起使用。 想获得 Elastic 认证吗?了解下一期 Elasticsearch Engineer 培训的时间吧! Elasticsearch 拥有众多新功能,助你为自己…...

【网络安全产品大调研系列】2. 体验漏洞扫描
前言 2023 年漏洞扫描服务市场规模预计为 3.06(十亿美元)。漏洞扫描服务市场行业预计将从 2024 年的 3.48(十亿美元)增长到 2032 年的 9.54(十亿美元)。预测期内漏洞扫描服务市场 CAGR(增长率&…...

[ICLR 2022]How Much Can CLIP Benefit Vision-and-Language Tasks?
论文网址:pdf 英文是纯手打的!论文原文的summarizing and paraphrasing。可能会出现难以避免的拼写错误和语法错误,若有发现欢迎评论指正!文章偏向于笔记,谨慎食用 目录 1. 心得 2. 论文逐段精读 2.1. Abstract 2…...
数据链路层的主要功能是什么
数据链路层(OSI模型第2层)的核心功能是在相邻网络节点(如交换机、主机)间提供可靠的数据帧传输服务,主要职责包括: 🔑 核心功能详解: 帧封装与解封装 封装: 将网络层下发…...

C++ 求圆面积的程序(Program to find area of a circle)
给定半径r,求圆的面积。圆的面积应精确到小数点后5位。 例子: 输入:r 5 输出:78.53982 解释:由于面积 PI * r * r 3.14159265358979323846 * 5 * 5 78.53982,因为我们只保留小数点后 5 位数字。 输…...
浅谈不同二分算法的查找情况
二分算法原理比较简单,但是实际的算法模板却有很多,这一切都源于二分查找问题中的复杂情况和二分算法的边界处理,以下是博主对一些二分算法查找的情况分析。 需要说明的是,以下二分算法都是基于有序序列为升序有序的情况…...

云原生玩法三问:构建自定义开发环境
云原生玩法三问:构建自定义开发环境 引言 临时运维一个古董项目,无文档,无环境,无交接人,俗称三无。 运行设备的环境老,本地环境版本高,ssh不过去。正好最近对 腾讯出品的云原生 cnb 感兴趣&…...

【JVM面试篇】高频八股汇总——类加载和类加载器
目录 1. 讲一下类加载过程? 2. Java创建对象的过程? 3. 对象的生命周期? 4. 类加载器有哪些? 5. 双亲委派模型的作用(好处)? 6. 讲一下类的加载和双亲委派原则? 7. 双亲委派模…...