gtfsr2pgsql/src/db.js

23 lines
411 B
JavaScript

const { Pool } = require('pg');
const config = require('./config');
const pool = new Pool(config.db);
/**
* Query the database using the pool
* @param {*} query
* @param {*} params
*
* @see https://node-postgres.com/features/pooling#single-query
*/
async function query(query, params) {
const {rows, fields} = await pool.query(query, params);
return rows;
};
module.exports = {
query
};