在C++中异步执行 sql 查询

Question

我有一个应用程序，可以将数据读取到映射中并将它们写入sqlite数据库。该应用程序做了很多其他事情，并且是异步的(使用boost asio(，除了写入数据库部分。下面是示例伪代码：

struct records;
std::map<int, records> list;
void read() {
// Dump(read) X records into list
// If record id doesn't exist, add it. dirty = true
// If it exists, update all other fields. dirty = true if any fields changed.
}
void writeDB() {
sqlite3_prepare_v2();
for(const auto& record : list) { // iterate map
if(!record.dirty())
continue;
sqlite3_bind(); // bind record fields
sqlite3_step(); // execute sql 
sqlite3_reset(); // reset
}
sqlite3_finalize();
}
main() {
while(1) {
read();
writeDB();
}
}

我最初的计划是在 for 循环中生成一个新线程，该线程将并行写入数据库中的每条记录。有两个问题。

1( 可能需要实现数据库锁定。

2( sqlitebind(), step() and reset()在同一语句上运行。因此，记录必须按顺序写入。

我正在使用C++ 17。关于使数据库调用异步的任何建议？感谢您的帮助！

Answer 1

您不必实现锁定。SQLite确实提供了ACID保证，这意味着您不必在插入物周围实现锁定。

话虽如此，为每个插入操作生成一个线程肯定是矫枉过正的。您可以考虑将列表拆分为与计算机上内核数相等的部分，并执行 N 个并行循环进行插入。但在我看来，除此之外的任何事情都可能是矫枉过正。

但不要把我的话视为理所当然。考虑检测您的代码并对你现在拥有的单线程版本以及你可能选择的任何并行实现进行基准测试。您可以测试各种 # 线程(但请记住，多线程代码性能和可用内核 # 之间存在关系(以及并发实现：C++17 std 并行执行或 boost 变体等。