.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 .前置連線Mongo程式碼

           var client = new MongoClient("xxx");
           var database = client.GetDatabase("xxx");

3. 構建BsonDocumentProjectionDefinition

BsonDocumentProjectionDefinition<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();

第一次寫部落格，各位大佬請指教。