} else {
mdb->sqlite_errmsg = NULL;
}
+#ifdef SQLITE3_INIT_QUERY
+ db_sql_query(mdb, SQLITE3_INIT_QUERY, NULL, NULL);
+#endif
#else
mdb->db = sqlite_open(
free(db_name);
V(mutex);
return 0;
- }
+ }
+ mdb->connected = true;
free(db_name);
if (!check_tables_version(jcr, mdb)) {
V(mutex);
sqlite_busy_handler(mdb->db, my_busy_handler, NULL);
#endif
- mdb->connected = true;
V(mutex);
return 1;
}
}
db_end_transaction(jcr, mdb);
P(mutex);
+ sql_free_result(mdb);
mdb->ref_count--;
if (mdb->ref_count == 0) {
qdchain(&mdb->bq);
V(mutex);
}
+void db_thread_cleanup()
+{
+#ifdef HAVE_SQLITE3
+ sqlite3_thread_cleanup();
+#endif
+}
+
/*
* Return the next unique index (auto-increment) for
* the given table. Return 0 on error.
*/
int db_next_index(JCR *jcr, B_DB *mdb, char *table, char *index)
{
-#ifdef xxxx
- SQL_ROW row;
-
- db_lock(mdb);
-
- Mmsg(mdb->cmd,
-"SELECT id FROM NextId WHERE TableName=\"%s\"", table);
- if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
- Mmsg(mdb->errmsg, _("next_index query error: ERR=%s\n"), sql_strerror(mdb));
- db_unlock(mdb);
- return 0;
- }
- if ((row = sql_fetch_row(mdb)) == NULL) {
- Mmsg(mdb->errmsg, _("Error fetching index: ERR=%s\n"), sql_strerror(mdb));
- db_unlock(mdb);
- return 0;
- }
- bstrncpy(index, row[0], 28);
- sql_free_result(mdb);
-
- Mmsg(mdb->cmd,
-"UPDATE NextId SET id=id+1 WHERE TableName=\"%s\"", table);
- if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
- Mmsg(mdb->errmsg, _("next_index update error: ERR=%s\n"), sql_strerror(mdb));
- db_unlock(mdb);
- return 0;
- }
- sql_free_result(mdb);
-
- db_unlock(mdb);
-#endif
strcpy(index, "NULL");
return 1;
}
{
int stat;
+ my_sqlite_free_table(mdb);
if (mdb->sqlite_errmsg) {
#ifdef HAVE_SQLITE3
sqlite3_free(mdb->sqlite_errmsg);
free(mdb->fields);
mdb->fields_defined = false;
}
- sqlite_free_table(mdb->result);
+ if (mdb->result) {
+ sqlite_free_table(mdb->result);
+ mdb->result = NULL;
+ }
mdb->nrow = mdb->ncolumn = 0;
}