Тема: Nodejs и mysql
Показать сообщение отдельно
  #1 (permalink)  
Старый 03.08.2014, 10:28
Интересующийся
Отправить личное сообщение для Chrome Посмотреть профиль Найти все сообщения от Chrome
 
Регистрация: 17.01.2013
Сообщений: 21

Nodejs и mysql
Данный код каждую секунду доблит базу и отсылает строчку клиенту.
var http = require('http');
var mysql      = require('mysql');
var connection = mysql.createConnection({
    host     : 'localhost',
    user     : 'root',
    password : '',
    database : 'test'
 
});
 
connection.connect();
 
var sockjs = require('sockjs');
 
var echo = sockjs.createServer();
echo.on('connection', function(conn) {
 
    setInterval(function(){
    connection.query('SELECT id FROM  users ', function(err, rows, fields) {
        if (err) throw err;
 
        conn.write('The solution is: '+rows[1]['id']);
    });
    },1000);
 
    conn.on('data', function(message) {
        console.log(message);
    });
    conn.on('close', function() {});
});
 
var server = http.createServer();
echo.installHandlers(server, {prefix:'/echo'});
server.listen(9999, '0.0.0.0');


Можно ли избавится от setInterval и установить соединение с таблицой базы на прямую другим способом? Или данная реализация является верной и других решений нет?
Ответить с цитированием