public void save(Author author) {
    String sql = "INSERT INTO authors (id, first_name, last_name, bio, image_path) VALUES (?, ?, ?, ?, ?)";
    try (Connection conn = connectionManager.getConnection();
         PreparedStatement stmt = conn.prepareStatement(sql)) {
        stmt.setObject(1, author.getId());
        stmt.setString(2, author.getFirstName());
        stmt.setString(3, author.getLastName());
        stmt.setString(4, author.getBio());
        stmt.setString(5, author.getImagePath());
        stmt.executeUpdate();
    } catch (SQLException e) {
        throw new DatabaseException("Помилка збереження автора", e);
    }
}

public void update(Author author) {
    String sql = "UPDATE authors SET first_name=?, last_name=?, bio=?, image_path=? WHERE id=?";
    try (Connection conn = connectionManager.getConnection();
         PreparedStatement stmt = conn.prepareStatement(sql)) {
        stmt.setString(1, author.getFirstName());
        stmt.setString(2, author.getLastName());
        stmt.setString(3, author.getBio());
        stmt.setString(4, author.getImagePath());
        stmt.setObject(5, author.getId());
        stmt.executeUpdate();
    } catch (SQLException e) {
        throw new DatabaseException("Помилка оновлення автора", e);
    }
}

private Author mapRow(ResultSet rs) throws SQLException {
    return new Author(
        rs.getObject("id", UUID.class),
        rs.getString("first_name"),
        rs.getString("last_name"),
        rs.getString("bio"),
        rs.getString("image_path")
    );
}

package com.example.audiobook.gateway;

import com.example.audiobook.db.ConnectionManager;
import com.example.audiobook.db.DatabaseException;

import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
import java.util.UUID;

/**
 * Row Data Gateway для таблиці authors.
 * <p>
 * Один екземпляр цього класу відповідає одному рядку таблиці authors.
 * Клас містить:
 * <ul>
 *   <li>Поля, що відповідають стовпцям таблиці (стан рядка)</li>
 *   <li>Методи збереження: {@code insert()}, {@code update()}, {@code delete()}</li>
 *   <li>Статичні finder-методи для пошуку рядків</li>
 * </ul>
 * <p>
 * Зверніть увагу: це НЕ доменна модель. Клас не містить бізнес-логіки.
 * Для бізнес-правил доменний шар повинен або використовувати Gateway напряму,
 * або конвертувати його в окремий доменний об'єкт.
 */
public class AuthorGateway {

    // --- Стан: поля, що відповідають стовпцям таблиці authors ---

    private UUID id;
    private String firstName;
    private String lastName;
    private String bio;
    private String imagePath;

    /**
     * ConnectionManager зберігається в кожному екземплярі —
     * він потрібен для виконання SQL у методах insert/update/delete.
     * Це принципова відмінність від наївного DAO, де CM був полем DAO.
     */
    private final ConnectionManager connectionManager;

    // --- SQL-константи для операцій із таблицею authors ---

    private static final String SQL_FIND_BY_ID = """
        SELECT id, first_name, last_name, bio, image_path
        FROM authors WHERE id = ?
        """;

    private static final String SQL_FIND_ALL = """
        SELECT id, first_name, last_name, bio, image_path
        FROM authors ORDER BY last_name, first_name
        """;

    private static final String SQL_FIND_BY_LAST_NAME = """
        SELECT id, first_name, last_name, bio, image_path
        FROM authors WHERE LOWER(last_name) LIKE LOWER(?)
        ORDER BY last_name, first_name
        """;

    private static final String SQL_INSERT = """
        INSERT INTO authors (id, first_name, last_name, bio, image_path)
        VALUES (?, ?, ?, ?, ?)
        """;

    private static final String SQL_UPDATE = """
        UPDATE authors
        SET first_name = ?, last_name = ?, bio = ?, image_path = ?
        WHERE id = ?
        """;

    private static final String SQL_DELETE = "DELETE FROM authors WHERE id = ?";

    // --- Конструктори ---

    /**
     * Конструктор для створення НОВОГО рядка.
     * ID генерується автоматично.
     * Після виклику {@code insert()} цей рядок з'явиться у БД.
     */
    public AuthorGateway(String firstName, String lastName,
                         ConnectionManager connectionManager) {
        this.id = UUID.randomUUID();
        this.firstName = firstName;
        this.lastName = lastName;
        this.connectionManager = connectionManager;
    }

