// Entity Framework Extensions

// Doc: https://entityframework-extensions.net/matched-and-condition

​

// @nuget: Microsoft.EntityFrameworkCore.SqlServer

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

​

using System;

using System.Linq;

using Microsoft.EntityFrameworkCore;

using System.Collections.Generic;

using Microsoft.Data.SqlClient;

using Z.BulkOperations;

​

public class Program

{

    public static void Main()

    {

        // SCENARIO: https://entityframework-extensions.net/matched-and-condition

        // CREATE & SEED

        using (var context = new EntityContext())

        {

            context.Database.EnsureCreated();

            var customers = new List<Customer>();

            // "Jonathan" is currently locked in the database. No modification can be done on this customer.

            customers.Add(new Customer() { CustomerID = 1, Name = "Jonathan", Email = "Email_Jonathan", Note = "Note_Jonathan", IsLocked = true });

            customers.Add(new Customer() { CustomerID = 2, Name = "Mikael", Email = "Email_Mikael", Note = "Note_Mikael", IsLocked = false });

            customers.Add(new Customer() { CustomerID = 3, Name = "Sara", Email = "Email_Sara", Note = "Note_Sara", IsLocked = false });

            context.BulkInsert(customers, options => { options.InsertKeepIdentity = true; });

            FiddleHelper.WriteTable("1 - Before BulkSynchronize", context.Customers.ToList());

        }

​

        using (var context = new EntityContext())

        {

            var customers = new List<Customer>();

            // DATA coming from an importation

            customers.Add(new Customer() { CustomerID = 1, Name = "Jonathan (Updated)", Email = "Email_Jonathan (Updated)", Note = "Note_Jonathan (Updated)" });

            customers.Add(new Customer() { CustomerID = 2, Name = "Mikael (Updated)", Email = "Email_Mikael (Updated)", Note = "Note_Mikael (Updated)"  });

            customers.Add(new Customer() { CustomerID = 3, Name = "Sara (Updated)", Email = "Email_Sara (Updated)", Note = "Note_Sara (Updated)"});

            customers.ForEach(x => x.IsLocked = false);

            context.BulkSynchronize(customers, options => 

            {

                // ON UPDATE, modify customers that has the same `IsLocked` value (always "false" on the source)

                options.SynchronizeMatchedAndConditionExpression = x => new { x.IsLocked };

            });

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

        }

    }

    public class EntityContext : DbContext

    {

        public EntityContext() 

        {

        }

​

        protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)

        {

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

​

            base.OnConfiguring(optionsBuilder);

        }

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

    }

    public class Customer

    {

        public int CustomerID { get; set; }

        public string Name { get; set; }

        public string Email { get; set; }

        public string Note { get; set; }

        public bool IsLocked { get; set; }

    }

}