码迷，mamicode.com
首页 > 数据库 > 详细

.net Core MongoDB用法演示

时间：2019-07-22 13:19:15      阅读：137      评论：0      收藏：0      [点我收藏+]

标签：查询   简单例子   clu   nosql   ESS   mamicode   命名   nbsp   project   

C#驱动MongoDB的本质是将C#的操作代码转换为mongo shell，驱动的API也比较简单明了，方法名和js shell的方法名基本都保持一致，熟悉mongo shell后学习MongoDB的C#驱动是十分轻松的，直接看几个demo吧。

0.准备测试数据

使用js shell添加一些测试数据，如下：

use myDb
db.userinfos.insertMany([
   {_id:1, name: "张三", age: 23,level:10, ename: { firstname: "san", lastname: "zhang"}, roles: ["vip","gen" ]},
   {_id:2, name: "李四", age: 24,level:20, ename: { firstname: "si", lastname: "li"}, roles:[ "vip" ]},
   {_id:3, name: "王五", age: 25,level:30, ename: { firstname: "wu", lastname: "wang"}, roles: ["gen","vip" ]},
   {_id:4, name: "赵六", age: 26,level:40, ename: { firstname: "liu", lastname: "zhao"}, roles: ["gen"] },
   {_id:5, name: "田七", age: 27, ename: { firstname: "qi", lastname: "tian"}, address:‘北京‘ },
   {_id:6, name: "周八", age: 28,roles:["gen"], address:‘上海‘ }
])

1 添加(InsertOne,InsertMany)

　　安装nuget包（或者执行命令  Install-Package MongoDB.Driver）

 技术图片

然后就可以使用C#操作MongoDB数据库了，看一个添加的demo：

 class Program
    {
        static void Main(string[] args)
        {
            //连接数据库
            var client = new MongoClient("mongodb://root:root@192.168.100.3:27017/");
            //获取database
            var mydb = client.GetDatabase("myDb");
            //获取collection
            var collection = mydb.GetCollection<BsonDocument>("userinfos");
            //待添加的document
            var doc = new BsonDocument{
                { "_id",7 },
                { "name", "吴九" },
                { "age", 29 },
                { "ename", new BsonDocument
                    {
                        { "firstname", "jiu" },
                        { "lastname", "wu" }
                    }
                }
            };
            //InsertOne()添加单条docment
            collection.InsertOne(doc);
        }
    }

执行完成后，查看在NoSQLBooster中查询，看到已经添加成功了：

　技术图片

我们也可以是用 collection.InsertMany(IEnumerable<BsonDocument> docs) 来批量添加docment，这里就不再演示了。

2  查询(Find,Filter,Sort,Projection)

1.简单查询(Find、Filter)

 查找name=“吴九"的记录

var client = new MongoClient("mongodb://root:root@192.168.100.3:27017/");
//获取database
var mydb = client.GetDatabase("myDb");
//获取collection
var collection = mydb.GetCollection<BsonDocument>("userinfos");
//Fileter用于过滤，如查询name = 吴九的第一条记录
var filter = Builders<BsonDocument>.Filter;
//Find(filter)进行查询
var doc = collection.Find(filter.Eq("name", "吴九")).FirstOrDefault();
Console.WriteLine(doc);

查询结果如下：

 技术图片

如果我们想查询所有的记录，可以设置过滤器为空，代码为： var docs = collection.Find(filter.Empty).ToList(); 

2.AND查询

查询年龄大于25且小于28的记录

//连接数据库
var client = new MongoClient("mongodb://root:root@192.168.100.3:27017/");
//获取database
var mydb = client.GetDatabase("myDb");
//获取collection
var collection = mydb.GetCollection<BsonDocument>("userinfos");
//查询25<age<28的记录
var filter = Builders<BsonDocument>.Filter;
var docs = collection.Find(filter.Gt("age", 25) & filter.Lt("age", 28)).ToList();
docs.ForEach(d => Console.WriteLine(d));

 查询结果如下：

 技术图片

