Function NODE_METHOD

src/objects/database.cpp:139–195

}

NODE_METHOD(Database::JS_new) {
	assert(info.IsConstructCall());
	REQUIRE_ARGUMENT_STRING(first, Napi::String filename);
	REQUIRE_ARGUMENT_STRING(second, Napi::String filenameGiven);
	REQUIRE_ARGUMENT_BOOLEAN(third, bool in_memory);
	REQUIRE_ARGUMENT_BOOLEAN(fourth, bool readonly);
	REQUIRE_ARGUMENT_BOOLEAN(fifth, bool must_exist);
	REQUIRE_ARGUMENT_INT32(sixth, int timeout);
	REQUIRE_ARGUMENT_ANY(seventh, Napi::Value logger);
	REQUIRE_ARGUMENT_ANY(eighth, Napi::Value buffer);

	UseAddon;
	UseIsolate;
	sqlite3* db_handle;
	std::string utf8 = filename.Utf8Value();
	int mask = readonly ? SQLITE_OPEN_READONLY
		: must_exist ? SQLITE_OPEN_READWRITE
		: (SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE);

	if (sqlite3_open_v2(utf8.c_str(), &db_handle, mask, NULL) != SQLITE_OK) {
		ThrowSqliteError(env, addon, db_handle);
		int status = sqlite3_close(db_handle);
		assert(status == SQLITE_OK); ((void)status);
		return env.Undefined();
	}

	assert(sqlite3_db_mutex(db_handle) == NULL);
	sqlite3_extended_result_codes(db_handle, 1);
	sqlite3_busy_timeout(db_handle, timeout);
	sqlite3_limit(db_handle, SQLITE_LIMIT_LENGTH, MAX_BUFFER_SIZE < MAX_STRING_SIZE ? MAX_BUFFER_SIZE : MAX_STRING_SIZE);
	sqlite3_limit(db_handle, SQLITE_LIMIT_SQL_LENGTH, MAX_STRING_SIZE);
	int status = sqlite3_db_config(db_handle, SQLITE_DBCONFIG_ENABLE_LOAD_EXTENSION, 1, NULL);
	assert(status == SQLITE_OK); ((void)status);
	status = sqlite3_db_config(db_handle, SQLITE_DBCONFIG_DEFENSIVE, 1, NULL);
	assert(status == SQLITE_OK); ((void)status);

	if (buffer.IsBuffer() && !Deserialize(env, buffer.As<Napi::Object>(), addon, db_handle, readonly)) {
		int status = sqlite3_close(db_handle);
		assert(status == SQLITE_OK); ((void)status);
		return env.Undefined();
	}

	this->db_handle = db_handle;
	open = true;
	has_logger = logger.IsFunction();
	if (has_logger) this->logger.Reset(logger, 1);
	addon->dbs.insert(this);

	Napi::Object _this = info.This().As<Napi::Object>();
	SetFrozen(env, _this, addon->cs.memory, Napi::Boolean::New(env, in_memory));
	SetFrozen(env, _this, addon->cs.readonly, Napi::Boolean::New(env, readonly));
	SetFrozen(env, _this, addon->cs.name, filenameGiven);
	SetInstanceGetter<Database, &Database::JS_open>(_this, "open", addon);
	SetInstanceGetter<Database, &Database::JS_inTransaction>(_this, "inTransaction", addon);

	return info.This();
}