在.NET Core中使用MongoDB明细教程(2)：使用Filter语句检索文档-低调大师

在.NET Core中使用MongoDB明细教程(2)：使用Filter语句检索文档

2020-08-18 727

在上篇文章在.NET Core中使用MongoDB明细教程(1):驱动基础及文档插入我们介绍了一些驱动程序相关的基础知识，以及如何将文档插入到集合中。在这篇文章中，我们将学习如何从数据库中检索文档。

作者：依乐祝

译文地址：https://www.cnblogs.com/yilezhu/p/13520021.html

英文地址：https://www.codementor.io/@pmbanugo/working-with-mongodb-in-net-2-retrieving-mrlbeanm5

任何文档都属于集合，因此所有CRUD操作都是在单个集合范围中完成的。若要从集合中检索文档，可以使用Find, FindSync，和FindAsync等方法。

FindSync&FindAsync

FindSync和FindAsync两者都有两个带有三个参数的重载。FindSync和FindAsync很相似，只是FindSync是同步的，并阻塞直到它的调用完成。FindSync返回IAsyncCursor ，而FindAsync返回一个IAsyncCursor的任务.

什么是IAsyncCursor

MongoDB以批形式返回查询结果，批处理大小不会超过BSON文档的最大大小。从版本3.2开始，BSON文档的最大大小为16 MB。最大文档大小有助于确保单个文档在传输过程中不能使用过多的RAM或过多的带宽。此约束在将文档添加到集合时也适用，但是为了存储更大的文档，MongoDB已经将GridFS API作为一项规定。对于大多数查询，第一批将返回101个文档或刚好超过1MB的文档，随后的批处理将为4MB。我们可以在驱动程序中通过设置FindOptions 的BatchSize 属性来覆盖默认的批大小，该属性作为第二个参数传递给任何find方法。所以基本上，游标是指向查询结果集的指针。

默认情况下，服务器将在不活动10分钟后或客户端耗尽游标后自动关闭游标。若要重写此行为，可以指定在查询中使用FindOptions类的NoCursorTimeout属性值设置为false。但是，如果你这样做您应该手动关闭游标或耗尽游标。

驱动程序中的这个IAsyncCursor表示异步游标。要访问文档，我们需要手动迭代游标。

检索文件

让我们构建我们的第一个Read查询，这个查询返回我们数据库中books中的所有数据。更新MainAsync方法如下：

static async Task Main(string[] args)
        {
            await TestFindAsync();
            Console.ReadLine();
        }

        static async Task TestFindAsync()
        {
            var connectionString = "mongodb://localhost:27017";
            var client = new MongoClient(connectionString);
            var database = client.GetDatabase("bookstore");
            var collection = database.GetCollection<BsonDocument>("books");
            using IAsyncCursor<BsonDocument> cursor = await collection.FindAsync(new BsonDocument());
            while (await cursor.MoveNextAsync())
            {
                IEnumerable<BsonDocument> batch = cursor.Current;
                foreach (BsonDocument document in batch)
                {
                    Console.WriteLine(document);
                    Console.WriteLine();
                }
            }
        }

任何find方法的第一个重载都有3个参数:FilterDefinition （用于定义查询的筛选器）、一个可选的FindOptions（用于指定查询的选项（例如游标超时、批处理大小等）和一个可选的cancellationToken。

在上面的代码中，我们通过向方法传递一个空的BsonDocument来指定一个空的过滤器定义。另一种编写方法是使用FilterDefinition<BsonDocument>.Empty来表示一个空的过滤器。有了空过滤器，我们基本上是告诉它返回给我们集合中的所有文档。然后，我们迭代游标以成批获取文档（while循环中的MoveNextAsync），并调用cursor.Current获取当前批中的文档，然后将其打印出来。

运行上面的代码应该可以为我们提供该集合中已有的所有文档

{ "_id" : ObjectId("5f33630f9e7b20e7e29208f3"), "bookname" : ".net core3.1 with mongodb", "description" : "这是一本关于 在.net core3.1中使用mongodb进行开发的教程", "tags" : [".net core", "mongodb"], "remark" : "C#是世界上最好的语言", "publishyear" : 2020 }

{ "_id" : ObjectId("5f3367482d2d59d358e1219b"), "bookname" : ".net core3.1 with mongodb1", "description" : "这是一本关于在.net core3.1中使用mongodb进行开发的教程1", "tags" : [".net core", "mongodb"], "remark" : "C#是世界上最好的语言", "publishyear" : 2020 }

