test$onUpdateFnAnd$onUpdateWorksUpdating() — drizzle-orm Function Reference

Source Code

integration-tests/tests/sqlite/durable-objects/index.ts lines 3172–3221

	async test$onUpdateFnAnd$onUpdateWorksUpdating(): Promise<void> {
		try {
			await this.beforeEach();
			this.db.run(sql`drop table if exists ${usersOnUpdate}`);

			this.db.run(
				sql`
					create table ${usersOnUpdate} (
					id integer primary key autoincrement,
					name text not null,
					update_counter integer default 1,
					updated_at integer,
					always_null text
					)
				`,
			);

			await this.db
				.insert(usersOnUpdate)
				.values([{ name: 'John', alwaysNull: 'this will be null after updating' }, { name: 'Jane' }, { name: 'Jack' }, {
					name: 'Jill',
				}]);
			const { updatedAt, ...rest } = getTableColumns(usersOnUpdate);

			await this.db.update(usersOnUpdate).set({ name: 'Angel' }).where(eq(usersOnUpdate.id, 1));
			await this.db.update(usersOnUpdate).set({ updateCounter: null }).where(eq(usersOnUpdate.id, 2));

			const justDates = await this.db.select({ updatedAt }).from(usersOnUpdate).orderBy(asc(usersOnUpdate.id));

			const response = await this.db
				.select({ ...rest })
				.from(usersOnUpdate)
				.orderBy(asc(usersOnUpdate.id));

			expect(response).deep.equal([
				{ name: 'Angel', id: 1, updateCounter: 2, alwaysNull: null },
				{ name: 'Jane', id: 2, updateCounter: null, alwaysNull: null },
				{ name: 'Jack', id: 3, updateCounter: 1, alwaysNull: null },
				{ name: 'Jill', id: 4, updateCounter: 1, alwaysNull: null },
			]);
			const msDelay = 250;

			for (const eachUser of justDates) {
				expect(eachUser.updatedAt!.valueOf()).greaterThan(Date.now() - msDelay);
			}
		} catch (error: any) {
			console.error(error);
			throw new Error(`test$onUpdateFnAnd$onUpdateWorksUpdating error`);
		}
	}