irongit
26 lines599 BJavaScript
1const { Pool } = require('pg');
2
3if (!process.env.DATABASE_URL) {
4 console.error('DATABASE_URL environment variable is not set');
5 process.exit(1);
6}
7
8const pool = new Pool({
9 connectionString: process.env.DATABASE_URL,
10 max: 20,
11 idleTimeoutMillis: 30000,
12 connectionTimeoutMillis: 2000,
13});
14
15pool.on('connect', () => {
16 console.log('Connected to PostgreSQL');
17});
18
19pool.on('error', (err) => {
20 console.error('PostgreSQL pool error:', err);
21});
22
23const query = (text, params) => pool.query(text, params);
24const getClient = () => pool.connect();
25
26module.exports = { query, getClient, pool };