Commit cfc5bd00368f678a111abb05b583b975e846444e
1 parent
096a49ea4b
Exists in
master
avances
Showing
1 changed file
with
11 additions
and
1 deletions
Show diff stats
data/index.js
1 | module.exports = function(config) { | 1 | module.exports = function(config) { |
2 | 2 | ||
3 | var knex = require('knex')(config); | 3 | var knex = require('knex')(config); |
4 | 4 | ||
5 | return { | 5 | return { |
6 | getEntity: function (message) { | 6 | getEntity: function (message) { |
7 | 7 | ||
8 | return new Promise(function(resolve, reject) { | 8 | return new Promise(function(resolve, reject) { |
9 | 9 | ||
10 | knex(message.tableName).where(message.where).select('*').then(function (data) { | 10 | var promise; |
11 | |||
12 | if (message.queryString) { | ||
13 | |||
14 | promise = knex.schema.raw(message.queryString); | ||
15 | } else { | ||
16 | |||
17 | promise = knex(message.tableName).where(message.where).select('*'); | ||
18 | } | ||
19 | |||
20 | promise.then(function (data) { | ||
11 | 21 | ||
12 | message.data = data[0]; | 22 | message.data = data[0]; |
13 | resolve(message); | 23 | resolve(message); |
14 | }); | 24 | }); |
15 | }); | 25 | }); |
16 | } | 26 | } |
17 | } | 27 | } |
18 | } | 28 | } |
19 | 29 |