feat(resource): support batch in BulkUpsert

goto · Sep 15, 2023 · c3d93eb · c3d93eb
1 parent 3bd8e74
commit c3d93eb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/store/postgres/resource_repository.go b/internal/store/postgres/resource_repository.go
@@ -115,7 +115,7 @@ func (r *ResourceRepository) BulkUpsert(ctx context.Context, resources []*domain
 	if len(models) > 0 {
 		return r.db.WithContext(ctx).Transaction(func(tx *gorm.DB) error {
 			// upsert clause is moved to model.Resource.BeforeCreate() (gorm's hook) to apply the same for associations (model.Resource.Children)
-			if err := r.db.Create(models).Error; err != nil {
+			if err := r.db.CreateInBatches(models, 1000).Error; err != nil {
 				return err
 			}