MongoDB學習筆記~大叔分享批量添加—批量更新—批量刪除

回到目錄

說它是批量操作，就是說將集合對象一次提交到服務器，並對數據進行持久化，如果您的代碼是一次一次的提交，那不算是批量操作！在之前的mongodb倉儲中並沒有對批量更新和批量刪除進行實現，而今天在項目中，還是實現了這種批量的操作，並且已經通過測試，下面公開一下源代碼

        public void Insert(IEnumerable<TEntity> item)
        {
            var list = new List<WriteModel<TEntity>>();
            foreach (var iitem in item)
            {
                list.Add(new InsertOneModel<TEntity>(iitem));
            }
            _table.BulkWriteAsync(list).Wait();
        }

        public void Update(IEnumerable<TEntity> item)
        {

            var list = new List<WriteModel<TEntity>>();

            foreach (var iitem in item)
            {
                QueryDocument queryDocument = new QueryDocument("_id", new ObjectId(typeof(TEntity).GetProperty(EntityKey).GetValue(iitem).ToString()));
                list.Add(new UpdateOneModel<TEntity>(queryDocument, Builders<TEntity>.Update.Combine(GeneratorMongoUpdate(iitem))));
            }
            _table.BulkWriteAsync(list).Wait();
        }

        public void Delete(IEnumerable<TEntity> item)
        {
            var list = new List<WriteModel<TEntity>>();

            foreach (var iitem in item)
            {
                QueryDocument queryDocument = new QueryDocument("_id", new ObjectId(typeof(TEntity).GetProperty(EntityKey).GetValue(iitem).ToString()));
                list.Add(new DeleteOneModel<TEntity>(queryDocument));
            }
            _table.BulkWriteAsync(list).Wait();
        }

在程序實現之中，我們使用了WriteModel泛型對象，這將存儲要插入，更新和刪除的對象，對於插入來說，只有一個參數就是它的實體集合，而對象更新來說，它不僅有實體集合而且還有對應的條件QueryDocument，而對於刪除操作來說，只提供QueryDocument即可！

回到目錄