SQLite事务在断电、系统崩溃场景下的可靠性验证咨询

是的，SQLite的事务机制（配合你使用的BEGIN TRANSACTION和COMMIT）完全可以在断电、欠压或操作系统崩溃这类故障场景下保障数据一致性——崩溃发生后，数据库要么完整保留事务提交后的状态，要么回滚到事务开始前的状态，不会出现部分更新的不一致情况。这是SQLite对ACID特性中原子性的核心保障，依赖于它的事务日志（WAL或rollback journal）实现故障恢复。

不过你的代码存在几个关键问题，会影响事务可靠性和安全性，需要修正：

1. 错误处理严重缺失 #

你的代码几乎没有检查关键操作的返回值，一旦某步执行失败（比如sqlite3_prepare_v2编译SQL失败、sqlite3_step执行语句出错），程序会继续执行后续逻辑，这可能导致事务处于异常状态，甚至破坏数据一致性：

• sqlite3_open失败后，后续操作仍会继续执行，可能引发空指针操作
• 没有检查sqlite3_step的返回值（正确成功返回值为SQLITE_DONE），无法判断事务启动、更新、提交是否成功
• 一旦某步出错，未执行ROLLBACK回滚事务，直接提交会导致数据库处于未定义状态

2. 存在严重SQL注入风险 #

你通过字符串拼接构造UPDATE语句，若用户输入的desc包含单引号（比如O'Neil），会直接破坏SQL语法，甚至被利用执行恶意操作。必须使用参数化查询规避该风险。

3. 事务流程不严谨 #

事务的正确流程应为：启动事务 → 执行操作 → 检查结果，成功则提交，失败则回滚 → 清理资源。你的代码未处理失败回滚的分支。

改进后的代码示例 #

#include <stdio.h>
#include <string.h>
#include <sqlite3.h>

int main(void) {
    sqlite3 *db_ptr = NULL;
    sqlite3_stmt *update_stmt = NULL;
    char desc[25];
    int ret = SQLITE_OK;

    // 打开数据库，失败直接退出
    ret = sqlite3_open("stock.db", &db_ptr);
    if (ret != SQLITE_OK) {
        printf("Database opening error: %s\n", sqlite3_errmsg(db_ptr));
        goto cleanup;
    }

    printf("Modify description: ");
    gets_s(desc, 24);

    // 启动事务
    ret = sqlite3_exec(db_ptr, "BEGIN TRANSACTION;", NULL, NULL, NULL);
    if (ret != SQLITE_OK) {
        printf("Failed to start transaction: %s\n", sqlite3_errmsg(db_ptr));
        goto rollback_and_cleanup;
    }

    // 使用参数化查询构造UPDATE语句
    const char *update_sql = "UPDATE tbl_stock SET DESCRIPTION = ? WHERE BCID = '900012345';";
    ret = sqlite3_prepare_v2(db_ptr, update_sql, -1, &update_stmt, NULL);
    if (ret != SQLITE_OK) {
        printf("Failed to prepare update statement: %s\n", sqlite3_errmsg(db_ptr));
        goto rollback_and_cleanup;
    }

    // 绑定参数到占位符
    ret = sqlite3_bind_text(update_stmt, 1, desc, -1, SQLITE_TRANSIENT);
    if (ret != SQLITE_OK) {
        printf("Failed to bind parameter: %s\n", sqlite3_errmsg(db_ptr));
        goto rollback_and_cleanup;
    }

    // 执行UPDATE语句
    ret = sqlite3_step(update_stmt);
    if (ret != SQLITE_DONE) {
        printf("Failed to execute update: %s\n", sqlite3_errmsg(db_ptr));
        goto rollback_and_cleanup;
    }

    // 提交事务
    ret = sqlite3_exec(db_ptr, "COMMIT;", NULL, NULL, NULL);
    if (ret != SQLITE_OK) {
        printf("Failed to commit transaction: %s\n", sqlite3_errmsg(db_ptr));
        goto rollback_and_cleanup;
    }

    printf("Stock description updated successfully.\n");
    goto cleanup;

rollback_and_cleanup:
    // 出错时回滚事务
    if (db_ptr != NULL) {
        sqlite3_exec(db_ptr, "ROLLBACK;", NULL, NULL, NULL);
    }

cleanup:
    // 清理资源
    if (update_stmt != NULL) {
        sqlite3_finalize(update_stmt);
    }
    if (db_ptr != NULL) {
        sqlite3_close(db_ptr);
    }
    return ret != SQLITE_OK ? 1 : 0;
}

额外说明 #

• SQLite从3.7.0版本开始默认使用WAL（Write-Ahead Logging）模式，相比传统DELETE模式，WAL在崩溃恢复时更高效，且支持读写并发。若你的数据库仍使用DELETE模式，可通过PRAGMA journal_mode=WAL;切换。
• 无论使用哪种日志模式，SQLite都会在崩溃后自动执行恢复流程，确保数据库回到一致状态，前提是你正确使用事务的BEGIN/COMMIT/ROLLBACK逻辑。

内容的提问来源于stack exchange，提问作者ordinary_guy