Add concurrent creation

Author: isaacvando

src/Extensions/ParadeDbIndexBuilderExtensions.cs

@@ -131,6 +131,13 @@ public Bm25IndexBuilder<TEntity> HasFilter(string? sql)
         return this;
     }
 
+    public Bm25IndexBuilder<TEntity> IsCreatedConcurrently(bool createdConcurrently = true)
+    {
+        _indexBuilder.IsCreatedConcurrently(createdConcurrently);
+
+        return this;
+    }
+
     private void AddField(string field, string kind, Tokenizer? tokenizer, string? @alias)
     {
         var properties = GetAnnotation(ParadeDbAnnotationNames.Bm25FieldProperties);

src/Internal/Migrations/ParadeDbMigrationsSqlGenerator.cs

@@ -2,6 +2,7 @@
 using Microsoft.EntityFrameworkCore.Migrations;
 using Microsoft.EntityFrameworkCore.Migrations.Operations;
 using Npgsql.EntityFrameworkCore.PostgreSQL.Infrastructure.Internal;
+using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata.Internal;
 using Npgsql.EntityFrameworkCore.PostgreSQL.Migrations;
 using ParadeDB.EntityFrameworkCore.Internal.Metadata;
 
@@ -34,9 +35,12 @@ is not string keyField
         }
 
         var helper = Dependencies.SqlGenerationHelper;
+        var createdConcurrently =
+            operation.FindAnnotation(NpgsqlAnnotationNames.CreatedConcurrently)?.Value is true;
 
         builder
             .Append("CREATE INDEX ")
+            .Append(createdConcurrently ? "CONCURRENTLY " : "")
             .Append(helper.DelimitIdentifier(operation.Name))
             .Append(" ON ")
             .Append(helper.DelimitIdentifier(operation.Table, operation.Schema))
@@ -57,7 +61,9 @@ is not string keyField
 
         if (terminate)
         {
-            builder.AppendLine(helper.StatementTerminator).EndCommand();
+            builder
+                .AppendLine(helper.StatementTerminator)
+                .EndCommand(suppressTransaction: createdConcurrently);
         }
     }
 }

tests/IndexingTest.cs

@@ -127,6 +127,7 @@ protected override void OnModelCreating(ModelBuilder modelBuilder)
 
                 entity
                     .HasBm25Index("indexing_items_idx", e => e.Id)
+                    .IsCreatedConcurrently()
                     .HasField(e => e.Description)
                     .HasField(e => e.Metadata);
             });
@@ -153,7 +154,7 @@ rating int
 
         sql.ShouldBe(
             """
-            CREATE INDEX indexing_items_idx ON indexing_items USING bm25 (id, description, metadata) WITH (key_field = 'id');
+            CREATE INDEX CONCURRENTLY indexing_items_idx ON indexing_items USING bm25 (id, description, metadata) WITH (key_field = 'id');
 
             """
         );