f

Author: killagu

src/channels.ts

@@ -24,12 +24,14 @@ export interface ConnectionEnqueueMessage {
 
 export interface QueryStartMessage {
   connection: PoolConnectionPromisify;
+  values?: object | any[];
   sql: string;
 }
 
 export interface QueryEndMessage {
   connection: PoolConnectionPromisify;
   sql: string;
+  values?: object | any[];
   duration: number;
   error?: Error;
 }

src/operator.ts

@@ -92,6 +92,7 @@ export abstract class Operator {
     let lastError: Error | undefined;
     channels.queryStart.publish({
       sql,
+      values,
       connection: this.#connection,
     } as QueryStartMessage);
     try {
@@ -112,6 +113,7 @@ export abstract class Operator {
       channels.queryEnd.publish({
         sql,
         connection: this.#connection,
+        values,
         duration,
         error: lastError,
       } as QueryEndMessage);