{ "_id" : ObjectId("5f3367482d2d59d358e1219c"), "bookname" : ".net core3.1 with mongodb2", "description" : "这是一本关于在.net core3.1中使用mongodb进行开发的教程2", "tags" : [".net core", "mongodb"], "remark" : "C#是世界上最好的语言", "publishyear" : 2020 }

{ "_id" : ObjectId("5f3367482d2d59d358e1219d"), "bookname" : ".net core3.1 with mongodb2", "description" : "这是一本关于在.net core3.1中使用mongodb进行开发的教程2", "tags" : [".net core", "mongodb"], "remark" : "C#是世界上最好的语言", "publishyear" : 2020 }

{ "_id" : ObjectId("5f33850d467bf3877966f1ea"), "BookName" : ".net core3.1 with mongodb21", "Description" : "这是一本关 于在.net core3.1中使用mongodb进行开发的教程21", "Tags" : [".net core", "mongodb"], "Remark" : "C#是世界上最好的语言", "PublishYear" : 2020 }

{ "_id" : ObjectId("5f33850d467bf3877966f1eb"), "BookName" : ".net core3.1 with mongodb22", "Description" : "这是一本关 于在.net core3.1中使用mongodb进行开发的教程22", "Tags" : [".net core", "mongodb"], "Remark" : "C#是世界上最好的语言", "PublishYear" : 2020 }

{ "_id" : ObjectId("5f33850d467bf3877966f1ec"), "BookName" : ".net core3.1 with mongodb23", "Description" : "这是一本关 于在.net core3.1中使用mongodb进行开发的教程23", "Tags" : [".net core", "mongodb"], "Remark" : "C#是世界上最好的语言", "PublishYear" : 2020 }

我们可以看到返回的数据跟我们在上一篇文章中添加的文档基本一样，除了多了一个_id属性，所有集合在这个字段上都有一个唯一的主索引，如果您在创建文档时没有提供主索引，那么MongoDB会默认提供一个主索引。它的类型是ObjectId，这是在Bson规范中定义。

为了演示FindOptions，我将添加一个将批大小限制为2的选项，该选项将显示我们在控制台中循环的批。使用以下内容更新代码

static async Task Main(string[] args)
        {
            await TestFindAsync();
            Console.ReadLine();
        }

        static async Task TestFindAsync()
        {
            var connectionString = "mongodb://localhost:27017";
            var client = new MongoClient(connectionString);
            var database = client.GetDatabase("bookstore");
            var collection = database.GetCollection<BsonDocument>("books");
            FilterDefinition<BsonDocument> filter = FilterDefinition<BsonDocument>.Empty;
            FindOptions<BsonDocument> options = new FindOptions<BsonDocument> {
                BatchSize = 2,
                NoCursorTimeout = false
            };
            using IAsyncCursor<BsonDocument> cursor = await collection.FindAsync(filter,options);
            var batch = 0;
            while (await cursor.MoveNextAsync())
            {
                batch++;
                Console.WriteLine($"Batch: {batch}");
                IEnumerable<BsonDocument> documents = cursor.Current;
                foreach (BsonDocument document in documents)
                {
                    Console.WriteLine(document);
                    Console.WriteLine();
                }
            }
            Console.WriteLine($"Total Batch: { batch}");
        }

并运行它以获得以下结果：

Batch: 1
{ "_id" : ObjectId("5f33630f9e7b20e7e29208f3"), "bookname" : ".net core3.1 with mongodb", "description" : "这是一本关于 在.net core3.1中使用mongodb进行开发的教程", "tags" : [".net core", "mongodb"], "remark" : "C#是世界上最好的语言", "publishyear" : 2020 }

{ "_id" : ObjectId("5f3367482d2d59d358e1219b"), "bookname" : ".net core3.1 with mongodb1", "description" : "这是一本关于在.net core3.1中使用mongodb进行开发的教程1", "tags" : [".net core", "mongodb"], "remark" : "C#是世界上最好的语言", "publishyear" : 2020 }

Batch: 2
{ "_id" : ObjectId("5f3367482d2d59d358e1219c"), "bookname" : ".net core3.1 with mongodb2", "description" : "这是一本关于在.net core3.1中使用mongodb进行开发的教程2", "tags" : [".net core", "mongodb"], "remark" : "C#是世界上最好的语言", "publishyear" : 2020 }

{ "_id" : ObjectId("5f3367482d2d59d358e1219d"), "bookname" : ".net core3.1 with mongodb2", "description" : "这是一本关于在.net core3.1中使用mongodb进行开发的教程2", "tags" : [".net core", "mongodb"], "remark" : "C#是世界上最好的语言", "publishyear" : 2020 }

