All files / app/lib/postgres execute.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
21x
21x
21x
21x
3x
3x
21x
21x
4x
4x
4x
4x
4x
21x
21x
21x
 
const Postgres = require('./postgres');
 
class Execute extends Postgres {
  constructor(pool, options = {}) {
    super(pool, options);
  }
 
  _fn(d, cb) {
    // TODO make transaction or use {maxBuffer:1} in options
    // console.log(d);
    return this.query(d, cb)
      .then(d => (this.options.pushResult || this.options.pushResults) && d || undefined);
  }
}
 
module.exports = (...params) => new Execute(...params);