错误：从 fork() 子调用 sqlite3_exec() 时数据库被锁定

Question

我有一个服务器/客户端程序，服务器为每个连接的客户端生成一个带有 fork() 的子程序。然后，客户端向服务器发送命令以在 sqlite3 数据库上执行某些查询（INSERT INTO、SELECT、DELETE FROM）。
注意：我在 fork() 之后打开数据库，如下所示：@ 987654321@ 2.6

问题

当 1 个客户端连接时完美运行，但当有 2 个客户端连接时：当其中一个执行修改数据库的第一个查询（例如：INSERT INTO）时，从那时起只有它可以继续修改。其余的得到错误：数据库已锁定。即使在阻塞.db的客户端终止后，对方仍然无法修改。

我试过了：

• PRAGMA journal_mode=wal 在 sqlite3 终端中
• 手动执行BEGIN TRANSACTION;在INSERT查询之前和COMMIT;之后
• sqlite3_close(db) 在 INSERT 查询之后并在之后重新打开它

观察：

我知道使用线程可能会更安全并且可以解决问题，但我想在更改整个项目结构之前尝试使用 fork() 进行所有操作。

服务器代码（我删除了不相关的代码部分）：

int main () {
   sqlite3* db;
   //code for connection...
   while (1) {
        client = accept(sd, (struct sockaddr *) &from, &length);
        if (-1 == (pid = fork())) {
            perror("Error at fork");
        }
        if (pid == 0) {
            if (sqlite3_open("./Database.db", &db))
            perror("Error: Could not open database.\n")
            while (1) {
                sprintf(query, "INSERT INTO table VALUES ('%s','%s','%s','%s','%s','%s');",string1, string2,string3,string4,string5,string6);
                if(sqlite3_exec(db, query, NULL, 0, &error) != SQLITE_OK){
                      printf("%s", sqlite3_errmsg(db));
                      fflush(stdout);
                }
         }
} 

感谢您的宝贵时间！

Answer 1

回答

问题是数据库一次只能与一个进程通信，所以我在每次查询之前和之后打开和关闭数据库，现在它可以正常工作了。
现在仍然会出现的唯一问题是如果多个进程同时运行查询，但这在我的程序中不会发生。
解决方案： 这可以通过使用线程和互斥体而不是 fork() 来解决。
感谢您的帮助

Answer 2

这是一个最小的测试程序，它派生出一堆子进程，所有这些子进程都试图一次将单行插入到数据库中，而没有事务。我无法复制您的结果 - 即使没有繁忙的超时，也有多个进程能够插入至少一些数据（尽管在这种情况下会出现很多锁定错误）。

这是否与您在尝试时看到的行为相同？

#include <sqlite3.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <unistd.h>

#define TRIALS 5

// The smaller the timeout, the more likely to get a locked error.
#define TIMEOUT 200

int main(void) {
  for (int n = 0; n < TRIALS; n++) {
    pid_t pid = fork();
    if (pid < 0) {
      perror("fork");
      return EXIT_FAILURE;
    }
    if (pid == 0) {
      sqlite3 *db;
      sqlite3_stmt *stmt;
      // test.db needs a table named test like:
      // CREATE TABLE test(a,b)
      if (sqlite3_open("test.db", &db) != SQLITE_OK) {
        fprintf(stderr, "sqlite3_open in child %d: %s\n", n,
                sqlite3_errmsg(db));
        sqlite3_close(db);
        return EXIT_FAILURE;
      }
      sqlite3_busy_timeout(db, TIMEOUT);
      if (sqlite3_prepare_v2(db, "INSERT INTO test VALUES (?, ?)", -1, &stmt,
                             NULL) != SQLITE_OK) {
        fprintf(stderr, "sqlite3_prepare_v2 in child %d: %s\n", n,
                sqlite3_errmsg(db));
        sqlite3_close(db);
        return EXIT_FAILURE;
      }
      sqlite3_bind_int(stmt, 1, n);
      for (int m = 0; m < TRIALS; m++) {
        sqlite3_bind_int(stmt, 2, m);
        if (sqlite3_step(stmt) != SQLITE_DONE) {
          fprintf(stderr, "sqlite3_step in child %d: %s\n", n,
                  sqlite3_errmsg(db));
        } else {
          fprintf(stderr, "child %d inserted %d\n", n, m);
        }
        sqlite3_reset(stmt);
        // Sleep for a short time to allow another process to run.
        // Otherwise this loop runs fast enough that it might as well
        // be done in serial, not parallel.
        unsigned int p;
        sqlite3_randomness(sizeof p, &p);
        sqlite3_sleep((p % 50) + 1);
      }
      sqlite3_finalize(stmt);
      sqlite3_close(db);
      return 0;
    }
  }
  for (int n = 0; n < TRIALS; n++) {
    wait(NULL);
  }
  return 0;
}