// Entity Framework Extensions

// Doc: https://entityframework-extensions.net/bulk-merge

​

// @nuget: Microsoft.Data.SqlClient -Version 3.0.0

// @nuget: Microsoft.EntityFrameworkCore.SqlServer -Version 5.0.7

// @nuget: Z.EntityFramework.Extensions.EFCore -Version 5.1.39

​

using Microsoft.EntityFrameworkCore;

using Microsoft.EntityFrameworkCore.SqlServer;

using System.Collections.Generic;

using System.Linq;

using System.ComponentModel.DataAnnotations;

using System.ComponentModel.DataAnnotations.Schema;

using System.Data.SqlClient;

using System;

public class Program

{

    public static void Main()

    {

        using (var context = new EntityContext())

        {

            context.Database.EnsureCreated();

        }

        var XXXQueues = GenerateXXXQueues(5);

        using (var context = new EntityContext())

        {

            FiddleHelper.WriteTable("1 - XXXQueues Before", context.XXXQueues.AsNoTracking()); 

            // only new 

            context.BulkMerge(XXXQueues); 

​

            FiddleHelper.WriteTable("2 - XXXQueues After insert only ", context.XXXQueues.AsNoTracking()); 

            XXXQueues.ForEach(x => x.XXXTopic = "IsUpdate");

            var listToAdd = GenerateXXXQueues(5);

            // also have one data with set value for guid. 

            listToAdd.First().Id = Guid.NewGuid();

            XXXQueues.AddRange(listToAdd);

            context.BulkMerge(XXXQueues); 

​

            FiddleHelper.WriteTable("3 - XXXQueues After insert and Update", context.XXXQueues.AsNoTracking()); 

        }   

    } 

    public static List<XXXQueue> GenerateXXXQueues(int countXXXQueue) 

    {

        List<XXXQueue>  list = new List<XXXQueue>();

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

        {

            var XXXQueue = new XXXQueue() { CreatedDate = DateTime.Now };

            list.Add(XXXQueue); 

        }

        return list;

    } 

    public class EntityContext : DbContext

    {

        public EntityContext() 

        {

        }

​

        protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)

        {

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

​

            base.OnConfiguring(optionsBuilder);

        }

        public DbSet<XXXQueue> XXXQueues { get; set; } 

    }

     [Table("XXX_Queue")]

    public partial class XXXQueue

    {

        public XXXQueue()

        {

            #region Generated Constructor

​

            #endregion

        }

​

        #region Generated Properties

        [Key]

        public Guid Id { get; set; }

        [Column(TypeName = "varchar")]

        [StringLength(50)]

        public string XXXId { get; set; }

        [Column(TypeName = "varchar")]

        [StringLength(100)]

        public string XXXTopic { get; set; }

        [Column(TypeName = "varchar")]

        [StringLength(50)]

        public string XXXOrgId { get; set; }

        [Column(TypeName = "nvarchar")]

        [StringLength(225)]

        public string XXXHmacSha256 { get; set; }

        [Column(TypeName = "nvarchar")]

        [StringLength(60)]

        public string TraceParent { get; set; }

        [Column(TypeName = "varchar")]

        [StringLength(20)]

        public string IPAddress { get; set; }

        [Column(TypeName = "nvarchar")]

        [StringLength(512)]

        public string UserAgent { get; set; }

        [Column(TypeName = "ntext")]

        [MaxLength]

        public string Payload { get; set; }

        //[Column(TypeName = "int")]

       // public QueueStatus Status { get; set; }

        [Column(TypeName = "datetime2")]

        public DateTime CreatedDate { get; set; }

        [Column(TypeName = "datetime2")]

        public DateTime? LastModified { get; set; }

        [Column(TypeName = "datetime2")]

        public DateTime? PushDate { get; set; }

        [Column(TypeName = "ntext")]

        public string PushException { get; set; }

        [Column(TypeName = "ntext")]

        public string PushResponse { get; set; }

        [Column(TypeName = "int")]

        public int? PushTimes { get; set; }

        #endregion

​

        #region Generated Relationships

​

​

        #endregion

​

    }

}