| const { Client } = require("pg"); |
|
|
| (async () => { |
| const client = new Client({ |
| connectionString: process.env.DATABASE_URL, |
| application_name: "$ docs_quickstart_node" |
| }); |
|
|
| const statements = [ |
| |
| "DROP TABLE IF EXISTS messages", |
| |
| "CREATE TABLE IF NOT EXISTS messages (id UUID PRIMARY KEY DEFAULT gen_random_uuid(), message STRING)", |
| |
| "INSERT INTO messages (message) VALUES ('Hello world!')", |
| |
| "SELECT message FROM messages", |
| ]; |
|
|
| try { |
| |
| await client.connect(); |
| for (let n = 0; n < statements.length; n++) { |
| let result = await client.query(statements[n]); |
| if (result.rows[0]) { console.log(result.rows[0].message); } |
| } |
| await client.end(); |
| } catch (err) { |
| console.log(`error connecting: ${err}`); |
| } |
|
|
| |
| process.exit(); |
| })().catch((err) => console.log(err.stack)); |
|
|
