Node js + Mysql：无法入队，因为致命错误

Question

我正在运行一个带有节点js（更具体地说是js）的应用程序，并使用mysql客户端保存了一些数据。

它完美地工作了一段时间，没有问题，但随后suddden的我得到这些错误回报：

Trace: Cannot enqueue Quit after fatal error. at Protocol._validateEnqueue (C:\nodejs\twelve-coiffure\node_modules\mysql\lib\protocol\Protocol.js:218:11) at Protocol._enqueue (C:\nodejs\twelve-coiffure\node_modules\mysql\lib\protocol\Protocol.js:135:13) at Protocol.quit (C:\nodejs\twelve-coiffure\node_modules\mysql\lib\protocol\Protocol.js:88:23) at PoolConnection.end (C:\nodejs\twelve-coiffure\node_modules\mysql\lib\Connection.js:255:18) at Pool._purgeConnection (C:\nodejs\twelve-coiffure\node_modules\mysql\lib\Pool.js:259:16) at PoolConnection._removeFromPool (C:\nodejs\twelve-coiffure\node_modules\mysql\lib\PoolConnection.js:70:8) at PoolConnection. (C:\nodejs\twelve-coiffure\node_modules\mysql\lib\PoolConnection.js:29:12) at emitOne (events.js:77:13) at PoolConnection.emit (events.js:169:7) at PoolConnection.Connection._handleProtocolError (C:\nodejs\twelve-coiffure\node_modules\mysql\lib\Connection.js:439:8) Trace: Cannot enqueue Query after fatal error. at Protocol._validateEnqueue (C:\nodejs\twelve-coiffure\node_modules\mysql\lib\protocol\Protocol.js:218:11) at Protocol._enqueue (C:\nodejs\twelve-coiffure\node_modules\mysql\lib\protocol\Protocol.js:135:13) at PoolConnection.query (C:\nodejs\twelve-coiffure\node_modules\mysql\lib\Connection.js:214:25) at Object.fetchDatas (C:\nodejs\twelve-coiffure\public\javascripts\twelvebase.js:94:12) at C:\nodejs\twelve-coiffure\routes\index.js:7:7 at Layer.handle [as handle_request] (C:\nodejs\twelve-coiffure\node_modules\express\lib\router\layer.js:95:5) at next (C:\nodejs\twelve-coiffure\node_modules\express\lib\router\route.js:131:13) at Route.dispatch (C:\nodejs\twelve-coiffure\node_modules\express\lib\router\route.js:112:3) at Layer.handle [as handle_request] (C:\nodejs\twelve-coiffure\node_modules\express\lib\router\layer.js:95:5) at C:\nodejs\twelve-coiffure\node_modules\express\lib\router\index.js:277:22 C:\nodejs\twelve-coiffure\public\javascripts\twelvebase.js:26 throw(message); ^

Error: Cannot enqueue Query after fatal error. at Protocol._validateEnqueue (C:\nodejs\twelve-coiffure\node_modules\mysql\lib\protocol\Protocol.js:199:16) at Protocol._enqueue (C:\nodejs\twelve-coiffure\node_modules\mysql\lib\protocol\Protocol.js:135:13) at PoolConnection.query (C:\nodejs\twelve-coiffure\node_modules\mysql\lib\Connection.js:214:25) at Object.fetchDatas (C:\nodejs\twelve-coiffure\public\javascripts\twelvebase.js:94:12) at C:\nodejs\twelve-coiffure\routes\index.js:7:7 at Layer.handle [as handle_request] (C:\nodejs\twelve-coiffure\node_modules\express\lib\router\layer.js:95:5) at next (C:\nodejs\twelve-coiffure\node_modules\express\lib\router\route.js:131:13) at Route.dispatch (C:\nodejs\twelve-coiffure\node_modules\express\lib\router\route.js:112:3) at Layer.handle [as handle_request] (C:\nodejs\twelve-coiffure\node_modules\express\lib\router\layer.js:95:5) at C:\nodejs\twelve-coiffure\node_modules\express\lib\router\index.js:277:22

的问题是，我真的找不到在哪里这个问题来自于我的代码，并我甚至不知道为什么有时在作品中，有时甚至不在。

这里是我的代码来启动数据库：

var mysql = require('mysql'); 
var dbPool = mysql.createPool({ 
connectionLimit: 50, 
waitForConnections: true, 
queueLimit: 0, 
host: '*my host*', 
user: '*me*', 
password: '*my password*', 
database: '*heroku database*', 
wait_timeout:28800, 
connect_timeout:10, 
debug:true 
}); 

dbPool.getConnection(function(err, connection) { 
if (err) throw (err); 

var db = connection; 

fetchDatas = function(callback) { 

    // openDatabase(); 

    var servicesFemmes, servicesHommes, products; 

    db.query("SELECT * FROM servicesFemmes", function(err, servicesFemmes, fields) { 

     if (err) { 
      callback(sendError(err)); 
     } else { 

      db.query("SELECT * FROM servicesHommes", function(err, servicesHommes, fields) { 
       if (err) { 
        callback(sendError(err)); 
       } else { 
        db.query("SELECT * FROM produits", function(err, products, fields) { 
         if (err) { 
          callback(sendError(err)); 
         } else { 
          db.query("SELECT * FROM carousel", function(err, carousel, fields) { 
           if (err) { 
            callback(sendError(err)); 
           } else { 
            callback(null, servicesFemmes, servicesHommes, products, carousel); 
           } 

          }); 
         } 
        }); 
       } 
      }); 

     } 
    }); 

} 
} 
} 

当然我打电话fetchDatas（）从另一个文件把所有的DATAS显示。

我真的迷路了，一直在寻找解决方案超过4个小时在每个现有的论坛..请帮助我，并提前感谢你。

Answer 1

最后，我抛弃了普通的MYSQL，而是使用了Sequelize。这里是我的代码（最终作品）：

var mysql = require('mysql'); 
var Sequelize = require('sequelize'); 

var sequelize = new Sequelize('database name', 'username', 'password', { 
host: 'your host url', 
dialect: 'mysql', 

pool: { 
    max: 10, 
    min: 0, 
    idle: 3000 
} 
}); 


//Models' creation 
var servicesHommes = sequelize.define('servicesHommes', { 
nom: { 
    type: Sequelize.STRING, 
    field: 'nom' 
}, 
cheveuxLongs: { 
    type: Sequelize.STRING, 
    field: 'cheveuxLongs' 
}, 
cheveuxCourts: { 
    type: Sequelize.STRING, 
    field: 'cheveuxCourts' 
} 
}, { 
freezeTableName: true 
}); 

var servicesFemmes = sequelize.define('servicesFemmes', { 
nom: { 
    type: Sequelize.STRING, 
    field: 'nom' 
}, 
cheveuxLongs: { 
    type: Sequelize.STRING, 
    field: 'cheveuxLongs' 
}, 
cheveuxCourts: { 
    type: Sequelize.STRING, 
    field: 'cheveuxCourts' 
} 
}, { 
freezeTableName: true 
}); 

var carousel = sequelize.define('carousel', { 
photo: { 
    type: Sequelize.STRING, 
    field: 'photo' 
} 
}); 

var produits = sequelize.define('produits', { 
    marque: { 
    type: Sequelize.STRING, 
    field: 'marque' 
    }, 
    nom: { 
    type: Sequelize.STRING, 
    field: 'nom' 
    }, 
    photo: { 
    type: Sequelize.STRING, 
    field: 'photo' 
    } 
}, { 
freezeTableName: true 
}); 

synchronizeBdd = function(callback) { 

sequelize.sync().then(function() { 
//any function querying the database should be placed here in this callback 


    fetchDatas = function(callback) { 

     servicesFemmes.findAll().then(function(femmes) { 
      servicesHommes.findAll().then(function(hommes) { 
       produits.findAll().then(function(products) { 
        carousel.findAll().then(function(carousels) { 
         callback(null, femmes, hommes, products, carousels); 
        }) 
       }) 
      }) 
     }); 
    } 

    //end of sync() 
    exports.fetchDatas = fetchDatas; 
    callback(); 
}); 
} 

exports.synchronize = synchronizeBdd; 

然后，我有另外一个文件叫我的功能“同步”在最后一行代码（“exports.synchronize = synchronizeBdd”）出口：

var bdd = require('fileWithSequelizeInstantiation') 

bdd.synchronize(function() { 
//here I call the functions related to my database. In my case: bdd.fetchDatas() 
})