3 OR查询

查询年龄小于25或年龄大于28的记录

var client = new MongoClient("mongodb://root:root@192.168.100.3:27017/");
//获取database
 var mydb = client.GetDatabase("myDb");
//获取collection
var collection = mydb.GetCollection<BsonDocument>("userinfos");
//查询年龄小于25或年龄大于28的记录
var filter = Builders<BsonDocument>.Filter;
var docs = collection.Find(filter.Lt("age", 25) | filter.Gt("age", 28)).ToList();
docs.ForEach(d => Console.WriteLine(d));

查询结果如下：

 技术图片

4 字段存在(Exists)

查询包含address字段的所有记录

//连接数据库
var client = new MongoClient("mongodb://root:root@192.168.100.3:27017/");
//获取database
var mydb = client.GetDatabase("myDb");
//获取collection
var collection = mydb.GetCollection<BsonDocument>("userinfos");
//查询存在address字段的记录
var filter = Builders<BsonDocument>.Filter;
var docs = collection.Find(filter.Exists("address")).ToList();
docs.ForEach(d => Console.WriteLine(d));

查询结果如下：

 技术图片

5 排序(Sort)

查询年龄小于26岁的记录，并按年龄倒序排列

//连接数据库
var client = new MongoClient("mongodb://root:root@192.168.100.3:27017/");
//获取database
var mydb = client.GetDatabase("myDb");
//获取collection
var collection = mydb.GetCollection<BsonDocument>("userinfos");
//查询age<26的记录，按年龄倒序排列
var filter = Builders<BsonDocument>.Filter;
var sort = Builders<BsonDocument>.Sort;
var docs = collection.Find(filter.Lt("age", 26))//过滤
                     .Sort(sort.Descending("age")).ToList();//按age倒序
docs.ForEach(d => Console.WriteLine(d));

查询结果如下：

技术图片

6 查询指定字段(Projection)

MongoDB查询会默认返回_id字段，如果要不返回_id字段可以使用Exclude("_id")将其排除。

//连接数据库
var client = new MongoClient("mongodb://root:root@192.168.100.3:27017/");
//获取database
var mydb = client.GetDatabase("myDb");
//获取collection
var collection = mydb.GetCollection<BsonDocument>("userinfos");
//查询age<26的记录 包含name age 排除 _id
var project = Builders<BsonDocument>.Projection;
var filter = Builders<BsonDocument>.Filter;
var docs = collection.Find(filter.Lt("age", 26))//过滤
                     .Project(project.Include("name")//包含name
                                     .Include("age")//包含age
                                     .Exclude("_id")//不包含_id
                           ).ToList();
docs.ForEach(d => Console.WriteLine(d));

查询结果：

 技术图片

 3 修改(UpdateOne,UpdateMany)

1 修改单条记录(UpdateOne)

修改符合过滤条件的第一条记录，例子：将张三的年龄改成18岁

//连接数据库
var client = new MongoClient("mongodb://root:root@192.168.100.3:27017/");
//获取database
var mydb = client.GetDatabase("myDb");
//获取collection
var collection = mydb.GetCollection<BsonDocument>("userinfos");
var filter = Builders<BsonDocument>.Filter;
var update = Builders<BsonDocument>.Update;
var project = Builders<BsonDocument>.Projection;
//将张三的年龄改成18
collection.UpdateOne(filter.Eq("name", "张三"), update.Set("age", 18));
//查询张三的记录
var doc = collection.Find(filter.Eq("name", "张三"))
                    .Project(project.Include("age").Include("name"))
                    .FirstOrDefault();
Console.WriteLine(doc);

执行结果：

技术图片

2 修改多条记录(UpdateMany)

UpdateMany会修改所有符合过滤条件的记录，例子：将所有年龄小于25的记录标记为young（如果没有mark字段会自动添加）

//连接数据库
var client = new MongoClient("mongodb://root:root@192.168.100.3:27017/");
//获取database
var mydb = client.GetDatabase("myDb");
//获取collection
var collection = mydb.GetCollection<BsonDocument>("userinfos");
var filter = Builders<BsonDocument>.Filter;
var update = Builders<BsonDocument>.Update;
var project = Builders<BsonDocument>.Projection;
//将张三的年龄改成18
collection.UpdateOne(filter.Eq("name", "张三"), update.Set("age", 18));
//查询张三的记录
var doc = collection.Find(filter.Eq("name", "张三"))
                    .Project(project.Include("age").Include("name"))
                    .FirstOrDefault();
Console.WriteLine(doc);

查询结果如下，可以看到age<25的记录的mark字段值为young：

 技术图片

4 删除(DeleteOne和DeleteMany)

删除操作比较简单，DeleteOne用于删除符合过滤条件的第一条记录，DeleteMany用于删除所有符合过滤条件的记录。

1 删除单条记录(DeleteOne)

　删除名字为张三的记录

//连接数据库
var client = new MongoClient("mongodb://root:root@192.168.100.3:27017/");
//获取database
var mydb = client.GetDatabase("myDb");
//获取collection
var collection = mydb.GetCollection<BsonDocument>("userinfos");
var filter = Builders<BsonDocument>.Filter;
var project = Builders<BsonDocument>.Projection;
//删除名字为张三的记录
collection.DeleteOne(filter.Eq("name", "张三"));
var docs = collection.Find(filter.Empty)
                .Project(project.Include("age").Include("name").Include("mark"))
                .ToList();
docs.ForEach(d => Console.WriteLine(d));

执行结果如下，我们看到张三的记录已经被删除了：

技术图片

2  删除多条记录(DeleteMany)

删除所有年龄大于25岁的记录

//连接数据库
var client = new MongoClient("mongodb://root:root@192.168.100.3:27017/");
//获取database
var mydb = client.GetDatabase("myDb");
//获取collection
var collection = mydb.GetCollection<BsonDocument>("userinfos");
var filter = Builders<BsonDocument>.Filter;
var project = Builders<BsonDocument>.Projection;
//删除age>25的记录
DeleteResult result = collection.DeleteMany(filter.Gt("age", 25));
Console.WriteLine($"一共删除了{result.DeletedCount}条记录");
var docs = collection.Find(filter.Empty)
                .Project(project.Include("age").Include("name").Include("mark"))
                .ToList();
docs.ForEach(d => Console.WriteLine(d));

执行结果如下，所有年龄大于25岁的记录都被删除了：

技术图片

5 类型映射

1 简单例子

