ts-sql-query - npm Package Compare versions

Comparing version 1.28.0 to 1.29.0

connections/AbstractConnection.js

@@ -130,3 +130,3 @@ "use strict";
             }, (e) => {
-                // Transaction only closed when commit successful, in case of error there is still an open transaction 
+                // Transaction only closed when commit successful, in case of error there is still an open transaction
                 // No rollback yet, then no executeAfterNextRollback will be executed
@@ -133,0 +133,0 @@ throw (0, attachSource_1.attachSource)(new chained_error_1.default(e), source);

expressions/insert.d.ts

@@ -597,3 +597,3 @@ import type { IExecutableSelectQuery, RemapIValueSourceType, ValueSourceValueType, AnyValueSource, ValueSourceOf, ValueSourceValueTypeForResult, RemapIValueSourceTypeWithOptionalType, IExecutableInsertQuery, IIfValueSource, IBooleanValueSource, IStringValueSource, ITypeSafeStringValueSource } from "./values";
 };
-declare type DefaultValueType<TABLE extends ITableOrView<any>> = unknown extends TABLE ? () => CustomizableExecutableSimpleInsertOnConflict<TABLE> : keyof RequiredColumnsForSetOf<TABLE> extends never ? () => CustomizableExecutableSimpleInsertOnConflict<TABLE> : never;
+declare type DefaultValueType<TABLE extends ITableOrView<any>> = unknown extends TABLE ? () => CustomizableExecutableSimpleInsertOnConflict<TABLE> : RequiredColumnsForSetOf<TABLE> extends never ? () => CustomizableExecutableSimpleInsertOnConflict<TABLE> : never;
 declare type MaybeExecutableInsertExpression<TABLE extends ITableOrView<any>, MISSING_KEYS> = MISSING_KEYS extends never ? ExecutableInsertExpression<TABLE> : MissingKeysInsertExpression<TABLE, MISSING_KEYS>;
@@ -610,3 +610,3 @@ declare type SelectForInsertResultType<TABLE extends ITableOrView<any>> = {
 };
