Как связать две модели в одну посредством перебора в node.js and mongoos?

Question

[Александр Дроздов]

Есть две модели простые, связть один ко многим.
1 - product
2 - product_info (тут есть поле product_id)
Так вот, пытаюсь все это заджонить. Но у меня не получается, мне кажется что-то конечно не то, но проблема именно в том, что цикл forEach пробегает быстрее чем данные запушаться в итоговый массив. И в итоге def.resolve(result); пусто

var mongoose = require('mongoose');
var Q = require('q');

var catalog = function(app) {
    var product = mongoose.model('product', require('../model/product'));
    var productInfo = mongoose.model('product_info', require('../model/ProductInfo'));

    var getAllProducts = function() {
        var result = [];
        var def = Q.defer();

        product.find(function(err, products) {
            products.forEach(function(product) {
                productInfo.find({product_id: product._id}, function(err, info) {
                    product.info = info;
                    result.push(product);
                });
            });

            def.resolve(result);
        });

        return def.promise;
    };

    return {
        getAllProducts : getAllProducts
    };
};

module.exports = catalog;

и вот вызываем

var products = require('../src/catalog')(app).getAllProducts();

        products.then(function (products) {
            console.log(products);
            res.render('index', { products : products });
        });

Как все это сделать более грамотно? спасибо.

Answer 1

[Илья Шатохин]

У вас асинхронный код. Логично, что def.resolve(result) сработает раньше, чем закончится любой из productInfo.find.
Вам нужен контроль выполнения асинхронного кода, например async.

product.find(function(err, products) {
  async.each(products, function (product, cb) {
    productInfo.find({product_id: product._id}, function(err, info) {
      product.info = info;
      cb(err);
    });
  }, function (err) {
    def.resolve(products);
  });
});

Другой вариант вашего кода в один запрос и без async:

product.find(function(err, products) {
 var p_ids = products.map(function (product) { // создаем массив id продуктов
    return product._id; 
  });

  productInfo.find({product_id : {$in:  p_ids}}, function(err, infos) { // запрашиваем info для всех совпадающих id продуктов в массиве
    var obj = infos.reduce(function(a, b) { // создаем коллекцию для быстрого поиска, где ключ - id продукта
      return a[b.product_id ] = b;
    }, {});

    products.forEach(function (product) {
      product.info = obj[product._id];
    });

    def.resolve(products);
  }));
});

Comments

[Александр Дроздов]

Спасибо, попробую и отпишу. А как насчет правильности? Есть ли лучший способ реализовать подобный алгоритм?

[Илья Шатохин]

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

[Александр Дроздов]

Да не, там максимум 100

[Илья Шатохин]

Александр Дроздов: Я там расширил ответ - добавил другой вариант. При малых количествах записей он эффективней, т.к. дополнительный запрос к базе всего один.

[Александр Дроздов]

Илья Шатохин: Спасибо за второй вариант, так действительно лучше, оптимизированее =)
Я только недавно стал работать с nosql, и пока сложновато работать с nosql бд.

[Илья Шатохин]

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