sql.js

/* jshint node: true */
'use strict';

const pg     = require('pg');
const util   = require('util');
const logger = require('./services/logger.service').getLogger();

const dbConfig = require('./configs/dev.config').database;

const pool = new pg.Pool({
    host: dbConfig.host,
    user: dbConfig.username,
    database: dbConfig.db,
    password: dbConfig.password,
    port: dbConfig.port,
    max: 20,
    idleTimeoutMillis: 30000,
    connectionTimeoutMillis: 200000
});

pool.on('error', (err, client) => {
    logger.error('[error] Unexpected error on idle client: %s', err);
});

logger.info('[sql] connecting to: %s@%s:%s', dbConfig.db, dbConfig.host, dbConfig.port);

pool.on('error', (err, client) => {
    logger.error('[error] Unexpected error on idle client: %s', err);
    //process.exit(-1)
});

logger.info('[sql] connecting to: %s@%s:%s', dbConfig.db, dbConfig.host, dbConfig.port);
class db {
    executeQuery(query) {
        return new Promise((resolve, reject) => {
            pool.connect((err, client, done) => {
                if (err){
                    reject(err);   
                }else{
                    client.query(query, (err, result) => {
                        done();
                        if (err) {
                            logger.trace('[query]  %s', query);
                            logger.error('[db] %j', err);
                            reject(err);
                        } else {
                            logger.trace('[db] returned %d rows | %s', result.rowCount, query);
                            resolve(result.rows);
                        }
                    })
                }
            })
        });
    }
};

module.exports = db;