Added xmin to PostgresLockStatementFormatter.cs queries to allow for …

…EF-style optimistic concurrency checking.
MassTransit · May 1, 2024 · 12563fa · 12563fa
1 parent 25fd050
commit 12563fa
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...FrameworkCoreIntegration/EntityFrameworkCoreIntegration/PostgresLockStatementFormatter.cs b/...FrameworkCoreIntegration/EntityFrameworkCoreIntegration/PostgresLockStatementFormatter.cs
@@ -8,7 +8,7 @@ public class PostgresLockStatementFormatter :
     {
         public void Create(StringBuilder sb, string schema, string table)
         {
-            sb.AppendFormat("SELECT * FROM {0} WHERE ", FormatTableName(schema, table));
+            sb.AppendFormat("SELECT *, xmin FROM {0} WHERE ", FormatTableName(schema, table));
         }
 
         public void AppendColumn(StringBuilder sb, int index, string columnName)
@@ -26,7 +26,7 @@ public void Complete(StringBuilder sb)
 
         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);
+            sb.AppendFormat(@"SELECT *, xmin FROM {0} ORDER BY ""{1}"" LIMIT 1 FOR UPDATE SKIP LOCKED", FormatTableName(schema, table), columnName);
         }
 
         static string FormatTableName(string schema, string table)