Angelelz

test.serial('transaction with RLS', async (t) => {
	const { db } = t.context;

	const users = pgTable('users_transactions', {
		id: serial('id').primaryKey(),
		name: text('name').notNull(),
		lastName: text('lastname'),
	});

	await db.execute(sql`drop table if exists ${users}`);

Angelelz

import { MySqlTable } from "drizzle-orm/mysql-core";
import { db as drizzleDb } from "./mysql/mysql2";
import { eq } from "drizzle-orm";
import { users } from "./mysql/schema";

interface Reader<T extends MySqlTable & { id: any }> {
  findAll(): Promise<T["$inferSelect"][]>;
  findOne(id: number): Promise<T["$inferSelect"] | undefined>;
}