NuGet：Shashlik.EventBus.RelationDbStorage

所有关系型数据库（MySQL / PostgreSQL / SqlServer / Sqlite / Oracle 等）已统一到本包，不再需要为每种数据库引入独立存储包。

Shashlik.EventBus.RelationDbStorage 基于 FreeSql 实现跨数据库支持，FreeSql 仅在 EventBus 内部使用，对业务系统本身无侵入。你的业务代码可以继续使用 EF Core、Dapper 或任何其他 ORM，互不影响。唯一需要做的就是在项目中引入 FreeSql 对应数据库的 Provider 包，确保 EventBus 内部能够正确连接数据库。

需自行引入对应数据库的 FreeSql Provider 包。

FreeSql Provider 文档：https://freesql.net/guide/freesql-provider-mysqlconnector.html

重要：FreeSql Provider 使用的底层 ADO.NET 驱动必须与应用本身使用的驱动一致！

驱动不一致会导致连接池冲突、类型映射异常等不可预期的问题。

以 MySQL 为例：

• 应用使用 Pomelo.EntityFrameworkCore.MySql（底层驱动为 MySqlConnector）→ FreeSql 应引入 FreeSql.Provider.MySqlConnector
• 应用使用官方 MySql.Data 驱动 → FreeSql 应引入 FreeSql.Provider.MySql

其他数据库同理：如果 EF Core / 应用层 ORM 使用的是某种 ADO.NET 驱动，FreeSql Provider 也必须使用基于同一驱动的版本。常见对照：

数据库	应用用 Connector 驱动	应用用官方驱动
MySQL	FreeSql.Provider.MySqlConnector	FreeSql.Provider.MySql
PostgreSQL	FreeSql.Provider.PostgreSQL (Npgsql)	—
SqlServer	FreeSql.Provider.SqlServer (System.Data.SqlClient)	FreeSql.Provider.MicrosoftData.SqlClient
Sqlite	FreeSql.Provider.Sqlite (Microsoft.Data.Sqlite)	—

务必根据应用实际使用的底层驱动选择对应的 FreeSql Provider！

services.AddEventBus()
    .AddRelationDb(options => options.UseConnection(DataType.MySql, "Server=...;Database=...;Uid=...;Pwd=...;"));

DataType 枚举值包括：MySql、PostgreSQL、SqlServer、Sqlite、Oracle、Dameng 等，详见 FreeSql 文档。

需引入包 Shashlik.EventBus.Extensions.EfCore：

services.AddEventBus()
    .AddRelationDb<TDbContext>(DataType.MySql);

此方式自动从 DbContext 中获取连接字符串，同时可使用 DbContext.PublishEventAsync() 等扩展方法。

services.AddEventBus()
    .AddRelationDb(options => options.UseConnection(typeof(MyConnectionFactory)));

自定义工厂需实现 IConnectionFactory 接口。

关系型数据库事务上下文为 RelationDbStorageTransactionContext，基于 IDbTransaction。

获取方式详见 事件发布 - 事务集成。

RelationDbStorage 启动时通过 IMessageStorageInitializer 自动创建消息表。内部时间字段使用 UTC ticks (long) 持久化，以兼容各数据库方言。

已发布消息表（默认 eventbus_published）：

已接收消息表（默认 eventbus_received）额外包含 EventHandlerName 字段。