Recentemente fiz um refactor do meu código para adotar o padrão MVC, pois o mesmo estava muito desorganizado!
Entretanto, começou a aparecer um erro chamado "Too many connections". Esse erro faz com que o meu node-mysql cai e não realize mais requisições até que eu restart o node.
Link do código: https://github.com/LeonardoVini/node-refctoring/blob/master/refctoring-backend.zip
Não sei o ES6 esteja causando isso ou eu tenha feito algo de errado. Eu tentei diversas vezes arrumar este erro.
Código de conexão:
const mysql = require('mysql')
const connMySQL = () => {
return mysql.createConnection({
host: 'localhost',
user: 'root',
password: 'eqix1998',
database: 'quotedb',
port: 3306
});
}
module.exports = () => {
return connMySQL;
}
server.js:
const express = require('express');
const consign = require('consign')
const bodyParser = require('body-parser');
const cors = require('cors');
const corsOptions = {
origin: 'http://localhost:4200',
optionsSuccessStatus: 200
}
const app = express();
app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());
app.use(cors(corsOptions))
consign()
.include('app/routes')
.then('config/dbConnection.js')
.then('app/models')
.then('app/controllers')
.into(app);
module.exports = app;
Arquivo de rotas:
module.exports = (application) => {
application.get('/quotes-createdBy/:username', (req, res) => {
application.app.controllers.quotes_by_name.getQuotesByName(application, req, res);
});
application.get('/quotes-closed-createdBy/:username', (req, res) => {
application.app.controllers.quotes_by_name.getClosedQuotesByName(application, req, res);
});
application.get('/quotes-qss-createdBy/:username', (req, res) => {
application.app.controllers.quotes_by_name.getQSSQuotesByName(application, req, res);
});
}
Arquivo de controller:
module.exports.getQuotesByName = (application, req, res) => {
let username = req.params.username
var connection = application.config.dbConnection();
var quotes_by_nameDAO = new application.app.models.Quotes_By_NameDAO(connection);
quotes_by_nameDAO.getQuotesByName(username, (error, results) => {
if (error) throw error
return res.send(results)
});
}
module.exports.getClosedQuotesByName = (application, req, res) => {
let username = req.params.username
var connection = application.config.dbConnection();
var quotes_by_nameDAO = new application.app.models.Quotes_By_NameDAO(connection);
quotes_by_nameDAO.getClosedQuotesByName(username, (error, results) => {
if (error) throw error
return res.send(results)
});
}
module.exports.getQSSQuotesByName = (application, req, res) => {
let username = req.params.username
var connection = application.config.dbConnection();
var quotes_by_nameDAO = new application.app.models.Quotes_By_NameDAO(connection);
quotes_by_nameDAO.getQSSQuotesByName(username, (error, results) => {
if (error) throw error
return res.send(results)
});
}
Arquivo model:
function Quotes_By_NameDAO(connection) {
this._connection = connection;
}
// Get quotes by nome - QuoteStatus = 'In Progress' OR QuoteStatus = 'Stand By'
Quotes_By_NameDAO.prototype.getQuotesByName = function (username, callback) {
this._connection.query(`
SELECT * FROM quotes
WHERE
(QuoteStatus = 'In Progress' OR QuoteStatus = 'Stand By')
AND
CreatedBy = ?
`, username, callback)
}
// Get closed quotes by nome - QuoteStatus = 'Closed'
Quotes_By_NameDAO.prototype.getClosedQuotesByName = function (username, callback) {
this._connection.query(`
SELECT * FROM quotes
WHERE
QuoteStatus = 'Closed'
AND
CreatedBy = ?
`, username, callback)
}
// Get QSS quotes by nome - QuoteStatus = 'Sent to QSS'
Quotes_By_NameDAO.prototype.getQSSQuotesByName = function (username, callback) {
this._connection.query(`
SELECT * FROM quotes
WHERE
QuoteStatus = 'Sent to QSS'
AND
CreatedBy = ?
`, username, callback)
}
module.exports = () => {
return Quotes_By_NameDAO;
}