Working test.

Author: kamilwylegala

packages/outbox-prisma-adapter/lib/outbox-prisma-adapter.spec.ts

@@ -0,0 +1,42 @@
+import { PrismaClient } from '@prisma/client'
+import { afterAll, beforeAll, describe, expect, it } from 'vitest'
+
+describe('outbox-prisma-adapter', () => {
+  let prisma: PrismaClient
+
+  beforeAll(async () => {
+    prisma = new PrismaClient()
+
+    await prisma.$queryRaw`create schema if not exists prisma;`
+    await prisma.$queryRaw`
+      CREATE TABLE prisma.outbox_entry (
+        id UUID PRIMARY KEY, 
+        created TIMESTAMP NOT NULL
+      )
+    `
+  })
+
+  afterAll(async () => {
+    await prisma.$queryRaw`DROP TABLE prisma.outbox_entry;`
+    await prisma.$queryRaw`DROP SCHEMA prisma;`
+    await prisma.$disconnect()
+  })
+
+  it('test db connection', async () => {
+    const creationDate = new Date()
+    await prisma.outboxEntry.create({
+      data: {
+        id: 'ce08b43b-6162-4913-86ea-fa9367875e3b',
+        created: creationDate,
+      },
+    })
+
+    const result = await prisma.outboxEntry.findMany()
+    expect(result).toEqual([
+      {
+        id: 'ce08b43b-6162-4913-86ea-fa9367875e3b',
+        created: creationDate,
+      },
+    ])
+  })
+})

packages/outbox-prisma-adapter/test/outbox-prisma-adapter.spec.ts

@@ -1,6 +1,6 @@
 datasource db {
   provider = "postgresql"
-  url      = "postgresql://prisma:prisma@localhost:5432/prisma?schema=testdb"
+  url      = "postgresql://prisma:prisma@localhost:5432/prisma?schema=prisma"
 }
 
 model OutboxEntry {