added request to configuration java bridge

Author: thabofletcher

initializers/dataAccess.js

@@ -34,8 +34,11 @@ var fs = require("fs");
 var async = require("async");
 var java = require('java');
 var Jdbc = require('informix-wrapper');
+var req = require('request');
 var helper;
 
+var javaReadBridge = process.env.JAVA_READ_BRIDGE || "http://localhost:5555/bridge";
+
 /**
  * Regex for sql paramters e.g @param_name@
  */
@@ -110,7 +113,7 @@ function parameterizeQuery(query, params, callback) {
     });
 }
 
-function executePreparedStatement(api, sql, parameters, connection, next) {
+function executePreparedStatement(api, sql, parameters, connection, next, db) {
     async.waterfall([
         function (cb) {
             parameterizeQuery(sql, parameters, cb);
@@ -119,8 +122,19 @@ function executePreparedStatement(api, sql, parameters, connection, next) {
 
             if (api.helper.readTransaction) {
                 api.log("CALLING SANTTOSH'S MAGIC");
-                api.log(new Buffer(sql).toString('base64'));
-                cb(null, []); // necessary?
+                
+                var body = {
+                    "sql": new Buffer(sql).toString('base64'),
+                    "db": db 
+                };
+                
+                api.log(body);
+                
+                req({ url: javaReadBridge, body: body, json: true }, function(response) {
+                    api.log(response);
+                });
+                
+                cb(null, []);
             } else {
                 api.log("Database connected", 'debug');
                 // the connection might have been closed due to other errors, so this check must be done
@@ -294,7 +308,7 @@ exports.dataAccess = function (api, next) {
                 return;
             }
 
-            executePreparedStatement(api, sql, parameters, connection, next);
+            executePreparedStatement(api, sql, parameters, connection, next, queries[queryName].db);
         },
 
         /**
@@ -337,7 +351,7 @@ exports.dataAccess = function (api, next) {
                 return;
             }
 
-            executePreparedStatement(api, sql, parameters, connection, next);
+            executePreparedStatement(api, sql, parameters, connection, next, dbName);
         }
     };
     next();

package.json

@@ -37,7 +37,7 @@
     "moment-timezone": "0.0.x",
     "nodemailer": "0.5.x",
     "redis": "0.10.x",
-    "request": "~2.33.0",
+    "request": "^2.33.0",
     "soap": "~0.3.2",
     "ssha": "*",
     "string": "1.6.x",