diff --git a/data/index.js b/data/index.js
index 9314b59..f6fb798 100644
--- a/data/index.js
+++ b/data/index.js
@@ -7,7 +7,17 @@ module.exports = function(config) {
 
       return new Promise(function(resolve, reject) {
 
-        knex(message.tableName).where(message.where).select('*').then(function (data) {
+        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);