文章詳情頁
.NET Core利用BsonDocumentProjectionDefinition和Lookup進行 join 關(guān)聯(lián)查詢(推薦)
瀏覽:372日期:2022-06-09 10:56:05
目錄
- 前序
- 1. 準備實體模型
- 2 .前置連接Mongo代碼
- 3. 構(gòu)建BsonDocumentProjectionDefinition
- 4.利用 Lookup 進行關(guān)聯(lián)
前序
前段時間由于項目需要用到MongoDB,但是MongoDB不建議Collection join 查詢,網(wǎng)上很多例子查詢都是基于linq 進行關(guān)聯(lián)查詢。但是在stackoverflow找到一個例子,程序員的朋友們請善于利用google搜索。主要介紹一個查詢角色的所有用戶的例子。MongoDB創(chuàng)建Collection 和準備數(shù)據(jù),請自行處理。
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>
/// 構(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 進行關(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進行 join 關(guān)聯(lián)查詢的文章就介紹到這了,更多相關(guān).net core join 關(guān)聯(lián)查詢內(nèi)容請搜索以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持!
標簽:
ASP.NET
排行榜

網(wǎng)公網(wǎng)安備