D5379.1768431748.diff
No OneTemporary
Actions

Size

1 KB

Referenced Files

None

Subscribers

None

D5379.1768431748.diff
View Options

	diff --git a/native/cpp/CommonCpp/DatabaseManagers/SQLiteQueryExecutor.cpp b/native/cpp/CommonCpp/DatabaseManagers/SQLiteQueryExecutor.cpp
	--- a/native/cpp/CommonCpp/DatabaseManagers/SQLiteQueryExecutor.cpp
	+++ b/native/cpp/CommonCpp/DatabaseManagers/SQLiteQueryExecutor.cpp
	@@ -671,6 +671,28 @@
	return MigrationResult::SUCCESS;
	}

	+bool set_up_database(sqlite3 *db) {
	+ auto write_ahead_enabled = enable_write_ahead_logging_mode(db);
	+ if (!write_ahead_enabled) {
	+ return false;
	+ }
	+
	+ sqlite3_exec(db, "BEGIN TRANSACTION;", nullptr, nullptr, nullptr);
	+ auto db_version = get_database_version(db);
	+ auto latest_version = migrations.back().first;
	+ if (db_version == latest_version) {
	+ sqlite3_exec(db, "ROLLBACK;", nullptr, nullptr, nullptr);
	+ return true;
	+ }
	+ if (db_version != 0 \|\| !create_schema(db) \|\|
	+ !set_database_version(db, latest_version)) {
	+ sqlite3_exec(db, "ROLLBACK;", nullptr, nullptr, nullptr);
	+ return false;
	+ }
	+ sqlite3_exec(db, "END TRANSACTION;", nullptr, nullptr, nullptr);
	+ return true;
	+}
	+
	void SQLiteQueryExecutor::migrate() const {
	validate_encryption();

	@@ -688,6 +710,14 @@
	version_msg << "db version: " << db_version << std::endl;
	Logger::log(version_msg.str());

	+ if (db_version == 0) {
	+ set_up_database(db);
	+ Logger::log("Database structure created.");
	+
	+ sqlite3_close(db);
	+ return;
	+ }
	+
	for (const auto &[idx, migration] : migrations) {
	const auto &[applyMigration, shouldBeInTransaction] = migration;