1

требуется последовательно выполнить несколько sql запросов к MySQL

вызов команд реализую через Promise

но встал вопрос как сделать универсальный метод обрабатывающий последовательно массив запросов?

более конктретно как на Promise реализовать такую цепочку вызовов?

class myClass() {

    constructor() {
        this.list = [sq1,sql2,sql3];
    }   

    function myFunc(i) {

        ...

        if(++i < list.length) {

            if(...) list.push(newSQL); <= {1} <=

            this.myFunc(i)
        }
    }
}

let m = new MyClass();
m.myFunct(0);

UPDATE

сейчас так реализована одна итерация, вопрос как последовательно обработать весь список:

    myBuy(sql) {

        return new Promise((resolve, reject) => {

            ...

            let promise = global._query(sql);

            promise
            .then(
                data=>resolve(data),
                err=>reject(err)
            )
        })

    }


listSQL.forEach((e) => 
    myClass.myBuy(e)
)    
11
  • вы хотите, чтобы promise выполнялись одна за одной последовательно? параллельно? в случае неудачи одной что будет с остальными? 23 июн 2017 в 16:00
  • @MikhailVaysman, последовательно. Неудача в данной задаче не критична. Вопрос как Promise.all сделать последовательным и обрабатывающим динамический (дополняемый) массив.
    – ravend
    23 июн 2017 в 16:07
  • дополняемый в какой момент? 23 июн 2017 в 16:08
  • дополнил код, посмотрите строчку с {1}.
    – ravend
    23 июн 2017 в 16:10
  • @MikhailVaysman, хотя динамичность здесь не принципиальна. Больше вопрос в последовательности
    – ravend
    23 июн 2017 в 16:12

1 ответ 1

2

Можно что-то вроде этого "наваять", но я бы рекомендовал использовать готовые библиотеки.
Когда-то для подобных вещей я использовал async

let list = [
  Promise.resolve(1),
  Promise.resolve(2),
];

const add = (p, newP) => 
  p.then(results => newP.then(newRes => {
    results.push(newRes);
    return results;
  }));


let p = Promise.resolve([]);
list.forEach(newP => p = add(p, newP));

p = add(p, Promise.resolve(3));
p = add(p, Promise.resolve(4));

p.then(results => console.log(results));

p = add(p, Promise.resolve(5));
p.then(results => console.log(results));

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.