C# .NET Core 3.1中使用 MongoDB.Driver 更新数组元素和关联的一些坑
前言：
由于工作的原因，使用的数据库由原来的 关系型数据库 MySQL、SQL Server 变成了 非关系型数据库 MongoDB。可以简单的理解为存下的是 Json（实际是一个类似的东西叫 Bson）。由于仍然使用 C# 作为开发语言，自然是绕不开官方的数据库驱动 MongoDB.Driver。由于 MongoDB 的特性和驱动程序自身的实现，也可能是因为个人的习惯，感觉使用起来并不顺手，还遇到了很多坑XD，因此记录一下。
环境与数据
A. 使用 Visual Studio 2019、.NET Core 3.1 和 MongoDB.Driver 2.13.1
B. 类的定义（还是用《原神》了哈哈）
/// <summary>
/// 原神角色
/// </summary>
public class YuanshenRole
{
/// <summary>
/// 主键
/// </summary>
public ObjectId _id { get; set; }
/// <summary>
/// 名字
/// </summary>
public string Name { get; set; }
/// <summary>
/// 元素：火、水、岩、冰、风等
/// </summary>
public ObjectId ElementId { get; set; }
/// <summary>
/// 所拥有的武器
/// </summary>
public List<Weapon> Weapons { get; set; }
}/// <summary>
/// 元素
/// </summary>
public class Element
{
/// <summary>
/// 主键
/// </summary>
public ObjectId _id { get; set; }
/// <summary>
/// 名称
/// </summary>
public string ElementName { get; set; }
}/// <summary>
/// 武器
/// </summary>
public class Weapon
{
/// <summary>
/// 唯一标志
/// </summary>
public string Id { get; set; }
/// <summary>
/// 名称
/// </summary>
public string Name { get; set; }
/// <summary>
/// 星级
/// </summary>
public int LevelStart { get; set; }
}
其中每个“角色”拥有多把“武器”，同时与一种“元素”对应
C. 数据展示
可以看出，“琴”与“风”元素对应，“可莉”与“火”元素对应
主要内容
通用的结论：所谓驱动程序，就是将 C# 的写法翻译为 MongoDB 的查询语句写法（如 EntityFramework 将 C# 写法翻译为 Sql 语句）。
1. 更新数组类型字段的某个元素
不同于关系型数据库 SQL 的 UPDATE … SET … WHERE …，MongoDB 中更新嵌套的类型可以使用 “outer.inner” 的形式来表示嵌套对象的对应字段。而更新嵌套的数组元素则要绕一个弯子。比如我们要把 “琴” 的 “手里剑” 改为 “新手大刀”，可以这样写：
var update = Builders<YuanshenRole>.Update
.Set(w => w.Weapons[-1].Name, "新手大刀");
collectionRole.UpdateOne(role => role.Name == "琴" && role.Weapons.Any(w => w.Name == "手里剑"), update);
“奇妙”之处在于：在查询时隐式地查询数组中的内容（Any方法），并且在更新时使用 -1 对应要更新的数组元素
对比下原生的写法：
db.YuanshenRole.updateMany({Name: "琴", "Weapons.Name":"手里剑"}, {$set:{"Weapons.$.Name":"新手大刀"}})
注意此处的 $ 符号。驱动正是将 -1 替换为了 $ 符号，参见源代码
2. 关联查询
对于关系型数据库而言，为了符合数据库的设计三大范式，不可避免的要建立多张表，关联也是家常便饭， MongoDB 中的关联思路也基本一致。
此时需要查询：角色和其对应的元素，则需要关联 角色表 和 元素表
Linq 方式关联查询的代码为：（注意：要引入 MongoDB.Driver）
var query = from role in collectionRole.AsQueryable().Where(a => a.Weapons.Count > 0)
join element in collectionElement.AsQueryable()
on role.ElementId equals element._id
select new
{
role.Name,
element.ElementName
};
var dataList = query.ToList();
foreach(var data in dataList)
{
Console.WriteLine(string.Format("角色名：{0}，元素属性：{1}", data.Name, data.ElementName));
}
查询结果：
角色名：琴，元素属性：风
角色名：可莉，元素属性：火
关联字段的类型要一致。这种方式可以正常查出结果，可如果稍微变化一下，如：
A.（报错）给关联的子表加入 where 条件
查阅了许多资料，似乎并没有说 MongoDB 关联的子表不能加入条件，或者说 MongoDB 关联的子表可以加入条件 ，最后只有一篇泛泛的描述
B.（报错）查询时查出整个“文档”
个人认为这是驱动“翻译”的问题
3. 关联查询的类原生写法
先看下 Mongo Shell 中的写法：
C# 语言中类原生的写法为：
BsonDocument query = new BsonDocument
{
{ "Weapons", new BsonDocument{ { "$size", 3 } } }
};// 匹配条件
PipelineStageDefinition<BsonDocument, BsonDocument> match =
PipelineStageDefinitionBuilder.Match<BsonDocument>(query);// 关联条件
PipelineStageDefinition<BsonDocument, BsonDocument> lookup =
PipelineStageDefinitionBuilder.Lookup<BsonDocument, BsonDocument, BsonDocument>(
dbYuanShen.GetCollection<BsonDocument>("Element"), # 要关联的表
(FieldDefinition<BsonDocument>)"ElementId", # 主表的字段
(FieldDefinition<BsonDocument>)"_id", # 子表的对应字段
(FieldDefinition<BsonDocument>)"ElementAttr"); # 此处将关联后得到的子表对应字段设置为 “ElementAttr”// 组合并形成最终查询
var pipeline = PipelineDefinition<BsonDocument, BsonDocument>.Create(
new List<PipelineStageDefinition<BsonDocument, BsonDocument>> { match, lookup });// 执行并得到数据
var dataList = dbYuanShen.GetCollection<BsonDocument>("YuanshenRole").Aggregate(pipeline).ToList();var resultList = dataList.Select(a => new
{
Name = a.GetValue("Name").AsString,
ElementName = a.GetValue("ElementAttr").AsBsonArray[0] # 与上面设置的子表字段对应，不过要注意类型为数组
.AsBsonDocument.GetValue("ElementName").AsString
}).ToList();
foreach (var result in resultList)
{
Console.WriteLine(string.Format("角色名：{0}，元素属性：{1}", result.Name, result.ElementName));
}
可以看出，在形成查询的 Json 时还是有一点复杂的，至少泛型的名称就够长的了QAQ。不过逻辑还算清晰，对比原生的写法也算是勉勉强强可以接受吧。需要注意的是：
（1）BsonDocument 的创建中，new BsonDocument{ { A, B } } 等价于 new BsonDocument{ new BsonElement(A, B) }
（2）如果想要在查询中使用 null, 应使用 BsonValue.Null
（3）时间的时区问题，应使用 BsonUtils.ToUniversalTime(MY_TIME) 转换一下时间。而在上面的 Linq 写法中，如果属性（如 CreateTime）添加了 BsonDateTimeOptions 特性 ，查询时驱动程序会根据类的定义自动转换，但也应注意操作系统的时区设置。
（4）如果要使用 $in 和 BsonArray，可以使用 BsonArray.Create(IEnumerable类型的值) 创建 BsonArray 对象
（5）此处的查询实际上是左外连接，从表的映射字段（即代码中的 ElementAttr）所表示的类型实际上是一个数组，如果子表中没有对应的关联，则映射字段结果为空数组。此处由于确定有关联数据，因此直接使用即可。如果要展开，可以在 pipeline 中加入 $unwind 操作。
4. 变动时多字段问题
A. 情况1，定义的类里面新加了字段 而 MongoD数据库没加
不影响。新加的字段会默认赋值为其类型的默认值
B. 情况2，MongoDB数据库中的新加了字段 而 定义的类中没加
会报错。如下：
但可通过在类上添加特性 BsonIgnoreExtraElements 来忽略数据库中多出的字段
番外篇
众所周知，MongoDB 中查询时如果要匹配数组的元素数量，只能写等于，而不能写大于或者小于。而我在 “2.关联查询”中居然写了 Count > 0，而且并没有报错，这是怎么回事呢。为了泛化这种情况，我把 Count > 0 改成 Count > 1，然后调试下：
原来是 指定了某个数组元素 配合 $exists 判断的，妙啊！
参考
MongoDB .Net Driver(C#驱动) – 内嵌数组/嵌入文档的操作(增加、删除、修改、查询(Linq 分页))（其中还有显式地调用扩展方法的讲解）
https://blog.csdn.net/qq_27441069/article/details/79586372
Mongodb在CSharp里实现Aggregate
