下午好,我现在正在学习nodejs。现在,我对自己设计的功能有问题,我似乎找不到问题
var http = require('http');
var mysql = require('mysql');
var url = require('url');
http.createServer(function (req, res) {
if (req.url === '/favicon.ico') {
//res.writeHead(200, {'Content-Type': 'image/x-icon'} );
res.end();
//console.log('favicon requested');
return;
}
var con = mysql.createConnection({
host: "localhost",
user: "admin",
password: "admin",
database: "brandibDB"
});
res.writeHead(200, {'Content-Type': 'text/plain'});
var addr = url.parse(req.url, true);
var teste = addr.pathname.split('/');
var tester = getJson(teste,con);
console.log(tester);
//console.log(teste);
//res.write(teste[1] + teste[2]);
res.end();
}).listen(8080);
function getJson(teste,con){
var resultado = "";
con.connect(function(err){
if (err) throw err;
if(teste[1] == 'users'){
if(teste.length!=2){
var str = "SELECT * FROM tblUsers where id ="+ mysql.escape(teste[2]) + "";
con.query(str, function (err, result, fields) {
if (err) throw err;
resultado = JSON.stringify(result);
});
}
else{
var str = "SELECT * FROM tblUsers";
con.query(str, function (err, result, fields) {
if (err) throw err;
resultado = JSON.stringify(result);
});
}
}
});
con.end;
return resultado;
}
console.log('Isto deve ser uma consola');
现在,我在数据库中有数据,我正在测试使用URL访问该服务器的数据:" localhost:8080/users/1"或" localhost:8080/users/users/"例如,当我运行第二个链接时,它应该进入函数getjson并返回正确的值(带有所有用户注册表的JSON),但它只是返回空。我尝试将控制台日志放入函数围绕" ResultAdo = JSON ..."的函数中,并显示正确的值。结果丢失了。
有什么提示?
这是因为您的getjson函数已经在查询完成的异步回调之前返回,因此Resultado仍然是一个空字符串。
取而代之的是,您可以向GetJson提供回调,该回调是在查询返回时被调用的,或者更好地使用Prosises。这样的东西:
var tester = getJson(teste, con)
.then(result => {
console.log('the results were:', results)
})
.catch(err => {
console.log('Something went wrong', err);
});
,您的功能变成了:
function getJson(teste, con) {
return new Promise((resolve, reject) => {
con.connect(function (err) {
if (err) throw err;
if (teste[1] == 'users') {
if (teste.length != 2) {
var str = "SELECT * FROM tblUsers where id =" + mysql.escape(teste[2]) + "";
con.query(str, function (err, result, fields) {
if (err) return reject(err);
return resolve(JSON.stringify(result));
});
} else {
var str = "SELECT * FROM tblUsers";
con.query(str, function (err, result, fields) {
if (err) return reject(err);
return resolve(JSON.stringify(result));
});
}
}
});
})
}
我还建议沟渠var并使用let and const,以这种方式跟踪您的变量范围要容易得多。