23 lines
554 B
JavaScript
23 lines
554 B
JavaScript
|
import { Pool } from 'pg';
|
||
|
|
import 'dotenv/config';
|
||
|
|
|
||
|
|
const poolCreds = {
|
||
|
|
host: process.env.POSTGRES_HOST,
|
||
|
|
database: process.env.POSTGRES_DB_SHIFT,
|
||
|
|
port: process.env.POSTGRES_PORT,
|
||
|
|
user: process.env.POSTGRES_USER,
|
||
|
|
password: process.env.POSTGRES_PASSWORD
|
||
|
|
};
|
||
|
|
|
||
|
|
const pool = new Pool(poolCreds);
|
||
|
|
|
||
|
|
export const shiftRunQuery = async (query, params = []) => {
|
||
|
|
const client = await pool.connect();
|
||
|
|
|
||
|
|
try {
|
||
|
|
const pgQueryResponse = await client.query(query, params);
|
||
|
|
return pgQueryResponse?.rows || [];
|
||
|
|
} finally {
|
||
|
|
client.release();
|
||
|
|
}
|
||
|
|
}
|