added support for using an existing node-odbc connection

Signed-off-by: Eric Henson <ehenson238@gmail.com>

Author: ehenson

lib/transports/odbcTransport.js

@@ -20,6 +20,7 @@ function odbcCall(config, xmlInput, done) {
   const odbc = require('odbc');
 
   const {
+    odbcConnection = null,
     host = 'localhost',
     username = null,
     password = null,
@@ -51,36 +52,52 @@ function odbcCall(config, xmlInput, done) {
     console.log(`SQL to run is ${sql}`);
   }
 
-  odbc.connect(connectionString, (connectError, connection) => {
-    if (connectError) {
-      done(connectError, null);
+  function processXml(results) {
+    if (!results) {
+      done('Empty result set was returned', null);
       return;
     }
+
+    let xmlOutput = '';
+
+    results.forEach((chunk) => {
+      xmlOutput += chunk.OUT151;
+    });
+    done(null, xmlOutput);
+  }
+
+  function query(connection) {
     connection.query(sql, [ipc, ctl, xmlInput], (queryError, results) => {
       if (queryError) {
         done(queryError, null);
         return;
       }
-      connection.close((closeError) => {
-        if (closeError) {
-          done(closeError, null);
-          return;
-        }
-
-        if (!results) {
-          done('Empty result set was returned', null);
-          return;
-        }
+      if (!odbcConnection) {
+        connection.close((closeError) => {
+          if (closeError) {
+            done(closeError, null);
+            return;
+          }
 
-        let xmlOutput = '';
-
-        results.forEach((chunk) => {
-          xmlOutput += chunk.OUT151;
+          processXml(results);
         });
-        done(null, xmlOutput);
-      });
+      } else {
+        processXml(results);
+      }
     });
-  });
+  }
+
+  if (!odbcConnection) {
+    odbc.connect(connectionString, (connectError, connection) => {
+      if (connectError) {
+        done(connectError, null);
+        return;
+      }
+      query(connection);
+    });
+  } else {
+    query(odbcConnection);
+  }
 }
 
 exports.odbcCall = odbcCall;