index.js
363 Bytes
module.exports = function(config) {
var knex = require('knex')(config);
return {
getEntity: function (message) {
return new Promise(function(resolve, reject) {
knex(message.tableName).where(message.where).select('*').then(function (data) {
message.data = data[0];
resolve(message);
});
});
}
}
}