Compare Prisma 6 and Prisma Next runtime behavior

.github/workflows/e2e.yaml

@@ -18,7 +18,7 @@ jobs:
       - name: Setup Node.js environment
         uses: actions/setup-node@v4
         with:
-          node-version: 20
+          node-version: 24
           cache: "pnpm"
 
       - name: Install dependencies

.github/workflows/playwright.yaml

@@ -22,8 +22,7 @@ jobs:
     env:
       CI: "true"
       NODE_OPTIONS: "--max-old-space-size=8192"
-      DATABASE_URL: "mysql://root:@localhost:3306/planetscale"
-      PLANETSCALE_DATABASE_URL: "http://root:unused@localhost:3900/planetscale"
+      DATABASE_URL: "postgresql://postgres:postgres@localhost:5432/dub?schema=public"
 
       NEXTAUTH_SECRET: "e2e-test-secret-at-least-32-chars-long"
       NEXTAUTH_URL: "http://partners.localhost:8888"
@@ -70,19 +69,19 @@ jobs:
       STRIPE_APP_SECRET_KEY: "xx"
 
     services:
-      mysql:
-        image: mysql:8.0
+      postgres:
+        image: postgres:16
         env:
-          MYSQL_DATABASE: planetscale
-          MYSQL_ROOT_HOST: "%"
-          MYSQL_ALLOW_EMPTY_PASSWORD: "yes"
+          POSTGRES_DB: dub
+          POSTGRES_USER: postgres
+          POSTGRES_PASSWORD: postgres
         options: >-
-          --health-cmd="mysqladmin ping -h 127.0.0.1"
+          --health-cmd="pg_isready -U postgres -d dub"
           --health-interval=10s
           --health-timeout=5s
           --health-retries=5
         ports:
-          - 3306:3306
+          - 5432:5432
 
       mailhog:
         image: mailhog/mailhog:latest
@@ -113,24 +112,13 @@ jobs:
       - name: Check out code
         uses: actions/checkout@v4
 
-      - name: Start PlanetScale simulator
-        run: |
-          docker run -d --name ps-http-sim \
-            --network host \
-            ghcr.io/mattrobenolt/ps-http-sim:latest \
-            -listen-addr=0.0.0.0 \
-            -listen-port=3900 \
-            -mysql-dbname=planetscale \
-            -mysql-no-pass \
-            -mysql-addr=127.0.0.1
-
       - name: Setup pnpm
         uses: pnpm/action-setup@v3
 
       - name: Setup Node.js
         uses: actions/setup-node@v4
         with:
-          node-version: 20
+          node-version: 24
           cache: "pnpm"
 
       - name: Install dependencies
@@ -155,6 +143,10 @@ jobs:
         working-directory: apps/web
         run: pnpm prisma:push
 
+      - name: Apply PostgreSQL postdeploy SQL
+        working-directory: packages/prisma
+        run: pnpm postdeploy:postgres
+
       - name: Seed test data
         working-directory: apps/web
         run: pnpm tsx playwright/seed.ts

.gitignore

@@ -35,6 +35,7 @@ dist/
 # typescript
 *.tsbuildinfo
 next-env.d.ts
+packages/prisma/.tmp/
 
 # miscellaneous
 apps/web/scripts/fix.ts
@@ -50,4 +51,4 @@ packages/stripe-app/.build/*
 playwright-report/
 **/playwright/.auth/
 test-results/
-blob-report/
+blob-report/

README.md

