Now attaching error listener to connection

Author: zubairov

lib/actions/insert.js

@@ -12,6 +12,8 @@ function init(cfg) {
     return co(function* gen() {
         console.log('Connecting to the database uri=%s', conString);
         const connection = new cosql.Connection(conString);
+        // Always attach an error listener
+        connection.on('error', (err) => this.emit('error', err));
         let sql = cfg.query;
         yield connection.connect();
         console.log('Preparing query=%s', sql);
@@ -46,7 +48,7 @@ function init(cfg) {
         console.log('Resulting SQL=%s', sql);
         yield pstmt.prepare(sql);
         console.log('Preparing statement created');
-    });
+    }.bind(this));
 }
 
 /**

lib/actions/select.js

@@ -16,8 +16,9 @@ function init(cfg) {
     return co(function* gen() {
         console.log('Connecting to the database uri=%s', conString);
         connection = new cosql.Connection(conString);
+        connection.on('error', (err) => this.emit('error', err));
         yield connection.connect();
-    });
+    }.bind(this));
 }
 /**
  * This method will be called from elastic.io platform providing following data