use NpgsqlSqlNullabilityProcessor

Author: PawelGerr

src/Thinktecture.EntityFrameworkCore.PostgreSQL/EntityFrameworkCore/Query/ThinktectureNpgsqlSqlNullabilityProcessor.cs

@@ -1,15 +1,16 @@
 using System.Diagnostics.CodeAnalysis;
 using Microsoft.EntityFrameworkCore.Query;
 using Microsoft.EntityFrameworkCore.Query.SqlExpressions;
+using Npgsql.EntityFrameworkCore.PostgreSQL.Query.Internal;
 using Thinktecture.EntityFrameworkCore.Query.SqlExpressions;
 
 namespace Thinktecture.EntityFrameworkCore.Query;
 
 /// <summary>
-/// Extends <see cref="SqlNullabilityProcessor"/> to support Thinktecture extensions.
+/// Extends <see cref="NpgsqlSqlNullabilityProcessor"/> to support Thinktecture extensions.
 /// </summary>
 [SuppressMessage("Usage", "EF1001", MessageId = "Internal EF Core API usage.")]
-public class ThinktectureNpgsqlSqlNullabilityProcessor : SqlNullabilityProcessor
+public class ThinktectureNpgsqlSqlNullabilityProcessor : NpgsqlSqlNullabilityProcessor
 {
    /// <inheritdoc />
    public ThinktectureNpgsqlSqlNullabilityProcessor(

tests/Thinktecture.EntityFrameworkCore.PostgreSQL.Tests/EntityFrameworkCore/Query/ThinktectureNpgsqlSqlNullabilityProcessorTests.cs

@@ -0,0 +1,28 @@
+using Thinktecture.TestDatabaseContext;
+
+namespace Thinktecture.EntityFrameworkCore.Query;
+
+public class ThinktectureNpgsqlSqlNullabilityProcessorTests : IntegrationTestsBase
+{
+   public ThinktectureNpgsqlSqlNullabilityProcessorTests(ITestOutputHelper testOutputHelper, NpgsqlFixture npgsqlFixture)
+      : base(testOutputHelper, npgsqlFixture)
+   {
+   }
+
+   [Fact]
+   public async Task Should_handle_HashSet_Contains_translated_to_PgAnyExpression()
+   {
+      var entityId = new Guid("4883F7E0-FC8C-45FF-A579-DF351A3E79BA");
+      ArrangeDbContext.TestEntities.Add(new TestEntity { Id = entityId, Name = "Test", RequiredName = "RequiredName", Count = 1 });
+      await ArrangeDbContext.SaveChangesAsync();
+
+      var ids = new HashSet<Guid> { entityId };
+
+      var result = await ActDbContext.TestEntities
+                                     .Where(e => ids.Contains(e.Id))
+                                     .ToListAsync();
+
+      result.Should().HaveCount(1);
+      result[0].Id.Should().Be(entityId);
+   }
+}