feat(node): Add Prisma v7 support

Upgrades `@prisma/instrumentation` from `6.19.0` to `7.2.0`. The instrumentation
should be backwards compatible with v5 and v6 (we have integration tests for v5
and v6). I also added integration tests for v7.

Closes: #18876

Author: andreiborza

dev-packages/node-integration-tests/package.json

@@ -35,6 +35,7 @@
     "@nestjs/common": "^11",
     "@nestjs/core": "^11",
     "@nestjs/platform-express": "^11",
+    "@prisma/adapter-pg": "7.2.0",
     "@prisma/client": "6.15.0",
     "@sentry/aws-serverless": "10.35.0",
     "@sentry/core": "10.35.0",

dev-packages/node-integration-tests/suites/tracing/prisma-orm-v7/docker-compose.yml

@@ -0,0 +1,13 @@
+version: '3.9'
+
+services:
+  db:
+    image: postgres:13
+    restart: always
+    container_name: integration-tests-prisma-v7
+    ports:
+      - '5435:5432'
+    environment:
+      POSTGRES_USER: prisma
+      POSTGRES_PASSWORD: prisma
+      POSTGRES_DB: tests

dev-packages/node-integration-tests/suites/tracing/prisma-orm-v7/instrument.mjs

@@ -0,0 +1,9 @@
+import * as Sentry from '@sentry/node';
+import { loggingTransport } from '@sentry-internal/node-integration-tests';
+
+Sentry.init({
+  dsn: 'https://public@dsn.ingest.sentry.io/1337',
+  release: '1.0',
+  tracesSampleRate: 1.0,
+  transport: loggingTransport,
+});

dev-packages/node-integration-tests/suites/tracing/prisma-orm-v7/prisma.config.ts

@@ -0,0 +1,12 @@
+import { defineConfig } from 'prisma/config';
+
+export default defineConfig({
+  earlyAccess: true,
+  schema: './prisma/schema.prisma',
+  migrate: {
+    migrations: './prisma/migrations',
+  },
+  datasource: {
+    url: 'postgresql://prisma:prisma@localhost:5435/tests',
+  },
+});

dev-packages/node-integration-tests/suites/tracing/prisma-orm-v7/prisma/migrations/migration_lock.toml

@@ -0,0 +1,3 @@
+# Please do not edit this file manually
+# It should be added in your version-control system (i.e. Git)
+provider = "postgresql"

dev-packages/node-integration-tests/suites/tracing/prisma-orm-v7/prisma/migrations/sentry_test/migration.sql

