nodejs Muitos processos no mysql

[Good 4]

tenho uma aplicação funcionando com php e ajax... Meu tráfego aumentou e preciso mudar para socket, etc.

 

Eu pesquisei e achei este projeto: https://codeforgeek.com/2015/03/real-time-app-socket-io/

 

O problema, é que antes de funcionar com este sistema... o mysql rodava com menos de 5 processos.. E por incrível que pareça, toda vez que eu ligo e coloco para funcionar ele abre mais de 50 processos e fica dando o erro "Too many connections", atinge o limite e não é possível liberar conexão... Chega ter em média 100 pessoas simultâneas.

 

Eu não faço ideia do porque, mas tipo quando chama este emit: socket.emit('status added')

ele abre a conexão com o bd e insere o valor, mas o meu sistema precisa fazer 3 verificações em tabelas diferente, e sim, é necessário...

Neste estilo:

 

pool.getConnection(function(err,connection){
        if (err) {
          callback(false);
          return;
        }


        db.query(sql1, function(err, res1) {
             if (err) {
                 callback(err);
                 return;
             }
             db.query(sql2, function(err, res2) {
                 if (err) {
                     callback(err);
                     return;
                }
                callback(null, res2); // think 'return'
             }
        });
});

 

 

Eu não entendo o porque de criar vários processos do mysql... É errado a maneira de como estou fazendo? Porque só executo uma query se a primeira passar na validação, etc.

 

Agradeço muito uma resposta de urgência!

[Good 4]

Liguei e tirei print:

 

com pouca conexão, mas deu pra ver a diferença de processos entre o início e o fim

[marcelo.lipienski 1]

Cadê seu connection.release()?

[Good 4]

Aah, bem que você falou... Acho que identifiquei o problema.. na última query, ficou assim:

if (rows3[0].total <= 0) {
	connection.release();
	return;
} else {
	return;
}

Ele só ia fechar a conexão se não houve registros. Vou salvar e depois fazer os testes. Enfim, no caso o código final deve ficar assim???

pool.getConnection(function(err,connection){
    if (err) {
        callback(false);
        connection.release();
        return;
    }

    db.query(sql1, function(err, res1) {
        if (err) {
            callback(err);
        }
        db.query(sql2, function(err, res2) {
            if (err) {
                callback(err);
            }
            callback(null, res2); // think 'return'
        }
    });

    connection.release();
    return;
});

OBS.: retirei os returns e coloquei o return no final, com o release antes.