Added Card model, updated database initialization, udated readme.
This commit is contained in:
50
SDG-Backend-Barracuda/Models/CardModel.cs
Normal file
50
SDG-Backend-Barracuda/Models/CardModel.cs
Normal file
@@ -0,0 +1,50 @@
|
||||
using Dapper;
|
||||
using Npgsql;
|
||||
|
||||
namespace SDG_Backend_Barracuda.Models;
|
||||
|
||||
public record Card(int Id, string Value);
|
||||
public record CardInput(string Value);
|
||||
|
||||
public interface ICardModel : IDatabaseModel<Card, CardInput>
|
||||
{
|
||||
}
|
||||
|
||||
public class CardModel(NpgsqlDataSource dataSource) : ICardModel
|
||||
{
|
||||
public async Task<IEnumerable<Card>> GetAllAsync()
|
||||
{
|
||||
await using var connection = await dataSource.OpenConnectionAsync();
|
||||
var sql = """SELECT "Id", "Value" FROM "Card";""";
|
||||
return await connection.QueryAsync<Card>(sql);
|
||||
}
|
||||
|
||||
public async Task<Card?> GetByIdAsync(int id)
|
||||
{
|
||||
await using var connection = await dataSource.OpenConnectionAsync();
|
||||
var sql = """SELECT "Id", "Value" FROM "Card" WHERE "Id" = @Id;""";
|
||||
return await connection.QueryFirstOrDefaultAsync<Card>(sql, new { Id = id });
|
||||
}
|
||||
|
||||
public async Task<Card> CreateAsync(CardInput input)
|
||||
{
|
||||
await using var connection = await dataSource.OpenConnectionAsync();
|
||||
var sql = """INSERT INTO "Card" ("Value") VALUES (@Value) RETURNING "Id", "Value";""";
|
||||
return await connection.QuerySingleAsync<Card>(sql, input);
|
||||
}
|
||||
|
||||
public async Task<Card?> UpdateAsync(int id, CardInput input)
|
||||
{
|
||||
await using var connection = await dataSource.OpenConnectionAsync();
|
||||
var sql = """UPDATE "Card" SET "Value" = @Value WHERE "Id" = @Id RETURNING "Id", "Value";""";
|
||||
return await connection.QueryFirstOrDefaultAsync<Card>(sql, new { Id = id, Value = input.Value });
|
||||
}
|
||||
|
||||
public async Task<bool> DeleteAsync(int id)
|
||||
{
|
||||
await using var connection = await dataSource.OpenConnectionAsync();
|
||||
var sql = """DELETE FROM "Card" WHERE "Id" = @Id;""";
|
||||
var rowsAffected = await connection.ExecuteAsync(sql, new { Id = id });
|
||||
return rowsAffected > 0;
|
||||
}
|
||||
}
|
||||
10
SDG-Backend-Barracuda/Models/IDatabaseModel.cs
Normal file
10
SDG-Backend-Barracuda/Models/IDatabaseModel.cs
Normal file
@@ -0,0 +1,10 @@
|
||||
namespace SDG_Backend_Barracuda.Models;
|
||||
|
||||
public interface IDatabaseModel<T, in TInput>
|
||||
{
|
||||
Task<IEnumerable<T>> GetAllAsync();
|
||||
Task<T?> GetByIdAsync(int id);
|
||||
Task<T> CreateAsync(TInput input);
|
||||
Task<T?> UpdateAsync(int id, TInput input);
|
||||
Task<bool> DeleteAsync(int id);
|
||||
}
|
||||
Reference in New Issue
Block a user