@@ -0,0 +1,12 @@
+-- CreateTable
+CREATE TABLE "User" (
+    "id" SERIAL NOT NULL,
+    "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "email" TEXT NOT NULL,
+    "name" TEXT,
+
+    CONSTRAINT "User_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateIndex
+CREATE UNIQUE INDEX "User_email_key" ON "User"("email");

dev-packages/node-integration-tests/suites/tracing/prisma-orm-v7/prisma/schema.prisma

@@ -0,0 +1,14 @@
+datasource db {
+  provider = "postgresql"
+}
+
+generator client {
+  provider = "prisma-client-js"
+}
+
+model User {
+  id        Int      @id @default(autoincrement())
+  createdAt DateTime @default(now())
+  email     String   @unique
+  name      String?
+}

dev-packages/node-integration-tests/suites/tracing/prisma-orm-v7/scenario.mjs

@@ -0,0 +1,46 @@
+import { PrismaPg } from '@prisma/adapter-pg';
+import { PrismaClient } from '@prisma/client';
+import * as Sentry from '@sentry/node';
+import { randomBytes } from 'crypto';
+
+// Stop the process from exiting before the transaction is sent
+setInterval(() => {}, 1000);
+
+const connectionString = 'postgresql://prisma:prisma@localhost:5435/tests';
+
+async function run() {
+  await Sentry.startSpan(
+    {
+      name: 'Test Transaction',
+      op: 'transaction',
+    },
+    async span => {
+      const adapter = new PrismaPg({ connectionString });
+      const client = new PrismaClient({ adapter });
+
+      await client.user.create({
+        data: {
+          name: 'Tilda',
+          email: `tilda_${randomBytes(4).toString('hex')}@sentry.io`,
+        },
+      });
+
+      await client.user.findMany();
+
+      await client.user.deleteMany({
+        where: {
+          email: {
+            contains: 'sentry.io',
+          },
+        },
+      });
+
+      setTimeout(async () => {
+        span.end();
+        await client.$disconnect();
+      }, 500);
+    },
+  );
+}
+
+run();

dev-packages/node-integration-tests/suites/tracing/prisma-orm-v7/test.ts

@@ -0,0 +1,71 @@
+import { afterAll, describe, expect } from 'vitest';
+import { cleanupChildProcesses, createEsmAndCjsTests } from '../../../utils/runner';
+
+afterAll(() => {
+  cleanupChildProcesses();
+});
+
+describe('Prisma ORM v7 Tests', () => {
+  createEsmAndCjsTests(
+    __dirname,
+    'scenario.mjs',
+    'instrument.mjs',
+    (createRunner, test, _mode, cwd) => {
+      test('should instrument PostgreSQL queries from Prisma ORM', { timeout: 75_000 }, async () => {
+        await createRunner()
+          .withDockerCompose({
+            workingDirectory: [cwd],
+            readyMatches: ['port 5432'],
+            setupCommand: `yarn prisma generate --schema ${cwd}/prisma/schema.prisma && yarn prisma migrate dev -n sentry-test --schema ${cwd}/prisma/schema.prisma`,
+          })
+          .expect({
+            transaction: transaction => {
+              expect(transaction.transaction).toBe('Test Transaction');
+
+              const spans = transaction.spans || [];
+              expect(spans.length).toBeGreaterThanOrEqual(5);
+
+              // Verify Prisma spans have the correct origin
+              const prismaSpans = spans.filter(
+                span => span.data && span.data['sentry.origin'] === 'auto.db.otel.prisma',
+              );
+              expect(prismaSpans.length).toBeGreaterThanOrEqual(5);
+
+              // Check for key Prisma span descriptions
+              const spanDescriptions = prismaSpans.map(span => span.description);
+              expect(spanDescriptions).toContain('prisma:client:operation');
+              expect(spanDescriptions).toContain('prisma:client:serialize');
+              expect(spanDescriptions).toContain('prisma:client:connect');
+              expect(spanDescriptions).toContain('prisma:client:db_query');
+
+              // Verify the create operation has correct metadata
+              const createSpan = prismaSpans.find(
+                span =>
+                  span.description === 'prisma:client:operation' &&
+                  span.data?.['method'] === 'create' &&
+                  span.data?.['model'] === 'User',
+              );
+              expect(createSpan).toBeDefined();
+
+              // Verify db_query span has system info and correct op (v7 uses db.system.name)
+              const dbQuerySpan = prismaSpans.find(span => span.description === 'prisma:client:db_query');
+              expect(dbQuerySpan?.data?.['db.system.name']).toBe('postgresql');
+              expect(dbQuerySpan?.data?.['sentry.op']).toBe('db');
+              expect(dbQuerySpan?.op).toBe('db');
+            },
+          })
+          .start()
+          .completed();
+      });
+    },
+    {
+      additionalDependencies: {
+        '@prisma/adapter-pg': '7.2.0',
+        '@prisma/client': '7.2.0',
+        pg: '^8.11.0',
+        prisma: '7.2.0',
+      },
+      copyPaths: ['prisma', 'prisma.config.ts', 'docker-compose.yml'],
+    },
+  );
+});

packages/node/package.json

@@ -94,7 +94,7 @@
     "@opentelemetry/resources": "^2.4.0",
     "@opentelemetry/sdk-trace-base": "^2.4.0",
     "@opentelemetry/semantic-conventions": "^1.37.0",
-    "@prisma/instrumentation": "6.19.0",
+    "@prisma/instrumentation": "7.2.0",
     "@sentry/core": "10.35.0",
     "@sentry/node-core": "10.35.0",
     "@sentry/opentelemetry": "10.35.0",