in stress-test/postgres.js [21:57]
async function main(args) {
console.log(args.postgres_url);
const client = new Client({ connectionString: args.postgres_url });
const createTableText = `
CREATE EXTENSION IF NOT EXISTS "pgcrypto";
CREATE TABLE IF NOT EXISTS nuvolaris_table (
id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
message varchar(100)
);
`
// Connect to database server
await client.connect();
response = { body: {} }
try {
await client.query(createTableText)
const message = (Math.random() + 1).toString(36).substring(2);
await client.query('INSERT INTO nuvolaris_table(message) VALUES($1)', [message])
const { rows } = await client.query('SELECT id, message FROM nuvolaris_table where message = $1', [message]);
const { rowCount } = await client.query('DELETE FROM nuvolaris_table WHERE id = $1', [rows[0].id]);
response.body = {
rows,
rowCount
}
} catch (e) {
console.log(e);
throw e
} finally {
client.end();
}
return response;
}