pg

import { Pool } from 'pg'; import dotenv from 'dotenv'; dotenv.config(); const pool = new Pool({ connectionString: process.env.DATABASE_URL ?? 'postgresql://user:password@localhost:5432/mydb', ssl: process.env.NODE_ENV === 'production' ? { rejectUnauthorized: false } : undefined, // Adjust SSL for production }); async function queryDatabase() { let client; try { client = await pool.connect(); // Acquire a client from the pool const res = await client.query('SELECT $1::text as message, NOW() as currentTime;', ['Hello from pg!']); console.log('Query result:', res.rows[0].message); console.log('Current DB Time:', res.rows[0].currenttime); const insertRes = await client.query('INSERT INTO users(name, email) VALUES($1, $2) RETURNING id;', ['John Doe', 'john.doe@example.com']); console.log('Inserted user with ID:', insertRes.rows[0].id); const usersRes = await client.query('SELECT * FROM users WHERE email = $1;', ['john.doe@example.com']); console.log('Found user:', usersRes.rows[0]); } catch (err) { console.error('Database operation failed:', err); process.exit(1); } finally { if (client) { client.release(); // Release the client back to the pool console.log('Client released.'); } } } async function setupDatabase() { const setupClient = await pool.connect(); try { console.log('Setting up database...'); await setupClient.query(` CREATE TABLE IF NOT EXISTS users ( id SERIAL PRIMARY KEY, name VARCHAR(100) NOT NULL, email VARCHAR(100) UNIQUE NOT NULL, created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP ); `); console.log('Table "users" ensured.'); } catch (err) { console.error('Database setup failed:', err); } finally { setupClient.release(); } } setupDatabase().then(() => queryDatabase().then(() => pool.end()));