module.exports = function(config) {

  var knex = require('knex')(config);

  return {
    getEntity: function (message) {

      return new Promise(function(resolve, reject) {

        var promise;

        if (message.queryString) {

          promise = knex.schema.raw(message.queryString);
        } else {

          promise = knex(message.tableName).where(message.where).select('*');
        }

        promise.then(function (data) {

          message.data = data[0];
          resolve(message);
        });
      });
    }
  }
}