Lekcja 16. Tworzenie aplikacji WPF z bazą danych SQLite

Kod (C#)

// BazaDanych.cs - cala logika SQL w jednym miejscu
using Microsoft.Data.Sqlite;
using System.Collections.Generic;

namespace SklepApp
{
    public class Produkt
    {
        public int Id { get; set; }
        public string Nazwa { get; set; } = "";
        public decimal Cena { get; set; }
    }

    public class BazaDanych
    {
        private const string ConnectionString = "Data Source=sklep.db";

        public BazaDanych()
        {
            using var polaczenie = new SqliteConnection(ConnectionString);
            polaczenie.Open();

            var utworzTabele = polaczenie.CreateCommand();
            utworzTabele.CommandText = @"
                CREATE TABLE IF NOT EXISTS Produkty (
                    Id INTEGER PRIMARY KEY AUTOINCREMENT,
                    Nazwa TEXT NOT NULL,
                    Cena REAL NOT NULL
                )";
            utworzTabele.ExecuteNonQuery();
        }

        public void DodajProdukt(string nazwa, decimal cena)
        {
            using var polaczenie = new SqliteConnection(ConnectionString);
            polaczenie.Open();

            var polecenie = polaczenie.CreateCommand();
            polecenie.CommandText = "INSERT INTO Produkty (Nazwa, Cena) VALUES ($nazwa, $cena)";
            polecenie.Parameters.AddWithValue("$nazwa", nazwa);
            polecenie.Parameters.AddWithValue("$cena", cena);
            polecenie.ExecuteNonQuery();
        }

        public List<Produkt> PobierzWszystkie()
        {
            var wynik = new List<Produkt>();
            using var polaczenie = new SqliteConnection(ConnectionString);
            polaczenie.Open();

            var polecenie = polaczenie.CreateCommand();
            polecenie.CommandText = "SELECT Id, Nazwa, Cena FROM Produkty";

            using var czytnik = polecenie.ExecuteReader();
            while (czytnik.Read())
            {
                wynik.Add(new Produkt
                {
                    Id = czytnik.GetInt32(),
                    Nazwa = czytnik.GetString(1),
                    Cena = (decimal)czytnik.GetDouble(2)
                });
            }
            return wynik;
        }

        public void UsunProdukt(int id)
        {
            using var polaczenie = new SqliteConnection(ConnectionString);
            polaczenie.Open();

            var polecenie = polaczenie.CreateCommand();
            polecenie.CommandText = "DELETE FROM Produkty WHERE Id = $id";
            polecenie.Parameters.AddWithValue("$id", id);
            polecenie.ExecuteNonQuery();
        }
    }
}