Method update

src/Repositories/CrudRepository.ts:119–156

(model: Model, attributes: Partial<ValidAttributes>)

	}

	public async update(model: Model, attributes: Partial<ValidAttributes>): Promise<Model> {
		return this.database.sequence(async (sequenceDb: DatabaseInterface): Promise<Model> => {
			const fieldQueries = Object.entries(attributes).map(
				([key, value]: [string, any]) => (
					sql`${new QueryIdentifier(key)} = ${value}`
				)
			);

			let results = await sequenceDb.updateAndGet(sql`
				UPDATE ${new QueryIdentifier(this.table)}
				SET ${SqlQuery.join(fieldQueries, sql`, `)}
				WHERE ${new QueryIdentifier(this.primaryKey)} = ${(<any>model)[this.primaryKey]}
			`);

			if (results === null) {
				results = await sequenceDb.query(sql`
					SELECT *
					FROM ${new QueryIdentifier(this.table)}
					WHERE ${new QueryIdentifier(this.primaryKey)} = ${(<any>model)[this.primaryKey]};
				`);

				if (results.length === 0) {
					throw new NotFoundError(`Object not found in table ${this.table} after update (got ${this.primaryKey} = ${(<any>model)[this.primaryKey]})`);
				}
			} else {
				if (results.length === 0) {
					throw new NotFoundError(`Object not found in table ${this.table} for ${this.primaryKey} = ${(<any>model)[this.primaryKey]}`);
				}
				if (results.length > 1) {
					throw new TooManyResultsError(`Multiple objects found in table ${this.table} for ${this.primaryKey} = ${(<any>model)[this.primaryKey]}`);
				}
			}

			const newModel = await this.createModelFromAttributes(model);
			Object.assign(newModel, results[0]);
			return newModel;
		});
	}

	public async delete(model: Model) {
		await this.database.query(sql`