2

我写了一个简单的程序,它产生 10 个线程,每个线程打开一个数据库(所有线程通用),或者如果打开失败,则创建它(使用“Write-Ahead Log”选项),在数据库上创建一个表然后它去进入一个无限循环,在该循环中它一次将一行添加到其表中。我发现程序每 5 分钟泄漏大约 2 个句柄,我尝试了一个名为 Memory Verify 的工具,它告诉我泄漏的句柄是 SQLite3 文件锁(版本 3.7.13 上的第 34034 行),但我不确定这个错误是否在 SQLite 或我使用它的方式中。

我没有指定任何编译器选项来构建 SQLite3,因此它被构建为多线程,据我所知,多线程在我的情况下应该可以正常工作,因为每个线程都有自己的 SQLite 连接。

要打开或创建数据库,我使用以下代码:

   bool Create()
   {
      int iFlags = 0;
      iFlags = iFlags | SQLITE_OPEN_READWRITE | SQLITE_OPEN_NOMUTEX | SQLITE_OPEN_CREATE;
      return sqlite3_open_v2(dbName_sm.c_str(), &pHandle_m, iFlags, 0) == SQLITE_OK;
   }

   bool Open()
   {
      int iFlags = 0;
      iFlags = iFlags | SQLITE_OPEN_READWRITE | SQLITE_OPEN_NOMUTEX;
      return sqlite3_open_v2(dbName_sm.c_str(), &pHandle_m, iFlags, 0) == SQLITE_OK;
   }

每个线程中的硬循环调用 ExecuteQuery,它会准备、执行和完成 INSERT 语句:

   bool ExecuteQuery(const std::string& statement)
   {
      bool res = Prepare(statement);
      if(!res)
      {
         return false;;
      }
      SQLiteStatus status = Step();
      Finalize();
      res = (ESuccess == status || EDatabaseDone == status);
      return res;
   }

   bool Prepare(const std::string& statement)
   {
      return sqlite3_prepare_v2(pHandle_m, statement.c_str(), -1, &pStmt_m, 0) == SQLITE_OK;
   }

   enum SQLiteStatus { ESuccess, EDatabaseDone, EDatabaseTimeout, EDatabaseError };
   SQLiteStatus Step()
   {
      int iRet = sqlite3_step(pStmt_m);
      if (iRet == SQLITE_DONE)
      {
         return EDatabaseDone;
      }
      else if (iRet == SQLITE_BUSY)
      {
         return EDatabaseTimeout;
      }
      else if (iRet != SQLITE_ROW)
      {
         return EDatabaseError;
      }
      return ESuccess;
   }

   bool Finalize()
   {
      int iRet = sqlite3_finalize(pStmt_m);
      pStmt_m = 0;
      return iRet == SQLITE_OK;
   }

你们在我的代码中看到任何错误还是 SQLite 中的已知问题?我试图用谷歌搜索它几天,但我找不到任何关于它的信息。

非常感谢您的帮助。

问候,

安德烈亚

PS我忘了说我在WinXP 64bit PC上运行我的测试,编译器是VS2010,应用程序是32位编译的,SQLite版本是3.7.13...

4

1 回答 1

-1

在每个 sqlite3_step 之后检查您是否有 sqlite3_reset,因为这是一种可能导致泄漏的情况。在使用 sqlite3_prepare 准备语句并使用 sqlite3_step 执行它之后,您需要始终使用 sqlite3_reset 重置它。

于 2013-02-19T10:13:39.640 回答