feat: new query function queryAsRows which gives result as array instead of objects

Author: Laszlo Radics

lib/pgDb.d.ts

@@ -73,6 +73,6 @@ export declare class PgDb extends QueryAble {
     private listeners;
     listen(channel: string, callback: (notification: Notification) => void): Promise<void>;
     unlisten(channel: string, callback?: (Notification: any) => void): Promise<void>;
-    notify(channel: string, payload?: string): Promise<any>;
+    notify(channel: string, payload?: string): Promise<any[]>;
 }
 export default PgDb;

lib/pgUtils.d.ts

@@ -17,10 +17,10 @@ export declare let pgUtils: {
     processQueryOptions(options: QueryOptions): string;
     transformInsertUpdateParams(param: any, fieldType: FieldType): any;
     postProcessResult(res: any[], fields: ResultFieldType[], pgdbTypeParsers: {
-        [oid: number]: (string: any) => any;
+        [oid: number]: (s: string) => any;
     }): void;
     convertTypes(res: any[], fields: ResultFieldType[], pgdbTypeParsers: {
-        [oid: number]: (string: any) => any;
+        [oid: number]: (s: string) => any;
     }): void;
     createFunctionCaller(q: QueryAble, fn: {
         schema: string;

lib/pgUtils.js

@@ -37,6 +37,10 @@ export interface ResultType {
     rowsAsArray: boolean;
     _getTypeParser: Function[];
 }
+export interface PgRowResult {
+    columns: string[];
+    rows: any[];
+}
 export declare class QueryAble {
     db: any;
     schema: any;
@@ -51,7 +55,15 @@ export declare class QueryAble {
         sql: string;
         params?: any;
         logger?: any;
-    }): Promise<any>;
+    }): Promise<any[]>;
+    protected internalQuery(options: {
+        connection: any;
+        sql: string;
+        params?: any;
+        logger?: any;
+        rowMode: true;
+    }): Promise<PgRowResult>;
+    queryAsRows(sql: string, params?: any[] | {}, options?: SqlQueryOptions): Promise<PgRowResult>;
     queryWithOnCursorCallback(sql: string, params: any[] | {}, options: SqlQueryOptions, callback: (any: any) => any): Promise<void>;
     queryAsStream(sql: string, params?: any[] | {}, options?: SqlQueryOptions): Promise<stream.Readable>;
     queryOne(sql: string, params?: any[] | {}, options?: SqlQueryOptions): Promise<any>;