68-mysql.js

/**
 * Copyright 2013 IBM Corp.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 **/

module.exports = function(RED) {
    "use strict";
    var reconnect = RED.settings.mysqlReconnectTime || 30000;
    var mysqldb = require('mysql');

    function MySQLNode(n) {
        RED.nodes.createNode(this, n);
        this.host = n.host;
        this.port = n.port;
        this.tz = n.tz || "local";

        this.connected = false;
        this.connecting = false;

        this.dbname = n.db;
        var node = this;

        node.connectionPool = mysqldb.createPool({
            host: node.host,
            port: node.port,
            user: node.credentials.user,
            password: node.credentials.password,
            database: node.dbname,
            timezone: node.tz,
            insecureAuth: true
        });

        this.getConnectionPool = function() {
            return node.connectionPool;
        };
    }
    RED.nodes.registerType("MySQLdatabase", MySQLNode, {
        credentials: {
            user: {
                type: "text"
            },
            password: {
                type: "password"
            }
        }
    });

    function MysqlDBNodeIn(n) {
        RED.nodes.createNode(this, n);
        this.mydb = n.mydb;
        this.mydbConfig = RED.nodes.getNode(this.mydb);

        if (this.mydbConfig) {
            var node = this;
            node.on('input', function(msg) {
                if (typeof msg.topic === 'string') {
                    var bind = Array.isArray(msg.payload) ? msg.payload : [];
                    node.mydbConfig.getConnectionPool().getConnection(function(err, connection) {
                        if (err) {
                            node.error(err, msg);
                        } else {
                            connection.query(msg.topic, bind, function(err, rows) {
                                try {
                                    connection.release();
                                } catch (e) {
                                    console.log('connection.release err', e);
                                }

                                if (err) {
                                    node.error(err, msg);
                                } else {
                                    msg.payload = rows;
                                    node.send(msg);
                                }
                            });
                        }
                    });
                } else {
                    if (typeof msg.topic !== 'string') {
                        node.error("msg.topic : the query is not defined as a string");
                    }
                }
            });
        } else {
            this.error("MySQL database not configured");
        }
    }
    RED.nodes.registerType("mysql", MysqlDBNodeIn);
}