zapatos

import pg from 'pg'; import * as db from 'zapatos/db'; import type * as s from 'zapatos/schema'; const pool = new pg.Pool({ connectionString: process.env.DATABASE_URL ?? 'postgres://user:password@localhost:5432/mydb', }); pool.on('error', (err) => console.error('PostgreSQL client error:', err)); async function runExample() { try { // Ensure schema is generated beforehand via `npx zapatos` // or programmatic generation with `zapatos/generate` // Example: Insert a new user const newUser: s.users.Insertable = { name: 'Alice Smith', email: 'alice@example.com' }; const insertedUsers = await db.insert('users', newUser).run(pool); console.log('Inserted user:', insertedUsers[0]); // Example: Select users older than 30 (assuming an 'age' column) // For a real-world example, ensure 'age' exists in your schema. // Here, we'll demonstrate a simple select without 'age' for broader applicability. const allUsers = await db.select('users', db.all).run(pool); console.log('All users:', allUsers); // Example: Update a user's email const updatedUsers = await db.update('users', { email: 'alice.s@example.com' }, { id: db.sql`${insertedUsers[0].id}` }).run(pool); console.log('Updated user:', updatedUsers[0]); // Example: Run a transaction await db.transaction(pool, async (txn) => { const product: s.products.Insertable = { name: 'New Widget', price: 99.99 }; await db.insert('products', product).run(txn); console.log('Product inserted within transaction.'); }); } catch (error) { console.error('Database operation failed:', error); } finally { await pool.end(); } } runExample();