Nodejs и mysql

[Chrome]

Данный код каждую секунду доблит базу и отсылает строчку клиенту.

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 и установить соединение с таблицой базы на прямую другим способом? Или данная реализация является верной и других решений нет?

[Chrome]

Может кому формулировка вопроса непонята?

[kobezzza]

Дык драйвер БД и так по сокетам общается с БД. Ты главное connection не убивай после выполнения работы, ибо соединения с БД - оч дорогая операция. Нода крутится в одном потоке, поэтому в ней нет смысла делать "пул соединений", а достаточно держать одно прогретое соединения и по нему ходить и это будет работать очень быстро.

Если тебе хочется писать код прямо на уровне СУБД, то MySQL так вроде не умеет (хотя можно создать хранимку), но есть другие решение, например Tarantool (правд там Lua, а не JS).

[Chrome]

Не могли бы вы показать на уровне когда пожалуйста. Как это будет выглядеть. К примеру если поле id будет изменено то Сервер отправляет Клиенту уведомление о новом значении поля id? Я с ноде связался очень недавно. И для меня большая часть терминов темный лес. К примеру Кое соединение является прогретым? И вообще как его прогреть ? Может на уровне кода я смогу легче понять хотя бы поверхностно. А так спасибо за помощь кое что удалось подчеркнуть для себя

[kobezzza]

Примитивный пример

var connectionCache;
function createConnection(params) {
    connectionCache = connectionCache  || mysql.createConnection(params);
    return connectionCache;
}

Т.е. mysql.createConnection делается один раз, а затем возвращается ссылка из кеш переменной. Конечно лучше написать дочерний класс от mysql, который будет это делать, туда же можно добавить логику кеширования на уровне приложения.

***

Вообще желательно тщательно ознакомиться с докой фреймворка (если вы таковой юзаете) и драйвера БД. Посмотреть не делают ли они это сами, но суть проста: соединение - это очень дорогая операция и поэтому его нужно кешировать.

Что касается самой БД, то главное, чтобы она целиком влезала в оперативу и были нормальные индексы. Если база не влезает в оперативу целиком, то будет всё тормозить и придётся делать сегментирование. Если сегментирование не закладывать сразу, то потом будет мучительно больно всё переписывать

[Chrome]

что касается

var connectionCache;
function createConnection(params) {
    connectionCache = connectionCache  || mysql.createConnection(params);
    return connectionCache;
}

Это понятно.

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

[kobezzza]

Можно ли как то избавиться от нее и не допрашивать каждый раз таблицу на предмет изменений, а сделать так что бы таблица сам говорила что в ней появились изменения.

Это от СУБД зависит, я знаю что MySQL поддерживает тригеры и хранимки, можно покопать в эту сторону. Т.е. да, есть СУБД, где такое делается легко, что касается MySQL я хз.

А вы перешил на подключение к базе.

Ну, потому что если подключение делается один раз, то нет ничего страшного в том, чтобы по интервалу туда долбиться (если конечно запрос не очень тяжёлый), т.е. - это нормально.

***

Можно поверх MySQL одеть Redis или MemCache, если MySQL будет тупить.