在AWS上使用mysql-npm运行mysql查询

嗨，伙计们，我有一个问题，我真的不知道该怎么解决。这也有点奇怪：/基本上，我已经创建了这个Lambda函数，使用节点包"mysql"连接到mysql数据库。

如果我在电脑的命令行中使用命令"sls function run function1"运行该函数，并进行不同的查询，一切都很好。但是，当我使用链接从web浏览器调用该函数时，我必须刷新页面两次才能得到正确的结果，因为在第一次刷新时，服务器会用旧的结果进行响应。

我注意到，在命令行中，我总是有不同的thredID，而在Web浏览器中，thredID总是相同的。

此外，我不会关闭lambda函数代码中的连接，因为如果我从命令行运行函数，一切都很好，但从浏览器运行函数，我只能进行2次查询，然后我收到一条消息，说我不能使用关闭的连接。

因此，当我从web浏览器调用它时，它似乎存储了旧的查询结果。

很明显，我犯了同样愚蠢的错误，但我不知道如何解决。有人有主意吗？谢谢：）

'use strict';
//npm packages
var mysql=require('mysql');
var deasync = require('deasync');
//variables
var goNext=false; 			//use to synchronize deasync
var error=false;    		//it becomes TRUE if an error occured during the connection to the DB
var dataColumnTable;		//the data thet you extract from the query to the DB
var errorMessage;
//----------------------------------------------------------------------------------------------------------------
//always same credentials
var connection = mysql.createConnection({
				   	host     : 'hostAddress',
				  	user     : 'Puser',
				 	password : 'password',
				  	port     : '3306',
				  	database : 'database1',
		});
//----------------------------------------------------------------------------------------------------------------
module.exports.handler = function(event, context) {
var Email=event.email;
connection.query('SELECT City, Address FROM Person WHERE E_Mail=?', Email, function(err, rows) {
  
			if(err){
				console.log("Cannot connect to DB");
				console.log(err);
				error=true;
				errorMessage=err;
			}
			else{
				console.log("data from column acquired!");
				dataColumnTable=rows;
			}
			
			//connection.end(function(err) {
  			//							connection.destroy();			
			//});	
			//console.log("Connection closed!");
			goNext=true;
});
require('deasync').loopWhile(function(){return goNext!=true;});
//----------------------------------------------------------------------------------------------------------------
if(error==true)
	return callback('Error '+ errorMessage);
else	
	return callback(null,dataColumnTable); //return a JsonFile
	
//fine headler
};