using System;

using ChoETL;

using System.Linq;

​

public class Program

{

    public static void Main()

    {

            string csv1 = @"ID,name

1,Danny

2,Fred

3,Sam";

​

            string csv2 = @"ID,name

1,Danny

3,Pamela

4,Fernando";

​

            var r1 = ChoCSVReader.LoadText(csv1).WithFirstLineHeader().ToArray();

            var r2 = ChoCSVReader.LoadText(csv2).WithFirstLineHeader().ToArray();

​

            using (var w = new ChoCSVWriter(Console.Out).WithFirstLineHeader())

            {

                var newItems = r2.OfType<ChoDynamicObject>().Except(r1.OfType<ChoDynamicObject>(), new ChoDynamicObjectEqualityComparer(new string[] { "ID" }))

                    .Select(r => 

                    {

                        var dict = r.AsDictionary();

                        dict["Status"] = "NEW"; 

                        return new ChoDynamicObject(dict); 

                    }).ToArray();

​

                var deletedItems = r1.OfType<ChoDynamicObject>().Except(r2.OfType<ChoDynamicObject>(), new ChoDynamicObjectEqualityComparer(new string[] { "ID" }))

                    .Select(r =>

                    {

                        var dict = r.AsDictionary();

                        dict["Status"] = "DELETED";

                        return new ChoDynamicObject(dict);

                    }).ToArray();

​

                var changedItems = r2.OfType<ChoDynamicObject>().Except(r1.OfType<ChoDynamicObject>(), ChoDynamicObjectEqualityComparer.Default)

                    .Except(newItems.OfType<ChoDynamicObject>(), new ChoDynamicObjectEqualityComparer(new string[] { "ID" }))

                    .Select(r =>

                    {

                        var dict = r.AsDictionary();

                        dict["Status"] = "CHANGED";

                        return new ChoDynamicObject(dict);

                    }).ToArray();

​

                var noChangeItems = r1.OfType<ChoDynamicObject>().Intersect(r2.OfType<ChoDynamicObject>(), ChoDynamicObjectEqualityComparer.Default)

                    .Select(r =>

                    {

                        var dict = r.AsDictionary();

                        dict["Status"] = "NOCHANGE";

                        return new ChoDynamicObject(dict);

                    }).ToArray();

​

                var finalResult = Enumerable.Concat(newItems, deletedItems).Concat(changedItems).Concat(noChangeItems).OfType<dynamic>().OrderBy(r => r.ID);

                w.Write(finalResult);

            }

​

            Console.WriteLine();

    }

}