Fix MySQL output plugin query parameter, error handling (#243)

The query parameter misspelling meant that a properly spelled config
file would not override the script default query, leading to a confusing
situation.

It looks like some debug logging was left in. This has been removed. If
people want to log to stdout, they'll add an output to do so.

The previous query callback statement had no effect, and we weren't
logging out any errors in the callback. That made troubleshooting any
database-related issues very tricky.

Author: braindawg

plugins/outputs/mysql/output_mysql.js

@@ -2,58 +2,51 @@ var base_output = require('@pastash/pastash').base_output,
     logger = require('@pastash/pastash').logger,
     util = require('util');
 var sqdb;
-var THIS ;
 var mysql = require('mysql2');
 
 function OutputMySql() {
     base_output.BaseOutput.call(this);
     this.mergeConfig({
         name: 'MySql',
-        optional_params: ['db',  'query', 'host', 'user', 'password', 'port','interval_ms'],
+        optional_params: ['db', 'query', 'host', 'user', 'password', 'port', 'interval_ms'],
         default_values: {
             'db' : 'database',
             'host': '127.0.0.1',
             'port': 3306,
             'user': 'root',
             'password': 'admin',
             'interval_ms': 10000,
-            'qurey': "call SP_UpdateSyncResult('{|data|}');"
+            'query': "call SP_UpdateSyncResult('{|data|}');"
         },
         start_hook: this.start,
     });
 }
 OutputMySql.prototype.start =function(callback) {
-    THIS =  this
     if (this.db) {
         try {
             var cfg = { database: this.db, rowsAsArray: true };
             if(this.host) cfg.host = this.host;
             if(this.user) cfg.user = this.user;
             if(this.password) cfg.password = this.password;
             sqdb = mysql.createConnection(cfg);
-            logger.info('Initializing Outpu MySql:',this.db);
-        } catch(e){ logger.error('Failed Initializing Filter MySql',e); }
+            logger.info('Initializing Output MySql:',this.db);
+        } catch(e) { logger.error('Failed Initializing Output MySql',e); }
     }
 
-
-    logger.info('Initialized Filter MySql');
+    logger.info('Initialized Output MySql');
     callback();
-
-
 }
 util.inherits(OutputMySql, base_output.BaseOutput);
 
 OutputMySql.prototype.process = function(data) {
+    var sqlstr = this.query
+    sqlstr = sqlstr.replace('{|data|}',JSON.stringify(data, null, 2));
 
-    process.stdout.write('[STDOUT] ' + JSON.stringify(data, null, 2) + '\n');
-    var sqlstr = THIS.qurey
-    sqlstr= sqlstr.replace('{|data|}',JSON.stringify(data, null, 2) )
-
-    console.log(sqlstr );
     sqdb.query(sqlstr ,null, function(err, results, fields) {
-
-        sqlstr= sqlstr.replace('{|data|}',JSON.stringify(results, null, 2) )
-    })
+        if (err) {
+            logger.error('MySQL query error:', err);
+        }
+    });
 };
 
 OutputMySql.prototype.close = function(callback) {