17

私はmongooseを使ってmongodbにデータを挿入しています。コードは次のようになります。

var mongoose = require('mongoose');
mongoose.connect('mongo://localhost/test');
var conn = mongoose.connection;

// insert users
conn.collection('users').insert([{/*user1*/},{/*user2*/}], function(err, docs) {
    var user1 = docs[0], user2 = docs[1];

    // insert channels
    conn.collection('channels').insert([{userId:user1._id},{userId:user2._id}], function(err, docs) {
        var channel1 = docs[0], channel2 = docs[1];

        // insert articles
        conn.collection('articles').insert([{userId:user1._id,channelId:channel1._id},{}], function(err, docs) {
            var article1 = docs[0], article2 = docs[1];

        }
    });
};

そこにはネストされたコールバックがたくさんあることがわかるので、qを使用してリファクタリングしようとしています。

コードが次のようになることを願っています。

Q.fcall(step1)
.then(step2)
.then(step3)
.then(step4)
.then(function (value4) {
    // Do something with value4
}, function (error) {
    // Handle any error from step1 through step4
})
.end();

しかし、私はそれを行う方法がわかりません。

4

5 に答える 5

13

READMEおよび WikiQ.nfcallに記載されているを使用することをお勧めします。すべての Mongoose メソッドは Node スタイルです。また、手動で destructuring する代わりに使用します。.spread.then

var mongoose = require('mongoose');
mongoose.connect('mongo://localhost/test');
var conn = mongoose.connection;

var users = conn.collection('users');
var channels = conn.collection('channels');
var articles = conn.collection('articles');

function getInsertedArticles() {
    return Q.nfcall(users.insert.bind(users), [{/*user1*/},{/*user2*/}]).spread(function (user1, user2) {
        return Q.nfcall(channels.insert.bind(channels), [{userId:user1._id},{userId:user2._id}]).spread(function (channel1, channel2) {
            return Q.nfcall(articles.insert.bind(articles), [{userId:user1._id,channelId:channel1._id},{}]);
        });
    })
}

getInsertedArticles()
    .spread(function (article1, article2) {
        // you only get here if all three of the above steps succeeded
    })
    .fail(function (error) {
        // you get here if any of the above three steps failed
    }
);

実際には、.spread通常はサイズがわからない配列を挿入するため、 を使用することはめったにありません。その場合、コードは次のようになります(ここでは も示していますQ.nbind)。

オリジナルにはエラー処理がないため、オリジナルと比較するのは公平ではありません。オリジナルのノード スタイル バージョンを修正すると、次のようになります。

var mongoose = require('mongoose');
mongoose.connect('mongo://localhost/test');
var conn = mongoose.connection;

function getInsertedArticles(cb) {
    // insert users
    conn.collection('users').insert([{/*user1*/},{/*user2*/}], function(err, docs) {
        if (err) {
            cb(err);
            return;
        }

        var user1 = docs[0], user2 = docs[1];

        // insert channels
        conn.collection('channels').insert([{userId:user1._id},{userId:user2._id}], function(err, docs) {
            if (err) {
                cb(err);
                return;
            }

            var channel1 = docs[0], channel2 = docs[1];

            // insert articles
            conn.collection('articles').insert([{userId:user1._id,channelId:channel1._id},{}], function(err, docs) {
                if (err) {
                    cb(err);
                    return;
                }

                var article1 = docs[0], article2 = docs[1];

                cb(null, [article1, article2]);
            }
        });
    };
}

getInsertedArticles(function (err, articles) {
    if (err) {
        // you get here if any of the three steps failed.
        // `articles` is `undefined`.
    } else {
        // you get here if all three succeeded.
        // `err` is null.
    }
});
于 2012-05-11T14:54:38.247 に答える
4

代替の据え置きプロミスの実装では、次のように実行できます。

var mongoose = require('mongoose');
mongoose.connect('mongo://localhost/test');
var conn = mongoose.connection;

// Setup 'pinsert', promise version of 'insert' method
var promisify = require('deferred').promisify
mongoose.Collection.prototype.pinsert = promisify(mongoose.Collection.prototype.insert);

var user1, user2;
// insert users
conn.collection('users').pinsert([{/*user1*/},{/*user2*/}])
// insert channels
.then(function (users) {
  user1 = users[0]; user2 = users[1];
  return conn.collection('channels').pinsert([{userId:user1._id},{userId:user2._id}]);
})
// insert articles
.match(function (channel1, channel2) {
  return conn.collection('articles').pinsert([{userId:user1._id,channelId:channel1._id},{}]);
})
.done(function (articles) {
  // Do something with articles
}, function (err) {
   // Handle any error that might have occurred on the way
});
于 2012-05-11T16:08:19.547 に答える
3

Collection.insertの代わりにModel.saveを検討します(私たちの場合もまったく同じです)。

Qを使用する必要はありません。 saveメソッドをラップして直接Mongoose Promiseを返すことができます。

最初に、save 関数をラップするためのユーティリティ メソッドを作成します。これはあまりクリーンではありませんが、次のようなものです。

  //Utility function (put it in a better place)
  var saveInPromise = function (model) {

    var promise = new mongoose.Promise();

    model.save(function (err, result) {
      promise.resolve(err, result);
    });

    return promise;
  }

次に、保存する代わりにそれを使用して、約束を連鎖させることができます

  var User = mongoose.model('User');
  var Channel = mongoose.model('Channel');
  var Article = mongoose.model('Article');

  //Step 1
  var user = new User({data: 'value'});
  saveInPromise(user).then(function () {

    //Step 2
    var channel = new Channel({user: user.id})
    return saveInPromise(channel);

  }).then(function (channel) {

    //Step 3
    var article = new Article({channel: channel.id})
    return saveInPromise(article);

  }, function (err) {
    //A single place to handle your errors

  });

それが私たちが求めているシンプルさだと思います..そうですか？もちろん、Mongoose とのより良い統合により、ユーティリティ関数を実装できます。

それについてどう思うか教えてください。

ちなみに、Mongoose Github には、その正確な問題に関する問題があります。

早く解決することを願っています。mpromiseからQへの切り替えを考えているので、しばらく時間がかかると思います。

于 2013-12-09T16:24:47.827 に答える
2

2 年後、私の RSS クライアントにこの質問が表示されました...

2012 年 5 月以降、事態はいくぶん進展しており、現在は別の方法でこの問題を解決することを選択する可能性があります。Array.prototype.reduceより具体的には、Javascript コミュニティは、ECMAScript5 に (および他の Array メソッドを)含めることを決定して以来、"reduce-aware" になりました。Array.prototype.reduceポリフィルとして常に (そして今も) 利用可能でしたが、当時はほとんど評価されませんでした。もちろん、時代を先取りしていた人たちは、この点について異議を唱えるかもしれません。

質問で提起された問題は、次のようなルールで定型化されているようです。

  • conn.collection(table).insert()配列内のオブジェクトは、次のように構築する最初のパラメーターとして渡されます (ここNで、配列内のオブジェクトのインデックスに対応します)。
    • [ {}, ... ]
    • [ {userId:userN._id}, ... ]
    • [ {userId:userN._id, channelId:channelN._id}, ... ]
  • テーブル名 (順番) はusers、 、channels、articlesです。
  • 対応するオブジェクト プロパティは : user, channel, article(つまり、複数形の 's' を除いたテーブル名) です。

Taoofcode によるこの記事からの一般的なパターンは、連続して非同期呼び出しを行うためのものです。

function workMyCollection(arr) {  
    return arr.reduce(function(promise, item) {
        return promise.then(function(result) {
            return doSomethingAsyncWithResult(item, result);
        });        
    }, q());
}

非常に軽い適応で、このパターンを作成して、必要なシーケンスを調整できます。

function cascadeInsert(tables, n) {
    /* 
    /* tables: array of unpluralisd table names
    /* n: number of users to insert.
    /* returns promise of completion|error
     */
    var ids = []; // this outer array is available to the inner functions (to be read and written to).
    for(var i=0; i<n; i++) { ids.push({}); } //initialize the ids array with n plain objects.
    return tables.reduce(function (promise, t) {
        return promise.then(function (docs) {
            for(var i=0; i<ids.length; i++) {
                if(!docs[i]) throw (new Error(t + ": returned documents list does not match the request"));//or simply `continue;` to be error tolerant (if acceptable server-side).
                ids[i][t+'Id'] = docs[i]._id; //progressively add properties to the `ids` objects
            }
            return insert(ids, t + 's');
        });
    }, Q());
}

最後に、Promise を返すワーカー関数は次のinsert()とおりです。

function insert(ids, t) {
    /* 
    /* ids: array of plain objects with properties as defined by the rules
    /* t: table name.
    /* returns promise of docs
     */
    var dfrd = Q.defer();
    conn.collection(t).insert(ids, function(err, docs) {
        (err) ? dfrd.reject(err) : dfrd.resolve(docs);
    });
    return dfrd.promise;
}

したがって、 に渡されるパラメータとしてcascadeInsert、実際のテーブル/プロパティ名と挿入するユーザー数を指定できます。

cascadeInsert( ['user', 'channel', 'article'], 2 ).then(function () {
   // you get here if everything was successful
}).catch(function (err) {
   // you get here if anything failed
});

質問のテーブルにはすべて通常の複数形 (ユーザー => ユーザー、チャネル => チャネル) があるため、これはうまく機能します。それらのいずれかが不規則である場合 (例:刺激 => 刺激、子 => 子供)、再考する必要があります - (そしておそらくルックアップ ハッシュを実装します)。いずれにせよ、適応はかなり簡単です。

于 2014-04-14T19:41:51.247 に答える
1

今日もmongoose-qがあります。Q promise を返す execQ や saveQ などを提供する mongoose のプラグイン。

于 2014-09-17T11:53:46.590 に答える