1. 首頁 > 生活百科 > >

.net core -利用 BsonDocumentProjectionDefinition 和Lookup 進行 join 關聯 MongoDB 查詢

生活百科

前序前段時間由于項目需要用到MongoDB，但是MongoDB不建議Collection join  查詢，網上很多例子查詢都是基于linq 進行關聯查詢 。但是在stackoverflow找到一個例子，程序員的朋友們請善于利用goole搜索 。主要介紹一個查詢角色的所有用戶的例子 。MongoDB創建Collection 和準備數據，請自行處理 。
1. 準備實體模型/// <summary>/// 用戶實體（Collection）/// </summary>public class User{public Guid UserId { get; set; }public string UserName { get; set; }public string Password { get; set; }public bool IsDelete { get; set; }public DateTime CreateTime { get; set; }public Guid RoleId { get; set; }}/// <summary>/// 角色實體（Collection）/// </summary>public class Role{public Guid RoleId { get; set; }public string RoleName { get; set; }public DateTime CreateTime { get; set; }}/// <summary>/// 構建用戶Dto（不在Mongo創建Collection）/// </summary>public class UserDto{public Guid UserId { get; set; }public string UserName { get; set; }public DateTime CreateTime { get; set; }public Guid RoleId { get; set; }public string RoleName { get; set; }}2 .連接配置和前置代碼
var client = new MongoClient("xxx");var database = client.GetDatabase("xxx");3. 構建BsonDocumentProjectionDefinitionBsonDocumentProjectionDefinition<BsonDocument> projectionDefinition = new BsonDocumentProjectionDefinition<BsonDocument>(new BsonDocument("UserId", "$UserId").Add("UserName", "$UserName").Add("CreateTime", "$CreateTime").Add("RoleId", "$RoleId").Add("RoleName", new BsonDocument("$arrayElemAt", new BsonArray().Add("$Role.RoleName").Add(0))));4.利用 Lookup 進行關聯Guid roleId = Guid.Empty;List<UserDto> list = database.GetCollection<BsonDocument>(typeof(User).Name).Aggregate()//過濾條件.Match(Builders<BsonDocument>.Filter.Eq("IsDelete", false)).Match(Builders<BsonDocument>.Filter.Eq("RoleId", roleId))//連接workflow.Lookup(typeof(Role).Name, "RoleId", "RoleId", typeof(UserDto).Name)//查詢需要顯示的列.Project(projectionDefinition).As<UserDto>().ToList();第一次寫博客 ， 各位大佬請指教 。
【.net core -利用 BsonDocumentProjectionDefinition 和Lookup 進行 join 關聯 MongoDB 查詢】

    推薦閱讀