Batch: 3
{ "_id" : ObjectId("5f33850d467bf3877966f1ea"), "BookName" : ".net core3.1 with mongodb21", "Description" : "这是一本关 于在.net core3.1中使用mongodb进行开发的教程21", "Tags" : [".net core", "mongodb"], "Remark" : "C#是世界上最好的语言", "PublishYear" : 2020 }

{ "_id" : ObjectId("5f33850d467bf3877966f1eb"), "BookName" : ".net core3.1 with mongodb22", "Description" : "这是一本关 于在.net core3.1中使用mongodb进行开发的教程22", "Tags" : [".net core", "mongodb"], "Remark" : "C#是世界上最好的语言", "PublishYear" : 2020 }

Batch: 4
{ "_id" : ObjectId("5f33850d467bf3877966f1ec"), "BookName" : ".net core3.1 with mongodb23", "Description" : "这是一本关 于在.net core3.1中使用mongodb进行开发的教程23", "Tags" : [".net core", "mongodb"], "Remark" : "C#是世界上最好的语言", "PublishYear" : 2020 }

Total Batch: 4

我们还可以通过调用ToListAsync或ForEachAsync从光标中获取所有文档并将它们放入内存中，从而以更简洁的方式编写此代码。在IAsyncCursor上有扩展方法可以这么做。下面是一些代码：

collection.FindSync(filter).ToList();

await collection.FindSync(filter).ToListAsync();

await collection.FindSync(filter).ForEachAsync(doc => Console.WriteLine());

collection.FindSync(filter).FirstOrDefault();

collection.FindSync(filter).FirstOrDefault();

await collection.FindSync(filter).FirstOrDefaultAsync();

从代码角度看，这看起来既简洁又简短，但它所做的是强制所有文档都保存在内存中。在某些情况下，这可能不太理想，当查询结果很大时，游标很有用，我们可以通过调用MoveNextAsync或MoveNext来移动光标。

Find

