Optimize search performance

src/common/db_cache.hpp

@@ -232,6 +232,54 @@ bool insertRom(sqlite3 *db, string name, RomEntry entry)
     return execSql(db, sql::insert(name, entry));
 }
 
+// Search builds can reuse one prepared INSERT for all result rows.
+bool prepareRomInsert(sqlite3 *db, string name, sqlite3_stmt **stmt)
+{
+    string table = TABLE_NAME(name);
+    char *query = sqlite3_mprintf(
+        "INSERT INTO %Q (disp, path, imgpath, type, ppath, pinyin, cpinyin) "
+        "VALUES (?, ?, ?, ?, ?, ?, '');", table.c_str());
+    if (query == NULL)
+        return false;
+
+    int rc = sqlite3_prepare_v2(db, query, -1, stmt, NULL);
+    if (rc != SQLITE_OK) {
+        std::cerr << "ERROR: while compiling prepared insert: "
+                  << sqlite3_errmsg(db) << std::endl;
+        sqlite3_free(query);
+        return false;
+    }
+
+    sqlite3_free(query);
+    return true;
+}
+
+bool insertRomPrepared(sqlite3 *db, sqlite3_stmt *stmt, const RomEntry &entry)
+{
+    sqlite3_reset(stmt);
+    sqlite3_clear_bindings(stmt);
+
+    if (sqlite3_bind_text(stmt, 1, entry.label.c_str(), -1, SQLITE_TRANSIENT) != SQLITE_OK ||
+        sqlite3_bind_text(stmt, 2, entry.path.c_str(), -1, SQLITE_TRANSIENT) != SQLITE_OK ||
+        sqlite3_bind_text(stmt, 3, entry.imgpath.c_str(), -1, SQLITE_TRANSIENT) != SQLITE_OK ||
+        sqlite3_bind_int(stmt, 4, entry.type) != SQLITE_OK ||
+        sqlite3_bind_text(stmt, 5, entry.ppath.c_str(), -1, SQLITE_TRANSIENT) != SQLITE_OK ||
+        sqlite3_bind_text(stmt, 6, entry.label.c_str(), -1, SQLITE_TRANSIENT) != SQLITE_OK) {
+        std::cerr << "ERROR: while binding prepared insert: "
+                  << sqlite3_errmsg(db) << std::endl;
+        return false;
+    }
+
+    int rc = sqlite3_step(stmt);
+    if (rc != SQLITE_DONE) {
+        std::cerr << "ERROR: while performing prepared insert: "
+                  << sqlite3_errmsg(db) << std::endl;
+        return false;
+    }
+
+    return true;
+}
+
 bool duplicateResults(sqlite3 *db, string name, string ppath)
 {
     return execSql(db, sql::dupChangePpath(name, ppath));