26 lines
597 B
JavaScript
26 lines
597 B
JavaScript
const Pool = require('pg-pool');
|
|
|
|
const pgConnection = new Pool({
|
|
user: process.env.POSTGRESQL_USERNAME,
|
|
password: process.env.POSTGRESQL_PASSWORD,
|
|
host: process.env.POSTGRESQL_HOST,
|
|
port: 5432,
|
|
database: process.env.POSTGRESQL_DATABASE
|
|
})
|
|
|
|
module.exports = {
|
|
pgQuery: async (sql, values) => {
|
|
let connection = false
|
|
try {
|
|
connection = await pgConnection.connect()
|
|
let results = await connection.query(sql, values)
|
|
return results
|
|
} catch (error) {
|
|
throw error
|
|
} finally {
|
|
if (connection) {
|
|
connection.release()
|
|
}
|
|
}
|
|
},
|
|
} |