    /**
     * Приватний конструктор для ВІДНОВЛЕННЯ рядка зі сховища.
     * Використовується виключно статичним методом {@code mapRow()}.
     * Зовнішній код не повинен створювати Gateway із заздалегідь відомим id.
     */
    private AuthorGateway(UUID id, String firstName, String lastName,
                          String bio, String imagePath,
                          ConnectionManager connectionManager) {
        this.id = id;
        this.firstName = firstName;
        this.lastName = lastName;
        this.bio = bio;
        this.imagePath = imagePath;
        this.connectionManager = connectionManager;
    }

    // --- Операції збереження (instance methods) ---

    /**
     * Вставляє поточний стан об'єкта у таблицю authors як новий рядок.
     * Якщо рядок з таким {@code id} вже існує — виключення PK violation.
     */
    public void insert() {
        try (Connection conn = connectionManager.getConnection();
             PreparedStatement stmt = conn.prepareStatement(SQL_INSERT)) {

            stmt.setObject(1, this.id);
            stmt.setString(2, this.firstName); // this — поля самого об'єкта
            stmt.setString(3, this.lastName);
            stmt.setString(4, this.bio);       // null → SQL NULL
            stmt.setString(5, this.imagePath); // null → SQL NULL

            int rows = stmt.executeUpdate();
            if (rows != 1) {
                throw new DatabaseException(
                    "Очікувався 1 вставлений рядок, отримано: " + rows, null);
            }

        } catch (SQLException e) {
            throw new DatabaseException("Помилка insert() для автора id=" + id, e);
        }
    }

    /**
     * Оновлює рядок у таблиці поточними значеннями полів об'єкта.
     * {@code id} не може бути змінений — він використовується в умові WHERE.
     *
     * @throws DatabaseException якщо рядка з таким id не існує у БД
     */
    public void update() {
        try (Connection conn = connectionManager.getConnection();
             PreparedStatement stmt = conn.prepareStatement(SQL_UPDATE)) {

            stmt.setString(1, this.firstName);
            stmt.setString(2, this.lastName);
            stmt.setString(3, this.bio);
            stmt.setString(4, this.imagePath);
            stmt.setObject(5, this.id); // id у WHERE — завжди останній

            int rows = stmt.executeUpdate();
            if (rows == 0) {
                throw new DatabaseException(
                    "Автора з id=" + id + " не знайдено для оновлення", null);
            }

        } catch (SQLException e) {
            throw new DatabaseException("Помилка update() для автора id=" + id, e);
        }
    }

    /**
     * Видаляє рядок із таблиці за {@code id} поточного об'єкта.
     *
     * @return {@code true} якщо рядок існував і був видалений
     */
    public boolean delete() {
        try (Connection conn = connectionManager.getConnection();
             PreparedStatement stmt = conn.prepareStatement(SQL_DELETE)) {

            stmt.setObject(1, this.id);
            return stmt.executeUpdate() > 0;

        } catch (SQLException e) {
            throw new DatabaseException("Помилка delete() для автора id=" + id, e);
        }
    }

    // --- Статичні finder-методи (фабрики) ---

    /**
     * Знаходить рядок у таблиці authors за первинним ключем.
     * Повертає {@code Optional.empty()} якщо рядка не існує.
     *
     * @param id               UUID первинного ключа
     * @param connectionManager менеджер з'єднань
     */
    public static Optional<AuthorGateway> findById(UUID id,
                                                    ConnectionManager connectionManager) {
        try (Connection conn = connectionManager.getConnection();
             PreparedStatement stmt = conn.prepareStatement(SQL_FIND_BY_ID)) {

            stmt.setObject(1, id);
            try (ResultSet rs = stmt.executeQuery()) {
                return rs.next()
                    ? Optional.of(mapRow(rs, connectionManager))
                    : Optional.empty();
            }

        } catch (SQLException e) {
            throw new DatabaseException("Помилка findById() для автора id=" + id, e);
        }
    }

    /**
     * Повертає всі рядки таблиці authors як список Gateway-об'єктів.
     *
     * @param connectionManager менеджер з'єднань
     */
    public static List<AuthorGateway> findAll(ConnectionManager connectionManager) {
        List<AuthorGateway> list = new ArrayList<>();

        try (Connection conn = connectionManager.getConnection();
             PreparedStatement stmt = conn.prepareStatement(SQL_FIND_ALL);
             ResultSet rs = stmt.executeQuery()) {

            while (rs.next()) {
                list.add(mapRow(rs, connectionManager));
            }

        } catch (SQLException e) {
            throw new DatabaseException("Помилка findAll() для authors", e);
        }
        return list;
    }

