【译】MongoDB EF Core 提供程序：有什么新功能？

摘要：这是 Rishit Bhatia 和 Luce Carter 的客座文章。Rishit 是 MongoDB 的高级产品经理，专注于 .NET 开发人员体验，在进入产品管理部门之前，他已经使用 C# 工作多年。Luce 是 MongoDB 的开发倡导者、Micr

回复“1 ”获取开发者路线图

学习分享丨作者 / 郑子铭

原文 | Rishit, Luce

翻译 | 郑子铭

这是 Rishit Bhatia 和 Luce Carter 的客座文章。Rishit 是 MongoDB 的高级产品经理，专注于 .NET 开发人员体验，在进入产品管理部门之前，他已经使用 C# 工作多年。Luce 是 MongoDB 的开发倡导者、Microsoft MVP，热爱代码、阳光和学习。本博客由 Microsoft .NET 团队针对 EF Core 进行了审阅。

MongoDB 的 EF Core 提供程序于 2024 年 5 月正式发布。自六个月前首次发布此软件包的预览版以来，我们已经取得了长足的进步。我们想分享一些我们一直在研究的有趣功能，如果没有 Microsoft .NET 数据和实体框架团队的支持和合作，这些功能是不可能实现的。

在这篇文章中，我们将使用 MongoDB EF Core 提供程序和 MongoDB Atlas 来展示以下内容：

向实体添加属性并进行更改跟踪

利用出口创建索引

执行复杂查询

事务和乐观并发

与本博客相关的代码可以在 Github 上找到。入门样板代码位于“start”分支中。包含下面提到的所有功能亮点的完整代码位于“main”分支中。

我们将使用示例数据集 — 具体来说，本示例中 MongoDB Atlas 可用的 sample_mflix 数据库中的电影集合。要使用示例数据设置 Atlas 集群，您可以按照文档中的步骤操作。我们将创建一个简单的 .NET 控制台应用程序来开始使用 MongoDB EF Core 提供程序。有关如何执行此操作的更多详细信息，您可以查看快速入门指南。

此时，您应该已连接到 Atlas 并能够从快速入门指南中正在读取的电影中输出电影情节。

MongoDB 文档模型的优点之一是它支持灵活的架构。再加上 EF Core 支持 Code First 方法的能力，您可以动态向实体添加属性。为了展示这一点，我们将向我们的模型类添加一个名为adapted_from_book的新可空布尔属性。这将使我们的模型类如下所示：public classMovie
{
public ObjectId Id { get; set; }

[BsonElement("title")]
publicstring Title { get; set; }

[BsonElement("rated")]
publicstring Rated { get; set; }

[BsonElement("plot")]
publicstring Plot { get; set; }

[BsonElement("adaptedFromBook")]
publicbool? AdaptedFromBook { get; set; }
}

现在，我们将为找到的电影实体设置这个新添加的属性，并在保存更改后查看 EF Core 的更改跟踪功能。为此，我们将在打印电影情节后添加以下代码行：

movie.AdaptedFromBook = false;
await db.SaveChangesAsync;
在运行程序之前，让我们转到 Atlas 中的集合并找到这部电影，以确保这个新创建的字段不存在于我们的数据库中。为此，只需转到 Atlas Web UI 中的集群并选择浏览集合。

然后，从 sample_mflix 数据库中选择电影集合。在过滤器选项卡中，我们可以使用以下查询找到我们的电影：

{title: "Back to the Future"}

这应该可以找到我们的电影，并且我们可以确认我们想要添加的新字段确实没有被看到。

接下来，让我们在刚刚添加的两行代码中添加一个断点，以确保我们可以在继续操作时实时跟踪更改。选择“开始调试”按钮来运行应用程序。当第一个断点被击中时，我们可以看到本地字段值已被分配。

让我们点击“继续”并检查数据库中的文档。我们可以看到新字段尚未添加。让我们跳过将结束程序的“保存更改”调用。此时，如果我们检查数据库中的文档，我们会注意到新字段已添加，如下所示！

索引管理MongoDB EF Core 提供程序建立在现有的 .NET/C# 驱动程序之上。此架构的一个优点是，我们可以重用已为DbContext创建的MongoClient，以利用 MongoDB 开发人员数据平台公开的其他功能。这包括但不限于索引管理、Atlas 搜索和矢量搜索等功能。我们将了解如何在同一个应用程序中使用驱动程序创建新索引。首先，我们将列出集合中的索引，以查看哪些索引已经存在。MongoDB 默认在_id字段上创建索引。我们将创建一个辅助函数来打印索引：var moviesCollection = client.GetDatabase("sample_mflix").GetCollection("movies");
Console.WriteLine("Before creating a new Index:");
PrintIndexes;

