Files
workshop8/Data/SqliteClientRepository.cs

63 lines
1.8 KiB
C#

using System.Collections.Generic;
using System.Threading.Tasks;
using Microsoft.Data.Sqlite;
using Microsoft.Extensions.Configuration;
using Workshop8.Models;
namespace Workshop8.Data
{
public class SqliteClientRepository : IClientRepository
{
private readonly string _connectionString;
public SqliteClientRepository(IConfiguration configuration)
{
var dbConfig = configuration.GetSection("Database");
_connectionString = dbConfig.GetValue<bool>("UseRemote")
? dbConfig.GetValue<string>("Remote")
: dbConfig.GetValue<string>("Local");
}
public async Task<IEnumerable<Cliente>> GetAllClientsAsync()
{
var clientes = new List<Cliente>();
// TODO: implementar SELECT
await using var conn = new SqliteConnection("Data Source=database.sqlite;");
await conn.OpenAsync();
var cmd = conn.CreateCommand();
cmd.CommandText = "SELECT Nome, Email, CriadoEm FROM Clientes;";
await using var reader = await cmd.ExecuteReaderAsync();
while (await reader.ReadAsync())
{
var p = new Cliente
{
Id = reader.GetInt32(0),
Email = reader.GetString(1),
CriadoEm = reader.GetDateTime(2)
};
clientes.Add(p);
}
return clientes;
}
public async Task AddClientAsync(Cliente c)
{
// TODO: implementar INSERT
}
public async Task UpdateClientAsync(Cliente c)
{
// TODO: implementar UPDATE
}
public async Task DeleteClientAsync(int id)
{
// TODO: implementar DELETE
}
}
}