// Demonstrates: Schema Sync → Query → High-Performance Bulk Insert (Single DbContext)

using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using Microsoft.EntityFrameworkCore;

using DataArc;
using DataArc.Abstractions;

// SAMPLE ENTITY
public class Employee
{
    public int Id { get; set; }
    public string Name { get; set; } = "";
    public decimal Salary { get; set; }
}

// SAMPLE EF CORE CONTEXT
public class AppDbContext : DbContext
{
    public DbSet<Employee> Employees => Set<Employee>();
    public AppDbContext(DbContextOptions<AppDbContext> options) : base(options) { }
}

internal class Program
{
    static readonly IDatabaseDefinitionBuilder _schemaBuilder;
    static readonly IAsyncDatabaseCommandBuilder _commandBuilder;
    static readonly IAsyncDatabaseQueryBuilder _queryBuilder;

    private static int _batchSize = 20000;

    static Program()
    {
        // Logging
        ILoggerFactory factory = LoggerFactory.Create(builder =>
        {
            builder.AddConsole();
        });

        // Register DataArc with one DbContext
        var provider = new ServiceCollection()
            .AddLogging()
            .AddDataArcCore(ctx =>
            {
                ctx.AddDbContextPool<AppDbContext>(opts => opts
                    .UseSqlServer("Server=.;Database=ArcDemo;Integrated Security=True;TrustServerCertificate=True")
                    .UseLoggerFactory(factory));
            })
            .BuildServiceProvider();

        _schemaBuilder = provider.GetRequiredService<IDatabaseDefinitionBuilder>();
        _commandBuilder = provider.GetRequiredService<IAsyncDatabaseCommandBuilder>();
        _queryBuilder = provider.GetRequiredService<IAsyncDatabaseQueryBuilder>();
    }

    static async Task ExecuteMain()
    {
        // --- SCHEMA CREATION ---
        var schema = _schemaBuilder
            .UseContext<AppDbContext>()
            .Build(applyChanges: true, generateScripts: false);

        schema.ExecuteCreate();

        // --- QUERY SAMPLE ---
        var existing = await _queryBuilder
            .UseQueryContext<AppDbContext>()
            .ReadWhereAsync<Employee>(e => e.Salary > 50000);

        Console.WriteLine($"Found {existing.Count} employees with salary > 50000.");

        // --- BULK INSERT SAMPLE ---
        var bulkPipeline = await _commandBuilder
            .UseCommandContext<AppDbContext>()
            .AddBulk(new[]
            {
                new Employee { Name = "Alice", Salary = 72000 },
                new Employee { Name = "Bob",   Salary = 63000 }
            }, _batchSize)
            .BuildAsync();

        var result = await bulkPipeline.ExecuteAsync();

        Console.WriteLine($"Inserted {result.TotalEntitiesAffected} employees.");
    }

    private static void Main(string[] args)
    {
        ExecuteMain().GetAwaiter().GetResult();
    }
}