use select pg_advisory_xact_lock to serialize access to message table…

… creation
event-driven-io · Jul 23, 2024 · 376d748 · 376d748
1 parent 49408fa
commit 376d748
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Blumchen/Database/Run.cs b/src/Blumchen/Database/Run.cs
@@ -13,11 +13,11 @@ private static async Task Execute(
         CancellationToken ct)
     {
         await using var command = dataSource.CreateCommand(sql);
-        await command.ExecuteNonQueryAsync(ct).ConfigureAwait(false);
+        await command.ExecuteNonQueryAsync(ct);
     }
 
     public static async Task EnsureTableExists(this NpgsqlDataSource dataSource, TableDescriptorBuilder.MessageTable tableDescriptor, CancellationToken ct)
-        => await dataSource.Execute(tableDescriptor.ToString(), ct).ConfigureAwait(false);
+        => await dataSource.Execute(string.Concat("select pg_advisory_xact_lock(12345);", tableDescriptor), ct).ConfigureAwait(false);
 
     public static async Task<bool> Exists(
         this NpgsqlDataSource dataSource,