C#-mongodb

介绍

MongoDB 是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。他支持的数据结构非常松散，是类似json的bson格式，因此可以存储比较复杂的数据类型。Mongo最大的特点是他支持的查询语言非常强大，其语法有点类似于面向对象的查询语言，几乎可以实现类似关系数据库单表查询的绝大部分功能，而且还支持对数据建立索引。

本文资料从http://mongodb.github.io/mongo-csharp-driver/2.0/getting_started/quick_tour/整理而来。

增加一条数据

var client = new MongoClient("mongodb://localhost:27017");
            var database = client.GetDatabase("foo");
            var collection = database.GetCollection<BsonDocument>("bar");
            var document = new BsonDocument
            {
                  { "name", "MongoDB" },
                  { "type", "Database" },
                  { "count", 1 },
                  { "info", new BsonDocument
                    {
                  { "x", 203 },
                  { "y", 102 }
                      }}
            };
            collection.InsertOneAsync(document);

查看数据条数

var client = new MongoClient("mongodb://localhost:27017");
            var database = client.GetDatabase("foo");
            var collection = database.GetCollection<BsonDocument>("bar");
            var count =  collection.CountAsync(new BsonDocument());

            MessageBox.Show(count.ToString());

查看检索默认的数据

var client = new MongoClient("mongodb://localhost:27017");
                var database = client.GetDatabase("foo");
                var collection = database.GetCollection<BsonDocument>("bar");
                var document =  collection.Find(new BsonDocument()).FirstOrDefaultAsync();
                //Console.WriteLine(document.ToString());
                MessageBox.Show(document.ToString());
![](http://7xnav4.com1.z0.glb.clouddn.com/QQ%E6%88%AA%E5%9B%BE20160624204755.png)

查看所有的数据

如果想将链表中所有的数据都返回可以在Find操作之后调用ToListAsync方法就可以，将会直接返回List<T>类型的结果，比如下面的这段代码：
 var client = new MongoClient("mongodb://localhost:27017");
            var database = client.GetDatabase("foo");
            var collection = database.GetCollection<BsonDocument>("bar");
            var documents =  collection.Find(new BsonDocument()).ToListAsync().Result;
           foreach(BsonDocument mess in documents)
            {
                MessageBox.Show(mess.ToString());
            }
针对数量较少的数据情况下，上面这种方式是没有问题，但如果我们需要处理大量的数据，那么我们就不能使用上面的这种方式，就需要利用下面的方式，通过ForEachAsync来完成，因为这个方法会在每条数据返回的时候执行一个回调，从而达到并发处理的目的，比如下面这段代码就演示了如何使用：     var client = new MongoClient("mongodb://localhost:27017");
var database = client.GetDatabase("foo");
var collection = database.GetCollection<BsonDocument>("bar");
collection.Find(new BsonDocument()).ForEachAsync(x => MessageBox.Show(x.ToString()));

通过条件查询单条数据

我们可以在调用Find方法的时候传入一个过滤条件，从而在链表中查询我们希望的数据
var client = new MongoClient("mongodb://localhost:27017");
            var database = client.GetDatabase("foo");
            var collection = database.GetCollection<BsonDocument>("bar");
            var filter = Builders<BsonDocument>.Filter.Eq("count", 2);
            var document = collection.Find(filter).FirstAsync().Result;
            MessageBox.Show(document.ToString());

我们也可以获取多条数据

var client = new MongoClient("mongodb://localhost:27017");
           var database = client.GetDatabase("foo");
           var collection = database.GetCollection<BsonDocument>("bar");
           var filter = Builders<BsonDocument>.Filter.Eq("count", 2);
           var document = collection.Find(filter).ForEachAsync(x => MessageBox.Show(x.ToString()));

对数据排序

var client = new MongoClient("mongodb://localhost:27017");
            var database = client.GetDatabase("foo");
            var collection = database.GetCollection<BsonDocument>("bar");
            var filter = Builders<BsonDocument>.Filter.Exists("count");
            var sort = Builders<BsonDocument>.Sort.Descending("count");
            var documnt = collection.Find(filter).Sort(sort).ToListAsync().Result;
            foreach(BsonDocument mess in documnt)
            {
                MessageBox.Show(mess.ToString());
            }

对字段投射

许多时候我们并不需要文档中的所有数据，这就好比在SQL中我们都会只把我们需要的数据select出来，而不会把表中的所有字段的数据都拿出来，自然MongoDB也可以让我这样做，我们只需要跟过滤和排序一样利用Projection构造器来构造然后传递给Project方法中就可以了，下面这个例子中我们将排除“_id”字段：
 var client = new MongoClient("mongodb://localhost:27017");
            var database = client.GetDatabase("foo");
            var collection = database.GetCollection<BsonDocument>("bar");
            var projection = Builders<BsonDocument>.Projection.Exclude("_id");
            var document = collection.Find(new BsonDocument()).Project(projection).FirstAsync().Result;
            MessageBox.Show(document.ToString());

更新文档

果我们需要更新一个对象（如果条件不匹配那么可能是0条），可以使用UpdateOneAsync方法，并执行过滤条件和需要更新到的文档，比如下面我们将“counter”为1的数据中的“counter”更新为110：
var client = new MongoClient("mongodb://localhost:27017");
            var database = client.GetDatabase("foo");
            var collection = database.GetCollection<BsonDocument>("bar");
            var filter = Builders<BsonDocument>.Filter.Eq("count", 1);
            var updated = Builders<BsonDocument>.Update.Set("count", 110);
            var result = collection.UpdateOneAsync(filter, updated).Result;
如果我们需要批量的更新，我们可以调用UpdateManyAsync即可。比如我们需要将“counter”小于10的数据中的“counter”累加100，那么我们就可以像下面这样来写：
var client = new MongoClient("mongodb://localhost:27017");
            var database = client.GetDatabase("foo");
            var collection = database.GetCollection<BsonDocument>("bar");
            var filter = Builders<BsonDocument>.Filter.Lt("count", 3);
            var updated = Builders<BsonDocument>.Update.Inc("count", 100);
            var result = collection.UpdateManyAsync(filter, updated).Result;

删除文档

作为基础部分这也是最后一个部分了，利用上面的过滤，然后调用DeleteOneAsync或DeleteManyAsync方法就可以了，比如下面的列子就是删除“counter”大于100的所有数据：
var client = new MongoClient("mongodb://localhost:27017");
            var database = client.GetDatabase("foo");
            var collection = database.GetCollection<BsonDocument>("bar");
            var filter = Builders<BsonDocument>.Filter.Eq("count", 102);
            var resut = collection.DeleteManyAsync(filter).Result;

后记

我在学习mongodb的编程时首先遇到了问题，在网上的很多教程是
基于老版本的，一些函数都不能用了，很感慨，技术的更新很快。
而且多看官方教程比较好。