Test join

Author: thdxr

test/harness.ts

@@ -16,35 +16,29 @@ const dialect = new DataApiDialect({
   driver: opts,
 });
 
-interface Person {
+export interface Person {
   id: number;
   first_name: string;
   last_name: string;
   gender: "male" | "female" | "other";
 }
 
-interface Pet {
+export interface Pet {
   id: number;
   name: string;
   owner_id: number;
   species: "dog" | "cat";
 }
 
-interface Movie {
-  id: string;
-  stars: number;
-}
-
 // Keys are table names.
 interface Database {
   person: Person;
   pet: Pet;
-  movie: Movie;
 }
 
 export const db = new Kysely<Database>({ dialect });
 
-export async function reset() {
+export async function migrate() {
   await opts.client
     .executeStatement({
       sql: `
@@ -75,3 +69,8 @@ export async function reset() {
 
   await db.migration.migrateToLatest(path.resolve("./test/migrations"));
 }
+
+export async function reset() {
+  await db.deleteFrom("person").execute();
+  await db.deleteFrom("pet").execute();
+}

test/temporary.test.ts

@@ -1,12 +1,16 @@
-import { reset, db } from "./harness";
+import { migrate, db, reset } from "./harness";
 
 jest.setTimeout(1000 * 60);
 
+beforeAll(async () => {
+  await migrate();
+});
+
 beforeEach(async () => {
   await reset();
 });
 
-const person = {
+const PERSON = {
   gender: "male",
   first_name: "jeff",
   last_name: "bezos",
@@ -17,13 +21,43 @@ it("insert and read", async () => {
     .insertInto("person")
     .values({
       id: db.generated,
-      ...person,
+      ...PERSON,
     })
     .execute();
 
   const result = await db.selectFrom("person").selectAll().execute();
   expect(result).toHaveLength(1);
-  expect(result[0]).toMatchObject(person);
+  expect(result[0]).toMatchObject(PERSON);
+});
+
+it("join", async () => {
+  const person = await db
+    .insertInto("person")
+    .values({
+      id: db.generated,
+      ...PERSON,
+    })
+    .returning(["id"])
+    .executeTakeFirst();
+
+  await db
+    .insertInto("pet")
+    .values({
+      id: db.generated,
+      name: "fido",
+      species: "dog",
+      owner_id: person.id,
+    })
+    .execute();
+
+  const result = await db
+    .selectFrom("person")
+    .innerJoin("pet", "pet.owner_id", "person.id")
+    .select(["pet.name as pet_name", "person.first_name"])
+    .executeTakeFirst();
+
+  expect(result.first_name).toEqual("jeff");
+  expect(result.pet_name).toEqual("fido");
 });
 
 it("transaction", async () => {
@@ -32,12 +66,12 @@ it("transaction", async () => {
       .insertInto("person")
       .values({
         id: db.generated,
-        ...person,
+        ...PERSON,
       })
       .execute();
   });
 
   const result = await db.selectFrom("person").selectAll().execute();
   expect(result).toHaveLength(1);
-  expect(result[0]).toMatchObject(person);
+  expect(result[0]).toMatchObject(PERSON);
 });