分页排序和多条件查询
排序和分页模型设计,生成排序表达式树,实现自动分页和排序方法,扩展 IQueryable 以便通过属性名称排序,扩展 IQueryable 以便搜索和排序,在 API 控制器中使用扩展方法,实现灵活的复杂查询,基于 OData 或者 GraphQL 来实现更复杂的查询。
分页排序和多条件查询
分页参数
请求应使用 GET 方法
http://localhost:8080/api/products?keyword=test&pagenumber=1&pagesize=5&orderby=id desc,price ascshell响应返回如下
{
"totalCount": 100,
"items": [
{
"id": 1,
"name": "test",
"price": 100
},
{
"id": 2,
"name": "test",
"price": 200
}
]
}json分页请求模型
public class PagedAndSortedRequest : PagedRequest
{
public string? OrderBy { get; init; }
}csharp分页响应模型
public class PagedResponse<T>(IReadOnlyList<T> items, int totalCount)
{
public IReadOnlyList<T> Items { get; init; } = items;
public int TotalCount { get; init; } = totalCount;
}csharp扩展 IQueryable 以便通过属性名称排序
QueryableOrderByExtensions.csshell将字符串条件转化为排序表达式
IOrderedQueryable<TSource> OrderBy(IQueryable<TSource> source, string propertyName)csharp扩展 IQueryable 以便搜索和排序
QueryableExtensions.csshell扩展分页和排序方法
IQueryable<TEntity> SortBy<TEntity>(this IQueryable<TEntity> query, string? orderBy = null);
IQueryable<TEntity> PageBy<TEntity>(this IQueryable<TEntity> query, PagedRequest pagedRequest)
IQueryable<TEntity> SortAndPageBy<TEntity>(this IQueryable<TEntity> query, PagedAndSortedRequest? pagedAndSortedRequest = null);csharp再扩展一个 WhereIf 条件查询
IQueryable<TSource> WhereIf<TSource>(this IQueryable<TSource> source, bool condition, Expression<Func<TSource, bool>> predicate);csharp在 API 控制器中使用扩展方法
[HttpGet]
[Authorize(IdentityPermissions.Users.Default)]
public async Task<ActionResult<PagedResponse<UserListItem>>> GetUsers([FromQuery] UserListRequest model)
{
IQueryable<User> users = dbContext.Set<User>();
if (model.Keyword is not null)
{
users = users.Where(e => e.UserName != null && e.UserName.Contains(model.Keyword));
}
users = users.WhereIf(model.PhoneNumber is not null, e => e.PhoneNumber == model.PhoneNumber);
var pagedUsers = users.SortAndPageBy(model);
var list = new List<UserListItem>();
return new PagedResponse<UserListItem>(mapper.Map<List<UserListItem>>(await pagedUsers.ToListAsync()), await users.CountAsync());
}csharp实现灵活的复杂查询
可以使用 OData 或者 GraphQL 来实现更复杂的查询。
OData 是一种基于 REST 的协议,它使用 URL 来查询和操作数据。OData 通过 URL 查询字符串参数来过滤、排序、分页和选择数据。示例:
http://localhost:8080/api/products?$filter=price gt 100&$orderby=price desc&$top=5&$skip=10shell关于 OData 的更多信息请参考 零度 OData 课程
GraphQL 是一种用于 API 的查询语言,它提供了一种更高效、强大和灵活的替代方案。GraphQL 通过一个单一的端点来查询和操作数据。示例:
http://localhost:8080/graphqlshellquery {
products(filter: {price: {gt: 100}}, orderBy: {price: desc}, top: 5, skip: 10) {
id
name
price
}
}graphql接着看
构建可靠的事务性发件箱模式
事务性发件箱模式确保将事件保存在数据存储中,然后再最终推送到消息代理。 如果业务对象和相应的事件保存在同一数据库事务中,则保证不会丢失任何数据。 所有内容都将被提交,或在出错时所有内容回滚。 为了最终发布事件,其他服务或工作进程会在发件箱表中查询未处理项,发布这些事件,并将其标记为已处理。 此模式可确保创建或修改业务对象后不会丢失事件。
自动迁移和数据库初始化
EF Core中数据库迁移与初始化的核心概念与实用技巧。内容包括生成与应用迁移脚本、EnsureCreatedAsync与MigrateAsync的使用及冲突解决、通过内部服务实现优雅的自动迁移、EF Core 9.0推荐的异步种子数据初始化方法,以及利用IHostedService或BackgroundService实现耗时操作的异步数据库初始化。通过本课程,开发者将掌握高效管理数据库生命周期的最佳实践,提升项目开发效率与质量。
重构代码并抽取基础构建库
本次重构优化了事件总线架构,提升了系统的扩展性和灵活性。新增支持包和多个项目,增强了事件处理能力。通过实现基于 Dapr 和 RabbitMQ 的事件总线,改进了消息传递效率。加入了分布式锁功能,确保并发场景下的数据一致性。
在 Aspire 中集成 PostgreSQL 数据库
在 Host 项目中添加 PostgreSQL 数据库,在最终的应用中引用 PostgreSQL 数据库,添加 PostgreSQL pgAdmin 资源,添加 PostgreSQL pgWeb 资源。