Socket.io mysql connection error

Question

When i started my socket on the npm , my Mysql conection going to down about 30 sec .I do not know why. The mysql insert method worked . But when i am waiting about 1 min -30 sec the conenction shut down.

This is error code ;

events.js:141 throw er; // Unhandled 'error' event ^

Error: Connection lost: The server closed the connection. at Protocol.end (C:\xampp\htdocs\tem\node_modules\mysql\lib\protocol\Protocol.js:109:13) at Socket. (C:\xampp\htdocs\tem\node_modules\mysql\lib\Connection.js:115:28) at emitNone (events.js:72:20) at Socket.emit (events.js:166:7) at endReadableNT (_stream_readable.js:921:12) at nextTickCallbackWith2Args (node.js:442:9) at process._tickCallback (node.js:356:17)

This is my source code;

var app = require('express')();
var mysql = require("mysql");
var http=require('http').Server(app);
var io=require('socket.io')(http);
var con = mysql.createConnection({
    host: "hostname",
    user: "username",
    password: "pw",
    database: "db"
});
con.connect(function(err){
    if(err){
        console.log('UnSuccesfull');
        return;
    }
    console.log('Succesfull');
});
app.get("/",function(req,res){

    res.sendfile(__dirname+"/asd.html");

});
io.on('connection',function(socket){

    var UserLog={
        Log:'A User Connected'
    };
    con.query('Insert Into Log SET ?',UserLog ,function(err){
        if(err)
            console.log(err);
    });
});
var port=xx;
http.listen(port,'xx.xx.xx');

try sequelize docs.sequelizejs.com/en/v3

abhaygarg12493
– abhaygarg12493

2016-09-01 20:46:26 +00:00
Commented Sep 1, 2016 at 20:46 — abhaygarg12493
– abhaygarg12493, Commented Sep 1, 2016 at 20:46

Furkan yeşiloğlu · Accepted Answer · 2016-09-01 15:05:25Z

1

I recommend to you, use connection pooling.

You can create connection pool like that;

var pool  = mysql.createPool({
connectionLimit : 60,
host    : hostname,
user    : dbUser,
password: dbPass,
database: dbName,
multipleStatements: true
});

And when you need to run query on mysql;

pool.getConnection(function(err, connection) {
            connection.query( "SELECT * FROM `users`", function(err, users) {
                connection.release();
            });
        });

answered Sep 1, 2016 at 15:05

Furkan yeşiloğlu

1661 silver badge11 bronze badges

Sign up to request clarification or add additional context in comments.

3 Comments

Somomo1q Over a year ago

Hocam 4 saniyede bir mysql boş sorgu yapsam SELECT X FROM Y diye sıkıntı cıkar mı ? aynı mantık olsa gerek

Furkan yeşiloğlu Over a year ago

@MuhammedAlmaz sıkıntı çıkartacağını sanmıyorum, ayrıca limit 1 diyerek biraz daha az yük bindirmiş olursun.

Somomo1q Over a year ago

Tamamdır hocam o şekilde yapayım :) eyvallah

Vinicius Guerato · Accepted Answer · 2016-09-01 12:17:54Z

0

io.on('connect')*

The database rules is correct ?

answered Sep 1, 2016 at 12:17

Vinicius Guerato

1

1 Comment

Vinicius Guerato Over a year ago

if(err) throw err;

Collectives™ on Stack Overflow

Socket.io mysql connection error

2 Answers 2

3 Comments

1 Comment

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

3 Comments

1 Comment

Your Answer

Sign up or log in

Post as a guest

Related