Skip to content

Commit 97e2acb

Browse files
Merge pull request #466 from DRFredy/fix_transaction_param_within_chunk_methods
transaction parameter within Chunk and ChunkAsync methods
2 parents 422878c + 5c10737 commit 97e2acb

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

SqlKata.Execution/QueryFactory.cs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -527,7 +527,7 @@ public void Chunk<T>(
527527

528528
while (result.HasNext)
529529
{
530-
result = result.Next();
530+
result = result.Next(transaction);
531531
if (!func(result.List, result.Page))
532532
{
533533
return;
@@ -543,7 +543,7 @@ public async Task ChunkAsync<T>(
543543
int? timeout = null
544544
)
545545
{
546-
var result = await this.PaginateAsync<T>(query, 1, chunkSize);
546+
var result = await this.PaginateAsync<T>(query, 1, chunkSize, transaction);
547547

548548
if (!func(result.List, 1))
549549
{
@@ -552,7 +552,7 @@ public async Task ChunkAsync<T>(
552552

553553
while (result.HasNext)
554554
{
555-
result = result.Next();
555+
result = result.Next(transaction);
556556
if (!func(result.List, result.Page))
557557
{
558558
return;
@@ -568,7 +568,7 @@ public void Chunk<T>(Query query, int chunkSize, Action<IEnumerable<T>, int> act
568568

569569
while (result.HasNext)
570570
{
571-
result = result.Next();
571+
result = result.Next(transaction);
572572
action(result.List, result.Page);
573573
}
574574
}
@@ -587,7 +587,7 @@ public async Task ChunkAsync<T>(
587587

588588
while (result.HasNext)
589589
{
590-
result = result.Next();
590+
result = result.Next(transaction);
591591
action(result.List, result.Page);
592592
}
593593
}

0 commit comments

Comments
 (0)