此方法与其对应方法相似，但它返回IFindFluent接口。这是一个流畅的接口，它为我们提供了一些简单的语法：Count,Skip ,Sort，和Limit(关于这些，下篇文章中会有更多的介绍)。从IFindFluent中我们也可以返回一个游标(通过调用ToCursor或ToCursorAsync或一个列表(通过调用ToList或ToListAsync)。通过下面的代码，我们可以使用Find方法获取所有文档并将它们打印到控制台

await collection.Find(FilterDefinition<BsonDocument>.Empty)
        .ForEachAsync(doc => Console.WriteLine(doc));

结果

{ "_id" : ObjectId("5f33630f9e7b20e7e29208f3"), "bookname" : ".net core3.1 with mongodb", "description" : "这是一本关于 在.net core3.1中使用mongodb进行开发的教程", "tags" : [".net core", "mongodb"], "remark" : "C#是世界上最好的语言", "publishyear" : 2020 }
{ "_id" : ObjectId("5f3367482d2d59d358e1219b"), "bookname" : ".net core3.1 with mongodb1", "description" : "这是一本关于在.net core3.1中使用mongodb进行开发的教程1", "tags" : [".net core", "mongodb"], "remark" : "C#是世界上最好的语言", "publishyear" : 2020 }
{ "_id" : ObjectId("5f3367482d2d59d358e1219c"), "bookname" : ".net core3.1 with mongodb2", "description" : "这是一本关于在.net core3.1中使用mongodb进行开发的教程2", "tags" : [".net core", "mongodb"], "remark" : "C#是世界上最好的语言", "publishyear" : 2020 }
{ "_id" : ObjectId("5f3367482d2d59d358e1219d"), "bookname" : ".net core3.1 with mongodb2", "description" : "这是一本关于在.net core3.1中使用mongodb进行开发的教程2", "tags" : [".net core", "mongodb"], "remark" : "C#是世界上最好的语言", "publishyear" : 2020 }
{ "_id" : ObjectId("5f33850d467bf3877966f1ea"), "BookName" : ".net core3.1 with mongodb21", "Description" : "这是一本关 于在.net core3.1中使用mongodb进行开发的教程21", "Tags" : [".net core", "mongodb"], "Remark" : "C#是世界上最好的语言", "PublishYear" : 2020 }
{ "_id" : ObjectId("5f33850d467bf3877966f1eb"), "BookName" : ".net core3.1 with mongodb22", "Description" : "这是一本关 于在.net core3.1中使用mongodb进行开发的教程22", "Tags" : [".net core", "mongodb"], "Remark" : "C#是世界上最好的语言", "PublishYear" : 2020 }
{ "_id" : ObjectId("5f33850d467bf3877966f1ec"), "BookName" : ".net core3.1 with mongodb23", "Description" : "这是一本关 于在.net core3.1中使用mongodb进行开发的教程23", "Tags" : [".net core", "mongodb"], "Remark" : "C#是世界上最好的语言", "PublishYear" : 2020 }

查找特定的文件

大多数情况下，我们不想检索所有文档，而是指定一个筛选器，它返回与特定筛选器匹配的文档。现在让我们看看为查询指定筛选器的方法。

使用`BsonDocument`或`String`

我们可以将BsonDocument定义为一个过滤器，查询将找到与文档中定义的字段相匹配的文档。将以下代码添加到您的方法中，并运行它以检索description为“这是一本关于在.net core3.1中使用mongodb进行开发的教程1”的书籍

var filter = new BsonDocument("description", "这是一本关于在.net core3.1中使用mongodb进行开发的教程1");
            await collection.Find(filter).ForEachAsync(doc => Console.WriteLine(doc));

这样只返回符合条件的一个文档

var filter = new BsonDocument("description", "这是一本关于在.net core3.1中使用mongodb进行开发的教程1");
            await collection.Find(filter).ForEachAsync(doc => Console.WriteLine(doc));

您可能会有些困惑，因为这些方法接受FilterDefinition，但是我们给了它一个BsonDocument，它没有出异常。之所以会发生这种情况，是因为它被隐式转换，而且我们也可以通过字符串进行转换。要使用字符串，我们需要定义一个有效的JSON字符串来指定过滤器。我们可以使用下面的代码对字符串执行上述相同的操作，仍然会得到相同的结果：

var filter= "{description:'这是一本关于在.net core3.1中使用mongodb进行开发的教程1'}";
            await collection.Find(filter).ForEachAsync(doc => Console.WriteLine(doc));

我们也可以指定比较或逻辑运算符。例如，查找2020年出版的书。我们可以如下所示构建查询：

var filter = new BsonDocument("publishyear", new BsonDocument("$eq", 2020));

或者使用字符串

var filter = "{ Age: {'$eq': 23}}";

我们所做的是为操作符添加一个标识符，在我们的例子中是$eq。

使用FilterDefinitionBuilder

您可以使用FilterDefinitionBuilder，它是FilterDefinition的构建器。它提供了一套方法来构建查询，而Lt作为其中之一，指定了小于比较。因此，我们可以使用FilterDefinitionBuilder定义过滤器，如下所示：

var filter = new FilterDefinitionBuilder<BsonDocument>().Lt("publishyear", 2020);

或者使用接受LINQ表达式的重载方法：

var filter = new FilterDefinitionBuilder<Book>().Lt( book => book.PublishYear, 2020);

此外，您还可以使用静态Builders类来构建过滤器定义，该类还具有用于构建其他内容的静态帮助方法，如投影定义、排序定义和其他一些方法。

var filter = Builders<BsonDocument>.Filter.Lt("publishyear", 2020);
var filter = Builders<Book>.Filter.Lt(book => book.PublishYear, 2020);

驱动程序还为过滤器定义重载了3个操作符。这个and (&), or (|)和not (!)操作。例如，我们希望得到出版年份是2020年且描述信息为这是一本关于在.net core3.1中使用mongodb进行开发的教程1的书籍信息，我们可以使用构建器帮助方法和&重载操作符如下

var builder = Builders<BsonDocument>.Filter;
var filter = builder.Eq("publishyear", 2020) & builder.Eq("description", "`这是一本关于在.net core3.1中使用mongodb进行开发的教程1");

Linq表达式

最后一部分我们没有讨论的是这些方法的重载，这些方法采用LINQ表达式，当我们有一个强类型对象时，我们可以使用LINQ表达式构建一个过滤器查询。假设我们想让出版年份为2020，描述信息为这是一本关于在.net core3.1中使用mongodb进行开发的教程1的书籍信息打印出他们。我们使用以下代码：

  var collection = database.GetCollection<Book>("books");
            await collection.Find(book => book.PublishYear == 2020 && book.Description == "这是一本关于在.net core3.1中使用mongodb进行开发的教程1").ForEachAsync(doc => Console.WriteLine(doc));

我们将集合类型更改为Book并运行以下代码，我们将在控制台上得到一个错误：

1597668394922.png

错误描述显示_id不匹配任何类型的字段或属性。这是因为Book对象无法映射_id字段从数据库到“学生”类型的任何属性。这是在我们创建文档时自动添加的。让我们通过在Book类中添加Bson类型的ID属性。

internal class Book
    {
        public ObjectId Id { get; set; }
        public string BookName { get; set; }
        public string Description { get; set; }
        public IEnumerable<string> Tags { get; set; }
        public string Remark { get; set; }
        public int PublishYear { get; set; }
    }

并运行发现正常了。当然你也可以通过设置IgnoreExtraElement为true来规避这个问题

它只是起作用了。所以很多时候，你会想用表达式树语法来构建您的查询。在需要更多粒度的情况下，可以使用其他方法。

在下一个教程中，我们将看到如何进行 projections, sort, skip, limit and sort. 。

往期精彩回顾

【推荐】.NET Core开发实战视频课程 ★★★

.NET Core实战项目之CMS 第一章入门篇-开篇及总体规划

【.NET Core微服务实战-统一身份认证】开篇及目录索引

Redis基本使用及百亿数据量中的使用技巧分享（附视频地址及观看指南）

.NET Core中的一个接口多种实现的依赖注入与动态选择看这篇就够了

10个小技巧助您写出高性能的ASP.NET Core代码

用abp vNext快速开发Quartz.NET定时任务管理界面

在ASP.NET Core中创建基于Quartz.NET托管服务轻松实现作业调度

现身说法：实际业务出发分析百亿数据量下的多表查询优化

关于C#异步编程你应该了解的几点建议

C#异步编程看这篇就够了

本文分享自微信公众号 - DotNetCore实战（czarcore）。
如有侵权，请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”，欢迎正在阅读的你也加入，一起分享。

微信关注我们

原文链接：https://my.oschina.net/jkingzhu/blog/4503716

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

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

Python中得可视化：使用Seaborn绘制常用图表

Seaborn是Python中的一个库，主要用于生成统计图形。 Seaborn是构建在matplotlib之上的数据可视化库，与Python中的pandas数据结构紧密集成。可视化是Seaborn的核心部分，可以帮助探索和理解数据。要了解Seaborn，就必须熟悉Numpy和Matplotlib以及pandas。 Seaborn提供以下功能: 面向数据集的API来确定变量之间的关系。线性回归曲线的自动计算和绘制。它支持对多图像的高级抽象绘制。可视化单变量和双变量分布。这些只是Seaborn提供的功能的一部分，还有很多其他功能，我们可以在这里探索所有的功能。要引入Seaborn库，使用的命令是: import seaborn as sns 使用Seaborn，我们可以绘制各种各样的图形，如: 分布曲线饼图和柱状图散点图配对图热力图在文章中，我们使用从Kaggle下载的谷歌Playstore数据集。 1.分布曲线我们可以将Seaborn的分布图与Matplotlib的直方图进行比较。它们都提供非常相似的功能。这里我们画的不是直方图中的频率图，而是y轴上的近似概率密度...

2020-08-18

682

前言 🕸️雷达图（Radar Chart）也称为网络图、星图或蜘蛛网图。是以从同一点开始的轴上表示的三个或更多个定量变量的二维图表的形式显示多元数据的图形方法。适用于显示三个或更多的维度的变量。网上偷的图(侵删) 🕸️雷达图常用于📚数据统计或对比，对于查看哪些变量具有相似的值、变量之间是否有异常值都很有用。 🎮同时在不少游戏中都有雷达图的身影，可以很直观地展示并对比一些数据。例如王者荣耀中的对战资料中就用到了：网上偷的图(侵删) 🔎那么在本篇文章中，皮皮就来分享下在 Cocos Creator 中如何利用 Graphics 组件来绘制炫酷的雷达图~ 文中会对原始代码进行一定的削减以保证阅读体验。需要完整代码文件的小伙伴可在文章底部“阅读原文”处获取。预览 😲先来看看效果吧~ 在线预览：https://ifaswind.gitee.io/eazax-cases/?case=radarChart 😃「两条数据」 😮「缓动数据」 😵「花里胡哨」 😱「艺术就是爆炸」 😈「逐渐偏离主题」 🙌 没有人 👐 比我 👌 更懂 ☝️ 花里胡哨（👱川老师直呼...

2020-08-18

669

资源下载

更多资源

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

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

WebStorm

WebStorm 是jetbrains公司旗下一款JavaScript 开发工具。目前已经被广大中国JS开发者誉为“Web前端开发神器”、“最强大的HTML5编辑器”、“最智能的JavaScript IDE”等。与IntelliJ IDEA同源，继承了IntelliJ IDEA强大的JS部分的功能。