fetch-Database

var AWS = require('aws-sdk');
var mysql = require('mysql');

// DataSource info
var mysql_host = process.env.SQL_HOST;
var mysql_user = process.env.SQL_USER;
var mysql_dbname = process.env.SQL_DB;
var mysql_password = process.env.SQL_PASSWORD;

exports.handler = function(event, context){

    console.log("event : ", event);

    // Set SQL Statements
    var sql = "SELECT date, weight, category FROM mydb.weight_table";
    if (event.category && event.category.length != 0) {
        sql = sql + " WHERE category='" + event.category + "'";
    }
    sql = sql + " ORDER BY date;";
    console.log("QUERY : " + sql);

    var connection = mysql.createConnection({
                            host     : mysql_host,
                            user     : mysql_user,
                            password : mysql_password,
                            database : mysql_dbname
                       });

    // Connect MySQL DB
    connection.connect();

    // Execute
    connection.query(sql, function(err, rows, fields) {
        if (err) {
            throw err;
        } else {
               console.log("MySQL Select Success");
               console.log(rows);
               console.log(fields);
               context.succeed(rows);
        }
    });

    connection.end(function(err) {
       if(err) throw err;
       context.done();
    });
}