Klasy modelu oraz DAO dla aplikacji sklep

PC24-SklepWeb/sql/sklep_create.sql

@@ -64,9 +64,8 @@ CREATE TABLE orders
     FOREIGN KEY (customer_email) REFERENCES customers (customer_email),
     -- kolumna customer_email z tej tabeli wskazuje na kolumnę customer_email z tabeli customers
     -- (można wpisać tylko email istniejącego klienta)
-    CHECK (delivery_date >= order_date:: DATE
-)
-    );
+    CHECK (delivery_date >= order_date::DATE)
+);
 
 CREATE TABLE order_products
 (

PC24-SklepWeb/src/main/java/sklep/db/CustomerDAO.java

+package sklep.db;
+
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
+
+import sklep.model.Customer;
+
+public class CustomerDAO {
+    private final DBConnection db;
+
+    CustomerDAO(DBConnection db) {
+        this.db = db;
+    }
+
+    public Customer findByEmail(String email) throws DBException, RecordNotFound {
+        final String sql = "SELECT * FROM customers WHERE customer_email = ?";
+        try (PreparedStatement stmt = db.getSqlConnection().prepareStatement(sql)) {
+            stmt.setString(1, email);
+            try (ResultSet rs = stmt.executeQuery()) {
+                if (rs.next()) {
+                    return customerFromRS(rs);
+                } else {
+                    throw new RecordNotFound("Cannot find customer with email " + email);
+                }
+            }
+        } catch (SQLException e) {
+            throw new DBException("SQL error in CustomerDAO.findById: " + e.getMessage(), e);
+        }
+    }
+
+    public List<Customer> readAll() throws DBException {
+        final String sql = "SELECT * FROM customers";
+        try (PreparedStatement stmt = db.getSqlConnection().prepareStatement(sql)) {
+            try (ResultSet rs = stmt.executeQuery()) {
+                return customerListFromRS(rs);
+            }
+        } catch (SQLException e) {
+            throw new DBException("SQL error in CustomerDAO.readAll: " + e.getMessage(), e);
+        }
+    }
+
+    private List<Customer> customerListFromRS(ResultSet rs) throws SQLException {
+        List<Customer> records = new ArrayList<>();
+        while (rs.next()) {
+            Customer product = customerFromRS(rs);
+            records.add(product);
+        }
+        return records;
+    }
+
+    private Customer customerFromRS(ResultSet rs) throws SQLException {
+        return new Customer(
+                rs.getString("customer_email"),
+                rs.getString("customer_name"),
+                rs.getString("phone_number"),
+                rs.getString("address"),
+                rs.getString("postal_code"),
+                rs.getString("city"));
+    }
+    
+    public void insert(Customer customer) throws DBException {
+        // używać gdy obiekt ma wpisane ID (tu: email)
+        final String sql = "INSERT INTO customers("
+                + "customer_email, customer_name, phone_number, address, postal_code, city)"
+                + " VALUES (?, ?, ?, ?, ?, ?)";
+        try(PreparedStatement stmt = db.getSqlConnection().prepareStatement(sql)) {
+            stmt.setString(1, customer.getEmail());
+            stmt.setString(2, customer.getName());
+            stmt.setString(3, customer.getPhoneNumber());
+            stmt.setString(4, customer.getAddress());
+            stmt.setString(5, customer.getPostalCode());
+            stmt.setString(6, customer.getCity());
+            stmt.executeUpdate();
+        } catch (SQLException e) {
+            throw new DBException("Error during INSERT CUSTOMER", e);
+        }
+    }
+
+    public boolean update(Customer customer) throws DBException {
+        final String sql = "UPDATE customers SET "
+                + " customer_name=?, phone_number=?, address=?, postal_code=?, city=?"
+                + " WHERE customer_email = ?";
+        try(PreparedStatement stmt = db.getSqlConnection().prepareStatement(sql)) {
+            stmt.setString(1, customer.getName());
+            stmt.setString(2, customer.getPhoneNumber());
+            stmt.setString(3, customer.getAddress());
+            stmt.setString(4, customer.getPostalCode());
+            stmt.setString(5, customer.getCity());
+            stmt.setString(6, customer.getEmail());
+            int count = stmt.executeUpdate();
+            return count > 0;
+        } catch (SQLException e) {
+            throw new DBException("Error during UPDATE CUSTOMER", e);
+        } 
+    }
+    
+    public void save(Customer customer) throws DBException {
+        if(customer.getEmail() == null) {
+            throw new IllegalArgumentException("Customer email cannot be null");
+        } else {
+            if(! update(customer)) {
+                insert(customer);
+            }
+        }
+    }
+    
+    public boolean delete(String email) throws DBException {
+        final String sql = "DELETE FROM customers WHERE customer_email = ?";
+        try(PreparedStatement stmt = db.getSqlConnection().prepareStatement(sql)) {
+            stmt.setString(1, email);
+            int count = stmt.executeUpdate();
+            return count > 0;
+        } catch (SQLException e) {
+            throw new DBException("Error during DELETE CUSTOMER", e);
+        } 
+    }
+
+    public boolean delete(Customer customer) throws DBException {
+        return delete(customer.getEmail());
+    }
+    
+}

PC24-SklepWeb/src/main/java/sklep/db/DBConnection.java

+package sklep.db;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.SQLException;
+import java.util.Properties;
+
+public class DBConnection implements AutoCloseable {
+    private Connection sqlConnection;
+
+    private DBConnection(Connection sqlConnection) {
+        this.sqlConnection = sqlConnection;
+    }
+
+    public static DBConnection open() throws DBException {
+        return open(false);
+    }
+    
+    public static DBConnection open(boolean autoCommit) throws DBException {
+        try {
+            Properties props = DBSettings.load();
+            if(props.containsKey("driver_class")) {
+                Class.forName(props.getProperty("driver_class"));
+            }
+            Connection c = DriverManager.getConnection(props.getProperty("url") , props);
+            c.setAutoCommit(autoCommit);
+            return new DBConnection(c);
+        } catch (ClassNotFoundException | SQLException e) {
+            throw new DBException("Cannot connect to postgresql: " + e, e);
+        }
+    }
+
+    public static DBConnection openLocalhost() throws DBException {
+        try {
+            Connection c = DriverManager.getConnection("jdbc:postgresql://localhost/sklep", "kurs", "abc123");
+            c.setAutoCommit(false);
+            return new DBConnection(c);
+        } catch (SQLException e) {
+            throw new DBException("Cannot connect to postgresql: " + e, e);
+        }
+    }
+
+    @Override
+    public void close() {
+        try {
+            if (sqlConnection != null) {
+                sqlConnection.close();
+                sqlConnection = null;
+            }
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+    }
+
+    public Connection getSqlConnection() {
+        return sqlConnection;
+    }
+    
+    public void commit() throws DBException {
+        try {
+            sqlConnection.commit();
+        } catch (SQLException e) {
+            throw new DBException("Error during commit: " + e.getMessage(), e);
+        }
+    }
+
+    public void rollback() throws DBException {
+        try {
+            sqlConnection.rollback();
+        } catch (SQLException e) {
+            throw new DBException("Error during rollback: " + e.getMessage(), e);
+        }
+    }
+
+    public ProductDAO productDAO() {
+        return new ProductDAO(this);
+    }
+
+    public CustomerDAO customerDAO() {
+        return new CustomerDAO(this);
+    }
+
+    public OrderDAO orderDAO() {
+        return new OrderDAO(this);
+    }
+}

PC24-SklepWeb/src/main/java/sklep/db/DBException.java

+package sklep.db;
+
+public class DBException extends SklepException {
+
+    public DBException() {
+        super();
+    }
+
+    public DBException(String message, Throwable cause) {
+        super(message, cause);
+    }
+
+    public DBException(String message) {
+        super(message);
+    }
+
+}

PC24-SklepWeb/src/main/java/sklep/db/DBSettings.java

+package sklep.db;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Properties;
+
+public class DBSettings {
+    public static final String DB_SETTINGS_SYSTEM_PROPERTY = "sklep.db_settings_location";
+    private static final String INTERNAL_DEFAULT_PROPERTIES = "/sklep.properties";
+
+    private static DBSettings dbSettings; // singleton
+    
+    private final Properties props;
+
+    private DBSettings() throws DBException {
+        props = new Properties();
+        String systemProperty = System.getProperty(DB_SETTINGS_SYSTEM_PROPERTY);
+        try(InputStream input = systemProperty != null
+                    ? new FileInputStream(new File(systemProperty))
+                    : DBSettings.class.getResourceAsStream(INTERNAL_DEFAULT_PROPERTIES) ) {
+            props.load(input);
+        } catch (IOException e) {
+            //e.printStackTrace();
+            throw new DBException("Cannot read settings. " + e, e);
+        }
+    }
+    
+    public static synchronized DBSettings getInstance() throws DBException {
+        // Dla klasy typu "singleton" w aplikacji powstaje tylko jedna instancja (obiekt) tej klasy.
+        // Dostęp do tego obiektu odbywa się poprzez metodę statyczną taką jak ta.
+        // Tutaj mamy "leniwą inicjalizację", czyli obiekt jest tworzony przy pierwszej próbie dostepu.
+        if(dbSettings == null) {
+            dbSettings = new DBSettings();
+        }
+        return dbSettings;
+    }
+    
+    public Properties getProperties() {
+        return props;
+    }
+    
+    public static Properties load() throws DBException {
+        return getInstance().getProperties();
+    }
+    
+}

PC24-SklepWeb/src/main/java/sklep/db/OrderDAO.java

+package sklep.db;
+
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
+
+import sklep.model.Order;
+import sklep.model.OrderProduct;
+
+public class OrderDAO {
+    private static final String[] ID_COLUMNS = {"order_id", "order_date"};
+    private final DBConnection db;
+
+    OrderDAO(DBConnection db) {
+        this.db = db;
+    }
+
+    public Order findById(int orderId) throws DBException, RecordNotFound {
+        final String sql = "SELECT * FROM orders WHERE order_id = ?";
+        try (PreparedStatement stmt = db.getSqlConnection().prepareStatement(sql)) {
+            stmt.setInt(1, orderId);
+            try (ResultSet rs = stmt.executeQuery()) {
+                if (rs.next()) {
+                    return orderFromRS(rs);
+                } else {
+                    throw new RecordNotFound("Cannot find order with id " + orderId);
+                }
+            }
+        } catch (SQLException e) {
+            throw new DBException("SQL error in OrderDAO.findById: " + e.getMessage(), e);
+        }
+    }
+
+    public List<Order> readAll() throws DBException {
+        final String sql = "SELECT * FROM orders ORDER BY order_id";
+        try (PreparedStatement stmt = db.getSqlConnection().prepareStatement(sql)) {
+            try (ResultSet rs = stmt.executeQuery()) {
+                return orderListFromRS(rs);
+            }
+        } catch (SQLException e) {
+            throw new DBException("SQL error in OrderDAO.readAll: " + e.getMessage(), e);
+        }
+    }
+
+    public List<Order> customerOrders(String email) throws DBException {
+        final String sql = "SELECT * FROM orders WHERE customer_email = ? ORDER BY order_id";
+
+        try (PreparedStatement stmt = db.getSqlConnection().prepareStatement(sql)) {
+            stmt.setString(1, email);
+            try (ResultSet rs = stmt.executeQuery()) {
+                return orderListFromRS(rs);
+            }
+        } catch (SQLException e) {
+            throw new DBException("SQL error in OrderDAO.customerOrders: " + e.getMessage(), e);
+        }
+    }
+
+    private List<Order> orderListFromRS(ResultSet rs) throws SQLException, DBException {
+        List<Order> orders = new ArrayList<>();
+        while (rs.next()) {
+            Order order = orderFromRS(rs);
+            orders.add(order);
+        }
+        return orders;
+    }
+
+    private Order orderFromRS(ResultSet rs) throws SQLException, DBException {
+        Order order = Order.ofDbFields(
+                rs.getInt("order_id"),
+                rs.getString("customer_email"),
+                rs.getTimestamp("order_date"),
+                rs.getString("status"));
+        order.addProducts(orderProductsForOrder(order.getOrderId()));
+        return order;
+    }
+    
+    List<OrderProduct> orderProductsForOrder(int orderId) throws DBException {
+        final String sql = "SELECT * FROM order_products WHERE order_id = ? ORDER BY product_id";
+
+        try (PreparedStatement stmt = db.getSqlConnection().prepareStatement(sql)) {
+            stmt.setInt(1, orderId);
+            try (ResultSet rs = stmt.executeQuery()) {
+                List<OrderProduct> ops = new ArrayList<>();
+                while(rs.next()) {
+                    ops.add(orderProductFromRS(rs));
+                }
+                return ops;
+            }
+        } catch (SQLException e) {
+            throw new DBException("SQL error in OrderDAO.customerOrders: " + e.getMessage(), e);
+        }
+    }
+
+    private OrderProduct orderProductFromRS(ResultSet rs) throws SQLException {
+        return new OrderProduct(rs.getInt("order_id"), rs.getInt("product_id"), rs.getInt("quantity"), rs.getBigDecimal("actual_price"));
+    }
+    
+}

PC24-SklepWeb/src/main/java/sklep/db/ProductDAO.java

+package sklep.db;
+
+import java.math.BigDecimal;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
+
+import sklep.model.Product;
+
+/* DAO - Data Access Object(s) 
+
+Dostęp do baz danych oparty o takie zasady:
+tabelom bazodanowym odpowiadają klasy w naszej aplikacji
+np. dla tabeli products mamy klasę Product  (w pakiecie model)
+dla takie pary tabela products + klasa Product tworzymy klasę narzędziową ProductDAO , której zadaniem jest obsługa tej tabeli: odczyt, zapis, wyszukiwanie, i inne operacje jeśli są potrzebne.
+*/
+
+public class ProductDAO {
+    private static final BigDecimal MAX_PRICE = new BigDecimal(1_000_000_000);
+    private static final String[] ID_COLUMNS = {"product_id"};
+    
+    private final DBConnection db;
+
+    ProductDAO(DBConnection db) {
+        this.db = db;
+    }
+
+    public Product findById(int productId) throws DBException, RecordNotFound {
+        final String sql = "SELECT * FROM products WHERE product_id = ?";
+        try (PreparedStatement stmt = db.getSqlConnection().prepareStatement(sql)) {
+            stmt.setInt(1, productId);
+            try (ResultSet rs = stmt.executeQuery()) {
+                if (rs.next()) {
+                    return productFromRS(rs);
+                } else {
+                    throw new RecordNotFound("Cannot find product with id " + productId);
+                }
+            }
+        } catch (SQLException e) {
+            throw new DBException("SQL error in ProductDAO.findById: " + e.getMessage(), e);
+        }
+    }
+
+    public List<Product> readAll() throws DBException {
+        final String sql = "SELECT * FROM products ORDER BY product_id";
+        try (PreparedStatement stmt = db.getSqlConnection().prepareStatement(sql)) {
+            try (ResultSet rs = stmt.executeQuery()) {
+                return productListFromRS(rs);
+            }
+        } catch (SQLException e) {
+            throw new DBException("SQL error in ProductDAO.readAll: " + e.getMessage(), e);
+        }
+    }
+
+    public List<Product> findByPrice(BigDecimal minPrice, BigDecimal maxPrice) throws DBException {
+        final String sql = "SELECT * FROM products WHERE price BETWEEN ? AND ? ORDER BY product_id";
+        if(minPrice == null)
+            minPrice = BigDecimal.ZERO;
+        
+        if(maxPrice == null)
+            maxPrice = MAX_PRICE;
+
+        try (PreparedStatement stmt = db.getSqlConnection().prepareStatement(sql)) {
+            stmt.setBigDecimal(1, minPrice);
+            stmt.setBigDecimal(2, maxPrice);
+            try (ResultSet rs = stmt.executeQuery()) {
+                return productListFromRS(rs);
+            }
+        } catch (SQLException e) {
+            throw new DBException("SQL error in ProductDAO.findByPrice: " + e.getMessage(), e);
+        }
+    }
+
+    private List<Product> productListFromRS(ResultSet rs) throws SQLException {
+        List<Product> products = new ArrayList<>();
+        while (rs.next()) {
+            Product product = productFromRS(rs);
+            products.add(product);
+        }
+        return products;
+    }
+
+    private Product productFromRS(ResultSet rs) throws SQLException {
+        return new Product(
+                rs.getInt("product_id"),
+                rs.getString("product_name"),
+                rs.getBigDecimal("price"),
+                rs.getBigDecimal("vat"),
+                rs.getString("description"));
+    }
+    
+    public void insert(Product product) throws DBException {
+        // używać gdy obiekt ma wpisane ID
+        final String sql = "INSERT INTO products("
+                + " product_id, product_name, price, vat, description)"
+                + " VALUES (?, ?, ?, ?, ?)";
+        try(PreparedStatement stmt = db.getSqlConnection().prepareStatement(sql)) {
+            stmt.setInt(1, product.getProductId());
+            stmt.setString(2, product.getProductName());
+            stmt.setBigDecimal(3, product.getPrice());
+            stmt.setBigDecimal(4, product.getVat());
+            stmt.setString(5, product.getDescription());
+            stmt.executeUpdate();
+        } catch (SQLException e) {
+            throw new DBException("Error during INSERT PRODUCT", e);
+        }
+    }
+
+    public void insertNew(Product product) throws DBException {
+        // używać gdy obiekt nie ma wpisanego ID (productID == null)
+        final String sql = "INSERT INTO products("
+                + " product_name, price, vat, description)"
+                + " VALUES (?, ?, ?, ?)";
+        try(PreparedStatement stmt = db.getSqlConnection().prepareStatement(sql, ID_COLUMNS)) {
+            stmt.setString(1, product.getProductName());
+            stmt.setBigDecimal(2, product.getPrice());
+            stmt.setBigDecimal(3, product.getVat());
+            stmt.setString(4, product.getDescription());
+            stmt.executeUpdate();
+
+            try (ResultSet rs = stmt.getGeneratedKeys()) {
+                if(rs.next()) {
+                    // w obiekcie, który mamy w pamięci, uzupełniamy brakujące ID na podstawie tego, co wygenerowała baza
+                    product.setProductId(rs.getInt(1));
+                }
+            };
+
+        } catch (SQLException e) {
+            throw new DBException("Error during INSERT PRODUCT", e);
+        }
+    }
+
+    public boolean update(Product product) throws DBException {
+        final String sql = "UPDATE products SET "
+                + " product_name = ?, price = ?, vat = ?, description = ?"
+                + " WHERE product_id = ?";
+        try(PreparedStatement stmt = db.getSqlConnection().prepareStatement(sql)) {
+            stmt.setString(1, product.getProductName());
+            stmt.setBigDecimal(2, product.getPrice());
+            stmt.setBigDecimal(3, product.getVat());
+            stmt.setString(4, product.getDescription());
+            stmt.setInt(5, product.getProductId());
+            int count = stmt.executeUpdate();
+            return count > 0;
+        } catch (SQLException e) {
+            throw new DBException("Error during UPDATE PRODUCT", e);
+        } 
+    }
+    
+    public void save(Product product) throws DBException {
+        if(product.getProductId() == null) {
+            // wstawiamy nowy rekord korzystajac z sekwecji
+            insertNew(product);
+        } else {
+            if(! update(product)) {
+                insert(product);
+            }
+        }
+    }
+    
+    public boolean delete(int productId) throws DBException {
+        final String sql = "DELETE FROM products WHERE product_id = ?";
+        try(PreparedStatement stmt = db.getSqlConnection().prepareStatement(sql)) {
+            stmt.setInt(1, productId);
+            int count = stmt.executeUpdate();
+            return count > 0;
+        } catch (SQLException e) {
+            throw new DBException("Error during DELETE PRODUCT", e);
+        } 
+    }
+
+    public boolean delete(Product product) throws DBException {
+        return delete(product.getProductId());
+    }
+    
+}

PC24-SklepWeb/src/main/java/sklep/db/RecordNotFound.java

+package sklep.db;
+
+public class RecordNotFound extends SklepException {
+
+    public RecordNotFound() {
+        super();
+    }
+
+    public RecordNotFound(String message) {
+        super(message);
+    }
+
+}

PC24-SklepWeb/src/main/java/sklep/db/SklepException.java

+package sklep.db;
+
+public class SklepException extends Exception {
+
+    public SklepException() {
+        super();
+    }
+
+    public SklepException(String message, Throwable cause) {
+        super(message, cause);
+    }
+
+    public SklepException(String message) {
+        super(message);
+    }
+
+    public SklepException(Throwable cause) {
+        super(cause);
+    }
+    
+}

PC24-SklepWeb/src/main/java/sklep/db/ZwyklyOdczyt_DAO.java

+package sklep.db;
+
+import java.util.List;
+
+import sklep.model.Product;
+
+public class ZwyklyOdczyt_DAO {
+
+    public static void main(String[] args) {
+        try(DBConnection db = DBConnection.open()) {
+            ProductDAO productDAO = db.productDAO();
+            List<Product> products = productDAO.readAll();
+            for (Product product : products) {
+                System.out.println(product);
+            }
+        } catch (DBException e) {
+            e.printStackTrace();
+        }
+    }
+
+}

PC24-SklepWeb/src/main/java/sklep/db/ZwyklyOdczyt_JDBC.java

+package sklep.db;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+public class ZwyklyOdczyt_JDBC {
+
+    public static void main(String[] args) {
+        String url = "jdbc:postgresql://localhost:5432/sklep";
+        String sql = "SELECT * FROM products";
+        try(Connection c = DriverManager.getConnection(url, "kurs", "abc123");
+            PreparedStatement stmt= c.prepareStatement(sql);
+            ResultSet rs = stmt.executeQuery()) {
+            
+            while(rs.next()) {
+                System.out.printf("%d: %s za cenę %s\n",
+                        rs.getInt("product_id"), rs.getString("product_name"), rs.getBigDecimal("price"));
+            }
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+    }
+
+}

PC24-SklepWeb/src/main/java/sklep/model/Customer.java

+package sklep.model;
+
+import java.util.Objects;
+
+public class Customer {
+    private String email;
+    private String name;
+    private String phoneNumber;
+    private String address;
+    private String postalCode;
+    private String city;
+    
+    public Customer() {
+    }
+    
+    public Customer(String email, String name, String phone, String address, String postalCode, String city) {
+        this.email = email;
+        this.name = name;
+        this.phoneNumber = phone;
+        this.address = address;
+        this.postalCode = postalCode;
+        this.city = city;
+    }
+
+    public String getEmail() {
+        return email;
+    }
+
+    public void setEmail(String email) {
+        this.email = email;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getPhoneNumber() {
+        return phoneNumber;
+    }
+
+    public void setPhoneNumber(String phone) {
+        this.phoneNumber = phone;
+    }
+
+    public String getAddress() {
+        return address;
+    }
+
+    public void setAddress(String address) {
+        this.address = address;
+    }
+
+    public String getPostalCode() {
+        return postalCode;
+    }
+
+    public void setPostalCode(String postalCode) {
+        this.postalCode = postalCode;
+    }
+
+    public String getCity() {
+        return city;
+    }
+
+    public void setCity(String city) {
+        this.city = city;
+    }
+
+    @Override
+    public String toString() {
+        return "Customer [email=" + email + ", name=" + name + ", phone=" + phoneNumber + ", address=" + address
+                + ", postalCode=" + postalCode + ", city=" + city + "]";
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(email, name, address, city, phoneNumber, postalCode);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj)
+            return true;
+        if (obj == null)
+            return false;
+        if (getClass() != obj.getClass())
+            return false;
+        Customer other = (Customer) obj;
+        return Objects.equals(email, other.email) && Objects.equals(name, other.name)
+                && Objects.equals(address, other.address) && Objects.equals(city, other.city)
+                && Objects.equals(phoneNumber, other.phoneNumber) && Objects.equals(postalCode, other.postalCode);
+    }
+
+}

PC24-SklepWeb/src/main/java/sklep/model/Order.java

+package sklep.model;
+
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.List;
+import java.util.Objects;
+
+public class Order {
+    private Integer orderId;
+    
+    private String customerEmail;
+    
+    private LocalDateTime orderDate;
+    
+    private Status orderStatus;
+    
+    public final List<OrderProduct> products = new ArrayList<>();
+    
+    public Order() {
+    }
+
+    public Order(Integer orderId, String customerEmail, LocalDateTime orderDate, Status orderStatus) {
+        this.orderId = orderId;
+        this.customerEmail = customerEmail;
+        this.orderDate = orderDate;
+        this.orderStatus = orderStatus;
+    }
+
+    public static Order ofDbFields(int orderId, String customerEmail, java.sql.Timestamp orderDate, String orderStatus) {
+        return new Order(orderId, customerEmail,
+                orderDate.toLocalDateTime(),
+                Status.valueOf(orderStatus.toUpperCase()));
+    }
+
+    public Integer getOrderId() {
+        return orderId;
+    }
+
+    public void setOrderId(Integer orderId) {
+        this.orderId = orderId;
+    }
+
+    public String getCustomerEmail() {
+        return customerEmail;
+    }
+
+    public void setCustomerEmail(String customerEmail) {
+        this.customerEmail = customerEmail;
+    }
+
+    public LocalDateTime getOrderDate() {
+        return orderDate;
+    }
+
+    public void setOrderDate(LocalDateTime orderDate) {
+        this.orderDate = orderDate;
+    }
+
+    public Status getOrderStatus() {
+        return orderStatus;
+    }
+
+    public void setOrderStatus(Status orderStatus) {
+        this.orderStatus = orderStatus;
+    }
+    
+    public List<OrderProduct> getProducts() {
+        return Collections.unmodifiableList(products);
+    }
+
+    public void addProduct(OrderProduct product) {
+        this.products.add(product);
+    }
+
+    public void addProducts(Collection<OrderProduct> products) {
+        this.products.addAll(products);
+    }
+
+    public void setProducts(Collection<OrderProduct> products) {
+        this.products.clear();
+        this.products.addAll(products);
+    }
+
+    
+    @Override
+    public String toString() {
+        return "Order [orderId=" + orderId + ", customerEmail=" + customerEmail + ", orderDate=" + orderDate
+                + ", orderStatus=" + orderStatus + "]";
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(customerEmail, orderDate, orderId, orderStatus);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj)
+            return true;
+        if (obj == null)
+            return false;
+        if (getClass() != obj.getClass())
+            return false;
+        Order other = (Order) obj;
+        return Objects.equals(customerEmail, other.customerEmail) && Objects.equals(orderDate, other.orderDate)
+                && Objects.equals(orderId, other.orderId) && orderStatus == other.orderStatus;
+    }
+
+
+    public enum Status {
+        NEW,
+        CONFIRMED,
+        PAID,
+        SHIPPED,
+        CLOSED,
+        RETURNED,
+        ;
+    }
+}

PC24-SklepWeb/src/main/java/sklep/model/OrderProduct.java

+package sklep.model;
+
+import java.math.BigDecimal;
+import java.util.Objects;
+
+public class OrderProduct {
+    private Integer orderId;
+    
+    private Integer productId;
+    
+    private int quantity;
+
+    private BigDecimal actualPrice;
+
+    public OrderProduct() {
+    }
+
+    public OrderProduct(Integer orderId, Integer productId, int quantity, BigDecimal actualPrice) {
+        this.orderId = orderId;
+        this.productId = productId;
+        this.quantity = quantity;
+        this.actualPrice = actualPrice;
+    }
+    
+    public static OrderProduct of(Integer orderId, Product product, int quantity) {
+        return new OrderProduct(orderId, product.getProductId(), quantity, product.getPrice());
+    }
+
+    public Integer getOrderId() {
+        return orderId;
+    }
+
+    public void setOrderId(Integer orderId) {
+        this.orderId = orderId;
+    }
+
+    public Integer getProductId() {
+        return productId;
+    }
+
+    public void setProductId(Integer productId) {
+        this.productId = productId;
+    }
+
+    public int getQuantity() {
+        return quantity;
+    }
+
+    public void setQuantity(int quantity) {
+        this.quantity = quantity;
+    }
+
+    public BigDecimal getActualPrice() {
+        return actualPrice;
+    }
+
+    public void setActualPrice(BigDecimal actualPrice) {
+        this.actualPrice = actualPrice;
+    }
+
+    @Override
+    public String toString() {
+        return "OrderProduct [orderId=" + orderId + ", productId=" + productId + ", quantity=" + quantity
+                + ", actualPrice=" + actualPrice+ "]";
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(orderId, productId, quantity, actualPrice);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj)
+            return true;
+        if (obj == null)
+            return false;
+        if (getClass() != obj.getClass())
+            return false;
+        OrderProduct other = (OrderProduct) obj;
+        return Objects.equals(orderId, other.orderId) && Objects.equals(productId, other.productId)
+                && quantity == other.quantity
+                && Objects.equals(actualPrice, other.actualPrice);
+    }
+    
+}

PC24-SklepWeb/src/main/java/sklep/model/Product.java

+package sklep.model;
+
+import java.math.BigDecimal;
+import java.util.Objects;
+
+public class Product {
+    private Integer productId;
+    private String productName;
+    private BigDecimal price;
+    private BigDecimal vat;
+    private String description;
+    
+    public Product() {
+    }
+    
+    public Product(Integer productId, String productName, BigDecimal price, BigDecimal vat, String description) {
+        this.productId = productId;
+        this.productName = productName;
+        this.price = price;
+        this.vat = vat;
+        this.description = description;
+    }
+
+    public Integer getProductId() {
+        return productId;
+    }
+
+    public void setProductId(Integer productId) {
+        this.productId = productId;
+    }
+
+    public String getProductName() {
+        return productName;
+    }
+
+    public void setProductName(String productName) {
+        this.productName = productName;
+    }
+
+    public BigDecimal getPrice() {
+        return price;
+    }
+
+    public void setPrice(BigDecimal price) {
+        this.price = price;
+    }
+    
+    public BigDecimal getVat() {
+        return vat;
+    }
+    
+    public void setVat(BigDecimal vat) {
+        this.vat = vat;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description;
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(description, price, vat, productId, productName);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj)
+            return true;
+        if (obj == null)
+            return false;
+        if (getClass() != obj.getClass())
+            return false;
+        Product other = (Product) obj;
+        return Objects.equals(productId, other.productId) && Objects.equals(productName, other.productName)
+                && Objects.equals(price, other.price)
+                && Objects.equals(vat, other.vat)
+                && Objects.equals(description, other.description);
+    }
+
+    @Override
+    public String toString() {
+        return "Product [productId=" + productId + ", productName=" + productName + ", price=" + price + ", vat=" + vat
+                + ", description=" + description + "]";
+    }
+
+    public String toHtml() {
+        return String.format("<div class='product'>"
+                + "<h2>%s</h2>"
+                + "<p>(nr %d)</p>"
+                + "<p>Cena: <strong>%,.2f PLN</strong></p>"
+                + "<p>%s</p>"
+                + "</div>",
+                getProductName(),
+                getProductId(),
+                getPrice(),
+                getDescription());
+    }
+
+}

