Node.JS 和 MySQL - 查询锁定并执行得非常慢
Node.JS and MySQL - queries lock up and execute extremely slowly
我将 Node.JS 和 MySQL 与此驱动程序一起使用时出现奇怪的行为 - https://github.com/mysqljs/mysql
本质上,我在前端有一个按钮可以触发一个 app.get
在数据库中进行查询,我可以愉快地在我的后端使用结果。
这很好用,直到我在一秒钟内按下按钮 4-5 次,此时查询锁定,我必须等待 2-3 分钟,直到它们继续执行。我有一个类似的写函数,其行为方式相同。
这是否可能是一个问题,因为我正在尝试异步执行完全相同的查询? IE。我必须从前端限制这个还是后端问题?
关于如何调试到底发生了什么的任何想法?
// database.js
var mysql = require('mysql');
var pool = mysql.createPool({
connectionLimit: 100,
host : 'localhost',
user : 'secret',
password : 'secret',
database : 'mydb'
});
exports.getConnection = function(callback) {
pool.getConnection(function(err, connection) {
callback(err, connection);
});
};
// dbrw.js
var con = require('../config/database');
function read(id, done) {
con.getConnection(function(err, connection){
if(!err){
connection.query("SELECT * FROM users WHERE id = ?",[id], function(err, rows) {
connection.release();
if (err)
done(err);
if (rows.length) {
console.log("rows " + JSON.stringify(rows));
done(rows[0].progress);
};
});
}
else {
console.log(err);
}
});
}
exports.read = read;
// routes.js
var dbrw = require('./dbrw.js');
app.get('/read', isLoggedIn, function(req, res) {
dbrw.read(req.user.id, function(result) {
console.log(result);
});
});
// Frontend - angular app.js
$scope.tryread = function() {
$http.get('/read');
}
提前感谢您的任何意见。
我看到了几个问题:
function read(id, done) {
con.getConnection(function(id, connection){...}
}
注意如何通过为 getConnection
.
的回调参数指定相同的名称来覆盖传递给 read
的 id
此外,您的 Express 路由实际上并没有通过发回响应来结束请求,这会使您的浏览器连接超时。在某些时候,它甚至会拒绝发送更多请求,因为仍有太多请求未决。
所以请务必结束请求:
app.get('/read', isLoggedIn, function(req, res) {
dbrw.read(req.user.id, function(result) {
console.log(result);
res.end(); // or `res.send(result)`
});
});
提示:您应该使用 Node 的回调调用转换,其中第一个参数表示错误(如果有),第二个参数表示 return 值。
我将 Node.JS 和 MySQL 与此驱动程序一起使用时出现奇怪的行为 - https://github.com/mysqljs/mysql
本质上,我在前端有一个按钮可以触发一个 app.get
在数据库中进行查询,我可以愉快地在我的后端使用结果。
这很好用,直到我在一秒钟内按下按钮 4-5 次,此时查询锁定,我必须等待 2-3 分钟,直到它们继续执行。我有一个类似的写函数,其行为方式相同。
这是否可能是一个问题,因为我正在尝试异步执行完全相同的查询? IE。我必须从前端限制这个还是后端问题?
关于如何调试到底发生了什么的任何想法?
// database.js
var mysql = require('mysql');
var pool = mysql.createPool({
connectionLimit: 100,
host : 'localhost',
user : 'secret',
password : 'secret',
database : 'mydb'
});
exports.getConnection = function(callback) {
pool.getConnection(function(err, connection) {
callback(err, connection);
});
};
// dbrw.js
var con = require('../config/database');
function read(id, done) {
con.getConnection(function(err, connection){
if(!err){
connection.query("SELECT * FROM users WHERE id = ?",[id], function(err, rows) {
connection.release();
if (err)
done(err);
if (rows.length) {
console.log("rows " + JSON.stringify(rows));
done(rows[0].progress);
};
});
}
else {
console.log(err);
}
});
}
exports.read = read;
// routes.js
var dbrw = require('./dbrw.js');
app.get('/read', isLoggedIn, function(req, res) {
dbrw.read(req.user.id, function(result) {
console.log(result);
});
});
// Frontend - angular app.js
$scope.tryread = function() {
$http.get('/read');
}
提前感谢您的任何意见。
我看到了几个问题:
function read(id, done) {
con.getConnection(function(id, connection){...}
}
注意如何通过为 getConnection
.
read
的 id
此外,您的 Express 路由实际上并没有通过发回响应来结束请求,这会使您的浏览器连接超时。在某些时候,它甚至会拒绝发送更多请求,因为仍有太多请求未决。
所以请务必结束请求:
app.get('/read', isLoggedIn, function(req, res) {
dbrw.read(req.user.id, function(result) {
console.log(result);
res.end(); // or `res.send(result)`
});
});
提示:您应该使用 Node 的回调调用转换,其中第一个参数表示错误(如果有),第二个参数表示 return 值。