使用 PostgreSQL 数据库存储数据
在 Docker 中 启动 PostgreSQL 数据库,使用 PgAdmin 连接 PostgreSQL 数据库,EfCore 使用 PostgreSQL 数据库,命名约定,使用脚本迁移,列迁移排序,时间自动转换配置。
使用 PostgreSQL 数据库存储数据
在 Docker 中 启动 PostgreSQL 数据库
docker pull postgres
docker run --name postgres -e POSTGRES_PASSWORD=postgres -e TZ=Asia/Shanghai -d -p 5432:5432 postgresshell使用 PgAdmin 连接 PostgreSQL 数据库
SHOW timezone;shellEfCore 使用 PostgreSQL 数据库
dotnet add package Npgsql.EntityFrameworkCore.PostgreSQLshell定义实体类型
public class User
{
public int Id { get; set; }
public string UserName { get; set; }
public string PasswordHash { get; set; }
public DateTimeOffset CreationTime { get; set; } = DateTimeOffset.UtcNow;
}csharp配置实体类型
public class UserEntityTypeConfiguration : IEntityTypeConfiguration<User>
{
public void Configure(EntityTypeBuilder<User> builder)
{
builder.ToTable("Users");
builder.HasKey(x => x.Id);
builder.Property(x => x.UserName).IsRequired().HasMaxLength(50);
builder.Property(x => x.PasswordHash).IsRequired().HasMaxLength(50);
builder.Property(x => x.CreationTime);
}
}csharp创建 DbContext 上下文
public class IdentityServiceDbContext : DbContext
{
public IdentityServiceDbContext(DbContextOptions<IdentityServiceDbContext> options) : base(options)
{
}
protected override void OnModelCreating(ModelBuilder builder)
{
base.OnModelCreating(builder);
builder.ApplyConfigurationsFromAssembly(Assembly.GetExecutingAssembly());
AppContext.SetSwitch("Npgsql.EnableLegacyTimestampBehavior", true);
AppContext.SetSwitch("Npgsql.DisableDateTimeInfinityConversions", true);
}
}csharp数据库连接字符串
{
"ConnectionStrings": {
"IdentityDatabase": "Host=localhost;Port=5432;Database=IdentityService;Username=postgres;Password=postgres"
}
}json注册数据库上下文
builder.Services.AddDbContext<IdentityServiceDbContext>(options =>
{
options.UseNpgsql(builder.Configuration.GetConnectionString("IdentityDatabase"));
});csharp迁移数据库
dotnet tool install --global dotnet-ef
dotnet add package Microsoft.EntityFrameworkCore.Designshelldotnet ef migrations add InitialCreate --output-dir EntityFrameworks/Migrations
dotnet ef database updateshellPostgreSQL 数据库命名约定
https://github.com/efcore/EFCore.NamingConventions
删除数据库和迁移
dotnet ef database drop --force
dotnet ef migrations removeshell使用脚本迁移
dotnet ef migrations scriptshellEF Core 列迁移排序
默认情况下,在使用迁移创建表时,EF Core 首先为主键列排序,然后为实体类型和从属类型的属性排序,最后为基类型中的属性排序。 但是,你可以指定不同的列顺序:
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
modelBuilder.Entity<Blog>()
.Property(b => b.Url)
.HasColumnOrder(2);
modelBuilder.Entity<Blog>()
.Property(b => b.Rating)
.HasColumnOrder(3);
}csharpPostgreSQL 驱动时间自动转换配置
AppContext.SetSwitch("Npgsql.EnableLegacyTimestampBehavior", true);
AppContext.SetSwitch("Npgsql.DisableDateTimeInfinityConversions", true);
csharp接着看
构建可靠的事务性发件箱模式
事务性发件箱模式确保将事件保存在数据存储中,然后再最终推送到消息代理。 如果业务对象和相应的事件保存在同一数据库事务中,则保证不会丢失任何数据。 所有内容都将被提交,或在出错时所有内容回滚。 为了最终发布事件,其他服务或工作进程会在发件箱表中查询未处理项,发布这些事件,并将其标记为已处理。 此模式可确保创建或修改业务对象后不会丢失事件。
自动迁移和数据库初始化
EF Core中数据库迁移与初始化的核心概念与实用技巧。内容包括生成与应用迁移脚本、EnsureCreatedAsync与MigrateAsync的使用及冲突解决、通过内部服务实现优雅的自动迁移、EF Core 9.0推荐的异步种子数据初始化方法,以及利用IHostedService或BackgroundService实现耗时操作的异步数据库初始化。通过本课程,开发者将掌握高效管理数据库生命周期的最佳实践,提升项目开发效率与质量。
重构代码并抽取基础构建库
本次重构优化了事件总线架构,提升了系统的扩展性和灵活性。新增支持包和多个项目,增强了事件处理能力。通过实现基于 Dapr 和 RabbitMQ 的事件总线,改进了消息传递效率。加入了分布式锁功能,确保并发场景下的数据一致性。
在 Aspire 中集成 PostgreSQL 数据库
在 Host 项目中添加 PostgreSQL 数据库,在最终的应用中引用 PostgreSQL 数据库,添加 PostgreSQL pgAdmin 资源,添加 PostgreSQL pgWeb 资源。