void PrintIndexes
{
var indexes = moviesCollection.Indexes.List;
foreach (var index in indexes.ToList)
{
Console.WriteLine(index);
}
}

预期输出如下所示：

{ "v": 2 ,"key": {"_id":1},"name": "_id_" }

现在，我们将在我们的集合中的标题和评级字段上创建一个复合索引，并再次打印索引。

由于 EF Core 已经支持语言集成查询 (LINQ) 语法，因此使用 C# 编写强类型查询变得很容易。根据模型类中可用的字段，我们可以尝试从我们的收藏中查找一些有趣的电影。假设我想查找所有评级为“PG-13”且情节包含单词“shark”的电影，但我希望按标题字段对它们进行排序。我可以使用以下查询轻松完成此操作：

var myMovies = await db.Movies
.Where(m => m.Rated == "PG-13" && m.Plot.Contains("shark"))
.OrderBy(m => m.Title)
.ToListAsync;

foreach (var m in myMovies)
{
Console.WriteLine(m.Title);
}
然后，我们可以使用上面的代码打印出查询，并使用dotnet run运行程序以查看结果。我们应该能够在控制台中看到我们收藏的 20K+ 部电影中的两部电影名称，如下所示。Jaws: The Revenge
Shark Night3D
如果您想查看发送到服务器的查询（在本例中为 MQL），那么您可以在 DbContext 上的Create函数中启用日志记录，如下所示： public static MflixDbContext Create(IMongoDatabase database) =>
new(new DbContextOptionsBuilder
.UseMongoDB(database.Client, database.DatabaseNamespace.DatabaseName)
.LogTo(Console.WriteLine)
.EnableSensitiveDataLogging
.Options);

这样，当我们再次运行程序时，我们就可以看到以下内容作为详细日志的一部分：

Executed MQL query
sample_mflix.movies.aggregate([{ "$match" : { "rated" : "PG-13", "plot" : /shark/s } }, { "$sort" : { "title" : 1 } }])
自动事务和乐观并发是的，你没看错！MongoDB EF Core 提供程序从其 8.1.0 版本开始支持事务和乐观并发。这意味着默认情况下，SaveChanges和SaveChangesAsync是事务性的。这将使生产级工作负载中的操作在发生任何故障时自动回滚，并确保所有操作都以乐观并发的方式完成。如果您想关闭事务，您可以在调用任何SaveChanges操作之前的初始化阶段进行关闭。db.Database.AutoTransactionBehavior= AutoTransactionBehavior.Never;
根据您的需求，提供程序支持两种乐观并发方法，即通过并发检查或行版本。您可以在文档中阅读更多相关信息。我们将使用 RowVersion 来演示此用例。这将利用模型类中的Version字段，该字段将由 MongoDB EF 提供程序自动更新。要添加版本，我们将以下内容添加到模型类中。 [Timestamp]
public long? Version { get; set; }
首先，让我们创建一个名为myMovie的新电影实体，如下所示，并将其添加到DbSet，然后添加Movie myMovie1= new Movie {
Title = "The Rise of EF Core 1",
Plot = "Entity Framework (EF) Core is a lightweight, extensible, open source and cross-platform version of the popular Entity Framework data access technology.",
Rated = "G"
};

db.Movies.Add(myMovie1);
await db.SaveChangesAsync;
DbContext的新 DbContext。我们可以将数据库创建移到变量中，这样我们就不必再次定义数据库的名称。有了这个新上下文，让我们为电影添加续集并将其添加到 DbSet。我们还将添加第三部分（是的，这是三部曲），但使用与第二部电影实体相同的 ID 到这个新上下文，然后保存我们的更改。var dbContext2 = MflixDbContext.Create(database);
dbContext2.Database.AutoTransactionBehavior = AutoTransactionBehavior.Never;
var myMovie2 = new Movie { title = "The Rise of EF Core 2" };
dbContext2.Movies.Add(myMovie2);

var myMovie3 = new Movie { Id = myMovie2.Id,Title = "The Rise of EF Core 3" };
dbContext2.Movies.Add(myMovie3);
await dbContext2.SaveChangesAsync;
现在支持事务了，对于后两个电影实体的第二组操作不应该通过，因为我们试图用已经存在的_id添加它们。我们应该看到一个异常，事务应该只在我们的数据库中看到一部电影。让我们运行一下，看看这是否属实。

我们正确地看到了一个异常，我们可以确认我们只有一部电影（第一部分）插入了数据库。