История изменений
Исправление Qwentor, (текущая версия) :
Вот, код примерно такой. Выкладываю не все, только нужное для понимания.
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);
})
Куда тут корректно ставить connection.end() ?
Исправление Qwentor, :
Вот, код примерно такой. Выкладываю не все, только нужное для понимания.
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(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
});
});
});
});
});
}Куда тут корректно ставить connection.end() ?
Исправление Qwentor, :
Вот, код примерно такой. Выкладываю не все, только нужное для понимания.
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(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
});
});
});
});
});
}Исходная версия Qwentor, :
Вот, код примерно такой. Выкладываю не все, только нужное для понимания.
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(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.logs
});
});
});
});
});
}