From f43d54a90e670e42d4d2c6ee56bda905a45e5810 Mon Sep 17 00:00:00 2001
From: ymc9 <104139426+ymc9@users.noreply.github.com>
Date: Thu, 13 Nov 2025 20:06:23 -0800
Subject: [PATCH] fix(orm): enum doesn't properly use default postgres schema

---
 .../sdk/src/prisma/prisma-schema-generator.ts | 16 +++++-
 .../orm/client-api/pg-custom-schema.test.ts   | 52 ++++++++++++++++---
 2 files changed, 61 insertions(+), 7 deletions(-)

diff --git a/packages/sdk/src/prisma/prisma-schema-generator.ts b/packages/sdk/src/prisma/prisma-schema-generator.ts
index 45ffed3c..315c5063 100644
--- a/packages/sdk/src/prisma/prisma-schema-generator.ts
+++ b/packages/sdk/src/prisma/prisma-schema-generator.ts
@@ -402,10 +402,24 @@ export class PrismaSchemaGenerator {
             this.generateEnumField(_enum, field);
         }
 
-        for (const attr of decl.attributes.filter((attr) => this.isPrismaAttribute(attr))) {
+        const allAttributes = decl.attributes.filter((attr) => this.isPrismaAttribute(attr));
+        for (const attr of allAttributes) {
             this.generateContainerAttribute(_enum, attr);
         }
 
+        if (
+            this.datasourceHasSchemasSetting(decl.$container) &&
+            !allAttributes.some((attr) => attr.decl.ref?.name === '@@schema')
+        ) {
+            // if the datasource declared `schemas` and no @@schema attribute is defined, add a default one
+            _enum.addAttribute('@@schema', [
+                new PrismaAttributeArg(
+                    undefined,
+                    new PrismaAttributeArgValue('String', this.getDefaultPostgresSchemaName(decl.$container)),
+                ),
+            ]);
+        }
+
         // user defined comments pass-through
         decl.comments.forEach((c) => _enum.addComment(c));
     }
diff --git a/tests/e2e/orm/client-api/pg-custom-schema.test.ts b/tests/e2e/orm/client-api/pg-custom-schema.test.ts
index 4308e864..7f61f498 100644
--- a/tests/e2e/orm/client-api/pg-custom-schema.test.ts
+++ b/tests/e2e/orm/client-api/pg-custom-schema.test.ts
@@ -38,9 +38,15 @@ model Foo {
         const foundSchema = { create: false, read: false, update: false, delete: false };
         const db = await createTestClient(
             `
+enum Role {
+    ADMIN
+    USER
+}
+
 model Foo {
     id Int @id
     name String
+    role Role
 }
 `,
             {
@@ -57,7 +63,9 @@ model Foo {
             },
         );
 
-        await expect(db.$qb.insertInto('Foo').values({ id: 1, name: 'test' }).execute()).toResolveTruthy();
+        await expect(
+            db.$qb.insertInto('Foo').values({ id: 1, name: 'test', role: 'ADMIN' }).execute(),
+        ).toResolveTruthy();
         await expect(db.$qb.selectFrom('Foo').selectAll().executeTakeFirst()).toResolveTruthy();
         await expect(
             db.$qb.updateTable('Foo').set({ name: 'updated' }).where('id', '=', 1).execute(),
@@ -75,9 +83,15 @@ datasource db {
     defaultSchema = 'mySchema'
 }
 
+enum Role {
+    ADMIN
+    USER
+}
+
 model Foo {
     id Int @id
     name String
+    role Role
 }
 `,
             {
@@ -85,7 +99,7 @@ model Foo {
             },
         );
 
-        await expect(db.foo.create({ data: { id: 1, name: 'test' } })).rejects.toSatisfy(
+        await expect(db.foo.create({ data: { id: 1, name: 'test', role: 'ADMIN' } })).rejects.toSatisfy(
             (e) => e instanceof ORMError && !!e.dbErrorMessage?.includes('relation "mySchema.Foo" does not exist'),
         );
 
@@ -98,9 +112,15 @@ datasource db {
     defaultSchema = 'public'
 }
 
+enum Role {
+    ADMIN
+    USER
+}
+
 model Foo {
     id Int @id
     name String
+    role Role
 }
 `,
             {
@@ -108,7 +128,7 @@ model Foo {
             },
         );
 
-        await expect(db1.foo.create({ data: { id: 1, name: 'test' } })).toResolveTruthy();
+        await expect(db1.foo.create({ data: { id: 1, name: 'test', role: 'ADMIN' } })).toResolveTruthy();
     });
 
     it('supports custom schemas', async () => {
@@ -123,15 +143,29 @@ datasource db {
     url = '$DB_URL'
 }
 
+enum FooRole {
+    ADMIN
+    USER
+    @@schema('mySchema')
+}
+
 model Foo {
     id Int @id
     name String
+    role FooRole
     @@schema('mySchema')
 }
 
+enum BarRole {
+    ADMIN
+    USER
+    @@schema('public')
+}
+
 model Bar {
     id Int @id
     name String
+    role BarRole
     @@schema('public')
 }
 `,
@@ -150,8 +184,8 @@ model Bar {
             },
         );
 
-        await expect(db.foo.create({ data: { id: 1, name: 'test' } })).toResolveTruthy();
-        await expect(db.bar.create({ data: { id: 1, name: 'test' } })).toResolveTruthy();
+        await expect(db.foo.create({ data: { id: 1, name: 'test', role: 'ADMIN' } })).toResolveTruthy();
+        await expect(db.bar.create({ data: { id: 1, name: 'test', role: 'USER' } })).toResolveTruthy();
 
         expect(fooQueriesVerified).toBe(true);
         expect(barQueriesVerified).toBe(true);
@@ -226,9 +260,15 @@ datasource db {
     url = '$DB_URL'
 }
 
+enum Role {
+    ADMIN
+    USER
+}
+
 model Foo {
     id Int @id
     name String
+    role Role
     @@schema('mySchema')
 }
 
@@ -252,7 +292,7 @@ model Bar {
             },
         );
 
-        await expect(db.foo.create({ data: { id: 1, name: 'test' } })).toResolveTruthy();
+        await expect(db.foo.create({ data: { id: 1, name: 'test', role: 'ADMIN' } })).toResolveTruthy();
         await expect(db.bar.create({ data: { id: 1, name: 'test' } })).toResolveTruthy();
 
         expect(fooQueriesVerified).toBe(true);