Function db_setup

plugins/bkpr/db.c:205–228

#endif /* DB_FATAL */

struct db *db_setup(const tal_t *ctx, struct plugin *p,
		    const char *db_dsn, bool *created)
{
	bool migrated;
	struct db *db;

	/* Set global for db_fatal */
	plugin = p;
	db = db_open(ctx, db_dsn);
	db->report_changes_fn = NULL;

	db_begin_transaction(db);
	migrated = db_migrate(p, db, created);
	db->data_version = db_data_version_get(db);
	db_commit_transaction(db);

	/* This needs to be done outside a transaction, apparently.
	 * It's a good idea to do this every so often, and on db
	 * upgrade is a reasonable time. */
	if (migrated && !db->config->vacuum_fn(db))
		db_fatal("Error vacuuming db: %s", db->error);

	return db;
}