139     sqlite3* db;  in createTableIfNeeded()  local
140     if (sqlite3_open(dbName.c_str(), &db) != SQLITE_OK) {  in createTableIfNeeded()
141         sqlite3_close(db);  in createTableIfNeeded()
147     sqlite3_exec(db, zSql.c_str(), nullptr, nullptr, &error);  in createTableIfNeeded()
148     sqlite3_close(db);  in createTableIfNeeded()
158     sqlite3* db;  in isEventCompatible()  local
159     if (sqlite3_open(dbName.c_str(), &db) != SQLITE_OK) {  in isEventCompatible()
160         sqlite3_close(db);  in isEventCompatible()
170         sqlite3_close(db);  in isEventCompatible()
185     sqlite3_close(db);  in isEventCompatible()
192     sqlite3* db;  in deleteTable()  local
193     if (sqlite3_open(dbName.c_str(), &db) != SQLITE_OK) {  in deleteTable()
194         sqlite3_close(db);  in deleteTable()
199     sqlite3_exec(db, zSql.c_str(), nullptr, nullptr, &error);  in deleteTable()
200     sqlite3_close(db);  in deleteTable()
215     sqlite3* db;  in getDb()  local
216     if (sqlite3_open(dbName.c_str(), &db) == SQLITE_OK) {  in getDb()
217         return db;  in getDb()
222 void closeDb(sqlite3* db) {  in closeDb()  argument
223     sqlite3_close(db);  in closeDb()
226 static bool getInsertSqlStmt(sqlite3* db, sqlite3_stmt** stmt, const int64_t metricId,  in getInsertSqlStmt()  argument
246     if (sqlite3_prepare_v2(db, result.c_str(), -1, stmt, nullptr) != SQLITE_OK) {  in getInsertSqlStmt()
247         err = sqlite3_errmsg(db);  in getInsertSqlStmt()
286     sqlite3* db;  in insert()  local
287     if (sqlite3_open(dbName.c_str(), &db) != SQLITE_OK) {  in insert()
288         error = sqlite3_errmsg(db);  in insert()
289         sqlite3_close(db);  in insert()
292     bool success = insert(db, metricId, events, error);  in insert()
293     sqlite3_close(db);  in insert()
297 bool insert(sqlite3* db, const int64_t metricId, const vector<LogEvent>& events, string& error) {  in insert()  argument
299     if (!getInsertSqlStmt(db, &stmt, metricId, events, error)) {  in insert()
305         error = sqlite3_errmsg(db);  in insert()
317     sqlite3* db;  in query()  local
318     if (sqlite3_open_v2(dbName.c_str(), &db, SQLITE_OPEN_READONLY, nullptr) != SQLITE_OK) {  in query()
319         err = sqlite3_errmsg(db);  in query()
320         sqlite3_close(db);  in query()
324     if (sqlite3_prepare_v2(db, zSql.c_str(), -1, &stmt, nullptr) != SQLITE_OK) {  in query()
325         err = sqlite3_errmsg(db);  in query()
327         sqlite3_close(db);  in query()
356         err = sqlite3_errmsg(db);  in query()
357         sqlite3_close(db);  in query()
360     sqlite3_close(db);  in query()
364 bool flushTtl(sqlite3* db, const int64_t metricId, const int64_t ttlWallClockNs) {  in flushTtl()  argument
370     sqlite3_exec(db, zSql.c_str(), nullptr, nullptr, &error);  in flushTtl()
380     sqlite3* db;  in verifyIntegrityAndDeleteIfNecessary()  local
381     if (sqlite3_open(dbName.c_str(), &db) != SQLITE_OK) {  in verifyIntegrityAndDeleteIfNecessary()
382         sqlite3_close(db);  in verifyIntegrityAndDeleteIfNecessary()
388     sqlite3_exec(db, zSql.c_str(), integrityCheckCallback, nullptr, &error);  in verifyIntegrityAndDeleteIfNecessary()
392         sqlite3_close(db);  in verifyIntegrityAndDeleteIfNecessary()
396     sqlite3_close(db);  in verifyIntegrityAndDeleteIfNecessary()
399 static bool getDeviceInfoInsertStmt(sqlite3* db, sqlite3_stmt** stmt, string error) {  in getDeviceInfoInsertStmt()  argument
401     if (sqlite3_prepare_v2(db, insertSql.c_str(), -1, stmt, nullptr) != SQLITE_OK) {  in getDeviceInfoInsertStmt()
402         error = sqlite3_errmsg(db);  in getDeviceInfoInsertStmt()
454     sqlite3* db;  in updateDeviceInfoTable()  local
455     if (sqlite3_open(dbName.c_str(), &db) != SQLITE_OK) {  in updateDeviceInfoTable()
456         error = sqlite3_errmsg(db);  in updateDeviceInfoTable()
457         sqlite3_close(db);  in updateDeviceInfoTable()
463     sqlite3_exec(db, dropTableSql.c_str(), nullptr, nullptr, nullptr);  in updateDeviceInfoTable()
473     if (sqlite3_exec(db, createTableSql.c_str(), nullptr, nullptr, nullptr) != SQLITE_OK) {  in updateDeviceInfoTable()
474         error = sqlite3_errmsg(db);  in updateDeviceInfoTable()
476         sqlite3_close(db);  in updateDeviceInfoTable()
481     if (!getDeviceInfoInsertStmt(db, &stmt, error)) {  in updateDeviceInfoTable()
484         sqlite3_close(db);  in updateDeviceInfoTable()
489         error = sqlite3_errmsg(db);  in updateDeviceInfoTable()
492         sqlite3_close(db);  in updateDeviceInfoTable()
496     sqlite3_close(db);  in updateDeviceInfoTable()