-declare type InsertSets<TABLE extends ITableOrView<any>> = {
+export declare type InsertSets<TABLE extends ITableOrView<any>> = {
     [P in RequiredColumnsForSetOf<TABLE>]?: InputTypeOfColumn<TABLE, P>;
@@ -616,3 +616,3 @@ } & {
 };
-declare type OptionalInsertSets<TABLE extends ITableOrView<any>> = {
+export declare type OptionalInsertSets<TABLE extends ITableOrView<any>> = {
     [P in RequiredColumnsForSetOf<TABLE>]?: InputTypeOfColumn<TABLE, P> | null | undefined;
@@ -622,3 +622,3 @@ } & {
 };
-declare type MandatoryInsertSets<TABLE extends ITableOrView<any>> = {
+export declare type MandatoryInsertSets<TABLE extends ITableOrView<any>> = {
     [P in RequiredColumnsForSetOf<TABLE>]: InputTypeOfColumn<TABLE, P>;
@@ -625,0 +625,0 @@ } & {

expressions/update.d.ts

@@ -98,3 +98,3 @@ import type { AnyValueSource, IBooleanValueSource, IExecutableUpdateQuery, IIfValueSource, RemapIValueSourceType, RemapIValueSourceTypeWithOptionalType, ValueSourceOf, ValueSourceValueType, ValueSourceValueTypeForResult } from "./values";
 }
-declare type UpdateSets<TABLE extends ITableOrView<any>, USING extends ITableOrView<any>> = {
+export declare type UpdateSets<TABLE extends ITableOrView<any>, USING extends ITableOrView<any>> = {
     [P in RequiredColumnsForSetOf<TABLE>]?: InputTypeOfColumnAllowing<TABLE, P, USING>;
@@ -104,3 +104,3 @@ } & {
 };
-declare type OptionalUpdateSets<TABLE extends ITableOrView<any>, USING extends ITableOrView<any>> = {
+export declare type OptionalUpdateSets<TABLE extends ITableOrView<any>, USING extends ITableOrView<any>> = {
     [P in RequiredColumnsForSetOf<TABLE>]?: InputTypeOfColumnAllowing<TABLE, P, USING> | null | undefined;
@@ -107,0 +107,0 @@ } & {

extras/utils.d.ts

 import type { ITableOrView } from "../utils/ITableOrView";
 import { IfValueSource, BooleanValueSource, IAnyBooleanValueSource, IStringIntValueSource, StringIntValueSource, IStringNumberValueSource, StringNumberValueSource, IIntValueSource, IntValueSource, INumberValueSource, NumberValueSource, ITypeSafeBigintValueSource, TypeSafeBigintValueSource, IBigintValueSource, BigintValueSource, IStringDoubleValueSource, StringDoubleValueSource, IDoubleValueSource, DoubleValueSource, ITypeSafeStringValueSource, TypeSafeStringValueSource, IStringValueSource, StringValueSource, ILocalDateValueSource, LocalDateValueSource, IDateValueSource, DateValueSource, ILocalTimeValueSource, LocalTimeValueSource, ITimeValueSource, TimeValueSource, ILocalDateTimeValueSource, LocalDateTimeValueSource, IDateTimeValueSource, DateTimeValueSource, IEqualableValueSource, EqualableValueSource, IComparableValueSource, ComparableValueSource, IValueSource, AnyValueSource, MergeOptionalUnion } from "../expressions/values";
 import type { ifValueSourceType, optionalType, tableOrView, valueType } from "../utils/symbols";
-import { Column } from "../utils/Column";
+import type { ColumnKeys } from "./types";
 declare type OnlyStringKey<KEY> = KEY extends string ? KEY : never;
@@ -36,5 +36,2 @@ export declare function prefixCapitalized<O extends object, PREFIX extends string>(obj: O, prefix: PREFIX): {
 };
-declare type ColumnKeys<O extends object> = {
-    [K in keyof O]-?: O[K] extends Column ? K : never;
-}[keyof O];
 export declare function extractColumnsFrom<O extends object>(obj: O): {
@@ -41,0 +38,0 @@ [K in ColumnKeys<O>]: O[K];

package.json

 {
     "name": "ts-sql-query",
-    "version": "1.28.0",
+    "version": "1.29.0",
     "description": "Type-safe SQL query builder like QueryDSL or JOOQ in Java or Linq in .Net for TypeScript with MariaDB, MySql, Oracle, PostgreSql, Sqlite and SqlServer support.",
@@ -5,0 +5,0 @@ "license": "MIT",

queryRunners/ConsoleLogQueryRunner.d.ts

 import type { QueryRunner } from "./QueryRunner";
 import { LoggingQueryRunner } from "./LoggingQueryRunner";
+export declare type TimeGranularity = 'ms' | 'us' | 'ns';
+export interface ConsoleLogQueryRunnerOpts {
+    timeGranularity?: TimeGranularity;
+    logTimestamps?: boolean;
+    logDurations?: boolean;
+    logResults?: boolean;
+    paramsAsObject?: boolean;
+    includeLogPhase?: boolean;
+}
 export declare class ConsoleLogQueryRunner<T extends QueryRunner> extends LoggingQueryRunner<T> {
-    constructor(queryRunner: T);
+    constructor(queryRunner: T, opts?: ConsoleLogQueryRunnerOpts);
 }

queryRunners/ConsoleLogQueryRunner.js

@@ -6,9 +6,71 @@ "use strict";
 class ConsoleLogQueryRunner extends LoggingQueryRunner_1.LoggingQueryRunner {
-    constructor(queryRunner) {
-        super({ onQuery: onQuery }, queryRunner);
+    constructor(queryRunner, opts) {
+        const logEnd = opts?.logResults || opts?.logDurations || opts?.logTimestamps;
+        const timeGranularity = opts?.timeGranularity ?? 'ms';
+        super({
+            onQuery: (queryType, query, params, timestamps) => {
+                const phase = opts?.includeLogPhase ? ' (onQuery)' : '';
+                const ts = opts?.logTimestamps
+                    ? `[${formatDuration(timestamps.startedAt, timeGranularity)}] `
+                    : '';
+                const separator = opts?.logTimestamps ? ' ' : '';
+                if (opts?.paramsAsObject) {
+                    console.log(`${ts}${separator}${queryType}${phase}`, { query, params });
+                }
+                else {
+                    console.log(`${ts}${separator}${queryType}${phase}`, query, params);
+                }
+            },
+            onQueryResult: logEnd ? (queryType, query, params, result, timestamps) => {
+                const phase = opts?.includeLogPhase ? ' (onQueryResult)' : '';
+                const ts = opts?.logTimestamps
+                    ? `[${formatDuration(timestamps.endedAt, timeGranularity)}]`
+                    : '';
+                const duration = opts?.logDurations
+                    ? `[Took ${formatDuration(timestamps.endedAt - timestamps.startedAt, timeGranularity)}${timeGranularity}]`
+                    : '';
+                const separator = opts?.logTimestamps || opts?.logDurations ? ' ' : '';
+                if (opts?.logResults) {
+                    if (opts?.paramsAsObject) {
+                        console.log(`${ts}${duration}${separator}${queryType}${phase}`, { query, params });
+                    }
+                    else {
+                        console.log(`${ts}${duration}${separator}${queryType}${phase}`, query, params);
+                    }
+                }
+                else {
+                    if (opts?.paramsAsObject) {
+                        console.log(`${ts}${duration}${separator}${queryType}${phase}`, { query, params, result });
+                    }
+                    else {
+                        console.log(`${ts}${duration}${separator}${queryType}${phase}`, query, params, result);
+                    }
+                }
+            } : undefined,
+            onQueryError: logEnd ? (queryType, query, params, error, timestamps) => {
+                const phase = opts?.includeLogPhase ? ' (onQueryError)' : '';
+                const ts = opts?.logTimestamps
+                    ? `[${formatDuration(timestamps.endedAt, timeGranularity)}]`
+                    : '';
+                const duration = opts?.logDurations
+                    ? `[Took ${formatDuration(timestamps.endedAt - timestamps.startedAt, timeGranularity)}${timeGranularity}]`
+                    : '';
+                const separator = opts?.logTimestamps || opts?.logDurations ? ' ' : '';
+                if (opts?.paramsAsObject) {
+                    console.log(`${ts}${duration}${separator}${queryType}${phase}`, { query, params, error });
+                }
+                else {
+                    console.log(`${ts}${duration}${separator}${queryType}${phase}`, query, params, error);
+                }
+            } : undefined
+        }, queryRunner);
     }
 }
 exports.ConsoleLogQueryRunner = ConsoleLogQueryRunner;
-function onQuery(queryType, query, params) {
-    console.log(queryType + ':', query, params);
-}
+const formatDuration = (durationNS, granularity) => {
+    switch (granularity) {
+        case 'ns': return durationNS;
+        case 'us': return durationNS / 1000n;
+        case 'ms': return durationNS / 1000000n;
+    }
+};

queryRunners/LoggingQueryRunner.d.ts

@@ -5,5 +5,13 @@ import type { QueryRunner } from "./QueryRunner";
 export interface QueryLogger {
-    onQuery?: (queryType: QueryType, query: string, params: any[]) => void;
-    onQueryResult?: (queryType: QueryType, query: string, params: any[], result: any) => void;
-    onQueryError?: (queryType: QueryType, query: string, params: any[], error: any) => void;
+    onQuery?: (queryType: QueryType, query: string, params: any[], timestamps: {
+        startedAt: bigint;
+    }) => void;
+    onQueryResult?: (queryType: QueryType, query: string, params: any[], result: any, timestamps: {
+        startedAt: bigint;
+        endedAt: bigint;
+    }) => void;
+    onQueryError?: (queryType: QueryType, query: string, params: any[], error: any, timestamps: {
+        startedAt: bigint;
+        endedAt: bigint;
+    }) => void;
 }
@@ -10,0 +18,0 @@ export declare class LoggingQueryRunner<T extends QueryRunner> extends ChainedQueryRunner<T> {

queryRunners/LoggingQueryRunner.js

@@ -12,4 +12,5 @@ "use strict";
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('selectOneRow', query, params);
+            logger.onQuery('selectOneRow', query, params, { startedAt });
         }
@@ -20,3 +21,3 @@ let result = this.queryRunner.executeSelectOneRow(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('selectOneRow', query, params, r);
+                    logger.onQueryResult('selectOneRow', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -26,3 +27,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('selectOneRow', query, params, e);
+                    logger.onQueryError('selectOneRow', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -36,4 +37,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('selectManyRows', query, params);
+            logger.onQuery('selectManyRows', query, params, { startedAt });
         }
@@ -44,3 +46,3 @@ let result = this.queryRunner.executeSelectManyRows(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('selectManyRows', query, params, r);
+                    logger.onQueryResult('selectManyRows', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -50,3 +52,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('selectManyRows', query, params, e);
+                    logger.onQueryError('selectManyRows', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -60,4 +62,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('selectOneColumnOneRow', query, params);
+            logger.onQuery('selectOneColumnOneRow', query, params, { startedAt });
         }
@@ -68,3 +71,3 @@ let result = this.queryRunner.executeSelectOneColumnOneRow(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('selectOneColumnOneRow', query, params, r);
+                    logger.onQueryResult('selectOneColumnOneRow', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -74,3 +77,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('selectOneColumnOneRow', query, params, e);
+                    logger.onQueryError('selectOneColumnOneRow', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -84,4 +87,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('selectOneColumnManyRows', query, params);
+            logger.onQuery('selectOneColumnManyRows', query, params, { startedAt });
         }
@@ -92,3 +96,3 @@ let result = this.queryRunner.executeSelectOneColumnManyRows(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('selectOneColumnManyRows', query, params, r);
+                    logger.onQueryResult('selectOneColumnManyRows', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -98,3 +102,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('selectOneColumnManyRows', query, params, e);
+                    logger.onQueryError('selectOneColumnManyRows', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -108,4 +112,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('insert', query, params);
+            logger.onQuery('insert', query, params, { startedAt });
         }
@@ -116,3 +121,3 @@ let result = this.queryRunner.executeInsert(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('insert', query, params, r);
+                    logger.onQueryResult('insert', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -122,3 +127,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('insert', query, params, e);
+                    logger.onQueryError('insert', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -132,4 +137,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('insertReturningLastInsertedId', query, params);
+            logger.onQuery('insertReturningLastInsertedId', query, params, { startedAt });
         }
@@ -140,3 +146,3 @@ let result = this.queryRunner.executeInsertReturningLastInsertedId(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('insertReturningLastInsertedId', query, params, r);
+                    logger.onQueryResult('insertReturningLastInsertedId', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -146,3 +152,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('insertReturningLastInsertedId', query, params, e);
+                    logger.onQueryError('insertReturningLastInsertedId', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -156,4 +162,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('insertReturningMultipleLastInsertedId', query, params);
+            logger.onQuery('insertReturningMultipleLastInsertedId', query, params, { startedAt });
         }
@@ -164,3 +171,3 @@ let result = this.queryRunner.executeInsertReturningMultipleLastInsertedId(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('insertReturningMultipleLastInsertedId', query, params, r);
+                    logger.onQueryResult('insertReturningMultipleLastInsertedId', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -170,3 +177,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('insertReturningMultipleLastInsertedId', query, params, e);
+                    logger.onQueryError('insertReturningMultipleLastInsertedId', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -180,4 +187,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('insertReturningOneRow', query, params);
+            logger.onQuery('insertReturningOneRow', query, params, { startedAt });
         }
@@ -188,3 +196,3 @@ let result = this.queryRunner.executeInsertReturningOneRow(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('insertReturningOneRow', query, params, r);
+                    logger.onQueryResult('insertReturningOneRow', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -194,3 +202,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('insertReturningOneRow', query, params, e);
+                    logger.onQueryError('insertReturningOneRow', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -204,4 +212,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('insertReturningManyRows', query, params);
+            logger.onQuery('insertReturningManyRows', query, params, { startedAt });
         }
@@ -212,3 +221,3 @@ let result = this.queryRunner.executeInsertReturningManyRows(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('insertReturningManyRows', query, params, r);
+                    logger.onQueryResult('insertReturningManyRows', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -218,3 +227,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('insertReturningManyRows', query, params, e);
+                    logger.onQueryError('insertReturningManyRows', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -228,4 +237,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('insertReturningOneColumnOneRow', query, params);
+            logger.onQuery('insertReturningOneColumnOneRow', query, params, { startedAt });
         }
@@ -236,3 +246,3 @@ let result = this.queryRunner.executeInsertReturningOneColumnOneRow(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('insertReturningOneColumnOneRow', query, params, r);
+                    logger.onQueryResult('insertReturningOneColumnOneRow', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -242,3 +252,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('insertReturningOneColumnOneRow', query, params, e);
+                    logger.onQueryError('insertReturningOneColumnOneRow', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -252,4 +262,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('insertReturningOneColumnManyRows', query, params);
+            logger.onQuery('insertReturningOneColumnManyRows', query, params, { startedAt });
         }
@@ -260,3 +271,3 @@ let result = this.queryRunner.executeInsertReturningOneColumnManyRows(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('insertReturningOneColumnManyRows', query, params, r);
+                    logger.onQueryResult('insertReturningOneColumnManyRows', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -266,3 +277,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('insertReturningOneColumnManyRows', query, params, e);
+                    logger.onQueryError('insertReturningOneColumnManyRows', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -276,4 +287,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('update', query, params);
+            logger.onQuery('update', query, params, { startedAt });
         }
@@ -284,3 +296,3 @@ let result = this.queryRunner.executeUpdate(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('update', query, params, r);
+                    logger.onQueryResult('update', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -290,3 +302,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('update', query, params, e);
+                    logger.onQueryError('update', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -300,4 +312,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('updateReturningOneRow', query, params);
+            logger.onQuery('updateReturningOneRow', query, params, { startedAt });
         }
@@ -308,3 +321,3 @@ let result = this.queryRunner.executeUpdateReturningOneRow(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('updateReturningOneRow', query, params, r);
+                    logger.onQueryResult('updateReturningOneRow', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -314,3 +327,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('updateReturningOneRow', query, params, e);
+                    logger.onQueryError('updateReturningOneRow', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -324,4 +337,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('updateReturningManyRows', query, params);
+            logger.onQuery('updateReturningManyRows', query, params, { startedAt });
         }
@@ -332,3 +346,3 @@ let result = this.queryRunner.executeUpdateReturningManyRows(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('updateReturningManyRows', query, params, r);
+                    logger.onQueryResult('updateReturningManyRows', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -338,3 +352,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('updateReturningManyRows', query, params, e);
+                    logger.onQueryError('updateReturningManyRows', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -348,4 +362,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('updateReturningOneColumnOneRow', query, params);
+            logger.onQuery('updateReturningOneColumnOneRow', query, params, { startedAt });
         }
@@ -356,3 +371,3 @@ let result = this.queryRunner.executeUpdateReturningOneColumnOneRow(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('updateReturningOneColumnOneRow', query, params, r);
+                    logger.onQueryResult('updateReturningOneColumnOneRow', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -362,3 +377,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('updateReturningOneColumnOneRow', query, params, e);
+                    logger.onQueryError('updateReturningOneColumnOneRow', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -372,4 +387,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('updateReturningOneColumnManyRows', query, params);
+            logger.onQuery('updateReturningOneColumnManyRows', query, params, { startedAt });
         }
@@ -380,3 +396,3 @@ let result = this.queryRunner.executeUpdateReturningOneColumnManyRows(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('updateReturningOneColumnManyRows', query, params, r);
+                    logger.onQueryResult('updateReturningOneColumnManyRows', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -386,3 +402,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('updateReturningOneColumnManyRows', query, params, e);
+                    logger.onQueryError('updateReturningOneColumnManyRows', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -396,4 +412,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('delete', query, params);
+            logger.onQuery('delete', query, params, { startedAt });
         }
@@ -404,3 +421,3 @@ let result = this.queryRunner.executeDelete(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('delete', query, params, r);
+                    logger.onQueryResult('delete', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -410,3 +427,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('delete', query, params, e);
+                    logger.onQueryError('delete', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -420,4 +437,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('deleteReturningOneRow', query, params);
+            logger.onQuery('deleteReturningOneRow', query, params, { startedAt });
         }
@@ -428,3 +446,3 @@ let result = this.queryRunner.executeDeleteReturningOneRow(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('deleteReturningOneRow', query, params, r);
+                    logger.onQueryResult('deleteReturningOneRow', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -434,3 +452,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('deleteReturningOneRow', query, params, e);
+                    logger.onQueryError('deleteReturningOneRow', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -444,4 +462,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('deleteReturningManyRows', query, params);
+            logger.onQuery('deleteReturningManyRows', query, params, { startedAt });
         }
@@ -452,3 +471,3 @@ let result = this.queryRunner.executeDeleteReturningManyRows(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('deleteReturningManyRows', query, params, r);
+                    logger.onQueryResult('deleteReturningManyRows', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -458,3 +477,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('deleteReturningManyRows', query, params, e);
+                    logger.onQueryError('deleteReturningManyRows', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -468,4 +487,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('deleteReturningOneColumnOneRow', query, params);
+            logger.onQuery('deleteReturningOneColumnOneRow', query, params, { startedAt });
         }
@@ -476,3 +496,3 @@ let result = this.queryRunner.executeDeleteReturningOneColumnOneRow(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('deleteReturningOneColumnOneRow', query, params, r);
+                    logger.onQueryResult('deleteReturningOneColumnOneRow', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -482,3 +502,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('deleteReturningOneColumnOneRow', query, params, e);
+                    logger.onQueryError('deleteReturningOneColumnOneRow', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -492,4 +512,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('deleteReturningOneColumnManyRows', query, params);
+            logger.onQuery('deleteReturningOneColumnManyRows', query, params, { startedAt });
         }
@@ -500,3 +521,3 @@ let result = this.queryRunner.executeDeleteReturningOneColumnManyRows(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('deleteReturningOneColumnManyRows', query, params, r);
+                    logger.onQueryResult('deleteReturningOneColumnManyRows', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -506,3 +527,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('deleteReturningOneColumnManyRows', query, params, e);
+                    logger.onQueryError('deleteReturningOneColumnManyRows', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -516,4 +537,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('executeProcedure', query, params);
+            logger.onQuery('executeProcedure', query, params, { startedAt });
         }
@@ -524,3 +546,3 @@ let result = this.queryRunner.executeProcedure(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('executeProcedure', query, params, r);
+                    logger.onQueryResult('executeProcedure', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -530,3 +552,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('executeProcedure', query, params, e);
+                    logger.onQueryError('executeProcedure', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -540,4 +562,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('executeFunction', query, params);
+            logger.onQuery('executeFunction', query, params, { startedAt });
         }
@@ -548,3 +571,3 @@ let result = this.queryRunner.executeFunction(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('executeFunction', query, params, r);
+                    logger.onQueryResult('executeFunction', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -554,3 +577,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('executeFunction', query, params, e);
+                    logger.onQueryError('executeFunction', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -566,4 +589,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('beginTransaction', query, params);
+            logger.onQuery('beginTransaction', query, params, { startedAt });
         }
@@ -574,3 +598,3 @@ let result = this.queryRunner.executeBeginTransaction();
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('beginTransaction', query, params, r);
+                    logger.onQueryResult('beginTransaction', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -580,3 +604,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('beginTransaction', query, params, e);
+                    logger.onQueryError('beginTransaction', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -592,4 +616,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('commit', query, params);
+            logger.onQuery('commit', query, params, { startedAt });
         }
@@ -600,3 +625,3 @@ let result = this.queryRunner.executeCommit();
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('commit', query, params, r);
+                    logger.onQueryResult('commit', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -606,3 +631,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('commit', query, params, e);
+                    logger.onQueryError('commit', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -618,4 +643,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('rollback', query, params);
+            logger.onQuery('rollback', query, params, { startedAt });
         }
@@ -626,3 +652,3 @@ let result = this.queryRunner.executeRollback();
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('rollback', query, params, r);
+                    logger.onQueryResult('rollback', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -632,3 +658,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('rollback', query, params, e);
+                    logger.onQueryError('rollback', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -642,4 +668,5 @@ throw e;
         const logger = this.logger;
+        const startedAt = process.hrtime.bigint();
         if (logger.onQuery) {
-            logger.onQuery('executeDatabaseSchemaModification', query, params);
+            logger.onQuery('executeDatabaseSchemaModification', query, params, { startedAt });
         }
@@ -650,3 +677,3 @@ let result = this.queryRunner.executeDatabaseSchemaModification(query, params);
                 if (logger.onQueryResult) {
-                    logger.onQueryResult('executeDatabaseSchemaModification', query, params, r);
+                    logger.onQueryResult('executeDatabaseSchemaModification', query, params, r, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -656,3 +683,3 @@ return r;
                 if (logger.onQueryError) {
-                    logger.onQueryError('executeDatabaseSchemaModification', query, params, e);
+                    logger.onQueryError('executeDatabaseSchemaModification', query, params, e, { startedAt, endedAt: process.hrtime.bigint() });
                 }
@@ -659,0 +686,0 @@ throw e;

No alert changes

Improved metrics

Total package byte prevSize

1862532

increased by0.48%

Number of package files

267

increased by0.75%

Lines of code

31860

increased by0.37%

No dependency changes