embedded-postgres

import EmbeddedPostgres from 'embedded-postgres'; async function main() { // Create the object with custom options for data directory, user, password, port, and persistence. const pg = new EmbeddedPostgres({ databaseDir: './data/db', user: 'testuser', password: 'testpassword', port: 5433, // Use a non-default port to avoid conflicts persistent: true, }); try { // Create the cluster configuration files and data directory. await pg.initialise(); // Start the PostgreSQL server process. await pg.start(); // Create a new database named 'MYAPP_DB'. await pg.createDatabase('MYAPP_DB'); // Initialize a node-postgres client using the embedded instance's connection details. const client = pg.getPgClient(); await client.connect(); // Execute a simple query to verify connection and functionality. const result = await client.query('SELECT current_database(), current_user, pg_backend_pid() AS pid;'); console.log('PostgreSQL server started and connected successfully.'); console.log('Connected to database:', result.rows[0].current_database); console.log('Current user:', result.rows[0].current_user); console.log('Backend PID:', result.rows[0].pid); // Example: Create a table and insert data await client.query('CREATE TABLE IF NOT EXISTS users (id SERIAL PRIMARY KEY, name VARCHAR(255));'); await client.query("INSERT INTO users (name) VALUES ('Alice'), ('Bob');"); const users = await client.query('SELECT * FROM users;'); console.log('Users:', users.rows); // Drop the created database, cleaning up. await pg.dropDatabase('MYAPP_DB'); } catch (error) { console.error('An error occurred:', error); } finally { // Ensure the server is stopped, even if errors occur. await pg.stop(); console.log('PostgreSQL server stopped.'); } } main();