fix: option is passed to pg connect by a copied object not prototype

Author: Laszlo Radics

lib/pgDb.js

@@ -3,6 +3,7 @@ import {PgTable} from "./pgTable";
 import {PgSchema} from "./pgSchema";
 import * as PgConverters from "./pgConverters";
 import {pgUtils} from "./pgUtils";
+import * as _ from 'lodash';
 
 const pg = require('pg');
 const readline = require('readline');
@@ -213,10 +214,7 @@ export class PgDb extends QueryAble {
     }
 
     private async init(): Promise<PgDb> {
-        this.pool = new pg.Pool(Object.create(this.config, {
-            logger: {value: undefined},
-            skipUndefined: {value: undefined}
-        }));
+        this.pool = new pg.Pool(_.omit(this.config, ['logger','skipUndefined']));
         if (this.config.logger)
             this.setLogger(this.config.logger);
 

lib/pgDb.js.map

@@ -102,15 +102,9 @@ describe("pgdb", () => {
     }));
 
     afterEach(w(async () => {
-        if (pgdb.pool._pendingQueue.length != 0) {
+        if (pgdb.pool.waitingCount != 0) {
             expect('Not all connection is released').toBeFalsy();
-            for (let connection of pgdb.pool._clients) {
-                await connection.query('ROLLBACK');
-                if (connection.release) {
-                    console.log('stuck connection:', connection.processID);
-                    connection.release();
-                }
-            }
+            await pgdb.pool.end();
         }
     }));