　有时候我们要让查询的结果映射到我们的实体类中去，实现这个需求也十分简单，mongoDB支持自动映射，直接使用泛型即可，看一个（清空数据db.userinfos.remove({})，从新初始化js脚本）：

 class Program
    {
        static void Main(string[] args)
        {
            //连接数据库
            var client = new MongoClient("mongodb://root:root@192.168.100.3:27017/");
            //获取database
            var mydb = client.GetDatabase("myDb");
            //获取collection
            var collection = mydb.GetCollection<Userinfo>("userinfos");
            var filter = Builders<Userinfo>.Filter;
            var sort = Builders<Userinfo>.Sort;
            List<Userinfo> userinfos = collection.Find(filter.Lt("age", 25))    //查询年龄小于25岁的记录
                                                 .Sort(sort.Descending("age"))  //按年龄进行倒序
                                         .ToList();
            //遍历结果
            userinfos.ForEach(u => Console.WriteLine($"姓名：{u.name},年龄：{u.age},英文名：{u.ename.firstname} {u.ename.lastname}"));
            Console.ReadKey();
        }

        /// <summary>
        /// 用户类
        /// </summary>
        public class Userinfo
        {
            public int _id { get; set; }//id
            public string name { get; set; }//姓名
            public int age { get; set; }//年龄
            public int level { get; set; }//等级
            public Ename ename { get; set; }//英文名
            public string[] roles { get; set; }//角色
            public string address { get; set; }//地址
        }

        /// <summary>
        /// 英文名
        /// </summary>
        public class Ename
        {
            public string firstname { get; set; }
            public string lastname { get; set; }
        }


执行结果如下：

 技术图片

2 常用属性　　

上边的例子仅仅用了基本的自动化映射，使用基本的自动化映射时：类和Bson中的字段必须严格一致(_id除外，可以自动映射到_id/id/Id)，且Bson中的每一个字段在实体类中都必须有一个对应的字段，不然就会抛出异常，这就造成我们可能要写一个非常庞大的实体类，而且类中的字段命名也要严格和Bson中的字段一致。这些限制对我们开发来说是不能接受的，这里我们采用mongoDriver中的一些属性改进一下上边的代码，如下：

 class Program
    {
        static void Main(string[] args)
        {
            //连接数据库
            var client = new MongoClient("mongodb://root:root@192.168.100.3:27017/");
            //获取database
            var mydb = client.GetDatabase("myDb");
            //获取collection
            var collection = mydb.GetCollection<Userinfo>("userinfos");

            var filter = Builders<Userinfo>.Filter;
            var sort = Builders<Userinfo>.Sort;
            List<Userinfo> userinfos = collection.Find(filter.Lt("age", 25))    //查询年龄小于25岁的记录
                                                 .Sort(sort.Descending("age"))  //按年龄进行倒序
                                         .ToList();
            //遍历结果
            userinfos.ForEach(u =>
            {
                Console.WriteLine($"编号：{u.userId},姓名：{u.name},年龄：{u.age},英文名：{u.ename?.ming} {u.ename?.xing},性别：{u.gender}");
                Console.WriteLine($"其他属性：{u.otherprops}");
                Console.WriteLine();
            });

            Console.ReadKey();
        }

        /// <summary>
        /// 用户类
        /// </summary
        //[BsonIgnoreExtraElements]
        public class Userinfo
        {
            [BsonId]
            public int userId { get; set; }//id
            public string name { get; set; }//姓名
            public int age { get; set; }//年龄
            public Ename ename { get; set; }//英文名
            [BsonDefaultValue(‘男‘)]
            public char gender { get; set; }
            [BsonIgnore]
            public string nickname { get; set; }//昵称
            [BsonExtraElements]
            public BsonDocument otherprops { get; set; }//其他属性
        }
        /// <summary>
        /// 英文名
        /// </summary>
        public class Ename
        {
            [BsonElement("firstname")]
            public string ming { get; set; }
            [BsonElement("lastname")]
            public string xing { get; set; }
        }

执行结果如下：

 技术图片

这里用到了几个常用的属性，作用如下：

　　BsonId修饰的字段对应BsonDocument中的_id；

　　BsonDefaultValue(value)用于指定默认值；

　　BsonIgnore表示不映射，即使BsonDocument中包含该字段也不会赋值给属性；

　　BsonExtraElements修饰的字段用于存储没有映射到类中的其他属性；

　　BsonElement可以指定修饰的属性映射到BsonDocument中的哪个字段，

还有一些其他的属性，具体可以参考官方文档。

3 MongoDB使用Linq查询　

　MongoDB的驱动支持Linq查询，用法十分简单，引用  usingMongoDB.Driver.Linq;  后，使用  collection.AsQueryable()  获取IMongoQueryable<T>实例，然后就可以使用Linq对这个IMongoQueryable<T>进行查询了。

　　使用过EF的小伙伴应该都了解IQueryable+Linq的查询默认不是将整个结果集立即加载到内存中，而是延迟加载的，即只有使用结果时（如 在执行First,Last,Single,Count,ToList等）才会将Linq转换成Sql，在数据库中执行查询操作。类似的，在使用IMongoQueryable<T>+Linq进行查询时默认也是延迟加载的，在需要使用查询结果时，驱动会将Linq转换成聚合管道命令(aggregation pipeline)，如Linq中的Where被转换成$watch，Join转换为$lookup，Skip和Take转换为$skip和$limit等等，然后在Mongodb中执行这些管道命令获取结果，看一个栗子我们就会轻松地掌握了。

首先添加一些测试数据：

//添加学生数据
db.students.insertMany([
    {"no":1, "stuName":"jack", "age":23, "classNo":1},
    {"no":2, "stuName":"tom", "age":20, "classNo":2},
    {"no":3, "stuName":"hanmeimei", "age":22, "classNo":1},
    {"no":4, "stuName":"lilei", "age":24, "classNo":2}
    ])
        
//添加班级数据
db.classes.insertMany([
    {"no" : 1,"clsName" : "A班"},
    {"no" : 2,"clsName" : "B班"}
    ])

这里查找了两组数据：①基本查询：查找年龄大于22岁的学生；②连接查询：查询各个学生的学号、姓名、班级名。例子比较简单，直接看代码吧

namespace ConsoleAppCore
{
    using System;
    using MongoDB.Bson;
    using MongoDB.Bson.Serialization.Attributes;
    using MongoDB.Driver;
    using MongoDB.Driver.Linq;
    using System.Collections.Generic;
    class Program
    {
        static void Main(string[] args)
        {
            //连接数据库
            var client = new MongoClient("mongodb://root:root@192.168.100.3:27017/");
            //获取database
            var mydb = client.GetDatabase("myDb");
            //获取collection
            var stuCollection = mydb.GetCollection<Student>("students");
            var clsCollection = mydb.GetCollection<Classx>("classes");
            //查找年龄大于22的学生
            Console.WriteLine("-------------查找年龄大于22的学生列表--------------");
            //1.query语法
            List<Student> stuList1 = (from stu in stuCollection.AsQueryable()
                                      where stu.age > 22
                                      select stu).ToList();
            //2.点语法
            List<Student> stuList2 = stuCollection.AsQueryable().Where(s => s.age > 22).ToList();
            stuList1.ForEach(stu => Console.WriteLine($"姓名:{stu?.stuName},  年龄:{stu?.age}"));
            Console.WriteLine();

            //表连接查询，查询各个学生的班级名
            Console.WriteLine("-------------表连接，查询学生的班级名----------------");
            //1.query语法
            var result1 = from stu in stuCollection.AsQueryable()
                          join cls in clsCollection.AsQueryable()
                            on stu.classNo equals cls.no
                          select new { stuno = stu.no, stu.stuName, cls.clsName };
            //2.点语法
            var result2 = stuCollection.AsQueryable().Join(
                            clsCollection.AsQueryable(),
                            stu => stu.classNo,
                            cls => cls.no,
                            (stu, cls) => new { stuno = stu.no, stu.stuName, cls.clsName }
                         );
            //遍历结果
            foreach (var item in result1)
            {
                Console.WriteLine($"学号:{item.stuno}, 姓名:{item.stuName}, 班级:{item.clsName}");
            }

            Console.ReadKey();
        }
        /// <summary>
        /// 学生类
        /// </summary
        public class Student
        {
            public int no { get; set; }//学号
            public string stuName { get; set; }//姓名
            public int age { get; set; }//年龄
            public int classNo { get; set; }//班级编号
            [BsonExtraElements]
            public BsonDocument others { get; set; }
        }
        /// <summary>
        /// 班级类
        /// </summary>
        public class Classx
        {
            public int no { get; set; }//班级编号
            public string clsName { get; set; }//班级名
            [BsonExtraElements]
            public BsonDocument others { get; set; }
        }
    }
}

执行结果如下：

技术图片

.net Core MongoDB用法演示

标签：查询   简单例子   clu   nosql   ESS   mamicode   命名   nbsp   project   

原文地址：https://www.cnblogs.com/majiang/p/11225160.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！