csharp-uebung/FahrzeugDatenBank/FahrzeugRepository.cs

using MySqlConnector;

namespace FahrzeugDatenBank;

public class FahrzeugRepository
{
    private string _connectionString;

    public FahrzeugRepository(string connectionString)
    {
        _connectionString = connectionString;
    }

    public List<FahrzeugDTO> HoleAlleFahrzeuge()
    {
        using var datenbankVerbindung = new MySqlConnection(_connectionString);
        datenbankVerbindung.Open();

        const string query = "SELECT id, fahrzeug_name, fahrzeug_typ FROM fahrzeuge";
        using var kommando = new MySqlCommand(query, datenbankVerbindung);
        var reader = kommando.ExecuteReader();

        List<FahrzeugDTO> fahrzeugs = new();
        while (reader.Read())
        {
            var fahrzeug = new FahrzeugDTO();
            fahrzeug.Id = reader.GetInt32(0);
            fahrzeug.Name = reader.GetString(1);
            fahrzeug.Typ = reader.GetString(2);

            fahrzeugs.Add(fahrzeug);
        }

        return fahrzeugs;
    }

    public void FuegeFahrzeugEin(string fahrzeugName, string fahrzeugTyp)
    {
        using var datenbankVerbindung = new MySqlConnection(_connectionString);
        datenbankVerbindung.Open();

        const string query = "INSERT INTO fahrzeuge (fahrzeug_name, fahrzeug_typ)" + "VALUES (@fahrzeug_name, @fahrzeug_typ);";
        using var kommando = new MySqlCommand(query, datenbankVerbindung);
        kommando.Parameters.AddWithValue("@fahrzeug_name", fahrzeugName);
        kommando.Parameters.AddWithValue("@fahrzeug_typ", fahrzeugTyp);
        kommando.ExecuteNonQuery();
    }
}