Improve

framework/src/Volo.Abp.EntityFrameworkCore.PostgreSql/Volo/Abp/EntityFrameworkCore/DistributedEvents/PostgreSqlInboxConfigExtensions.cs

@@ -4,7 +4,7 @@ namespace Volo.Abp.EntityFrameworkCore.DistributedEvents
 {
     public static class PostgreSqlInboxConfigExtensions
     {
-        public static void UsePostgreSql<TDbContext>(this InboxConfig outboxConfig)
+        public static void UseNpgsql<TDbContext>(this InboxConfig outboxConfig)
             where TDbContext : IHasEventInbox
         {
             outboxConfig.ImplementationType = typeof(IPostgreSqlDbContextEventInbox<TDbContext>);

framework/src/Volo.Abp.EntityFrameworkCore.PostgreSql/Volo/Abp/EntityFrameworkCore/DistributedEvents/PostgreSqlOutboxConfigExtensions.cs

@@ -4,7 +4,7 @@ namespace Volo.Abp.EntityFrameworkCore.DistributedEvents
 {
     public static class PostgreSqlOutboxConfigExtensions
     {
-        public static void UsePostgreSql<TDbContext>(this OutboxConfig outboxConfig)
+        public static void UseNpgsql<TDbContext>(this OutboxConfig outboxConfig)
             where TDbContext : IHasEventOutbox
         {
             outboxConfig.ImplementationType = typeof(IPostgreSqlDbContextEventOutbox<TDbContext>);

framework/src/Volo.Abp.EntityFrameworkCore/Volo/Abp/EntityFrameworkCore/DistributedEvents/SqlRawDbContextEventInbox.cs

@@ -25,7 +25,7 @@ namespace Volo.Abp.EntityFrameworkCore.DistributedEvents
             var dbContext = await DbContextProvider.GetDbContextAsync();
             var tableName = dbContext.IncomingEvents.EntityType.GetSchemaQualifiedTableName();
 
-            var sql = $"UPDATE {tableName} SET Processed = '1', ProcessedTime = '{Clock.Now}' WHERE Id = '{id}'";
+            var sql = $"UPDATE {tableName} SET Processed = '1', ProcessedTime = '{Clock.Now}' WHERE Id = '{id.ToString().ToUpper()}'";
             await dbContext.Database.ExecuteSqlRawAsync(sql);
         }
 

framework/src/Volo.Abp.EntityFrameworkCore/Volo/Abp/EntityFrameworkCore/DistributedEvents/SqlRawDbContextEventOutbox.cs

@@ -19,7 +19,7 @@ namespace Volo.Abp.EntityFrameworkCore.DistributedEvents
             var dbContext = (IHasEventOutbox) await DbContextProvider.GetDbContextAsync();
             var tableName = dbContext.OutgoingEvents.EntityType.GetSchemaQualifiedTableName();
 
-            var sql = $"DELETE FROM {tableName} WHERE Id = '{id}'";
+            var sql = $"DELETE FROM {tableName} WHERE Id = '{id.ToString().ToUpper()}'";
             await dbContext.Database.ExecuteSqlRawAsync(sql);
         }
     }