@@ -42,7 +42,7 @@ Our platform powers 100M+ clicks and 2M+ links monthly, and is used by world-cla
 - [Prisma](https://www.prisma.io/) – ORM
 - [Upstash](https://upstash.com/) – redis
 - [Tinybird](https://tinybird.com/) – analytics
-- [PlanetScale](https://planetscale.com/) – database
+- [PostgreSQL](https://www.postgresql.org/) – database
 - [NextAuth.js](https://next-auth.js.org/) – auth
 - [BoxyHQ](https://boxyhq.com/enterprise-sso) – SSO/SAML
 - [Turborepo](https://turbo.build/repo) – monorepo

apps/web/.env.example

@@ -16,11 +16,10 @@ ENCRYPTION_KEY=
 # Email unsubscribe token secret (optional, falls back to NEXTAUTH_SECRET)
 UNSUBSCRIBE_TOKEN_SECRET=
 
-# MySQL Database via Planetscale
-# Get your MySQL Database URL here: https://planetscale.com/docs/tutorials/connect-nodejs-app
-DATABASE_URL="mysql://root:@localhost:3306/planetscale"
-# Set local development documentation for connecting to a local database: https://dub.co/docs/local-development#step-4-set-up-planetscale-mysql-database
-PLANETSCALE_DATABASE_URL="http://root:unused@localhost:3900/planetscale"
+# PostgreSQL Database
+DATABASE_URL="postgresql://postgres:postgres@localhost:5432/dub?schema=public"
+# Optional webhook to trigger an external PostgreSQL backup job from the backup cron route
+POSTGRES_BACKUP_WEBHOOK_URL=
 
 # Upstash Redis – required for Redis caching
 # Get your Redis REST URL and Token here: https://upstash.com/docs/redis/overall/getstarted
@@ -172,9 +171,6 @@ PAYPAL_WEBHOOK_ID=
 # Program lander generation
 FIRECRAWL_API_KEY=
 
-# for generating planetscale backups (https://planetscale.com/docs/api/service-tokens)
-PLANETSCALE_SERVICE_TOKEN=
-
 # Hubspot
 HUBSPOT_CLIENT_ID=
 HUBSPOT_CLIENT_SECRET=

apps/web/app/(ee)/api/admin/commissions/get-commissions-timeseries.ts

@@ -1,4 +1,7 @@
-import { sqlGranularityMap } from "@/lib/planetscale/granularity";
+import {
+  pgDateBucket,
+  sqlGranularityMap,
+} from "@/lib/postgres/granularity";
 import { TZDate } from "@date-fns/tz";
 import { prisma } from "@dub/prisma";
 import { Prisma } from "@dub/prisma/client";
@@ -27,15 +30,15 @@ export async function getCommissionsTimeseries({
     sqlGranularityMap[granularity];
 
   const commissions = await prisma.$queryRaw<Commission[]>`
-        SELECT 
-          DATE_FORMAT(CONVERT_TZ(createdAt, "UTC", ${timezone || "UTC"}), ${dateFormat}) AS start, 
+        SELECT
+          ${pgDateBucket({ column: Prisma.sql`"createdAt"`, timezone: timezone || "UTC", dateFormat })} AS start,
           SUM(earnings) AS commissions
-        FROM Commission
-        WHERE 
-          createdAt >= ${startDate}
-          AND createdAt < ${endDate}
-          AND status IN ("pending", "processed", "paid")
-          AND ${programId ? Prisma.sql`programId = ${programId}` : Prisma.sql`programId != ${ACME_PROGRAM_ID}`}
+        FROM "Commission"
+        WHERE
+          "createdAt" >= ${startDate}
+          AND "createdAt" < ${endDate}
+          AND status IN ('pending', 'processed', 'paid')
+          AND ${programId ? Prisma.sql`"programId" = ${programId}` : Prisma.sql`"programId" != ${ACME_PROGRAM_ID}`}
         GROUP BY start
         ORDER BY start ASC;`;
 

apps/web/app/(ee)/api/admin/partners/delete-account/route.ts

@@ -1,5 +1,5 @@
 import { withAdmin } from "@/lib/auth";
-import { conn } from "@/lib/planetscale";
+import { conn } from "@/lib/postgres";
 import { stripe } from "@/lib/stripe";
 import { recordLink } from "@/lib/tinybird";
 import { prisma } from "@dub/prisma";
@@ -142,7 +142,7 @@ export const POST = withAdmin(
         );
       }
 
-      await conn.execute(`DELETE FROM Partner WHERE id = ?`, [partner.id]);
+      await conn.execute(`DELETE FROM "Partner" WHERE id = ?`, [partner.id]);
       console.log(`Deleted partner ${partner.email} (${partner.id})`);
     }
 

apps/web/app/(ee)/api/admin/payouts/route.ts

@@ -1,6 +1,9 @@
 import { getStartEndDates } from "@/lib/analytics/utils/get-start-end-dates";
 import { withAdmin } from "@/lib/auth";
-import { sqlGranularityMap } from "@/lib/planetscale/granularity";
+import {
+  pgDateBucket,
+  sqlGranularityMap,
+} from "@/lib/postgres/granularity";
 import { analyticsQuerySchema } from "@/lib/zod/schemas/analytics";
 import { prisma } from "@dub/prisma";
 import { InvoiceStatus, Prisma } from "@dub/prisma/client";
@@ -93,17 +96,17 @@ export const GET = withAdmin(async ({ searchParams }) => {
     { date: Date; payouts: number; fees: number; total: number }[]
   >`
     SELECT 
-      DATE_FORMAT(CONVERT_TZ(createdAt, "UTC", ${timezone}), ${dateFormat}) as date,
+      ${pgDateBucket({ column: Prisma.sql`"createdAt"`, timezone, dateFormat })} as date,
       SUM(amount) as payouts,
       SUM(fee) as fees,
       SUM(total) as total
-    FROM Invoice
+    FROM "Invoice"
     WHERE 
-      ${programId ? Prisma.sql`programId = ${programId}` : Prisma.sql`programId != ${ACME_PROGRAM_ID}`}
+      ${programId ? Prisma.sql`"programId" = ${programId}` : Prisma.sql`"programId" != ${ACME_PROGRAM_ID}`}
       AND ${status ? Prisma.sql`status = ${status}` : Prisma.sql`status != 'failed'`}
-      AND createdAt >= ${startDate}
-      AND createdAt <= ${endDate}
-    GROUP BY DATE_FORMAT(CONVERT_TZ(createdAt, "UTC", ${timezone}), ${dateFormat})
+      AND "createdAt" >= ${startDate}
+      AND "createdAt" <= ${endDate}
+    GROUP BY date
     ORDER BY date ASC;
   `;
 

apps/web/app/(ee)/api/appsflyer/webhook/route.ts

@@ -61,7 +61,7 @@ export const GET = withAxiom(async (req) => {
       where: {
         integrationId: APPSFLYER_INTEGRATION_ID,
         settings: {
-          path: "$.appIds",
+          path: ["appIds"],
           array_contains: appId,
         },
       },

apps/web/app/(ee)/api/commissions/analytics/route.ts

@@ -6,7 +6,10 @@ import {
   commissionAnalyticsQuerySchema,
   commissionAnalyticsSchema,
 } from "@/lib/commissions/schema";
-import { sqlGranularityMap } from "@/lib/planetscale/granularity";
+import {
+  pgDateBucket,
+  sqlGranularityMap,
+} from "@/lib/postgres/granularity";
 import type { CommissionAnalyticsQuery } from "@/lib/types";
 import { prisma } from "@dub/prisma";
 import { CommissionStatus, CommissionType, Prisma } from "@dub/prisma/client";
@@ -59,9 +62,9 @@ function commissionSqlConditions({
   partnerTagIdParam: string | undefined;
 }): Prisma.Sql[] {
   const conditions: Prisma.Sql[] = [
-    Prisma.sql`c.programId = ${programId}`,
-    Prisma.sql`c.createdAt >= ${startDate}`,
-    Prisma.sql`c.createdAt < ${endDate}`,
+    Prisma.sql`c."programId" = ${programId}`,
+    Prisma.sql`c."createdAt" >= ${startDate}`,
+    Prisma.sql`c."createdAt" < ${endDate}`,
     status
       ? Prisma.sql`c.status = ${status}`
       : Prisma.sql`c.status NOT IN (${Prisma.join([...excludedStatuses])})`,
@@ -71,8 +74,8 @@ function commissionSqlConditions({
     const list = Prisma.join(partnerFilter.values.map((v) => Prisma.sql`${v}`));
     conditions.push(
       partnerFilter.sqlOperator === "NOT IN"
-        ? Prisma.sql`c.partnerId NOT IN (${list})`
-        : Prisma.sql`c.partnerId IN (${list})`,
+        ? Prisma.sql`c."partnerId" NOT IN (${list})`
+        : Prisma.sql`c."partnerId" IN (${list})`,
     );
   }
 
@@ -94,10 +97,10 @@ function commissionSqlConditions({
           ? Prisma.sql`NOT IN`
           : Prisma.sql`IN`;
       conditions.push(Prisma.sql`EXISTS (
-        SELECT 1 FROM ProgramEnrollment pe
-        WHERE pe.programId = c.programId
-          AND pe.partnerId = c.partnerId
-          AND pe.groupId ${op} (${list})
+        SELECT 1 FROM "ProgramEnrollment" pe
+        WHERE pe."programId" = c."programId"
+          AND pe."partnerId" = c."partnerId"
+          AND pe."groupId" ${op} (${list})
       )`);
     }
   }
@@ -312,15 +315,15 @@ async function byGroupId({
   const rows = await prisma.$queryRaw<CommissionGroupIdQueryRow[]>(
     Prisma.sql`
       SELECT
-        pe.groupId AS groupId,
+        pe."groupId" AS "groupId",
         SUM(c.earnings) AS earnings,
         COUNT(c.id) AS count
-      FROM Commission c
-      JOIN ProgramEnrollment pe
-        ON pe.programId = c.programId
-       AND pe.partnerId = c.partnerId
+      FROM "Commission" c
+      JOIN "ProgramEnrollment" pe
+        ON pe."programId" = c."programId"
+       AND pe."partnerId" = c."partnerId"
       WHERE ${whereClause}
-      GROUP BY pe.groupId
+      GROUP BY pe."groupId"
       ORDER BY earnings DESC`,
   );
 
@@ -631,10 +634,10 @@ async function byTimeseries({
   const rows = await prisma.$queryRaw<CommissionTimeseriesRow[]>(
     Prisma.sql`
       SELECT
-        DATE_FORMAT(CONVERT_TZ(c.createdAt, "UTC", ${timezone || "UTC"}), ${dateFormat}) AS start,
+        ${pgDateBucket({ column: Prisma.sql`c."createdAt"`, timezone: timezone || "UTC", dateFormat })} AS start,
         SUM(c.earnings) AS earnings,
         COUNT(c.id) AS count
-      FROM Commission c
+      FROM "Commission" c
       WHERE ${whereClause}
       GROUP BY start
       ORDER BY start ASC`,

apps/web/app/(ee)/api/cron/bounties/queue-sync-social-metrics/route.ts

@@ -28,7 +28,7 @@ export const GET = withCron(async () => {
         },
       ],
       submissionRequirements: {
-        path: "$.socialMetrics",
+        path: ["socialMetrics"],
         not: Prisma.JsonNull,
       },
     },

apps/web/app/(ee)/api/cron/domains/delete/route.ts

@@ -71,7 +71,7 @@ export async function POST(req: Request) {
             ),
           ),
 
-        // Remove the link from MySQL
+        // Remove the link from Postgres
         prisma.link.deleteMany({
           where: {
             id: { in: links.map((link) => link.id) },

apps/web/app/(ee)/api/cron/network/calculate-program-similarities/calculate-partner-similarity.ts

@@ -13,15 +13,15 @@ export async function calculatePartnerSimilarity(
 ): Promise<number> {
   const [result] = await prisma.$queryRaw<PartnerSimilarityResult[]>`
     SELECT 
-      COUNT(DISTINCT CASE WHEN e1.partnerId IS NOT NULL AND e2.partnerId IS NOT NULL THEN e1.partnerId END) AS sharedPartnersCount,
-      (SELECT COUNT(*) FROM ProgramEnrollment WHERE programId = ${program1Id}) AS program1PartnersCount,
-      (SELECT COUNT(*) FROM ProgramEnrollment WHERE programId = ${program2Id}) AS program2PartnersCount
+      COUNT(DISTINCT CASE WHEN e1."partnerId" IS NOT NULL AND e2."partnerId" IS NOT NULL THEN e1."partnerId" END) AS "sharedPartnersCount",
+      (SELECT COUNT(*) FROM "ProgramEnrollment" WHERE "programId" = ${program1Id}) AS "program1PartnersCount",
+      (SELECT COUNT(*) FROM "ProgramEnrollment" WHERE "programId" = ${program2Id}) AS "program2PartnersCount"
     FROM
-      ProgramEnrollment e1
+      "ProgramEnrollment" e1
     JOIN
-      ProgramEnrollment e2 ON e1.partnerId = e2.partnerId
+      "ProgramEnrollment" e2 ON e1."partnerId" = e2."partnerId"
     WHERE
-      e1.programId = ${program1Id} AND e2.programId = ${program2Id}
+      e1."programId" = ${program1Id} AND e2."programId" = ${program2Id}
   `;
 
   const { sharedPartnersCount, program1PartnersCount, program2PartnersCount } =

apps/web/app/(ee)/api/cron/partner-program-summary/process/route.ts

@@ -241,7 +241,7 @@ export const POST = withCron(async ({ rawBody }) => {
     const _previousMonthAnalytics = previousAnalyticsMap.get(partner.id);
     const _currentMonthAnalytics = currentAnalyticsMap.get(partner.id);
 
-    // Get lifetime analytics from MySQL
+    // Get lifetime analytics from Postgres
     const _lifetimeAnalytics = programEnrollments
       .find((enrollment) => enrollment.partner.id === partner.id)
       ?.links.reduce(
@@ -253,7 +253,7 @@ export const POST = withCron(async ({ rawBody }) => {
         { clicks: 0, leads: 0, sales: 0 },
       );
 
-    // Get earnings data from MySQL
+    // Get earnings data from Postgres
     const _previousMonthEarnings = previousEarningsMap.get(partner.id);
     const _currentMonthEarnings = currentEarningsMap.get(partner.id);
     const _lifetimeEarnings = lifetimeEarningsMap.get(partner.id);

apps/web/app/(ee)/api/cron/partners/merge-accounts/route.ts

@@ -5,7 +5,7 @@ import { includeProgramEnrollment } from "@/lib/api/links/include-program-enroll
 import { includeTags } from "@/lib/api/links/include-tags";
 import { syncTotalCommissions } from "@/lib/api/partners/sync-total-commissions";
 import { verifyQstashSignature } from "@/lib/cron/verify-qstash";
-import { conn } from "@/lib/planetscale";
+import { conn } from "@/lib/postgres";
 import { storage } from "@/lib/storage";
 import { recordLink } from "@/lib/tinybird";
 import { redis } from "@/lib/upstash";
@@ -420,7 +420,9 @@ export async function POST(req: Request) {
 
     try {
       // Finally, delete the partner account
-      await conn.execute(`DELETE FROM Partner WHERE id = ?`, [sourcePartnerId]);
+      await conn.execute(`DELETE FROM "Partner" WHERE id = ?`, [
+        sourcePartnerId,
+      ]);
       console.log(
         `Deleted partner ${sourceAccount.email} (${sourceAccount.id})`,
       );