PC24-SklepWeb/src/main/java/sklep/web/Products0.java

+package sklep.web;
+
+import java.io.IOException;
+import java.io.PrintWriter;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+
+import jakarta.servlet.ServletException;
+import jakarta.servlet.annotation.WebServlet;
+import jakarta.servlet.http.HttpServlet;
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.servlet.http.HttpServletResponse;
+
+@WebServlet("/products0")
+public class Products0 extends HttpServlet {
+       
+    @Override
+    protected void doGet(HttpServletRequest requets, HttpServletResponse response) throws ServletException, IOException {
+        response.setContentType("text/plain");
+        response.setCharacterEncoding("UTF-8");
+        PrintWriter out = response.getWriter();
+        out.println("Zaraz odczytam produkty z bazy...");
+        
+        final String url = "jdbc:postgresql://localhost/sklep";
+        final String sql = "SELECT * FROM products";
+        
+        try(Connection c = DriverManager.getConnection(url , "alx", "abc123");
+            Statement stmt = c.createStatement();
+            ResultSet rs = stmt.executeQuery(sql)) {
+            
+            while(rs.next()) {
+                out.printf("Produkt nr %s to jest %s za cenę %s\n",
+                        rs.getInt("product_id"), rs.getString("product_name"), rs.getBigDecimal("price"));
+            }
+        } catch(SQLException e) {
+            out.println("Wielka bieda!");
+            e.printStackTrace(out);
+        }
+    }
+}