diff --git a/Directory.Packages.props b/Directory.Packages.props index 91dc3609d41664bb48f024ebefd6cbb7bd8160ba..6fcdd2a82755b3cc06e2f1acf8f58219f3e49a3a 100644 --- a/Directory.Packages.props +++ b/Directory.Packages.props @@ -2,7 +2,7 @@ 6.0.0-rc.1.21406.1 6.0.0-rc.1.21401.3 - 6.0.0-preview6 + 6.0.0-preview7 diff --git a/src/EFCore.PG/Update/Internal/NpgsqlModificationCommandBatch.cs b/src/EFCore.PG/Update/Internal/NpgsqlModificationCommandBatch.cs index 8be9a60d6d4da84d721306563fb54f1badb00763..2e51128b58b019d92297dba04c161aa1ce0aad50 100644 --- a/src/EFCore.PG/Update/Internal/NpgsqlModificationCommandBatch.cs +++ b/src/EFCore.PG/Update/Internal/NpgsqlModificationCommandBatch.cs @@ -71,7 +71,11 @@ protected override bool IsCommandTextValid() protected override void Consume(RelationalDataReader reader) { var npgsqlReader = (NpgsqlDataReader)reader.DbDataReader; + +#pragma warning disable 618 Debug.Assert(npgsqlReader.Statements.Count == ModificationCommands.Count, $"Reader has {npgsqlReader.Statements.Count} statements, expected {ModificationCommands.Count}"); +#pragma warning restore 618 + var commandIndex = 0; try @@ -89,6 +93,7 @@ protected override void Consume(RelationalDataReader reader) // make sure they executed for (; commandIndex < nextPropagating; commandIndex++) { +#pragma warning disable 618 if (npgsqlReader.Statements[commandIndex].Rows == 0) { throw new DbUpdateConcurrencyException( @@ -96,6 +101,7 @@ protected override void Consume(RelationalDataReader reader) ModificationCommands[commandIndex].Entries ); } +#pragma warning restore 618 } if (nextPropagating == ModificationCommands.Count) @@ -139,7 +145,11 @@ protected override void Consume(RelationalDataReader reader) CancellationToken cancellationToken = default) { var npgsqlReader = (NpgsqlDataReader)reader.DbDataReader; + +#pragma warning disable 618 Debug.Assert(npgsqlReader.Statements.Count == ModificationCommands.Count, $"Reader has {npgsqlReader.Statements.Count} statements, expected {ModificationCommands.Count}"); +#pragma warning restore 618 + var commandIndex = 0; try @@ -158,6 +168,7 @@ protected override void Consume(RelationalDataReader reader) // make sure they executed for (; commandIndex < nextPropagating; commandIndex++) { +#pragma warning disable 618 if (npgsqlReader.Statements[commandIndex].Rows == 0) { throw new DbUpdateConcurrencyException( @@ -165,6 +176,7 @@ protected override void Consume(RelationalDataReader reader) ModificationCommands[commandIndex].Entries ); } +#pragma warning restore 618 } if (nextPropagating == ModificationCommands.Count)