using Detached.Annotations;

using Detached.Mappers.EntityFramework;

using Microsoft.Data.Sqlite;

using Microsoft.EntityFrameworkCore;

using System;

using System.Collections.Generic;

using System.Linq;

​

class Program

{

    // this example shows how to use detached to create/update an entity using an anonymous type 

    // as DTO.

    static void Main(string[] args)

    {

        Console.WriteLine("- create entity");

        using (DetachedDbContext context = new DetachedDbContext())

        {

            // create the sqlite db.

            context.Database.EnsureCreated();

​

            // add some invoice types. aggregations are top level independent entities, and expected to be there 

            // when the root entity is mapped.

            context.Add(new InvoiceType { Id = 1, Name = "A" });

            context.Add(new InvoiceType { Id = 2, Name = "B" });

            context.SaveChanges();

​

            // create an invoice by using Map method, passing an anonymous class.

            context.Map<Invoice>(new

            {

                Id = 1,

                InvoiceType = new { Id = 1 },

                Rows = new[]

                {

                    new { Id = 1, Description = "prod 1", Quantity = 5, Price = 25 },

                    new { Id = 2, Description = "prod 2", Quantity = 3, Price = 100 }

                }

            });

​

            context.SaveChanges();

        }

​

        // using is not necessary, but used to simulate different request in a stateless app, like a rest API.

        using (DetachedDbContext context = new DetachedDbContext())

        {

            Invoice persisted = context.Invoices.Where(i => i.Id == 1).Include(i => i.InvoiceType).Include(i => i.Rows).FirstOrDefault();

            // check that all created values are OK.

            Assert(persisted != null, "persisted not null");

            Assert(persisted.InvoiceType != null, "invoice type not null");

            Assert(persisted.InvoiceType.Name == "A", "invoice type is A");

            Assert(persisted.Rows.Count == 2, "row count is 2");

            Assert(persisted.Rows.Any(r => r.Description == "prod 1" && r.Quantity == 5), "row values inserted");

            Assert(persisted.Rows.Any(r => r.Description == "prod 2" && r.Quantity == 3), "row values inserted");

        }

​

        Console.WriteLine("- update entity");

        using (DetachedDbContext context = new DetachedDbContext())

        {

            // update the entity using Map.

            context.Map<Invoice>(new

            {

                Id = 1,

                InvoiceType = new { Id = 2 }, // for aggregations, only Id is needed.

                Rows = new[]

                {

                    new { Id = 1, Description = "prod 1", Quantity = 5, Price = 25 },

                    new { Id = 2, Description = "prod 2 edited", Quantity = 8, Price = 100 }

                }

            });

​

            context.SaveChanges();

        }

​

        using (DetachedDbContext context = new DetachedDbContext())

        {

            Invoice edited = context.Invoices.Where(i => i.Id == 1).Include(i => i.InvoiceType).Include(i => i.Rows).FirstOrDefault();

​

            // check again that all created values are OK.

            Assert(edited != null, "persisted not null");

            Assert(edited.InvoiceType != null, "invoice type not null");

            Assert(edited.InvoiceType.Name == "B", "invoice updated to B");

            Assert(edited.Rows.Count == 2, "row count is 2");

            Assert(edited.Rows.Any(r => r.Description == "prod 2 edited" && r.Quantity == 8), "row values updated");

        }

​

        Console.WriteLine("[test ended]");

        Console.ReadKey();

    }

​

    static void Assert(bool condition, string label)

    {

        if (condition)

            Console.WriteLine($"{label}: ok");

        else

            Console.WriteLine($"{label}: error!");

    }

}

​

class DetachedDbContext : DbContext

{

    static SqliteConnection _connection;

​

    protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)

    {

        if (_connection == null)

        {

            _connection = new SqliteConnection($"DataSource=file:{Guid.NewGuid()}?mode=memory&cache=shared");

            _connection.Open();

        }

​

        optionsBuilder.UseSqlite(_connection)

                      .UseDetached();

    }

​

    public DbSet<Invoice> Invoices { get; set; }

}

​

class Invoice

{

    public int Id { get; set; }

​

    [Aggregation]

    public InvoiceType InvoiceType { get; set; }

​

    [Composition]

    public List<InvoiceRow> Rows { get; set; }

}

​

class InvoiceType

{

    public int Id { get; set; }

​

    public string Name { get; set; }

}

​

class InvoiceRow

{

    public int Id { get; set; }

​

    public string Description { get; set; }

​

    public double Quantity { get; set; }

​

    public double Price { get; set; }

}

​