Jaki jest właściwy sposób korzystania z węzła.moduł js postgresql?

Jestem autorem PG-promise , który upraszcza użycie node-postgres poprzez promises.

Rozwiązuje problemy dotyczące właściwego sposobu łączenia się i odłączania od bazy danych, wykorzystując pulę połączeń zaimplementowaną przez node-postgres , między innymi, jak zautomatyzowane transakcje.

Indywidualne żądanie w PG-promise sprowadza się tylko do tego, co jest istotne dla Twojej logiki biznesowej:

db.any('SELECT * FROM users WHERE status = $1', ['active'])
    .then(data => {
        console.log('DATA:', data);
    })
    .catch(error => {
        console.log('ERROR:', error);
    });

Tzn. nie musisz radzić sobie z logiką połączenia podczas wykonywania zapytań, ponieważ skonfigurowałeś połączenie tylko raz, globalnie, jak to:

const pgp = require('pg-promise')(/*options*/);

const cn = {
    host: 'localhost', // server name or IP address;
    port: 5432,
    database: 'myDatabase',
    user: 'myUser',
    password: 'myPassword'
};
// alternative:
// const cn = 'postgres://username:password@host:port/database';

const db = pgp(cn); // database instance;

O wiele więcej przykładów można znaleźć w Learn by Example tutorial, lub na stronie głównej projektu.

Jak widać z Dokumentacji obie opcje są ważne, więc wybierz dowolną opcję. Jako ty, wybrałbym drugą opcję.

Lepiej jest utworzyć PG pool globalnie i za każdym razem, gdy musisz wykonać operację db, użyj klienta, a następnie zwolnij go z powrotem do puli. Po wykonaniu wszystkich operacji db Zakończ pulę używając pool.end()

Przykładowy kod-

let pool = new pg.Pool(dbConfig);
pool.connect(function(err, client, done) {

if (err) {
    console.error('Error connecting to pg server' + err.stack);
    callback(err);
} else {
    console.log('Connection established with pg db server');

    client.query("select * from employee", (err, res) => {

            if (err) {
                console.error('Error executing query on pg db' + err.stack);
                callback(err);
            } else {
                console.log('Got query results : ' + res.rows.length);


               async.each(res.rows, function(empRecord) {   
                        console.log(empRecord.name);
                });
            }
            client.release();

        });
}

});  

Źródło

Byłem zainteresowany bardzo prostym opiekunem do tego, więc zrobiłem swój własny, nie komplikując tego. Nie mam złudzeń, że jest super podstawowy, ale może pomóc niektórym zacząć. Zasadniczo łączy się, uruchamia zapytania i obsługuje błędy.

function runQuery(queryString, callback) {
  // connect to postgres database
  pg.connect(postgresDatabase.url,function(err,client,done) {
    // if error, stop here
    if (err) {console.error(err); done(); callback(); return;}
    // execute queryString
    client.query(queryString,function(err,result) {
      // if error, stop here
      if (err) {console.error(err+'\nQuery: '+queryString); done(); callback(); return;}
      // callback to close connection
      done();
      // callback with results
      callback(result.rows);
    });
  });
}

Wtedy użyłbyś nazywając to w ten sposób:

runQuery("SELECT * FROM table", function(result) {
  // Whatever you need to do with 'result'
}

Oto Jak to robię, coś w rodzaju "całego powyższego podejścia"

Promise = require 'bluebird'
pg = module.exports = require 'pg'

Promise.promisifyAll pg.Client.prototype
Promise.promisifyAll pg.Client
Promise.promisifyAll pg.Connection.prototype
Promise.promisifyAll pg.Connection
Promise.promisifyAll pg.Query.prototype
Promise.promisifyAll pg.Query
Promise.promisifyAll pg

connectionString = process.env.DATABASE_URL

module.exports.queryAsync = (sql, values) ->
  pg.connectAsync connectionString
  .spread (connection, release) ->
    connection.queryAsync sql, values
    .then (result) ->
      console.log result.rows[0]
    .finally ->
      release()