    /**
     * Знаходить рядки, де прізвище містить заданий підрядок
     * (регістр-незалежний пошук).
     *
     * @param lastNamePart     підрядок прізвища
     * @param connectionManager менеджер з'єднань
     */
    public static List<AuthorGateway> findByLastName(String lastNamePart,
                                                      ConnectionManager connectionManager) {
        List<AuthorGateway> list = new ArrayList<>();

        try (Connection conn = connectionManager.getConnection();
             PreparedStatement stmt = conn.prepareStatement(SQL_FIND_BY_LAST_NAME)) {

            stmt.setString(1, "%" + lastNamePart + "%");
            try (ResultSet rs = stmt.executeQuery()) {
                while (rs.next()) {
                    list.add(mapRow(rs, connectionManager));
                }
            }

        } catch (SQLException e) {
            throw new DatabaseException(
                "Помилка findByLastName() для прізвища: " + lastNamePart, e);
        }
        return list;
    }

    // --- Приватний маппінг: ЄДИНИЙ РЕЄСТР ВІДПОВІДНОСТІ полів і стовпців ---

    /**
     * Перетворює поточний рядок {@link ResultSet} на екземпляр AuthorGateway.
     * <p>
     * Це ЄДИНЕ місце у класі, де явно згадуються назви стовпців таблиці.
     * Решта методів (insert, update) звертаються до полів через {@code this},
     * а не через назви стовпців. Завдяки цьому: зміна назви стовпця
     * вимагає правки лише тут.
     */
    private static AuthorGateway mapRow(ResultSet rs,
                                         ConnectionManager cm) throws SQLException {
        return new AuthorGateway(
            rs.getObject("id", UUID.class),
            rs.getString("first_name"),
            rs.getString("last_name"),
            rs.getString("bio"),        // null → java null
            rs.getString("image_path"), // null → java null
            cm
        );
    }

    // --- Геттери та сеттери ---

    public UUID getId()          { return id; }
    public String getFirstName() { return firstName; }
    public String getLastName()  { return lastName; }
    public String getBio()       { return bio; }
    public String getImagePath() { return imagePath; }

    /** Повертає повне ім'я у форматі «Прізвище Ім'я». */
    public String fullName() { return lastName + " " + firstName; }

    public void setFirstName(String firstName) { this.firstName = firstName; }
    public void setLastName(String lastName)   { this.lastName = lastName; }
    public void setBio(String bio)             { this.bio = bio; }
    public void setImagePath(String imagePath) { this.imagePath = imagePath; }

    @Override
    public String toString() {
        return "AuthorGateway{id=" + id + ", name='" + fullName() + "'}";
    }
}

package com.example.audiobook.gateway;

import com.example.audiobook.db.ConnectionManager;
import com.example.audiobook.db.DatabaseException;

import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
import java.util.UUID;

/**
 * Row Data Gateway для таблиці genres.
 * <p>
 * Один екземпляр відповідає одному рядку таблиці genres.
 * Поле {@code name} є унікальним у БД — {@code insert()} може
 * кинути виключення при спробі додати жанр з назвою, що вже існує.
 */
public class GenreGateway {

    private UUID id;
    private String name;
    private String description;

    private final ConnectionManager connectionManager;

    private static final String SQL_FIND_BY_ID = """
        SELECT id, name, description FROM genres WHERE id = ?
        """;
    private static final String SQL_FIND_BY_NAME = """
        SELECT id, name, description FROM genres WHERE name = ?
        """;
    private static final String SQL_FIND_ALL = """
        SELECT id, name, description FROM genres ORDER BY name
        """;
    private static final String SQL_INSERT = """
        INSERT INTO genres (id, name, description) VALUES (?, ?, ?)
        """;
    private static final String SQL_UPDATE = """
        UPDATE genres SET name = ?, description = ? WHERE id = ?
        """;
    private static final String SQL_DELETE = "DELETE FROM genres WHERE id = ?";

    /** Конструктор для нового жанру — ID генерується автоматично. */
    public GenreGateway(String name, ConnectionManager connectionManager) {
        this.id = UUID.randomUUID();
        this.name = name;
        this.connectionManager = connectionManager;
    }

    /** Приватний конструктор відновлення — тільки через mapRow(). */
    private GenreGateway(UUID id, String name, String description,
                         ConnectionManager connectionManager) {
        this.id = id;
        this.name = name;
        this.description = description;
        this.connectionManager = connectionManager;
    }

