SQLiteC/C++接口详细介绍之sqlite3类(十三)

返回目录:SQLite—免费开源数据库系列文章目录 

上一篇:SQLiteC/C++接口详细介绍之sqlite3类(十二)

下一篇:SQLiteC/C++接口详细介绍之sqlite3类(十四)(未发表)

40.sqlite3_preupdate_blobwrite

用于将预更新钩子中的列值更改为BLOB值。

SQLite3预更新钩子是一种特殊类型的回调函数,在执行INSERT、UPDATE、DELETE语句时触发,允许您查看更改之前和之后的列值,并且可以修改列值、阻止更改、执行额外的更新并执行其他自定义操作。

sqlite3_preupdate_blobwrite函数是预更新钩子的一种特殊类型,允许您将列值更改为BLOB值。这是在预更新钩子中更新大型二进制数据类型(例如图像或文件)时非常有用的情况。

以下是sqlite3_preupdate_blobwrite函数的声明:

void sqlite3_preupdate_blobwrite(sqlite3 *db, void *pAux, int iKey1, int iKey2, int iIdx, const void *pData, int nData);

其中,sqlite3是指向SQLite3数据库实例的指针,pAux是指向与预更新钩子相关联的自定义数据的指针,iKey1、iKey2和iIdx参数指定正在更新的行和列的索引。pData和nData参数指定要写入的BLOB数据以及数据的长度。

注意:

sqlite3_preupdate_blobwrite函数需要在预更新钩子中注册,使用sqlite3session_preupdate_hook函数将其注册到数据库会话中。

下面是一个简单的示例,展示如何使用sqlite3_preupdate_blobwrite函数在SQLite3中预更新BLOB列:

