SQLiteC/C++接口详细介绍之sqlite3类（十三）

news2024/11/25 20:50:38

返回目录：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));

                        // 将列值更改为BLOB
                        sqlite3_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.coloradmin.cn/o/1522881.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

VMware Fusion 13.5.1 OEM BIOS Version - 在 macOS 中运行 Windows 虚拟机的最佳方式

VMware Fusion 13.5.1 OEM BIOS Version - 在 macOS 中运行 Windows 虚拟机的最佳方式

VMware Fusion 13.5.1 OEM BIOS Version VMware Fusion 13 原版 App 中集成 OEM BIOS 请访问原文链接&#xff1a;https://sysin.org/blog/vmware-fusion-13-oem/&#xff0c;查看最新版。原创作品&#xff0c;转载请保留出处。 作者主页&#xff1a;sysin.org 使用 VMware …
阅读更多...
51单片机-AT24C02(I2C总线）

51单片机-AT24C02(I2C总线）

目录 一&#xff0c;介绍及元件工作原理 7.时序结构&#xff08;重要&#xff09; 8.i2C总线数据帧&#xff08;重要&#xff09; 二&#xff0c;应用 一&#xff0c;介绍及元件工作原理 1.元件介绍 2.存储器 3.地址总线和数据总线 地址总线只能一次选中一行 4.引脚及应用…
阅读更多...
【ESP32 IDF】I2C的使用

【ESP32 IDF】I2C的使用

文章目录 前言一、I2C驱动使用的步骤二、I2C的使用2.1 配置驱动程序2.2 安装驱动程序2.3 主机写入数据写入数据的过程接收数据的过程 总结 前言 ESP32是一款强大的微控制器&#xff0c;广泛应用于物联网&#xff08;IoT&#xff09;和嵌入式系统开发。它具备丰富的硬件接口&am…
阅读更多...
前端Vue与uni-app中的九宫格、十二宫格和十五宫格菜单组件实现

前端Vue与uni-app中的九宫格、十二宫格和十五宫格菜单组件实现

在前端 Vue 开发中&#xff0c;我们经常会遇到需要开发九宫格、十二宫格和十五宫格菜单按钮的需求。这些菜单按钮通常用于展示不同的内容或功能&#xff0c;提供给用户快速访问和选择。 一、引言 在前端开发中&#xff0c;九宫格、十二宫格和十五宫格菜单按钮是一种常见的布局…
阅读更多...
提升物流效率，快递平台实战总结与分享

提升物流效率，快递平台实战总结与分享

随着电商行业的蓬勃发展&#xff0c;物流配送服务变得愈发重要。快递平台作为连接电商企业和消费者的桥梁&#xff0c;扮演着至关重要的角色。本篇博客将分享快递平台实战经验&#xff0c;总结关键要点&#xff0c;帮助物流从业者提升物流效率、优化服务质量。 ### 快递平台实…
阅读更多...
【四 （5）数据可视化之 Pyecharts常用图表及代码实现 】

【四 （5）数据可视化之 Pyecharts常用图表及代码实现 】

目录 文章导航一、介绍[✨ 特性]二、安装Pyecharts三、主题风格四、占比类图表1、饼图2、环形图3、玫瑰图4、玫瑰图-多图5、堆叠条形图6、百分比堆叠条形图 五、比较排序类1、条形图2、雷达图3、词云图4、漏斗图 六、趋势类图表1、折线图2、堆叠折线图3、面积图4、堆叠面积图 七…
阅读更多...
自动点击脚本

自动点击脚本

一个简单的自动点击脚本 配置文件张这样&#xff0c;需要的自己截图 excel配置文件 #!/usr/bin/python3# sys.path.append("C:\\Users\苏\\.vscode\\extensions\\ms-python.vscode-pylance-2023.10.50\\dist\\typeshed-fallback\\stubs\\PyAutoGUI") # print(sys.…
阅读更多...
python入门（二）

python入门（二）

python的安装很方便&#xff0c;我们这里就不再进行讲解&#xff0c;大家可以自己去搜索视频。下面分享一下Python的入门知识点。 执行命令的方式 在安装好python后&#xff0c;有两种方式可以执行命令&#xff1a; 命令行程序文件&#xff0c;后缀名为.py 对于命令行&…
阅读更多...
Javaweb day17 day18 day19

Javaweb day17 day18 day19

mysql-DDL 数据库操作 写法 客户端工具 &#xff08;也可以使用idea&#xff09; 表 写法 约束 数据类型 案例 写法 表的查询修改删除 写法 删除
阅读更多...
鲸鱼优化算法双馈风电机组一次调频三机九节点虚拟惯量下垂控制DFIG matlab/simulink

鲸鱼优化算法双馈风电机组一次调频三机九节点虚拟惯量下垂控制DFIG matlab/simulink

以频率偏差变化最小为优化目标&#xff0c;采用鲸鱼算法优化风电机组一次调频控制系数。 采用matlab.m文件与simulink.slx文件联合。 系统频率优化结果 鲸鱼算法 时域模型
阅读更多...
[MTK6771] android13系统启用OMAPI 支持esim.me

[MTK6771] android13系统启用OMAPI 支持esim.me

OMAPI是啥&#xff1f;看看谷歌的解释&#xff1a; 说了一大堆懂的人不需要看&#xff0c;不懂的还是看不懂&#xff0c;我就是后者 总之说人话就是&#xff0c;像SIM卡&#xff0c;NFC这类模块需要用到这个东西&#xff0c;那么接着往下看 上层APP想要使用这个OMAPI供应商稳…
阅读更多...
C语言-strtok（切片的使用）

C语言-strtok（切片的使用）

strtok&#xff08;切片的使用&#xff09; 使用规则 使用的基本情况 strcpy 第二次调用的时候传的是空指针 所以打印出来的是 每一次调用函数都会把当前函数的地址记住 所以二次调用的时候 传的是null 连起始位置都不传了 只是传null 但是需要知道的是 当知道三段 你调用第…
阅读更多...
Golang高效流控实践

Golang高效流控实践

流控对于构建高可靠弹性系统至关重要&#xff0c;本文介绍了Golang内置的流控组件&#xff0c;通过该组件就可以打造适合各种业务场景的流控系统。原文: Rate Limiting in Go: Controlling Traffic with Efficiency[1] Jon Cellier Unsplash 导言 流控(Rate limiting)是构建可扩…
阅读更多...
element-plus怎么修改表单中的label字体颜色及大小

element-plus怎么修改表单中的label字体颜色及大小

问题描述&#xff1a; 当我们在vue3中使用element-plus组件库提供的表单组件时&#xff0c;有时我们需要修改表单中label的字体颜色等属性&#xff0c;这是如果直接选中label的class进行修改是不起作用的&#xff0c;我们只需深度选择即可选中并进行修改。 比如&#xff1a; …
阅读更多...
阿里二面：什么情况会发生Full GC？如何避免频繁Full GC？

阿里二面：什么情况会发生Full GC？如何避免频繁Full GC？

阿里二面&#xff1a;什么情况会发生Full GC&#xff1f;如何避免频繁Full GC&#xff1f; Minor GC、Major GC 和 Full GC区别&#xff1f; Minor GC、Major GC和Full GC是垃圾回收中的三个重要概念&#xff0c;它们描述了垃圾回收的不同阶段和范围&#xff1a; Minor GC&am…
阅读更多...
旋转花键的制造工艺

旋转花键的制造工艺

旋转花键的制造工艺是一门精细的技术&#xff0c;涉及多个步骤和精细的操作&#xff0c;以确保最终产品的质量和性能&#xff0c;下面简单介绍下旋转花键的制造工艺。 1、原材料准备&#xff1a;制造旋转花键的核心是选择合适的材料&#xff0c;根据花键的规格和性能要求&#…
阅读更多...
lftp服务与http服务(包含scp服务)详解

lftp服务与http服务(包含scp服务)详解

目录 前言: 1.lftp服务 1.1lftp服务的介绍以及应用场景 1.2安装lftp服务 1.2进行配置 1.3实际操作 2.http服务 2.1http服务介绍以及应用场景 2.1安装httpd服务 2.2进行配置 2.3实际操作 3.scp服务 3.1scp服务的介绍以及应用场景 致谢: 前言: 在当今互联网…
阅读更多...
由浅到深认识C语言（11）：结构体

由浅到深认识C语言（11）：结构体

该文章Github地址&#xff1a;https://github.com/AntonyCheng/c-notes 在此介绍一下作者开源的SpringBoot项目初始化模板&#xff08;Github仓库地址&#xff1a;https://github.com/AntonyCheng/spring-boot-init-template & CSDN文章地址&#xff1a;https://blog.csdn…
阅读更多...
一起学数据分析_2

一起学数据分析_2

写在前面&#xff1a;代码运行环境为jupyter&#xff0c;如果结果显示不出来的地方就加一个print()函数。 一、数据基本处理 缺失值处理&#xff1a; import numpy as np import pandas as pd#加载数据train.csv df pd.read_csv(train_chinese.csv) df.head()# 查看数据基本…
阅读更多...
数据结构的概念大合集01（含数据结构的基本定义，算法及其描述）

数据结构的概念大合集01（含数据结构的基本定义，算法及其描述）

概念大合集01 1、数据结构基础的定义2、数据结构2.1 数据元素之间关系的集合2.2数据结构的三要素2.2.1数据的逻辑结构2.2.2数据的存储&#xff08;物理&#xff09;结构2.2.3数据的运算 3、数据类型4、抽象数据类型类型&#xff08;ADT&#xff09;5、算法及其描述5.1算法的5个…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023