    /**
     * Вставляє поточний жанр у таблицю genres.
     *
     * @throws DatabaseException з описовим повідомленням при порушенні UNIQUE
     */
    public void insert() {
        try (Connection conn = connectionManager.getConnection();
             PreparedStatement stmt = conn.prepareStatement(SQL_INSERT)) {

            stmt.setObject(1, this.id);
            stmt.setString(2, this.name);
            stmt.setString(3, this.description); // null → SQL NULL

            stmt.executeUpdate();

        } catch (SQLException e) {
            // SQLState 23* — клас порушень цілісності (UNIQUE, FK, NOT NULL)
            if (e.getSQLState() != null && e.getSQLState().startsWith("23")) {
                throw new DatabaseException(
                    "Жанр з назвою '" + name + "' вже існує у таблиці genres", e);
            }
            throw new DatabaseException("Помилка insert() для жанру '" + name + "'", e);
        }
    }

    /**
     * Оновлює назву та опис жанру у таблиці.
     *
     * @throws DatabaseException якщо жанру з таким id не знайдено
     */
    public void update() {
        try (Connection conn = connectionManager.getConnection();
             PreparedStatement stmt = conn.prepareStatement(SQL_UPDATE)) {

            stmt.setString(1, this.name);
            stmt.setString(2, this.description);
            stmt.setObject(3, this.id);

            int rows = stmt.executeUpdate();
            if (rows == 0) {
                throw new DatabaseException(
                    "Жанр з id=" + id + " не знайдено для оновлення", null);
            }

        } catch (SQLException e) {
            throw new DatabaseException("Помилка update() для жанру id=" + id, e);
        }
    }

    /**
     * Видаляє жанр із таблиці.
     * Якщо жанр використовується у таблиці audiobooks — FK constraint violation.
     *
     * @return {@code true} якщо жанр існував і видалений
     */
    public boolean delete() {
        try (Connection conn = connectionManager.getConnection();
             PreparedStatement stmt = conn.prepareStatement(SQL_DELETE)) {

            stmt.setObject(1, this.id);
            return stmt.executeUpdate() > 0;

        } catch (SQLException e) {
            // SQLState 23* — порушення FK: жанр використовується в audiobooks
            if (e.getSQLState() != null && e.getSQLState().startsWith("23")) {
                throw new DatabaseException(
                    "Не можна видалити жанр '" + name + "': він використовується у аудіокнигах", e);
            }
            throw new DatabaseException("Помилка delete() для жанру id=" + id, e);
        }
    }

    // --- Статичні finder-методи ---

    public static Optional<GenreGateway> findById(UUID id,
                                                   ConnectionManager cm) {
        try (Connection conn = cm.getConnection();
             PreparedStatement stmt = conn.prepareStatement(SQL_FIND_BY_ID)) {

            stmt.setObject(1, id);
            try (ResultSet rs = stmt.executeQuery()) {
                return rs.next() ? Optional.of(mapRow(rs, cm)) : Optional.empty();
            }

        } catch (SQLException e) {
            throw new DatabaseException("Помилка findById() жанру id=" + id, e);
        }
    }

    /**
     * Знаходить жанр за точною назвою.
     * Корисний для перевірки існування жанру перед вставкою.
     *
     * @param name точна назва жанру (чутливо до регістру)
     * @param cm   менеджер з'єднань
     */
    public static Optional<GenreGateway> findByName(String name,
                                                     ConnectionManager cm) {
        try (Connection conn = cm.getConnection();
             PreparedStatement stmt = conn.prepareStatement(SQL_FIND_BY_NAME)) {

            stmt.setString(1, name);
            try (ResultSet rs = stmt.executeQuery()) {
                return rs.next() ? Optional.of(mapRow(rs, cm)) : Optional.empty();
            }

        } catch (SQLException e) {
            throw new DatabaseException("Помилка findByName() жанру: " + name, e);
        }
    }

    public static List<GenreGateway> findAll(ConnectionManager cm) {
        List<GenreGateway> list = new ArrayList<>();

        try (Connection conn = cm.getConnection();
             PreparedStatement stmt = conn.prepareStatement(SQL_FIND_ALL);
             ResultSet rs = stmt.executeQuery()) {

            while (rs.next()) {
                list.add(mapRow(rs, cm));
            }

        } catch (SQLException e) {
            throw new DatabaseException("Помилка findAll() жанрів", e);
        }
        return list;
    }

    private static GenreGateway mapRow(ResultSet rs, ConnectionManager cm) throws SQLException {
        return new GenreGateway(
            rs.getObject("id", UUID.class),
            rs.getString("name"),
            rs.getString("description"), // null → java null
            cm
        );
    }

