postgres-fp

const righto = require('righto')
const connect = require('postgres-fp/connect')
const execute = require('postgres-fp/execute')
const getAll = require('postgres-fp/getAll')
 
const connection = righto(connect, {
  hostname: 'localhost',
  port: 1000
})
const tableCreated = righto(execute, connection, 'CREATE TABLE lorem (info TEXT)')
const testResults = righto(getAll, connection, 'SELECT * FROM test', righto.after(tableCreated))
 
testResults(function (error, results) {
  if (error) {
    throw error
  }
 
  console.log(results)
})

const postgres = require('postgres-fp/promises');
 
async function getTestRecords () {
  const connection = await postgres.connect({
    hostname: 'localhost',
    port: 1000
  });
 
  await postgres.execute(connection, 'CREATE TABLE lorem (info TEXT)');
 
  const results = await postgres.getAll(connection, 'SELECT * FROM test');
 
  console.log(results);
}