src/main/java/ru.machine.service/controller/RepairController.java - master - syunya/Course2026

src/main/java/ru.machine.service/controller/RepairController.java

115 строк3 KB

syunya

Create: WorkTypeController.java, RepairController.java, RegisterController.java

23 июн 2026, 23:29

23 июн 2026, 23:29485c25a

package ru.machine.service.dao;

import ru.machine.service.model.Client;

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

public class ClientDAO {

    private Connection connection;

    public ClientDAO() throws SQLException {

        connection =
                DatabaseConnection
                        .getInstance()
                        .getConnection();
    }

    public List<Client> getAll() throws SQLException {

        List<Client> clients =
                new ArrayList<>();

        String sql =
                "SELECT * FROM clients";

        Statement st =
                connection.createStatement();

        ResultSet rs =
                st.executeQuery(sql);

        while (rs.next()) {

            clients.add(
                    new Client(
                            rs.getInt("id"),
                            rs.getString("company_name"),
                            rs.getString("address"),
                            rs.getString("phone")
                    )
            );
        }

        return clients;
    }

    public void add(Client client)
            throws SQLException {

        String sql =
                "INSERT INTO clients(company_name,address,phone) VALUES(?,?,?)";

        PreparedStatement ps =
                connection.prepareStatement(sql);

        ps.setString(1, client.getCompanyName());
        ps.setString(2, client.getAddress());
        ps.setString(3, client.getPhone());

        ps.executeUpdate();
    }

    public void delete(int id)
            throws SQLException {

        String sql =
                "DELETE FROM clients WHERE id=?";

        PreparedStatement ps =
                connection.prepareStatement(sql);

        ps.setInt(1, id);

        ps.executeUpdate();
    }

    public void update(Client client)
            throws SQLException {

        String sql =
                "UPDATE clients " +
                        "SET company_name=?, " +
                        "address=?, " +
                        "phone=? " +
                        "WHERE id=?";

        PreparedStatement ps =
                connection.prepareStatement(sql);

        ps.setString(
                1,
                client.getCompanyName()
        );

        ps.setString(
                2,
                client.getAddress()
        );

        ps.setString(
                3,
                client.getPhone()
        );

        ps.setInt(
                4,
                client.getId()
        );

        ps.executeUpdate();
    }
}