我写了一个简单的程序,它产生 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...