Как закрыть соединение после выполнения всех запросов MySQL?

Question

[Вячеслав Грачунов]

Короче так: у меня скрипт посылает много запросов на вставку данных в MySQL - надо понять когда пройдут все запросы и закрыть соединение.
При этом все выполняется не последовательными запросами, а в цикле с кучей вложенных forEach (парсер). Как быть? Нужно чтобы скрипт завершался, а не висел, т.к. требуется его постоянный перезапуск по завершению
Да, Node.js
В тегах было - в тексте не написал

Answer 1

[IceJOKER]

А читать документацию ?
fi2.php.net/manual/en/mysqli.close.php

Comments

[Вячеслав Грачунов]

А читать вопрос?
1) Node.js - PHP не при чем вообще
2) Соответственно асихронность и просто так в конце написать connection.end() нельзя

[IceJOKER]

Вячеслав Грачунов: извиняюсь, читал вопрос, смотрел теги, подумал, что nodejs обращается к скрипту php + mysql. Может это поможет - stackoverflow.com/questions/10446944/how-to-close-...

[Вячеслав Грачунов]

IceJOKER: спасибо, но там написано только какой командой закрывать, а мне бы понять куда ее лепить, чтобы не закрыть раньше времени (до завершения всех запросов)

[Алексей Ярков]

Вячеслав Грачунов:

а мне бы понять куда ее лепить, чтобы не закрыть раньше времени (до завершения всех запросов)

А нам бы код хоть примерно посмотреть, чтоб сказать куда лепить ))

[IceJOKER]

Вячеслав Грачунов: не телепат, но полагаю, что после выполнения всех запросов. после for/foreach/while

[Вячеслав Грачунов]

Алексей Ярков: да, разумно. Чуть позже будет. Весь не могу, но значимую для вопроса часть выложу

[Вячеслав Грачунов]

Алексей Ярков:

var connection = mysql.createConnection({
  host     : '127.0.0.1',
  user     : 'root',
  password : 'password',
  database : 'database'
});

connection.connect(); 

var obj = {};
obj.one = 'http://blablabla'; //big big big json
obj.two = 'http://blablabla'; //big big big json
obj.three = 'http://blablabla'; //big big big json

function doparse(url){

//Тут получаем данные json по url и преобразуем их в объект 

body = JSON.parse(body);

var events = body['events'];

async.each(events, function(event, callback){

	var markets = event['markets'];
	markets.forEach(function(market){

		var runners = market['runners'];
		runners.forEach(function(runner){
			prices = runner['prices'];
			prices.forEach(function(price){


				var inserted_data = [...........]; //вставляемые данные

				connection.query('INSERT blablabla', inserted_data, function(err, result){

					//Обработка ошибок и просто console.log

				});

			});


		});




	});


});







}

async.each(obj, function(url, callback){
				
     doparse(url);
});

Примерно так

[Вячеслав Грачунов]

Как то так. Как тут поймать окончание вставки данных?

[Алексей Ярков]

Вячеслав Грачунов: Попробуйте так:

async.parallel(obj, function(err, url) {
    if (err){
        connection.close();
    }
    else{
        doparse(url);
    }
});

[Алексей Ярков]

Вячеслав Грачунов: А вот тут почти ваш вариант: stackoverflow.com/questions/13855715/how-to-struct...

[Вячеслав Грачунов]

Алексей Ярков: не работает, да и здесь caolan.github.io/async/docs.html#.parallel синтаксис другой. К тому же там нужен callback для вызова следующей функции, а куда его ставить в цикле?

Answer 2

[Виталий]

обернуть скуль запросы в промис, в then выполнить закрытие базы (ровно как и в catch на крайний пожарный)

Comments

[Вячеслав Грачунов]

Как их обернуть в промис, если заранее количество неизвестно и они выполняются во вложенном цикле?

[Виталий]

Вячеслав Грачунов: вот очень неплохой наглядный пример Как организовать promise в NodeJS при запросах к большому числу серверов? , отдельно обратите внимание, что единичный промис и готовый результат и ошибку отправляет в then. Это сделано, чтобы при исполнении промисс алл не потерять часть задач при ошибке в единичном промисе. Переводя на ваш пример, каждый запрос к скулю это промис, где что результат , что ошибка отправляются в ресольв. Далее собираете мапу этих промисов и пуляете в промис алл, где после завершения вссех из них в then делаете закрытие базы.

[Виталий]

Вячеслав Грачунов: естественно я ссылаюсь на ответ Константина в том топике.

[Вячеслав Грачунов]

все получилось через async, без промисов