Method xConnect

src/util/custom-table.cpp:105–155

This method uses the factory function to instantiate a new virtual table.

	// This method uses the factory function to instantiate a new virtual table.
	static int xConnect(sqlite3* db_handle, void* _self, int argc, const char* const * argv, sqlite3_vtab** output, char** errOutput) {
		CustomTable* self = static_cast<CustomTable*>(_self);
		Napi::Env env = self->env;
		Napi::HandleScope scope(env);

		napi_value* args = ALLOC_ARRAY<napi_value>(argc);
		for (int i = 0; i < argc; ++i) {
			args[i] = StringFromUtf8(env, argv[i], -1);
		}

		// Run the factory function to receive a new virtual table definition.
		Napi::Value returnValue = SafeCall(env, self->factory.Value(), env.Undefined(), argc, args);
		delete[] args;

		if (env.IsExceptionPending()) {
			self->PropagateJSError();
			return SQLITE_ERROR;
		}

		// Extract each part of the virtual table definition.
		Napi::Array array = returnValue.As<Napi::Array>();
		Napi::String sqlString = array.Get((uint32_t)0).As<Napi::String>();
		Napi::Function generator = array.Get((uint32_t)1).As<Napi::Function>();
		Napi::Array parameterNames = array.Get((uint32_t)2).As<Napi::Array>();
		int safe_ints = array.Get((uint32_t)3).As<Napi::Number>().Int32Value();
		bool direct_only = array.Get((uint32_t)4).As<Napi::Boolean>().Value();

		std::string sql = sqlString.Utf8Value();
		safe_ints = safe_ints < 2 ? safe_ints : static_cast<int>(self->db->GetState()->safe_ints);

		// Copy the parameter names into a std::vector.
		std::vector<std::string> parameter_names;
		for (int i = 0, len = parameterNames.Length(); i < len; ++i) {
			Napi::String parameterName = parameterNames.Get((uint32_t)i).As<Napi::String>();
			parameter_names.emplace_back(parameterName.Utf8Value());
		}

		// Pass our SQL table definition to SQLite (this should never fail).
		if (sqlite3_declare_vtab(db_handle, sql.c_str()) != SQLITE_OK) {
			*errOutput = sqlite3_mprintf("failed to declare virtual table \"%s\"", argv[2]);
			return SQLITE_ERROR;
		}
		if (direct_only && sqlite3_vtab_config(db_handle, SQLITE_VTAB_DIRECTONLY) != SQLITE_OK) {
			*errOutput = sqlite3_mprintf("failed to configure virtual table \"%s\"", argv[2]);
			return SQLITE_ERROR;
		}

		// Return the successfully created virtual table.
		*output = (new VTab(self, generator, parameter_names, safe_ints))->Downcast();
		return SQLITE_OK;
	}

	static int xDisconnect(sqlite3_vtab* vtab) {
		delete VTab::Upcast(vtab);