apiInsertPlusSelectPreparePlusAsyncExecute() — drizzle-orm Function Reference

Source Code

integration-tests/tests/sqlite/durable-objects/index.ts lines 2548–2587

	async apiInsertPlusSelectPreparePlusAsyncExecute(): Promise<void> {
		try {
			await this.beforeEach();
			const users = sqliteTable('users', {
				id: integer('id').primaryKey(),
				name: text('name'),
			});

			this.db.run(sql`drop table if exists ${users}`);

			this.db.run(sql`create table ${users} (id integer primary key, name text)`);

			const insertStmt = this.db.insert(users).values({ id: 1, name: 'John' }).prepare();
			insertStmt.execute().sync();

			const selectStmt = this.db.select().from(users).prepare();
			const res = selectStmt.execute().sync();

			expect(res).deep.equal([{ id: 1, name: 'John' }]);

			const updateStmt = this.db.update(users).set({ name: 'John1' }).where(eq(users.id, 1)).prepare();
			updateStmt.execute().sync();

			const res1 = selectStmt.execute().sync();

			expect(res1).deep.equal([{ id: 1, name: 'John1' }]);

			const deleteStmt = this.db.delete(users).where(eq(users.id, 1)).prepare();
			deleteStmt.execute().sync();

			const res2 = selectStmt.execute().sync();

			expect(res2).deep.equal([]);

			this.db.run(sql`drop table ${users}`);
		} catch (error: any) {
			console.error(error);
			throw new Error(`apiInsertPlusSelectPreparePlusAsyncExecute error`);
		}
	}