Lambdaで実行するためにdestoryしたい

Question

var Twitter = require('twitter');
var mysql = require('mysql');

var connection = mysql.createConnection({
  host: "localhost",
  user: "root",
  database: "db"
});

var client = new Twitter({
  consumer_key: key,
  consumer_secret: secret,
  access_token_key:key,
  access_token_secret: secret
});
var maxId;
function getTweet() {
  return new Promise(function(resolve,reject) {
    connection.query('SELECT MIN(tweet_id) FROM Tweets;',function(error,result,fields){
      maxId = result[0]["MIN(tweet_id)"];
      if (result) resolve(maxId);
      if (error) reject(error);
    });
  });
}
getTweet().then(function(maxId) {
  var params = {q: 'user',count:5,max_id_str:maxId};
  client.get('search/tweets',  params, function(error, tweets, response) {

    if(!error){
      var tweets_length = tweets["statuses"].length;
      for(var i = 1;i < tweets_length;i++){
        tweet_id = tweets["statuses"][i]["id_str"];
        screen_name = tweets["statuses"][i]["user"]["screen_name"];
        text = tweets["statuses"][i]["text"];
        //var url = 'https://twitter.com/' + screen_name + '/status/' + tweet_id;
        if(screen_name === "user"){
          console.log("user発見");
          break;
        }else{
          connection.query('INSERT INTO Tweets(`tweet_id`,`name`,`text`) VALUES(?,?,?)',[tweet_id,screen_name,text],function(error,results,fields){
connection.destory();
            if(error)console.log(error);
          });
        }
      }

    }
  });
}).catch(function(err){
  console.log(err);
});

Lambdaでこのプログラムを実行するためにはdestoryしないといけないのですがどうdestoryしたらいいのでしょうか？Lambdaではdestoryしないとtimeoutになります。
これだと1個目のInsertは可能なのですが、2個目はInsertできません。
This socket is closedとエラーが出ます。
どうdestoryしたらいいですか？

Answer 1

ソースコードの一部抜粋ですかね？
connectionの宣言回りがないので…

単純にmysqlのコネクションが繋ぎっぱなしであると推測します。
npm - mysqlにコネクションの切り方が載っていますので確認してみてください。