MongoDB入门及 c# .netcore客户端MongoDB.Driver2.9.1使用

什么场景下使用MongoDB

MongoDB虽然是NoSQL(非关系型的数据库)，但是实际使用的时候可以当做关系型数据库来用，
mysql等数据库中单表数据量大了之后，想要扩展字段就非常痛苦，应为要卡很长时间，这时候就必须面临着两种选择要么水平切分数据库，要么使用nosql来存储海量数据，mongodb作为日志存储是非常利于扩展的，还有数据分析等都可以用mongodb作为灵活的数据源的存储方式。

MongoDB 概念解析

在mongodb中基本的概念是文档、集合、数据库，下面我们挨个介绍。

SQL术语/概念 MongoDB术语/概念解释/说明

一个mongodb中可以建立多个数据库。
MongoDB的默认数据库为"db"，该数据库存储在data目录中。
MongoDB的单个实例可以容纳多个独立的数据库，每一个都有自己的集合和权限，不同的数据库也放置在不同的文件中。
"show dbs" 命令可以显示所有数据的列表。

集合就是 MongoDB 文档组，类似于 RDBMS （关系数据库管理系统：Relational Database Management System)中的表格。

集合存在于数据库中，集合没有固定的结构，这意味着你在对集合可以插入不同格式和类型的数据，但通常情况下我们插入集合的数据都会有一定的关联性。

比如，我们可以将以下不同数据结构的文档插入到集合中：

{"site":"www.baidu.com"}
{"site":"www.google.com","name":"Google"}
{"site":"www.runoob.com","name":"菜鸟教程","num":5}
当第一个文档插入时，集合就会被创建。

合法的集合名
集合名不能是空字符串""。
集合名不能含有\0字符（空字符)，这个字符表示集合名的结尾。
集合名不能以"system."开头，这是为系统集合保留的前缀。
用户创建的集合名字不能含有保留字符。有些驱动程序的确支持在集合名里面包含，这是因为某些系统生成的集合中包含该字符。除非你要访问这种系统创建的集合，否则千万不要在名字里出现$。

文档(Document)

文档是一组键值(key-value)对(即 BSON)。MongoDB 的文档不需要设置相同的字段，并且相同的字段不需要相同的数据类型，这与关系型数据库有很大的区别，也是 MongoDB 非常突出的特点。

下表列出了 RDBMS 与 MongoDB 对应的术语：

RDBMS MongoDB

ObjectId 类似唯一主键，可以很快的去生成和排序，包含 12 bytes，含义是：

前 4 个字节表示创建 unix 时间戳,格林尼治时间 UTC 时间，比北京时间晚了 8 个小时

接下来的 3 个字节是机器标识码

紧接的两个字节由进程 id 组成 PID

最后三个字节是随机数

MongoDB 中存储的文档必须有一个 _id 键。这个键的值可以是任何类型的，默认是个 ObjectId 对象

mongodb windows安装

下载地址 https://www.mongodb.com/download-center/community

客户端工具
使用以下三种都可以
https://robomongo.org/download【推荐】
https://www.mongodb.com/download-center/compass【官方的，windows下会默认安装】
https://nosqlbooster.com/downloads

引入 nuget包 MongoDB.Driver

以下是常用的CRUD测试用例

using Microsoft.VisualStudio.TestTools.UnitTesting;
using MongoDB.Bson;
using MongoDB.Bson.Serialization.Attributes;
using MongoDB.Driver;
using MongoDB.Driver.Linq;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
namespace MongoDBDemo
    /// <summary>
    /// mongodb先创建库 test
    /// 再创建表 testlist
    /// </summary>
    [TestClass]
    public class UnitTest1
        private MongoClient client;
        private IMongoDatabase database;
        public UnitTest1()
            this.client = new MongoClient(new MongoClientSettings { Server = new MongoServerAddress("127.0.0.1", 27017), });
            this.database = client.GetDatabase("test");
        /// <summary>
        /// 查所有记录
        /// </summary>
        [TestMethod]
        public void TestQueryAll()
            var list = database.GetCollection<A>("testlist");
            var result = list.Find("{}").ToList();
        /// <summary>
        /// 基础的查询方式
        /// </summary>
        [TestMethod]
        public void TestQueryBase()
            var collection = database.GetCollection<BsonDocument>("testlist");
            BsonDocument filter = new BsonDocument();
            var s = collection.Find(filter).ToList();
            using (var cursor = collection.FindAsync(filter).Result)
                while (cursor.MoveNextAsync().Result)
                    var batch = cursor.Current;
                    foreach (BsonDocument document in batch)
                        Console.WriteLine(document.ToJson());
        /// <summary>
        /// 组装查询语句方式
        /// </summary>
        [TestMethod]
        public void TestQueryBuilders()
            var list = database.GetCollection<A>("testlist");
            var filter = Builders<A>.Filter.Eq(x => x.Name, "b");
            var result = list.Find(filter).ToList();
        /// <summary>
        /// linq asqueryable方式
        /// </summary>
        [TestMethod]
        public void TestQueryLinq()
            var list = database.GetCollection<A>("testlist");
            var result = list.AsQueryable().Where(p => p.Name == "b").ToList();
        [TestMethod]
        public void TestQueryLinq2()
            var list = database.GetCollection<A>("testlist");
            var result = list.Find(p => p.Name == "b").ToList();
        [TestMethod]
        public void TestInsert()
            var list = database.GetCollection<A>("testlist");
            list.InsertOne(new A { Name = "a", Count = 1 });
        [TestMethod]
        public void TestUpdate()
            var list = database.GetCollection<A>("testlist");
            var update = Builders<A>.Update;
            list.UpdateOne(p => p.Name == "a", update.Set("Count", 2));
        [TestMethod]
        public void TestDelete()
            var list = database.GetCollection<A>("testlist");
            list.DeleteOne(p => p.Name == "s");
    //如果不加这个[BsonIgnoreExtraElements]会报错 
    // System.FormatException:“Element '_id' does not match any field or property of class，
    // 也可以加属性 public ObjectId _id { get; set; } 来解决
    [BsonIgnoreExtraElements]
    public class A
        //public ObjectId _id { get; set; }
        public string Name { get; set; }
        public int Count { get; set; }
更详细的关于CRUD操作可以看官方文档