Cross Reference: /dovecot/src/lib-sql/driver-sqlite.c

Lines Matching refs:db
12 /* retry time if db is busy (in ms) */
43  	struct sqlite_db *db = (struct sqlite_db *)_db;
45 	if (db->connected)
48 	db->rc = sqlite3_open(db->dbfile, &db->sqlite);
50 	if (db->rc == SQLITE_OK) {
51 		db->connected = TRUE;
52 		sqlite3_busy_timeout(db->sqlite, sqlite_busy_timeout);
55 		i_error("sqlite: open(%s) failed: %s", db->dbfile,
56 			sqlite3_errmsg(db->sqlite));
57 		sqlite3_close(db->sqlite);
58 		db->sqlite = NULL;
65  	struct sqlite_db *db = (struct sqlite_db *)_db;
67 	sqlite3_close(db->sqlite);
68 	db->sqlite = NULL;
73 	struct sqlite_db *db;
79 	db = p_new(pool, struct sqlite_db, 1);
80 	db->pool = pool;
81 	db->api = driver_sqlite_db;
82 	db->dbfile = p_strdup(db->pool, connect_string);
83 	db->connected = FALSE;
85 	return &db->api;
90 	struct sqlite_db *db = (struct sqlite_db *)_db;
93 	sql_db_set_state(&db->api, SQL_DB_STATE_DISCONNECTED);
95 	sqlite3_close(db->sqlite);
97 	pool_unref(&db->pool);
132 	struct sqlite_db *db = (struct sqlite_db *)_db;
137 	db->rc = sqlite3_exec(db->sqlite, query, NULL, NULL, NULL);
138 	if (db->rc != SQLITE_OK) {
140 			query, sqlite3_errmsg(db->sqlite), db->rc);
144 static void driver_sqlite_query(struct sql_db *db, const char *query,
149 	result = sql_query_s(db, query);
159 	struct sqlite_db *db = (struct sqlite_db *)_db;
170 		rc = sqlite3_prepare(db->sqlite, query, -1, &result->stmt, NULL);
181 	result->api.db = _db;
190 	struct sqlite_db *db = (struct sqlite_db *)	result->api.db;
199 				  sqlite3_errmsg(db->sqlite), rc);
301 	struct sqlite_db *db = (struct sqlite_db *)result->api.db;
303 	return sqlite3_errmsg(db->sqlite);
310 	struct sqlite_db *db = (struct sqlite_db *)_db;
313 	ctx->ctx.db = _db;
316 	if (db->rc != SQLITE_OK)
328 	sql_exec(_ctx->db, "ROLLBACK");
338 	struct sqlite_db *db = (struct sqlite_db *)ctx->ctx.db;
342 		sql_exec(_ctx->db, "COMMIT");
343 		if (db->rc != SQLITE_OK)
349 		commit_result.error = sqlite3_errmsg(db->sqlite);
365 	struct sqlite_db *db = (struct sqlite_db *) ctx->ctx.db;
373 	sql_exec(_ctx->db, "COMMIT");
374 	*error_r = sqlite3_errmsg(db->sqlite);
385 	struct sqlite_db *db = (struct sqlite_db *)ctx->ctx.db;
390 	sql_exec(_ctx->db, query);
391 	if (db->rc != SQLITE_OK)
394 		*affected_rows = sqlite3_changes(db->sqlite);