Ошибка: база данных заблокирована при вызове sqlite3_exec() из дочернего элемента fork()

Отвечать

Проблема заключалась в том, что база данных могла взаимодействовать только с одним процессом за раз, поэтому я открывал и закрывал базу данных до и после каждого запроса, и теперь она работает отлично. запрос в то же время, но это не может произойти в моей программе.
Решение. Это можно исправить, используя потоки и мьютекс вместо fork().
Спасибо за помощь

Вот минимальная тестовая программа, которая разветвляет кучу дочерних процессов, каждый из которых пытается вставить в базу данных по одной строке без транзакций. Я не могу воспроизвести ваши результаты - даже при отсутствии тайм-аута более одного процесса могут вставить хотя бы некоторые данные (хотя в этом случае много ошибок блокировки).

Это дает вам то же поведение, которое вы видите, когда пытаетесь это сделать?

#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;
}