Method open_check_create

src/platform/DBsqlite3.cpp:18–41

}

void sqlite::Dbi::open_check_create(OpenMode open_mode, const std::string &fp, bool *created) {
	full_path = fp;
	sqlite::check(sqlite3_open_v2(platform::expand_path(full_path).c_str(),
	                  &handle,
	                  open_mode == OpenMode::O_READ_EXISTING
	                      ? SQLITE_OPEN_READONLY
	                      : open_mode == OpenMode::O_OPEN_EXISTING ? SQLITE_OPEN_READWRITE
	                                                               : (SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE),
	                  nullptr),
	    "sqlite3_open ");
	invariant(open_mode != OpenMode::O_CREATE_ALWAYS, "sqlite database does not support clearing existing data");
	if (open_mode == OpenMode::O_READ_EXISTING)
		exec("BEGIN TRANSACTION",
		    "modifying database impossible. Disk read-only or database used by other running instance?");
	else
		exec("BEGIN IMMEDIATE TRANSACTION",
		    "modifying database impossible. Disk read-only or database used by other running instance?");
	sqlite::Stmt stmt_get_tables;
	stmt_get_tables.prepare(*this, "SELECT name FROM sqlite_master WHERE type = 'table'");
	*created = !stmt_get_tables.step();
	if (open_mode == OpenMode::O_CREATE_NEW && !*created)
		throw ErrorDBExists("sqlite database " + full_path + " already exists and will not be overwritten");
	sqlite::check(sqlite3_busy_timeout(handle, 5000), "sqlite3_busy_timeout");  // ms
}

void sqlite::Dbi::exec(const char *statement, const char *err_msg) {
	auto rc = sqlite3_exec(handle, statement, nullptr, nullptr, nullptr);