pg-pool

const Pool = require('pg-pool'); const { URL } = require('url'); // Node.js built-in URL parser // In a real application, ensure process.env.DATABASE_URL is set, // e.g., DATABASE_URL=postgres://user:password@localhost:5432/mydatabase const databaseUrl = process.env.DATABASE_URL || 'postgres://testuser:testpass@localhost:5432/testdb'; const params = new URL(databaseUrl); const auth = params.username && params.password ? params.username.split(':') : [params.username, params.password]; const config = { user: auth[0], password: auth[1], host: params.hostname, port: parseInt(params.port || '5432'), // Default PostgreSQL port database: params.pathname.split('/')[1], ssl: params.protocol === 'https:' || (process.env.NODE_ENV === 'production' && databaseUrl.includes('sslmode=require')), // Use SSL in production or if protocol specifies max: 10, // Max clients in the pool idleTimeoutMillis: 30000, // Close idle clients after 30 seconds connectionTimeoutMillis: 2000, // Return error after 2 seconds if connection not established }; const pool = new Pool(config); (async () => { let client; try { // Acquire a client from the pool client = await pool.connect(); console.log('Client acquired from pool.'); // Execute a query using the client const res = await client.query('SELECT $1::text as message', ['Hello from pg-pool with async/await!']); console.log('Query result:', res.rows[0].message); // Demonstrate direct pool.query (acquires, queries, and releases client automatically) const timeRes = await pool.query('SELECT NOW() as current_time'); console.log('Current database time via direct query:', timeRes.rows[0].current_time); } catch (err) { console.error('Database operation failed:', err.message, err.stack); } finally { // Release the client back to the pool to prevent resource leaks if (client) { client.release(); console.log('Client released back to pool.'); } // It's good practice to end the pool when the application is shutting down // For a quickstart, we end it here, but in a real app it's usually on process exit. await pool.end(); console.log('Pool has been ended.'); } })();