Advertisement
Guest User

pgsql2.js

a guest
Aug 20th, 2014
159
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. var pg = require('pg');
  2. var conString = "postgres://username:password@localhost/database";
  3.  
  4. pg.connect(conString, function (err, client, done) {
  5.     module.exports = function (/* arguments */) {
  6.         var args = [].slice.call(arguments), //Копируем массив аргументов
  7.             next = args.splice(args.length - 1, 1).shift(); //Вытягиваем колбек, который передается последним аргументом
  8.  
  9.         /* Подменяем старый колбек в массиве аргументов новым, который автоматически вызывает done() */
  10.         args.push(function (/* arguments */) {
  11.             done();
  12.             next.apply(null, arguments);
  13.         });
  14.         if (err) {
  15.             return console.error('error fetching client from pool', err);
  16.         }
  17.         client.query.apply(null, args);
  18.         client.query('SELECT $1::int AS number', ['1'], function (err, result) {
  19.             //call `done()` to release the client back to the pool
  20.             done();
  21.  
  22.             if (err) {
  23.                 return console.error('error running query', err);
  24.             }
  25.             console.log(result.rows[0].number);
  26.             //output: 1
  27.         });
  28.  
  29.     };
  30. });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement