快速掌握mongoDB(四)—— C#驱动MongoDB用法演示-低调大师

快速掌握mongoDB(四)—— C#驱动MongoDB用法演示

2019-07-19 540

快速掌握mongoDB(四)—— C#驱动MongoDB用法演示
阅读目录

0.准备测试数据

1 添加(InsertOne,InsertMany)

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

1.简单查询(Find、Filter)
2.AND查询
3 OR查询
4 字段存在(Exists)
4 排序(Sort)
5 查询指定字段(Projection)
3 修改(UpdateOne,UpdateMany)

1 修改单条记录(UpdateOne)
2 修改多条记录(UpdateMany)
4 删除(DeleteOne和DeleteMany)

1 删除单条记录(DeleteOne)
2 删除多条记录(DeleteMany)
5 类型映射

1 简单栗子
2 常用属性
3 MongoDB使用Linq查询

　　前边我们已经使用mongo shell进行增删查改和聚合操作，这一篇简单介绍如何使用C#驱动MongoDB。C#驱动MongoDB的本质是将C#的操作代码转换为mongo shell，驱动的API也比较简单明了，方法名和js shell的方法名基本都保持一致，熟悉mongo shell后学习MongoDB的C#驱动是十分轻松的，直接看几个栗子吧。

回到顶部
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)
　　首先创建一个Console应用程序，使用命令 Install-Package MongoDB.Driver 添加C#的驱动包，然后就可以使用C#操作MongoDB数据库了，看一个添加的栗子：

复制代码
class Program

