Как правильно использовать узел.модуль на JS в PostgreSQL?

Я автор pg-promise, что упрощает использование node-postgres через обещания.

Он решает вопросы о правильном способе подключения и отключения от базы данных, используя пул соединений, реализованный node-postgres, среди прочего, как автоматические транзакции.

индивидуальный запрос в pg-promise сводится к тому, что отношение к вашему бизнесу логика:

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

т. е. вам не нужно иметь дело с логикой соединения при выполнении запросов, потому что вы устанавливаете соединение только один раз, глобально, например:

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;

вы можете найти еще много примеров в учитесь на примере учебник, или на главная страница проекта.

Как вы можете видеть из документация оба варианта действительны, поэтому выберите то, что вы предпочитаете. Как вы, я бы выбрал второй вариант.

лучше создать пул pg глобально, и каждый раз, когда вам нужно сделать операцию db, используйте клиент, а затем отпустите его обратно в пул. Как только все операции с БД будут выполнены, завершите пул с помощью pool.end()

пример кода:

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();

        });
}

});  

источник

меня интересовал очень простой обработчик для этого, поэтому я сделал свой собственный, не делая его более сложным. Я не питаю иллюзий, что это супер базовый, но это может помочь некоторым людям начать работу. В основном, он подключается, выполняет запросы и обрабатывает ошибки для вас.

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);
    });
  });
}

тогда вы бы использовали, называя его так:

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

вот как я это делаю, своего рода"все вышеперечисленные подходы"

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()