Каков правильный способ использования модуля node.js postgresql?

Question

Я пишу приложение node.js на Heroku и используя pg module. Я не могу понять, «правильный» способ получить клиентский объект для каждого запроса, который мне нужен для запроса базы данных.

документация использует такой код:

pg.connect(conString, function(err, client) { 
    // Use the client to do things here 
}); 

Но, конечно, вам не нужно вызывать pg.connect внутри каждую функцию, которая использует право базы данных? Я видел other code, что делает это:

var conString = process.env.DATABASE_URL || "tcp://postgres:1234@localhost/postgres"; 
var client = new pg.Client(conString); 
client.connect(); 
// client is a global so you can use it anywhere now 

Я склоняюсь к второму варианту, так как я считаю, что свободный экземпляр базы данных для Heroku ограничивается одним соединением в любом случае, но есть какие-либо недостатки делать это таким образом? Нужно ли проверять, все ли мой клиентский объект все еще подключен каждый раз, прежде чем использовать его?

Answer 1

Я являюсь автором node-postgres. Во-первых, я приношу свои извинения, что документация не позволила сделать правильный выбор: это моя ошибка. Я постараюсь улучшить его. Я написал a Gist только сейчас, чтобы объяснить это, потому что the conversation слишком долго вырос для Twitter.

Использование pg.connect является путь в веб-среде.

Сервер PostgreSQL может обрабатывать только один запрос за один раз за соединение. Это означает, что если у вас есть 1 глобальный new pg.Client(), подключенный к вашему бэкэнд, все ваше приложение буксируется в зависимости от того, насколько быстро postgres может отвечать на запросы. Это буквально выровнят все, очереди каждого запроса. Да, это асинхронно, и так все в порядке ... но не могли бы вы умножить свою пропускную способность на 10 раз? Используйте pg.connect, установите pg.defaults.poolSize на что-то нормальное (мы делаем 25-100, не уверены правый номер еще).

new pg.Client для тех, кто знает, что вы делаете. Когда вам нужен один долговечный клиент по какой-либо причине или нужно очень тщательно контролировать жизненный цикл. Хорошим примером этого является использование LISTEN/NOTIFY. Слушающий клиент должен быть рядом, а подключен и не используется, поэтому он может правильно обрабатывать сообщения NOTIFY. Другим примером может быть открытие 1-офф-клиента, чтобы убить какой-либо висячий материал или сценарии командной строки.

Одна очень полезная вещь - централизовать весь доступ к вашей базе данных в приложении к одному файлу. Не засоряйте pg.connect звонки или новые клиенты. Есть файл, как db.js, который выглядит примерно так:

module.exports = { 
    query: function(text, values, cb) { 
     pg.connect(function(err, client, done) { 
     client.query(text, values, function(err, result) { 
      done(); 
      cb(err, result); 
     }) 
     }); 
    } 
} 

Таким образом, вы можете изменить вашу реализацию из pg.connect в пользовательский пул клиентов или независимо от того, и только должны изменить положение вещей в одном месте.

Посмотрите на node-pg-query module, который делает именно это.

Answer 2

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

Answer 3

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

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

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

db.any('SELECT * FROM users WHERE status = $1', ['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; 

Вы можете найти много примеров в Learn by Example учебнике или на project's home page.

Answer 4

Вот как я это сделать, вроде «все из изложенного выше подхода»

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

Answer 5

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

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' 
} 

Answer 6

Лучше создать пул пг глобально и каждый раз, когда вам нужно сделать операцию дб использовать клиент, а затем отпустить его обратно в бассейн. После того, как все дБ операции выполняются в конечном бассейне с помощью 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(); 

     }); 
} 

}); 

Source