ProductDao.java

package gift.model;

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.stereotype.Repository;

import java.util.ArrayList;
import java.util.List;

@Repository
public class ProductDao {
    private final JdbcTemplate jdbcTemplate;

    public ProductDao(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    //상품 테이블 생성
    public void createCustomerTable(){
        var sql = """
    create table customer (
      id bigint,
      name varchar(255),
      price int,
      image_url varchar(255),
      primary key (id)
    )
    """;
        jdbcTemplate.execute(sql); //여닫는 과정X, throws가 안나옴(내부에서 관리) excetion 추상화 해서 제공
    }

    //데이터베이스 반환결과인 Result Set 객체로 변환
    public RowMapper<Product> ProductRowMapper() {
        return ( (resultSet, rowNum) -> {
            Product product = new Product();
            product.setId(resultSet.getLong("id"));
            product.setName(resultSet.getString("name"));
            product.setPrice(resultSet.getInt("price"));
            product.setImageUrl(resultSet.getString("image_url"));
            return product;
        });
    }

    //모든 상품 리스트 반환
    public List<Product> selectAllProduct(){
        var sql = "select * from product";
        List<Product> list = new ArrayList<>();
        return jdbcTemplate.query(sql, ProductRowMapper(), list.toArray());
    }

    //상품 하나 반환
    public Product selectProduct(Long id){
        var sql = "select id, name, price, image_url from product where id = ?";
        return jdbcTemplate.queryForObject(sql, ProductRowMapper(), id);
    }

    //상품 추가
    public void insertProduct(Product product){
        var sql = "insert into product (id, name, price, image_url) values (?, ?, ?, ?)";
        jdbcTemplate.update(sql, product.getId(), product.getName(), product.getPrice(), product.getImageUrl());
    }

    //상품 삭제
    public void deleteProduct(Long id){
        var sql = "delete from product where id = ?";
        jdbcTemplate.update(sql, id);
    }

    //상품 업데이트
    public void updateProduct(Product product){
        var sql = "update product set name = ?, price = ?, image_url = ? where id = ?";
        jdbcTemplate.update(sql, product.getName(), product.getPrice(), product.getImageUrl(), product.getId());
    }
}