Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- var pg = require('pg');
- var conString = "postgres://username:password@localhost/database";
- pg.connect(conString, function (err, client, done) {
- module.exports = function (/* arguments */) {
- var args = [].slice.call(arguments), //Копируем массив аргументов
- next = args.splice(args.length - 1, 1).shift(); //Вытягиваем колбек, который передается последним аргументом
- /* Подменяем старый колбек в массиве аргументов новым, который автоматически вызывает done() */
- args.push(function (/* arguments */) {
- done();
- next.apply(null, arguments);
- });
- if (err) {
- return console.error('error fetching client from pool', err);
- }
- client.query.apply(null, args);
- client.query('SELECT $1::int AS number', ['1'], function (err, result) {
- //call `done()` to release the client back to the pool
- done();
- if (err) {
- return console.error('error running query', err);
- }
- console.log(result.rows[0].number);
- //output: 1
- });
- };
- });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement