目錄

• 前序
• 1. 準(zhǔn)備實(shí)體模型
• 2 .前置連接Mongo代碼
• 3. 構(gòu)建BsonDocumentProjectionDefinition
• 4.利用 Lookup 進(jìn)行關(guān)聯(lián)

前序

前段時(shí)間由于項(xiàng)目需要用到MongoDB，但是MongoDB不建議Collection join 查詢，網(wǎng)上很多例子查詢都是基于linq 進(jìn)行關(guān)聯(lián)查詢。但是在stackoverflow找到一個(gè)例子，程序員的朋友們請善于利用google搜索。主要介紹一個(gè)查詢角色的所有用戶的例子。MongoDB創(chuàng)建Collection 和準(zhǔn)備數(shù)據(jù)，請自行處理。

1. 準(zhǔn)備實(shí)體模型

/// <summary>
    /// 用戶實(shí)體（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>
    /// 角色實(shí)體（Collection）
    /// </summary>
    public class Role
    {
public Guid RoleId { get; set; }

public string RoleName { get; set; }

public DateTime CreateTime { get; set; }
    }
    /// <summary>
    /// 構(gòu)建用戶Dto（不在Mongo創(chuàng)建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. 構(gòu)建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 進(jìn)行關(guān)聯(lián)

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))
//連接Role
.Lookup(typeof(Role).Name, "RoleId", "RoleId", typeof(UserDto).Name)
//查詢需要顯示的列
.Project(projectionDefinition)
.As<UserDto>().ToList();

到此這篇關(guān)于.NET Core利用BsonDocumentProjectionDefinition和Lookup進(jìn)行 join 關(guān)聯(lián)查詢的文章就介紹到這了,更多相關(guān).net core  join 關(guān)聯(lián)查詢內(nèi)容請搜索以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持！