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

// connect mysql
var mysql_host = "hogehoge";
var mysql_user = "fuga";
var mysql_dbname = "api";
var mysql_password = "mogo";
var ngram = function(words, n) {
  var i;
  var grams = "";
  for(i=0; i<=words.length-n; i++) {
    grams = grams + "+" + words.substr(i, n) + " ";
  }
  return grams;
}

exports.handler = (event, context, callback) => {
  console.log(event);
  var sql = "select zipcode, address from zipcode where match( ngram ) against( ? in boolean mode );";
  var str = event.address;
  var connection = mysql.createConnection({
    host     : mysql_host,
    user     : mysql_user,
    password : mysql_password,
    database : mysql_dbname
  });
  connection.connect();

  var result = connection.query(sql, [ngram(str, 2)], function(err, rows, fields) {
    if (err) {
      throw err;
    } else {
      connection.destroy();
      context.done(null, rows);
    }
  });

  connection.end(function(err) {
  });
};