Как вытягивать данные из БД в реальном времени?

Question

[BEKa T]

Мне нужно получать новые записи из БД (если что, я создаю веб-чат).

Я уже знаю про метод типа:
1) нужно сделать функцию, которая проверяет на наличие новых записей из базы данных каждую секунду. Но, я думаю, что этот метод будет грузить сервер и пк, если ещё какой-то другой способ который выводить новые данные в момент его создания!
Вот мой текущий код:

app.js

// Socket Connect
io.on('connection', function (socket) {
	console.log('Socket Run...')

	// Send sms
	socket.on('chat message', function(msg){

			let sql = `INSERT INTO myDB VALUES(${msg})`;
			db.query(sql, (err, result) => {
				if (err) throw err;
				console.log(result);
			})

		io.emit('chat message', msg);
	});

	// Disconnect
	socket.on('disconnect', function(){
		console.log('Socket STOP!');
	});
});

chat.html

$(function () {
		var socket = io();

		$('form').submit((e) => {
	      e.preventDefault();
	      socket.emit('chat message', $('.m').val());
	      $('.m').val('');
	      return false;
	    });

	    socket.on('chat message', function(msg){
	    	$('.sms').append($('<li>').text(msg));
	    });
	  });

Comments

[kr_ilya]

А для какой конкретно цели вам нужно

выводить новые данные в момент его создания

?

[BEKa T]

Energy2,

Мне нужно получать новые записи из БД (если что, я создаю веб-чат).

Answer 1

[Евгений Ромашкан]

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

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

spoiler

Слушать изменения в БД тоже можно, конечно, например через listen/notify+процедуры в pg, но явно не нужно. Пусть логика уровня приложения остаётся на уровне приложения.

Comments

[BEKa T]

То есть по вашему:
1) записать в БД, но ещё не выводить в шаблоне
2) искать в БД такую же запись, отправить в шаблон
3) записать в шаблоне

Я правильно понял?

[Евгений Ромашкан]

Bred Thomson, Зачем искать в БД такую же запись?
Как только создаём новую запись(делаем insert в базу/коммитим транзакцию) - отправляем эту же записть в шаблон и делаем что нужно

[BEKa T]

Евгений Ромашкан, покажите, пожалуйста, пример

[kr_ilya]

Bred Thomson, у вас в вопросе уже всё написано

socket.on('chat message', function(msg){
      //получили сообщение с фронтэнда

      let sql = `INSERT INTO myDB VALUES(${msg})`;
      db.query(sql, (err, result) => {  //и записали его в БД
        if (err) throw err;
        console.log(result);
      })
  
    io.emit('chat message', msg); //после записи в базу отправили это сообщение всем пользователям на фронэенд
  });

[Евгений Ромашкан]

Bred Thomson, Всё как Energy2 упомянул выше.
Ваше сообщение лежит в перменной msg, можно не лезать в базу - делайте с ним что нужно.

[BEKa T]

Евгений Ромашкан, спасибо! Сейчас попробую

[BEKa T]

Energy2, спасибо! Сейчас попробую

[BEKa T]

И так, план значит такой:
1) клиент подключается, введет и отправить какое-то сообщение (var msg = doc.queryS('example-input';)
2) получаю эту переменную msg в бэкенде, создаю запись в БД и в тоже время отображаю то, что клиент отправил в шаблоне.
3) а клиентам подключенным позже вывожу все записи в БД
Верно? :)

[Евгений Ромашкан]

Bred Thomson, Да, всё так. При подключении отдаём некоторое количество последних сообщений, а новые отсылаем в момент их появления

[BEKa T]

Евгений Ромашкан, и последнее)
Как лучше всего сохранить таблицу в БД. Там мне нужно всего 2 поля с id и самим текстом. Вот что я имею в данный момент:

CREATE TABLE `db`.`messages` (
    `id` INT(9999) NOT NULL AUTO_INCREMENT ,
    `text` TEXT NOT NULL ,
    PRIMARY KEY (`id`)
) ENGINE = InnoDB;

[Евгений Ромашкан]

Bred Thomson, Ну если никакие другие поля не нужны, то так и хранить, а в чём проблема?

[BEKa T]

При попытке сохранить текст в БД выводит ошибку

code: 'ER_TRUNCATED_WRONG_VALUE_FOR_FIELD',
  errno: 1366,
  sqlMessage: "Incorrect string value: '\\xD0\\x9F\\xD1\\x80\\xD0\\xB8...' for column 'text' at row 1",
  sqlState: 'HY000',
  index: 0,
  sql: "INSERT INTO `messages` (`id`, `text`) VALUES (NULL, 'Привет!')"

app.js

socket.on('chat message', function(msg){

			let sql = `INSERT INTO \`messages\` (\`id\`, \`text\`) VALUES (NULL, '${msg}')`;
			db.query(sql, (err, result) => {
				if (err) throw err;
				console.log(result);
			})

		io.emit('chat message', msg);
	});

[Евгений Ромашкан]

Bred Thomson, Используете кодировку utf8mb4 в БД

Answer 2

[ski28]

Я бы сделал другую логику. Зачем постоянно дергать mysql ? Mysql должен отдавать данные только один раз , при загрузки страницы. Остальные сообщения должны доставляться пользователям на прямую по socket.io . И уже на этом этапе , данные парально должны записываться в mysql.

Comments

[BEKa T]

Я таки сделал. Почитайте последний комент в ответе выше

[ski28]

Не увидел сразу)