// Licensed to the .NET Foundation under one or more agreements.
// The .NET Foundation licenses this file to you under the MIT license.
 
using Dapper;
using MySqlConnector;
 
var builder = WebApplication.CreateBuilder(args);
 
// Add services to the container.
 
builder.AddServiceDefaults();
 
builder.Services.AddProblemDetails();
builder.AddMySqlDataSource("Catalog");
builder.AddKeyedMySqlDataSource("myTestDb2");
 
var app = builder.Build();
 
// Configure the HTTP request pipeline.
app.MapDefaultEndpoints();
app.MapGet("/catalog", async (MySqlConnection db) =>
{
    const string sql = """
                SELECT Id, Name, Description, Price
                FROM catalog
                """;
 
    return await db.QueryAsync<CatalogItem>(sql);
});
 
app.MapGet("/catalog/{id}", async (int id, MySqlConnection db) =>
{
    const string sql = """
                SELECT Id, Name, Description, Price
                FROM catalog
                WHERE Id = @id
                """;
 
    return await db.QueryFirstOrDefaultAsync<CatalogItem>(sql, new { id }) is { } item
        ? Results.Ok(item)
        : Results.NotFound();
});
 
app.MapPost("/catalog", async (CatalogItem item, MySqlConnection db) =>
{
    const string sql = """
                INSERT INTO catalog (Name, Description, Price)
                VALUES (@Name, @Description, @Price);
                SELECT LAST_INSERT_ID();
                """;
 
    var id = await db.ExecuteScalarAsync<int>(sql, item);
    return Results.Created($"/catalog/{id}", id);
});
 
app.MapDelete("/catalog/{id}", async (int id, MySqlConnection db) =>
{
    const string sql = """
                DELETE FROM catalog
                WHERE Id = @id
                """;
 
    var rows = await db.ExecuteAsync(sql, new { id });
    return rows > 0 ? Results.NoContent() : Results.NotFound();
});
 
app.MapGet("/myTestDb2", async ([FromKeyedServices("myTestDb2")] MySqlConnection db) =>
{
    const string sql = """
                SELECT id, name
                FROM example_table
                """;
 
    return await db.QueryAsync<ExampleTableItem>(sql);
});
 
app.Run();
 
public record CatalogItem(int Id, string Name, string Description, decimal Price);
public record ExampleTableItem(int Id, string Name);