insert-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 = "INSERT INTO mydb.weight_table(date, weight, category) VALUES (";
    sql += "cast('" + event.date + "' as date), ";
    sql += event.weight + ", '";
    sql += event.category + "')";
    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 {
               var response = {};
               response['item_id'] = event.item_id;
               response['name'] = event.name;
               
               context.succeed(response);
        }
    });

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