    // --- Геттери та сеттери ---

    public UUID getId()            { return id; }
    public String getName()        { return name; }
    public String getDescription() { return description; }

    public void setName(String name)               { this.name = name; }
    public void setDescription(String description) { this.description = description; }

    @Override
    public String toString() {
        return "GenreGateway{id=" + id + ", name='" + name + "'}";
    }
}

package com.example.audiobook;

import com.example.audiobook.db.ConnectionManager;
import com.example.audiobook.gateway.AuthorGateway;
import com.example.audiobook.gateway.GenreGateway;

import java.util.List;
import java.util.Optional;
import java.util.UUID;

public class Main {

    public static void main(String[] args) {

        ConnectionManager cm = ConnectionManager.forH2("./data/audiobook_db");

        // --- 1. Створення та вставка авторів ---
        AuthorGateway shevchenko = new AuthorGateway("Тарас", "Шевченко", cm);
        shevchenko.insert();
        System.out.println("✓ Збережено: " + shevchenko);

        AuthorGateway franko = new AuthorGateway("Іван", "Франко", cm);
        franko.insert();
        System.out.println("✓ Збережено: " + franko);

        // --- 2. Зміна стану об'єкта і оновлення у БД ---
        shevchenko.setBio("Великий український поет, художник і мислитель.");
        shevchenko.update(); // запис зміненого стану у таблицю
        System.out.println("✓ Біографію оновлено для: " + shevchenko.fullName());

        // --- 3. Пошук за id ---
        UUID frankoId = franko.getId();
        Optional<AuthorGateway> found = AuthorGateway.findById(frankoId, cm);
        found.ifPresent(a -> System.out.println("✓ Знайдено: " + a.fullName()));

        // --- 4. Пошук за прізвищем ---
        List<AuthorGateway> results = AuthorGateway.findByLastName("шевч", cm);
        System.out.println("✓ Пошук 'шевч': " + results.size() + " результат(ів)");
        results.forEach(a -> System.out.println("   → " + a.fullName()));

        // --- 5. Список всіх авторів ---
        List<AuthorGateway> all = AuthorGateway.findAll(cm);
        System.out.println("✓ Всього авторів: " + all.size());

        // --- 6. Жанри: вставка та обробка дублікату ---
        GenreGateway poetry = new GenreGateway("Поезія", cm);
        poetry.setDescription("Ліричні та епічні твори у віршованій формі");
        poetry.insert();
        System.out.println("✓ Жанр збережено: " + poetry);

        try {
            // Спроба вставити дублікат — порушення UNIQUE constraint
            GenreGateway duplicate = new GenreGateway("Поезія", cm);
            duplicate.insert();
        } catch (Exception e) {
            System.out.println("✓ Перехоплено дублікат: " + e.getMessage());
        }

        // --- 7. Пошук жанру за назвою ---
        GenreGateway.findByName("Поезія", cm)
            .ifPresent(g -> System.out.println("✓ Знайдено жанр: " + g.getName()));

        // --- 8. Видалення автора ---
        boolean deleted = franko.delete();
        System.out.println("✓ Франко видалений: " + deleted);

        // Перевірка: авторів тепер 1
        System.out.println("✓ Залишилось авторів: " + AuthorGateway.findAll(cm).size());

        cm.close();
    }
}

// Кожен з 1000 об'єктів несе посилання на менеджер з'єднань
List<AuthorGateway> authors = AuthorGateway.findAll(cm); // 1000 авторів
// → 1000 × (поля + посилання на cm) в пам'яті

// Як отримати автора аудіокниги?
AudiobookGateway audiobook = AudiobookGateway.findById(id, cm).orElseThrow();

// Варіант 1: AudiobookGateway містить authorId як UUID
UUID authorId = audiobook.getAuthorId(); // лише FK, не об'єкт!
AuthorGateway author = AuthorGateway.findById(authorId, cm).orElseThrow();
// → Клієнт мусить виконувати навігацію вручну. Дублювання у кожному місці.

// Варіант 2: AudiobookGateway містить AuthorGateway author
// → AudiobookGateway залежить від AuthorGateway. Зв'язування шлюзів.
// Але тоді ми маємо N+1: 100 аудіокниг → 100 запитів для авторів.

AuthorGateway gateway = new AuthorGateway("Тарас", "Шевченко", cm);
gateway.insert();

Optional<AuthorGateway> found = AuthorGateway.findById(id, cm);