MassTransit集成Devart Postgres EFCore参数问题及注意事项咨询

问题背景 #

使用Devart Postgres EF Core库集成MassTransit时，触发错误：

Devart.Data.PostgreSql.PgSqlException (0x80004005): column "p0" does not exist

根源是MassTransit默认的PostgresLockStatementFormatter生成的参数格式为@p0，而Devart Postgres EF Core要求参数使用:p0格式。

已验证的解决方案 #

通过自定义ILockStatementFormatter实现类替换默认逻辑，生成符合Devart要求的参数格式：

public class DevArtPostgresLockStatementFormatter : ILockStatementFormatter
{
    public void Create(StringBuilder sb, string schema, string table)
    {
        sb.AppendFormat("SELECT * FROM {0} WHERE ", FormatTableName(schema, table));
    }

    public void AppendColumn(StringBuilder sb, int index, string columnName)
    {
        if (index == 0)
            sb.AppendFormat("\"{0}\" = :p0", columnName);
        else
            sb.AppendFormat(" AND \"{0}\" = :p{1}", columnName, index);
    }

    public void Complete(StringBuilder sb)
    {
        sb.Append(" FOR UPDATE");
    }

    public void CreateOutboxStatement(StringBuilder sb, string schema, string table, string columnName)
    {
        sb.AppendFormat(@"SELECT * FROM {0} ORDER BY ""{1}"" LIMIT 1 FOR UPDATE SKIP LOCKED", FormatTableName(schema, table), columnName);
    }

    static string FormatTableName(string schema, string table)
    {
        return string.IsNullOrEmpty(schema) ? $"\"{table}\"" : $"\"{schema}\".\"{table}\"";
    }
}

在服务配置中指定该格式化器：

x.AddSagaRepository<MyStateMachine>()
  .EntityFrameworkRepository(r =>
  {                    
       r.LockStatementProvider = new DevArtPostgresLockStatementProvider();
       r.ExistingDbContext<MyDbContext>();
  });

关于其他场景的说明 #

持久化Outbox功能 #

你的自定义格式化器中已经实现了CreateOutboxStatement方法，该方法正是为MassTransit的持久化Outbox场景设计的。当使用EF Core作为Outbox的存储提供方时，MassTransit会调用此方法生成Outbox消息的锁查询语句，因此Outbox场景会自动复用你自定义的格式化逻辑，无需额外配置。

其他需要注意的点 #

• 全局覆盖所有Saga Repository：确保所有使用EF Core Repository的Saga都配置了DevArtPostgresLockStatementProvider，避免遗漏某个Saga导致重复触发参数格式错误。
• 版本兼容性：后续升级MassTransit时，需检查默认PostgresLockStatementFormatter的逻辑变化，若官方调整了锁语句生成规则，需同步更新自定义实现以保持兼容性。
• Outbox扩展验证：若后续MassTransit对Outbox的锁语句引入参数（当前你的实现中该语句无参数），需确保参数格式依然符合Devart要求（:pN格式）。
• Devart配置一致性：确认DbContext中Devart的参数格式配置（如PgSqlContextOptionsBuilder.UseParameterPrefix）与自定义格式化器的参数前缀保持一致，避免冲突。

内容的提问来源于stack exchange，提问作者Captain John