{
    static void Main(string[] args)
    {
        //连接数据库
        var client = new MongoClient("mongodb://192.168.70.131: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);
    }
}

复制代码
　　执行完成后，查看在RoboMongo中查询，看到已经添加成功了：

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

回到顶部
2 查询(Find,Filter,Sort,Projection)
1.简单查询(Find、Filter)
　　栗子：查找name=“吴九"的记录

//Fileter用于过滤，如查询name = 吴九的第一条记录
var filter = Builders.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的记录

//查询25　　var filter = Builders.Filter;
　　var docs = collection.Find(filter.Gt("age", 25) & filter.Lt("age", 28)).ToList();
　　docs.ForEach(d => Console.WriteLine(d));
　　查询结果如下：

3 OR查询
　　栗子：查询年龄小于25或年龄大于28的记录

//查询age<25或age>28的记录
　　var filter = Builders.Filter;
　　var docs = collection.Find(filter.Lt("age", 25) | filter.Gt("age", 28)).ToList();
　　docs.ForEach(d => Console.WriteLine(d));
　　查询结果如下：

4 字段存在(Exists)
　　栗子：查询包含address字段的所有记录

//查询存在address字段的记录
　　var filter = Builders.Filter;
　　var docs = collection.Find(filter.Exists("address")).ToList();
　　docs.ForEach(d => Console.WriteLine(d));
　　查询结果如下：

4 排序(Sort)
　　栗子：查询年龄小于26岁的记录，并按年龄倒序排列

//查询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));

　　查询结果如下：

5 查询指定字段(Projection)
　　MongoDB查询会默认返回_id字段，如果要不返回_id字段可以使用Exclude("_id")将其排除。栗子：查询年龄小于26岁记录的name和age

复制代码
//查询age<26的记录

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 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 filter = Builders<BsonDocument>.Filter;
        var update = Builders<BsonDocument>.Update;
        var project = Builders<BsonDocument>.Projection;
        //将所有年龄小于25的记录标记为young（如果没有mark字段会自动添加）
        UpdateResult reulst=collection.UpdateMany(filter.Lt("age",25), update.Set("mark", "young"));
        if (reulst.IsModifiedCountAvailable)
        {
            Console.WriteLine($"符合条件的有{reulst.MatchedCount}条记录");
            Console.WriteLine($"一共修改了{reulst.ModifiedCount}条记录");
           //查询修改后的记录
            var docs = collection.Find(filter.Empty)
                            .Project(project.Include("age").Include("name").Include("mark"))
                            .ToList();
            docs.ForEach(d => Console.WriteLine(d));
        }
        else
        {
            Console.WriteLine("无修改操作！");
        }

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

回到顶部
4 删除(DeleteOne和DeleteMany)
　　删除操作比较简单，DeleteOne用于删除符合过滤条件的第一条记录，DeleteMany用于删除所有符合过滤条件的记录。

1 删除单条记录(DeleteOne)
　　栗子：删除名字为张三的记录

复制代码

        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 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支持自动映射，直接使用泛型即可，看一个栗子：

复制代码

class Program
{
    static void Main(string[] args)
    {
        //连接数据库
        var client = new MongoClient("mongodb://192.168.70.133: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://192.168.70.133: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实例，然后就可以使用Linq对这个IMongoQueryable进行查询了。

　　使用过EF的小伙伴应该都了解IQueryable+Linq的查询默认不是将整个结果集立即加载到内存中，而是延迟加载的，即只有使用结果时（如在执行First,Last,Single,Count,ToList等）才会将Linq转换成Sql，在数据库中执行查询操作。类似的，在使用IMongoQueryable+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.classxes.insertMany([

{"no" : 1,"clsName" : "A班"},
{"no" : 2,"clsName" : "B班"}
])

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

复制代码

    static void Main(string[] args)
    {
        //连接数据库
        var client = new MongoClient("mongodb://192.168.70.133: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; }
}

复制代码
　执行结果如下：

小结

　　本篇简单介绍了C#驱动mongoDB进行CRUD操作，C#驱动功能十分丰富，几乎实现了所有的Mongo shell功能，这里就不再过多介绍了，有兴趣的小伙伴可以看看官方的文档。如果文中有错误的话，希望大家可以指出，我会及时修改，谢谢。

作者：捞月亮的猴子
　　　　
出处：https://www.cnblogs.com/wyy1234/

微信关注我们

原文链接：https://yq.aliyun.com/articles/710023

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

seleniumGrid分布式远程执行测试脚本

seleniumGrid分布式远程执行测试脚本执行UI自动化测试脚本时，不仅可以在本地执行，也可以远程指定某计算机执行测试脚本，seleniumGrid为我们提供了这类服务，但还需要自己搭建环境。一、本地计算机需要准备java环境和selenium-server-standalone-4.0.0-alpha-2.jar包，jar包主要开启本机的hub节点（理解成控制机）。红色部分是开启本机（控制机）节点，蓝色部分是开启远程node节点时需要连接控制机地址控制机地址复制代码λ java -jar selenium-server-standalone-4.0.0-alpha-2.jar -role hub11:05:38.938 INFO [GridLauncherV3.parse] - Selenium server version: 4.0.0-alpha-2, revision: f148142cf811:05:39.233 INFO [GridLauncherV3.lambda$buildLaunchers$5] - Launching Selenium Grid hub o...

2019-07-20

620

PYTHON趣用—配平化学方程式不知不觉已经毕业多年了，不知道大家是否还记得怎么配平化学方程式呢？反正小编我是已经记不太清了，所以今天的文章除了分享如何用python配平化学方程式，顺带着还会复习一些化学方程式的知识，希望广大化学爱好者喜欢。 1.化学方程式复习篇 1)定义化学方程式是指用化学式表示化学反应的式子，它不仅表明了反应物、生成物和反应条件；同时，化学计量数代表了各反应物、生成物物质的量关系，通过相对分子质量或相对原子质量还可以表示各物质之间的质量关系，对于气体反应物、生成物，还可以直接通过化学计量数得出体积比。 2)配平方法 a.最小公倍数法操作步骤： A.找出原子个数较多，且在反应式两边各出现一次的原子，求它的最小公倍数； B.推出各分子的系数；例如： 4P+5O2=2P2O5 第一步：P+O2—P2O5 第二步：P+5O2—2P2O5 第三步：4P+5O2—2P2O5 b.观察法从化学式生成物中较复杂的一种推算出有关各反应物化学式的化学计量数和该生成物的化学计量数；根据求得的化学式的化学计量数，再找出其他化学式的化学计量数，直至配平。例如: 4H2O(g)...

2019-07-20

638

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。