Отправка запросов в БД

[jtag]

Всем добрый день. Сейчас отправляю запросы в mysql таким образом:

let x = 0;
setInterval(function(){
    connection.query("SELECT * FROM person WHERE x = '"+x+"' ... ", function() {
         x++;
    });
},500);

Из этого видно что setInterval абсолютно не видит когда приходит обратный ответ с БД. Время пол секунды, установлено приблизительно, т.к. я уверен чтоб БД уже завершила ответ. Как сделать чтобы после ответа сразу отправлялся след запрос? Существует какой-либо шаблон, по которому все пишут, а я вот его не знаю?

[Nexus]

Зачем так бд сношать?

[jtag]

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

[Nexus]

jtag, что значит "события поступают в бд"?

[jtag]

события т.е. новые строки

[laimas]

т.к. я уверен чтоб БД уже завершила ответ

Ну выборка из БД не ради шутки же, а нужны ее данные, а ответил ли sql-сервер и если да, то чем узнают не по уверенности, а проверкой ответа.

[Nexus]

jtag, что мешает уже обработанным строкам добавлять флаг (либо хранить где-нибудь последний обработанный id) и запрашивать у бд сразу некоторое кол-во записей, которые нужно обработать?
Зачем каждые пол секунды долбить бд новым запросом?
Быстрее она от этого работать не станет.

[jtag]

Незнаю можно ли тут обсуждать БД, но вот что у меня получается. Вначала я делаю выборку одним разом всех не обработанных строк. Потом в цикле начинаю обрабатывать каждую строку, т.е. делаю запрос в БД, существует ли такой ИИН, если нет такого, то вставляю в базу. Потом вставляю телефон, и делаю запрос - отмечаю необработанную строку флагом "обрабатано". Получается, мне нужно все используемые таблицы скопировать и потом с ними в обычном цикле for производить операции?

let x = 0;
con.query("SELECT * FROM xml_person WHERE done='0'", function (err, resultFromXml) { //запрос всех необработанных строк
		setInterval(function () {
			con.query("SELECT * FROM person  WHERE iin='" + resultFromXml[x].iin + "'", function (err, resultFromPerson) { //проверка, имеется ли такой ИИН в базе
				if (resultFromPerson.length == 0) {  
					con.query("INSERT INTO `person` (`idperson`, `iin`, `surname`, `name`,..., function(err) {		//вставка person

						con.query("INSERT INTO `phone` (`id`, `phone`," ... function(err) {		//вставка телефона
							con.query("UPDATE xml_person SET done='4' WHERE id_xml_person='" + resultFromXml[x].id_xml_person, function(err) {  //ставлю флаг, что строка обработана
								x++;
							}
						}
					});
				}
					
			});
		}, 500);
		
}

[laimas]

jtag,
я не знаю node.js, но как можно обрабатывать результат запроса не зная, что он вернул? А если запрос завершился неудачей?

[jtag]

я просто сократил и вырезал, а так там конечно, ошибки обрабатываются.