Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- var pg = require("pg");
- var connectionString = {
- user: 'user',
- host: 'host',
- database: 'db',
- password: 'pass',
- port: 5432, };
- var pool = new pg.Pool(connectionString);
- pool.connect(function(err, client, done) {
- const query = client.query(new pg.Query("SELECT * from products")) query.on('row', (row) => {
- console.log(row);
- })
- query.on('end', (res) => {
- // pool shutdown
- console.log("ending");
- pool.end()
- })
- query.on('error', (res) => {
- console.log(res);
- })
- done() })
- SELECT array_to_string(array( SELECT row_to_json(products.*) FROM products),', ') as jsonData;
Add Comment
Please, Sign In to add comment