// Entity Framework Extensions

// Doc: https://entityframework-extensions.net/where-bulk-contains

​

// @nuget: Newtonsoft.Json

// @nuget: Microsoft.EntityFrameworkCore.SqlServer

// @nuget: Z.EntityFramework.Extensions.EFCore

​

​

using System.Collections.Generic;

using System.ComponentModel.DataAnnotations.Schema;

using System.Threading;

using Microsoft.Data.SqlClient;

using Microsoft.EntityFrameworkCore;

public class Program

{

    public static void Main()

    {

        // Doc: https://entityframework-extensions.net/where-bulk-contains

        using (var context = new EntityContext())

        {

            for (int i = 0; i < 5; i++)

            {

                context.Customers.Add(new Customer() { Code = "Original_" + i, Email = "Original_" + i, FirstName = "Original_" + i, LastName = "Original_" + i });

            }

​

            context.SaveChanges();

            // The `JOIN` statement will use the default entity key if none is provided (CustomerID)

            var customers1 = context.Customers.WhereBulkContains(new List<int> {999999});

            FiddleHelper.WriteTable("1 - WhereBulkContains + Default Key", customers1);

            var customers2 = context.Customers.WhereBulkContains(new List<int> {999999}, x => x.CustomerID);

            FiddleHelper.WriteTable("2 - WhereBulkContains + Specified Key", customers2);

            var customers3 = context.Customers.BulkRead(new List<int> {999999});

            FiddleHelper.WriteTable("3 - BulkRead + Default Key", customers3);

            var customers4 = context.Customers.BulkRead(new List<int> {999999}, x => x.CustomerID);

            FiddleHelper.WriteTable("4 - BulkRead + Specified Key", customers4);

        }

    }

​

    public class FixInterceptor : Microsoft.EntityFrameworkCore.Diagnostics.DbCommandInterceptor

    {

    }

    public class EntityContext : DbContext

    {

        static EntityContext()

        {

            using (var context = new EntityContext())

            {

                context.Database.EnsureCreated();

            }

        }

        public DbSet<Customer> Customers { get; set; }

​

        protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)

        {

            optionsBuilder.UseSqlServer(new SqlConnection(FiddleHelper.GetConnectionStringSqlServer())).AddInterceptors(new FixInterceptor());

​

            base.OnConfiguring(optionsBuilder);

        }

    }

​

    [Table("Customer")]

    public class Customer

    {

        public int CustomerID { get; set; }

        public string Code { get; set; }

        public string Email { get; set; }

        public string FirstName { get; set; }

        public string LastName { get; set; }

    }

}