// Entity Framework Extensions

// Doc: https://entityframework-extensions.net/where-bulk-contains#can-i-use-wherebulkcontains-with-updatefromquery-and-deletefromquery

​

// @nuget: Newtonsoft.Json

// @nuget: Microsoft.EntityFrameworkCore.SqlServer

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

​

using System;

using System.Collections.Generic;

using System.ComponentModel.DataAnnotations.Schema;

using System.Dynamic;

using System.Linq;

using Microsoft.Data.SqlClient;

using Microsoft.EntityFrameworkCore;

using Newtonsoft.Json;

public class Program

{

    public static void Main()

    {

        // Doc: https://entityframework-extensions.net/where-bulk-contains#can-i-use-wherebulkcontains-with-updatefromquery-and-deletefromquery

        SeedDatabase();

        var deserializedCustomers = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Customer>>(GetSerializedCustomers());

        FiddleHelper.WriteTable("1 - DeserializedCustomers", deserializedCustomers);

​

        // ## Can I use WhereBulkContains with UpdateFromQuery and DeleteFromQuery?

        // The `WhereBulkContains` method is compatible with our batch methods:

        //

        // - UpdateFromQuery: https://entityframework-extensions.net/update-from-query

        // - DeleteFromQuery: https://entityframework-extensions.net/delete-from-query

        // - InsertFromQuery: https://entityframework-extensions.net/insert-from-query

        {

            using (var context = new EntityContext())

            {

                // - UpdateFromQuery: https://entityframework-extensions.net/update-from-query

                context.Customers.WhereBulkContains(deserializedCustomers).UpdateFromQuery(x => new { FirstName = "UpdateFromQuery" });

                FiddleHelper.WriteTable("2 - UpdateFromQuery", context.Customers.AsNoTracking().ToList());

            }

            using (var context = new EntityContext())

            {

                // - DeleteFromQuery: https://entityframework-extensions.net/delete-from-query

                // Note: We used `WhereBulkNotContains` for example purpose

                context.Customers.WhereBulkNotContains(deserializedCustomers).DeleteFromQuery();

                FiddleHelper.WriteTable("3 - DeleteFromQuery", context.Customers.AsNoTracking().ToList());

            }

            using (var context = new EntityContext())

            {

                // - InsertFromQuery: https://entityframework-extensions.net/insert-from-query

                context.Customers.WhereBulkContains(deserializedCustomers).InsertFromQuery(x => new { x.Code, FirstName = "Copied", x.LastName, x.Email });

                FiddleHelper.WriteTable("4 - InsertFromQuery", context.Customers.AsNoTracking().ToList());

            }

        }

    }

​

    public static void SeedDatabase()

    {

        using (var context = new EntityContext())

        {

            var list = new List<Customer>();

​

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

            {

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

            }

​

            context.BulkInsert(list);

        }

    }

​

    public static string GetSerializedCustomers()

    {

        var customers = new List<Customer>();

​

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

        {

            customers.Add(new Customer() { CustomerID = i + 1, Code = "Original_" + i, Email = "Updated_" + i, FirstName = "Updated_" + i, LastName = "Updated_" + i });

        }

​

        return JsonConvert.SerializeObject(customers);

    }

​

    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()));

​

            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; }

    }

}