src/model/CourseManager.java - master - Maksim_Shchelochok/Course_Work

src/model/CourseManager.java
76 строк3 KB
Maksim
Добавление валидации
22 июн 2026, 18:40
22 июн 2026, 18:40d86e5d4
package model;

import util.ConnectDatabase;
import util.Validator;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

public class CourseManager {

    private Connection getConnection() {return ConnectDatabase.getInstance().getConnection();}

    public List<Course> getAll() {
        List<Course> list = new ArrayList<>();
        String sql = "SELECT course_id, name FROM courses ORDER BY course_id";
        try (PreparedStatement ps = getConnection().prepareStatement(sql);
             ResultSet rs = ps.executeQuery()) {
            while (rs.next()) {
                list.add(new Course(rs.getInt("course_id"), rs.getString("name")));
            }
        } catch (SQLException e) {
            System.out.println("Ошибка чтения курсов: " + e.getMessage());
        }
        return list;
    }

    public String create(String name) {
        if (name == null || name.trim().isEmpty()) {
            return "Название не может быть пустым.";
        }
        if (!Validator.isValidTitle(name)) {
            return "Название курса должно содержать минимум 2 символа.";
        }
        String sql = "INSERT INTO courses (name) VALUES (?)";
        try (PreparedStatement ps = getConnection().prepareStatement(sql)) {
            ps.setString(1, name.trim());
            ps.executeUpdate();
            return null;
        } catch (SQLException e) {
            return "Ошибка добавления: " + e.getMessage();
        }
    }

    public String update(int id, String name) {
        if (name == null || name.trim().isEmpty()) {
            return "Название не может быть пустым.";
        }
        if (!Validator.isValidTitle(name)) {
            return "Название курса должно содержать минимум 2 символа.";
        }
        String sql = "UPDATE courses SET name = ? WHERE course_id = ?";
        try (PreparedStatement ps = getConnection().prepareStatement(sql)) {
            ps.setString(1, name.trim());
            ps.setInt(2, id);
            ps.executeUpdate();
            return null;
        } catch (SQLException e) {
            return "Ошибка изменения: " + e.getMessage();
        }
    }

    public String delete(int id) {
        String sql = "DELETE FROM courses WHERE course_id = ?";
        try (PreparedStatement ps = getConnection().prepareStatement(sql)) {
            ps.setInt(1, id);
            ps.executeUpdate();
            return null;
        } catch (SQLException e) {
            return "Не удалось удалить (возможно, курс используется): " + e.getMessage();
        }
    }
}