47 lines
1.1 KiB
JavaScript
47 lines
1.1 KiB
JavaScript
/**
|
|
* @file
|
|
* Configures the database connection
|
|
*/
|
|
|
|
const { Pool, Client } = require('pg');
|
|
const logger = require('./logger');
|
|
//const connectionString = 'postgresql://wrenchboard:wrenchboard@10.10.10.23:5432/wrenchboard';
|
|
const connectionString = process.env.POSTGRE_URL;
|
|
const postgres = new Pool({
|
|
connectionString,
|
|
});
|
|
|
|
postgres.on('connect', client => {
|
|
logger.info('Connected to Database');
|
|
});
|
|
|
|
postgres.on('acquire', client => {
|
|
logger.info('Client is checked out from the DB connection pool');
|
|
});
|
|
|
|
postgres.on('remove', client => {
|
|
logger.info('Client is closed & removed from the DB connection pool');
|
|
});
|
|
|
|
postgres.on('error', (err, client) => {
|
|
logger.error(err);
|
|
});
|
|
|
|
// Connect to PostgreSQL
|
|
postgres.connect((err, client, release) => {
|
|
logger.info(connectionString);
|
|
if (err) {
|
|
logger.error('Error acquiring client', err.stack);
|
|
return null;
|
|
}
|
|
client.query('SELECT NOW()', (err, result) => {
|
|
release();
|
|
if (err) {
|
|
logger.error('Error executing query', err.stack);
|
|
return nul;
|
|
}
|
|
logger.info(result.rows);
|
|
});
|
|
});
|
|
|
|
module.exports = postgres; |