UpdateOrderDao.java

package com.example.order.dao;

import com.example.order.dto.ParamsDto;
import com.example.order.util.Database;
import com.example.order.util.ExceptionHandler;
import org.jetbrains.annotations.NotNull;

import java.io.IOException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

/**
 * DAO to update an order
 */
public class UpdateOrderDao {
    private final Database database;

    /**
     * Constructor
     *
     * @param database Database object
     */
    public UpdateOrderDao(Database database) {
        this.database = database;
    }

    /**
     * Updates the status of an order
     *
     * @param paramsDto Object with the parameters for the operation
     * @return Number of affected rows
     */
    public int updateOrderStatus(ParamsDto paramsDto) throws IOException {
        int numberResults = 0;

        try (Connection con = database.getConnection();
             PreparedStatement ps = createPreparedStatement(con, paramsDto)
        ) {
            numberResults = ps.executeUpdate();

        } catch (SQLException ex) {
            ExceptionHandler.handleException(ex);
        }

        return numberResults;
    }

    /**
     * Creates a PreparedStatement object to update the order
     *
     * @param con       Connnection object
     * @param paramsDto Object with the parameters to set on the PreparedStatement
     * @return A PreparedStatement object
     * @throws SQLException In case of an error
     */
    private @NotNull PreparedStatement createPreparedStatement(@NotNull Connection con, @NotNull ParamsDto paramsDto) throws SQLException {
        String query = "UPDATE orders o SET o.order_status = ? WHERE o.order_id = ?";
        PreparedStatement ps = con.prepareStatement(query);
        ps.setString(1, paramsDto.getStatus());
        ps.setLong(2, paramsDto.getOrderId());
        return ps;
    }
}