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().WithMaxScanRows(1).GetEnumerator();

            var r2 = ChoCSVReader.LoadText(csv2).WithFirstLineHeader().WithMaxScanRows(1).GetEnumerator();

​

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

            {

                var b1 = r1.MoveNext();

                var b2 = r2.MoveNext();

                dynamic rec = null;

​

                while (true)

                {

                    if (!b1 && !b2)

                        break;

                    else if (b1 && b2)

                    {

                        var rec1 = r1.Current;

                        var rec2 = r2.Current;

​

                        if (rec1.ID == rec2.ID)

                        {

                            rec = rec2;

                            rec.Status = ChoDynamicObjectEqualityComparer.Default.Equals(rec1, rec2) ? "NOCHANGE" : "CHANGED";

                            b1 = r1.MoveNext();

                            b2 = r2.MoveNext();

                        }

                        else if (rec1.ID < rec2.ID)

                        {

                            rec = rec1;

                            rec.Status = "DELETED";

                            b1 = r1.MoveNext();

                        }

                        else

                        {

                            rec = rec2;

                            rec.Status = "NEW";

                            b2 = r2.MoveNext();

                        }

                    }

                    else if (b1)

                    {

                        rec = r1.Current;

                        rec.Status = "DELETED";

                        b1 = r1.MoveNext();

                    }

                    else if (b2)

                    {

                        rec = r2.Current;

                        rec.Status = "NEW";

                        b2 = r2.MoveNext();

                    }

                    else

                        break;

​

                    w.Write(rec);

                }

            }

    }

}