pgsql-client

import { Client } from 'pgsql-client'; async function runPgsqlClientExample() { // Ensure DATABASE_URL is set in your environment or provide a default const connectionString = process.env.DATABASE_URL ?? 'postgresql://user:password@localhost:5432/mydb'; let client: Client | undefined; try { // Initialize and connect the PostgreSQL client client = new Client(connectionString); await client.connect(); console.log('Successfully connected to PostgreSQL database.'); // Set RLS context for the current session, crucial for secure data access // In a real application, this context comes from an authenticated user's JWT claims or session data. const currentUser = { id: 'usr_abc123', role: 'authenticated', tenant_id: 'org_xyz' }; await client.setContext({ role: currentUser.role, 'jwt.claims.user_id': currentUser.id, 'app.tenant_id': currentUser.tenant_id // Custom context variable for multi-tenancy }); console.log(`RLS context set for user '${currentUser.id}' in tenant '${currentUser.tenant_id}'.`); // Execute a query; RLS policies on the server will automatically filter results // based on the 'app.tenant_id' set in the context. const result = await client.query('SELECT id, name, description FROM products WHERE tenant_id = current_setting(\'app.tenant_id\', true)::text ORDER BY name LIMIT 3'); console.log('Query executed. Products (filtered by RLS):', result.rows); } catch (error: any) { console.error('Database operation failed:', error.message); } finally { if (client) { // Always ensure the client connection is closed await client.close(); console.log('PostgreSQL connection closed.'); } } } runPgsqlClientExample();