diff --git a/src/backend/EdFi.DataManagementService.Backend.Postgresql.Test.Integration/DatabaseTest.cs b/src/backend/EdFi.DataManagementService.Backend.Postgresql.Test.Integration/DatabaseTest.cs index 865650588..f041e4fc7 100644 --- a/src/backend/EdFi.DataManagementService.Backend.Postgresql.Test.Integration/DatabaseTest.cs +++ b/src/backend/EdFi.DataManagementService.Backend.Postgresql.Test.Integration/DatabaseTest.cs @@ -24,7 +24,7 @@ public abstract class DatabaseTest : DatabaseTestBase public async Task ConnectionSetup() { Connection = await DataSource!.OpenConnectionAsync(); - Transaction = await Connection.BeginTransactionAsync(IsolationLevel.Serializable); + Transaction = await Connection.BeginTransactionAsync(IsolationLevel.RepeatableRead); } [TearDown] @@ -235,7 +235,7 @@ Func> dbOperation2 // Connection and transaction for the setup await using var connectionForSetup = await DataSource!.OpenConnectionAsync(); await using var transactionForSetup = await connectionForSetup.BeginTransactionAsync( - IsolationLevel.Serializable + IsolationLevel.RepeatableRead ); // Run the setup @@ -250,7 +250,7 @@ Func> dbOperation2 // Connection and transaction managed in this method for DB transaction 1 await using var connection1 = await DataSource!.OpenConnectionAsync(); - await using var transaction1 = await connection1.BeginTransactionAsync(IsolationLevel.Serializable); + await using var transaction1 = await connection1.BeginTransactionAsync(IsolationLevel.RepeatableRead); // Use these for threads to signal each other for coordination using EventWaitHandle Transaction1Go = new AutoResetEvent(false); @@ -271,7 +271,7 @@ Func> dbOperation2 // Step #3: Create new connection and begin DB transaction 2 connection2 = await DataSource!.OpenConnectionAsync(); - transaction2 = await connection2.BeginTransactionAsync(IsolationLevel.Serializable); + transaction2 = await connection2.BeginTransactionAsync(IsolationLevel.RepeatableRead); // Step #4: Signal to transaction 1 thread to continue in parallel Transaction1Go?.Set(); diff --git a/src/backend/EdFi.DataManagementService.Backend.Postgresql.Test.Integration/DeleteTests.cs b/src/backend/EdFi.DataManagementService.Backend.Postgresql.Test.Integration/DeleteTests.cs index 14150a6a5..a6dd3d604 100644 --- a/src/backend/EdFi.DataManagementService.Backend.Postgresql.Test.Integration/DeleteTests.cs +++ b/src/backend/EdFi.DataManagementService.Backend.Postgresql.Test.Integration/DeleteTests.cs @@ -414,7 +414,7 @@ public async Task Setup() _upsertResults.Add(await CreateUpsert().Upsert(upsertRequest, Connection!, Transaction!)); await Transaction!.CommitAsync(); - Transaction = await Connection!.BeginTransactionAsync(IsolationLevel.Serializable); + Transaction = await Connection!.BeginTransactionAsync(IsolationLevel.RepeatableRead); _deleteResult = await CreateDeleteById() .DeleteById( @@ -489,7 +489,7 @@ public async Task Setup() _upsertResults.Add(await CreateUpsert().Upsert(upsertRequest, Connection!, Transaction!)); await Transaction!.CommitAsync(); - Transaction = await Connection!.BeginTransactionAsync(IsolationLevel.Serializable); + Transaction = await Connection!.BeginTransactionAsync(IsolationLevel.RepeatableRead); _deleteResult = await CreateDeleteById() .DeleteById( @@ -562,7 +562,7 @@ public async Task Setup() await Transaction!.CommitAsync(); - Transaction = await Connection!.BeginTransactionAsync(IsolationLevel.Serializable); + Transaction = await Connection!.BeginTransactionAsync(IsolationLevel.RepeatableRead); _deleteResult = await CreateDeleteById() .DeleteById(