1 Commits

Author SHA1 Message Date
db37684595 Update Data/SqliteClientRepository.cs 2025-07-30 18:46:00 +00:00

View File

@@ -3,7 +3,6 @@ using System.Threading.Tasks;
using Microsoft.Data.Sqlite;
using Microsoft.Extensions.Configuration;
using Workshop8.Models;
using System;
namespace Workshop8.Data
{
@@ -21,76 +20,43 @@ namespace Workshop8.Data
public async Task<IEnumerable<Cliente>> GetAllClientsAsync()
{
var clients = new List<Cliente>();
var clientes = new List<Cliente>();
// TODO: implementar SELECT
await using var conn = new SqliteConnection("Data Source=database.sqlite;");
await conn.OpenAsync();
using var connection = new SqliteConnection(_connectionString);
await connection.OpenAsync();
var cmd = conn.CreateCommand();
cmd.CommandText = "SELECT Nome, Email, CriadoEm FROM Clientes;";
var command = connection.CreateCommand();
command.CommandText = "SELECT Id, Nome, Email, CriadoEm FROM Clientes";
using var reader = await command.ExecuteReaderAsync();
await using var reader = await cmd.ExecuteReaderAsync();
while (await reader.ReadAsync())
{
clients.Add(new Cliente
var p = new Cliente
{
Id = reader.GetInt32(0),
Nome = reader.GetString(1),
Email = reader.GetString(2),
CriadoEm = reader.GetDateTime(3)
});
Email = reader.GetString(1),
CriadoEm = reader.GetDateTime(2)
};
clientes.Add(p);
}
return clients;
return clientes;
}
public async Task AddClientAsync(Cliente c)
{
using var connection = new SqliteConnection(_connectionString);
await connection.OpenAsync();
var command = connection.CreateCommand();
command.CommandText = @"
INSERT INTO Clientes (Nome, Email, CriadoEm)
VALUES ($nome, $email, $criadoEm);
";
command.Parameters.AddWithValue("$nome", c.Nome);
command.Parameters.AddWithValue("$email", c.Email);
command.Parameters.AddWithValue("$criadoEm", c.CriadoEm);
await command.ExecuteNonQueryAsync();
// TODO: implementar INSERT
}
public async Task UpdateClientAsync(Cliente c)
{
using var connection = new SqliteConnection(_connectionString);
await connection.OpenAsync();
var command = connection.CreateCommand();
command.CommandText = @"
UPDATE Clientes
SET Nome = $nome, Email = $email
WHERE Id = $id;
";
command.Parameters.AddWithValue("$nome", c.Nome);
command.Parameters.AddWithValue("$email", c.Email);
command.Parameters.AddWithValue("$id", c.Id);
await command.ExecuteNonQueryAsync();
// TODO: implementar UPDATE
}
public async Task DeleteClientAsync(int id)
{
using var connection = new SqliteConnection(_connectionString);
await connection.OpenAsync();
var command = connection.CreateCommand();
command.CommandText = "DELETE FROM Clientes WHERE Id = $id;";
command.Parameters.AddWithValue("$id", id);
await command.ExecuteNonQueryAsync();
// TODO: implementar DELETE
}
}
}