#include <sqlite3.h>
#include <stdio.h>
static int preupdate_callback(void *pCtx, sqlite3 *db, int opcode, char const *dbname, char const *tblname, sqlite3_int64 rowid) {if (opcode == SQLITE_UPDATE) {printf("PRE-UPDATE HOOK: table=%s, rowid=%lld\n", tblname, rowid);// 获取预更新钩子上下文sqlite3session *pSession = (sqlite3session *)pCtx;sqlite3_preupdate_data *pChanges = sqlite3session_changeset(pSession, db, tblname);while (pChanges) {if (pChanges->op == SQLITE_UPDATE && pChanges->pChanges->nCol > 0) {for (int i = 0; i < pChanges->pChanges->nCol; i++) {sqlite3_value *pVal = pChanges->pChanges->apNew[i];if (pVal && sqlite3_value_type(pVal) == SQLITE_BLOB) {printf("COLUMN '%s' WILL BE UPDATED TO BLOB\n", sqlite3_column_name(pChanges->pStmt, i));// 将列值更改为BLOBsqlite3_preupdate_blobwrite(db, NULL, pChanges->iKey1, pChanges->iKey2, i, sqlite3_value_blob(pVal), sqlite3_value_bytes(pVal));}}}pChanges = pChanges->pNext;}}return SQLITE_OK;
}
int main(int argc, char* argv[]) {sqlite3* db;sqlite3_session *pSession;int rc;// 打开数据库rc = sqlite3_open("test.db", &db);if (rc != SQLITE_OK) {printf("Can't open database: %s\n", sqlite3_errmsg(db));sqlite3_close(db);return 1;}// 创建数据库会话rc = sqlite3session_create(db, "temp.session", &pSession);if (rc != SQLITE_OK) {printf("Can't create session: %s\n", sqlite3_errmsg(db));sqlite3_close(db);return 1;}// 注册预更新钩子rc = sqlite3session_preupdate_hook(pSession, preupdate_callback, pSession);if (rc != SQLITE_OK) {printf("Can't register preupdate hook: %s\n", sqlite3_errmsg(db));sqlite3_close(db);return 1;}// 执行UPDATE语句rc = sqlite3_exec(db, "UPDATE my_table SET my_blob_column=?", NULL, NULL, NULL);if (rc != SQLITE_OK) {printf("Can't execute statement: %s\n", sqlite3_errmsg(db));sqlite3_close(db);return 1;}// 关闭数据库和会话sqlite3session_delete(pSession);sqlite3_close(db);return 0;
}

在上面的示例代码中,我们首先定义了一个预更新钩子回调函数preupdate_callback。当SQLITE_UPDATE操作码被传递给钩子时,我们遍历所有正在更新的列,并将值为BLOB的列更改为新的BLOB值。在此过程中,我们使用sqlite3_preupdate_blobwrite函数将列值更改为新值,并打印一条调试消息以示成功。

接着,我们创建一个SQLite3会话并将预更新钩子注册到会话中。最后,我们执行一个UPDATE查询更新带有一个BLOB列的表的行。更改将被捕获并处理,然后将提交到数据库。

注意:

预更新钩子仅在SQLite3的session扩展模块中可用。如果尝试将预更新钩子用于普通的SQLite3会话,则可能会收到错误消息。

41.sqlite3_preupdate_count

sqlite3_preupdate_count是SQLite3 C API提供的一个函数,它用于获取当前预更新操作中的更改数量。

SQLite3预更新钩子是一种特殊类型的回调函数,在执行INSERT、UPDATE、DELETE语句时触发,允许您查看更改之前和之后的列值,并且可以修改列值、阻止更改、执行额外的更新并执行其他自定义操作。

sqlite3_preupdate_count函数允许您获取当前预更新操作中的更改数量,这对于在预更新钩子中执行特定操作时非常有用。例如,您可能需要查看更改的列是否满足特定的条件,如果不符合,则阻止更改并抛出错误。

以下是sqlite3_preupdate_count函数的声明:

int sqlite3_preupdate_count(sqlite3 *db);

其中,sqlite3是指向SQLite3数据库实例的指针。该函数返回当前预更新操作中更改的列数。

注意:sqlite3_preupdate_count函数必须在预更新钩子中调用。预更新钩子由sqlite3session_preupdate_hook函数注册,并在执行预更新操作时调用。

下面是一个简单的示例,展示如何在SQLite3预更新钩子中使用sqlite3_preupdate_count函数:

#include <sqlite3.h>
#include <stdio.h>
static int preupdate_callback(void *pCtx, sqlite3 *db, int opcode, char const *dbname, char const *tblname, sqlite3_int64 rowid) {if (opcode == SQLITE_UPDATE) {printf("PRE-UPDATE HOOK: table=%s, rowid=%lld\n", tblname, rowid);// 获取预更新操作中更改的列数int nChanges = sqlite3_preupdate_count(db);printf("NUMBER OF CHANGES: %d\n", nChanges);// 遍历预更新操作中的列for (int i = 0; i < nChanges; i++) {sqlite3_preupdate_data const *p = sqlite3_preupdate_data_get(db, i);if (p && p->op == SQLITE_UPDATE && sqlite3_column_type(p->pStmt, p->iNew) == SQLITE_INTEGER) {int newValue = sqlite3_column_int(p->pStmt, p->iNew);printf("COLUMN #%d WILL BE UPDATED TO %d\n", i, newValue);// 检查更改的列是否符合特定条件if (newValue < 0 || newValue > 100) {printf("INVALID VALUE FOR COLUMN #%d\n", i);// 阻止更改并抛出错误sqlite3_preupdate_rollback(db);printf("ROLLBACK PRE-UPDATE\n");return SQLITE_ERROR;}}}}return SQLITE_OK;
}
int main(int argc, char* argv[]) {sqlite3* db;sqlite3_session *pSession;int rc;// 打开数据库rc = sqlite3_open("test.db", &db);if (rc != SQLITE_OK) {printf("Can't open database: %s\n", sqlite3_errmsg(db));sqlite3_close(db);return 1;}// 创建数据库会话rc = sqlite3session_create(db, "temp.session", &pSession);if (rc != SQLITE_OK) {printf("Can't create session: %s\n", sqlite3_errmsg(db));sqlite3_close(db);return 1;}// 注册预更新钩子rc = sqlite3session_preupdate_hook(pSession, preupdate_callback, NULL);if (rc != SQLITE_OK) {printf("Can't register preupdate hook: %s\n", sqlite3_errmsg(db));sqlite3_close(db);return 1;}// 执行UPDATE语句rc = sqlite3_exec(db, "UPDATE my_table SET my_column=my_column+1", NULL, NULL, NULL);if (rc != SQLITE_OK) {printf("Can't execute statement: %s\n", sqlite3_errmsg(db));sqlite3_close(db);return 1;}// 关闭数据库和会话sqlite3session_delete(pSession);sqlite3_close(db);return 0;
}

在上面的示例代码中,我们首先定义了一个预更新钩子回调函数preupdate_callback。当SQLITE_UPDATE操作码被传递给钩子时,我们使用sqlite3_preupdate_count函数获取当前预更新操作中的更改数量。然后,我们遍历所有更改的列并检查它们是否符合特定条件,如果不符合,则阻止更改并抛出错误。在此过程中,我们还使用sqlite3_preupdate_rollback函数阻止更改并恢复当前事务的其他更改。需

注意:

如果在预更新钩子中使用sqlite3_preupdate_rollback函数,则必须返回SQLITE_ERROR以指示错误。接着,我们创建一个SQLite3会话并将预更新钩子注册到会话中。最后,我们执行一个UPDATE查询,将带有一个整数列的表的行添加1。所有更改将被捕获并处理,然后将提交到数据库。预更新钩子仅在SQLite3的session扩展模块中可用。如果尝试将预更新钩子用于普通的SQLite3会话,则可能会收到错误消息。

42.sqlite3_preupdate_depth

用于获取当前预更新操作的嵌套深度。

SQLite3预更新钩子是一种特殊类型的回调函数,在执行INSERT、UPDATE、DELETE语句时触发,允许您查看更改之前和之后的列值,并且可以修改列值、阻止更改、执行额外的更新并执行其他自定义操作。

sqlite3_preupdate_depth函数允许您获取当前预更新操作中的嵌套深度,也就是当前预更新的预更新操作的数量。这对于在嵌套的预更新操作中执行特定操作时非常有用。例如,当更改发生时,您可能需要查找更改的列所依赖的其他列,这可能需要深入预更新操作树来查找列。

以下是sqlite3_preupdate_depth函数的声明:

int sqlite3_preupdate_depth(sqlite3 *db);

其中,sqlite3是指向SQLite3数据库实例的指针。该函数返回当前预更新操作的嵌套深度,如果没有嵌套操作,则返回0。

需要注意的是,sqlite3_preupdate_depth函数必须在预更新钩子中调用。预更新钩子由sqlite3session_preupdate_hook函数注册,并在执行预更新操作时调用。

下面是一个简单的示例,展示如何在SQLite3预更新钩子中使用sqlite3_preupdate_depth函数:

#include <sqlite3.h>
#include <stdio.h>
static int preupdate_callback(void *pCtx, sqlite3 *db, int opcode, char const *dbname, char const *tblname, sqlite3_int64 rowid) {if (opcode == SQLITE_UPDATE) {printf("PRE-UPDATE HOOK: table=%s, rowid=%lld\n", tblname, rowid);// 获取预更新操作的嵌套深度int depth = sqlite3_preupdate_depth(db);printf("PRE-UPDATE DEPTH: %d\n", depth);// 检查更改的列是否依赖于其他列sqlite3_preupdate_data const *p = sqlite3_preupdate_data_get(db, 0);if (depth > 0 && p->op == SQLITE_UPDATE && sqlite3_column_type(p->pStmt, p->iNew) == SQLITE_INTEGER) {int newValue = sqlite3_column_int(p->pStmt, p->iNew);printf("COLUMN WILL BE UPDATED TO %d\n", newValue);// 获取依赖列的值sqlite3_preupdate_data const *pDep = sqlite3_preupdate_data_get_parent(db, 0);if (pDep && pDep->op == SQLITE_UPDATE && sqlite3_column_type(pDep->pStmt, pDep->iNew) == SQLITE_INTEGER) {int depValue = sqlite3_column_int(pDep->pStmt, pDep->iNew);printf("COLUMN DEPENDS ON ANOTHER COLUMN WITH VALUE %d\n", depValue);}}}return SQLITE_OK;
}
int main(int argc, char* argv[]) {sqlite3* db;sqlite3_session *pSession;int rc;// 打开数据库rc = sqlite3_open("test.db", &db);if (rc != SQLITE_OK) {printf("Can't open database: %s\n", sqlite3_errmsg(db));sqlite3_close(db);return 1;}// 创建数据库会话rc = sqlite3session_create(db, "temp.session", &pSession);if (rc != SQLITE_OK) {printf("Can't create session: %s\n", sqlite3_errmsg(db));sqlite3_close(db);return 1;}// 注册预更新钩子rc = sqlite3session_preupdate_hook(pSession, preupdate_callback, NULL);if (rc != SQLITE_OK) {printf("Can't register preupdate hook: %s\n", sqlite3_errmsg(db));sqlite3_close(db);return 1;}// 执行UPDATE语句rc = sqlite3_exec(db, "UPDATE my_table SET my_column=my_column+1", NULL, NULL, NULL);if (rc != SQLITE_OK) {printf("Can't execute statement: %s\n", sqlite3_errmsg(db));sqlite3_close(db);return 1;}// 关闭数据库和会话sqlite3session_delete(pSession);sqlite3_close(db);return 0;
}

在上面的示例代码中,我们首先定义了一个预更新钩子回调函数preupdate_callback。当SQLITE_UPDATE操作码被传递给钩子时,我们使用sqlite3_preupdate_depth函数获取当前预更新操作中的嵌套深度。然后,如果更改的列依赖于其他列,则我们获取依赖列的值并打印一条调试消息。

在此过程中,我们还使用sqlite3_preupdate_data_get_parent函数获取当前预更新操作的父级预更新操作。需要注意的是,只有在预更新操作嵌套时,该函数才返回非空值。

接着,我们创建一个SQLite3会话并将预更新钩子注册到会话中。最后,我们执行一个UPDATE查询,将带有一个整数列的表的行添加1。所有更改将被捕获并处理,然后将提交到数据库。

需要注意的是,预更新钩子仅在SQLite3的session扩展模块中可用。如果尝试将预更新钩子用于普通的SQLite3会话,则可能会收到错误消息。

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

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

相关文章

[SaaS] 淘宝设AI

“淘宝设计AI” 让国际大牌造世界双11超级品牌 超级发布https://mp.weixin.qq.com/s/xFVDARQHxlweKAYG91DtYw下面是一个完整的品牌营销海报设计流程&#xff0c;AIGC起到了巨大作用&#xff0c;但是仍然很难去一步解决这个问题&#xff0c;还是逐步修改的一个过程。 Midjouner…

26.网络游戏逆向分析与漏洞攻防-网络通信数据包分析工具-实现生成日志文件的功能

免责声明&#xff1a;内容仅供学习参考&#xff0c;请合法利用知识&#xff0c;禁止进行违法犯罪活动&#xff01; 如果看不懂、不知道现在做的什么&#xff0c;那就跟着做完看效果 内容参考于&#xff1a;易道云信息技术研究院VIP课 上一个内容&#xff1a;25.利用全新的通…

Mybatis sql 控制台格式化

package com.mysql; import org.apache.commons.lang.StringUtils; import org.apache.ibatis.logging.Log;import java.util.*;/*** Description: sql 格式化* Author: DingQiMing* Date: 2023-07-17* Version: V1.0*/ public class StdOutImpl implements Log {private stati…

别忽视平台的重要性

目录 前言&#xff1a; 与谁在一起&#xff0c;真的很重要 别把运气当才华&#xff0c;别把平台当本事 珍惜平台&#xff0c;用好平台 前言&#xff1a; 对于做技术开发的人来说&#xff0c;一头扎进技术里面去固然重要&#xff0c;但是很多时候&#xff0c;也要看看人际交…

提高安全投资回报:威胁建模和OPEN FAIR™风险分析

对大多数人和企业来说&#xff0c;安全意味着一种成本。但重要的是如何获得适合的量&#xff0c;而不是越多越好。然而&#xff0c;你如何决定什么时候可以有足够的安全性&#xff0c;以及你如何获得它&#xff1f;则完全是另一回事。 该篇文章是由The Open Group安全论坛主办&…

英国伦敦交易所股票清单列表数据API接口

# Restful API https://tsanghi.com/api/fin/stock/XLON/list?token{token}更新时间&#xff1a;收盘后3~4小时。 更新周期&#xff1a;每天。 请求方式&#xff1a;GET。 # 测试&#xff1a;返回不超过10条数据&#xff08;2年历史&#xff09; https://tsanghi.com/api/fin/…

Postman进行Websocket接口测试

Postman进行Websocket接口测试 前言下载地址使用1、new一个一个WebSocket Request2、填写内容和需要请求头携带的参数3、表示成功 网页请求101表示握手成功 前言 有些较低版本postman不支持websocket接口测试&#xff0c;如果根据此文未找到创建websocket接口测试的目录&#…

SQLiteC/C++接口详细介绍之sqlite3类(十二)

返回目录&#xff1a;SQLite—免费开源数据库系列文章目录 上一篇&#xff1a;SQLiteC/C接口详细介绍之sqlite3类&#xff08;十一&#xff09; 下一篇&#xff1a;SQLiteC/C接口详细介绍之sqlite3类&#xff08;十三&#xff09; ​37.sqlite3_load_extension 用于在SQLit…

springboot“爱相连”儿童慈善管理系统的设计与实现

摘要 随着网络科技的不断发展以及人们经济水平的逐步提高&#xff0c;网络技术如今已成为人们生活中不可缺少的一部分&#xff0c;而信息管理系统是通过计算机技术&#xff0c;针对用户需求开发与设计&#xff0c;该技术尤其在各行业领域发挥了巨大的作用&#xff0c;有效地促…

Unity AI Navigation插件快速使用方法

AI Navigation插件使您能够创建能够在游戏世界中智能移动的角色。这些角色利用的是根据场景几何结构自动生成的导航网格。障碍物可以让您在运行时改变角色的导航路径。 演示使用的Unity版本为Tuanjie 1.0.0,团结引擎是Unity中国的引擎研发团队基于Unity 2022 LTS版本为中国开发…

免费阅读篇 | 芒果YOLOv8改进111:注意力机制CBAM:轻量级卷积块注意力模块,无缝集成到任何CNN架构中,开销可以忽略不计

&#x1f4a1;&#x1f680;&#x1f680;&#x1f680;本博客 改进源代码改进 适用于 YOLOv8 按步骤操作运行改进后的代码即可 该专栏完整目录链接&#xff1a; 芒果YOLOv8深度改进教程 该篇博客为免费阅读内容&#xff0c;YOLOv8CBAM改进内容&#x1f680;&#x1f680;&am…

JAVA基础—JVM内存结构基础需知

1.JVM内存结构 JVM内存结构分为5个区域&#xff1a;方法区&#xff0c;虚拟机栈&#xff0c;本地方法栈、堆、程序计数器。 1.方法区&#xff08;Method Area&#xff09;&#xff1a;用于存储类的结构信息、常量、静态变量、即使编译器编译后的代码等数据。方法区也是所有线…