feat(tracing): Add db connection attributes for postgres spans

packages/node-integration-tests/suites/tracing/auto-instrument/pg/test.ts

@@ -1,6 +1,11 @@
 import { assertSentryTransaction, TestEnv } from '../../../../utils';
 
 class PgClient {
+  database?: string = 'test';
+  user?: string = 'user';
+  host?: string = 'localhost';
+  port?: number = 5432;
+
   // https://node-postgres.com/api/client#clientquery
   public query(_text: unknown, values: unknown, callback?: () => void) {
     if (typeof callback === 'function') {
@@ -42,20 +47,32 @@ test('should auto-instrument `pg` package.', async () => {
         op: 'db',
         data: {
           'db.system': 'postgresql',
+          'db.user': 'user',
+          'db.name': 'test',
+          'server.address': 'localhost',
+          'server.port': 5432,
         },
       },
       {
         description: 'SELECT * FROM bazz',
         op: 'db',
         data: {
           'db.system': 'postgresql',
+          'db.user': 'user',
+          'db.name': 'test',
+          'server.address': 'localhost',
+          'server.port': 5432,
         },
       },
       {
         description: 'SELECT NOW()',
         op: 'db',
         data: {
           'db.system': 'postgresql',
+          'db.user': 'user',
+          'db.name': 'test',
+          'server.address': 'localhost',
+          'server.port': 5432,
         },
       },
     ],

packages/tracing-internal/src/node/integrations/postgres.ts

@@ -11,6 +11,13 @@ interface PgClient {
   };
 }
 
+interface PgClientThis {
+  database?: string;
+  host?: string;
+  port?: number;
+  user?: string;
+}
+
 interface PgOptions {
   usePgNative?: boolean;
 }
@@ -74,15 +81,35 @@ export class Postgres implements LazyLoadedIntegration<PGModule> {
      * function (pg.Cursor) => pg.Cursor
      */
     fill(Client.prototype, 'query', function (orig: () => void | Promise<unknown>) {
-      return function (this: unknown, config: unknown, values: unknown, callback: unknown) {
+      return function (this: PgClientThis, config: unknown, values: unknown, callback: unknown) {
         const scope = getCurrentHub().getScope();
         const parentSpan = scope?.getSpan();
+
+        const data: Record<string, string | number> = {
+          'db.system': 'postgresql',
+        };
+
+        try {
+          if (this.database) {
+            data['db.name'] = this.database;
+          }
+          if (this.host) {
+            data['server.address'] = this.host;
+          }
+          if (this.port) {
+            data['server.port'] = this.port;
+          }
+          if (this.user) {
+            data['db.user'] = this.user;
+          }
+        } catch (e) {
+          // ignore
+        }
+
         const span = parentSpan?.startChild({
           description: typeof config === 'string' ? config : (config as { text: string }).text,
           op: 'db',
-          data: {
-            'db.system': 'postgresql',
-          },
+          data,
         });
 
         if (typeof callback === 'function') {