💻 코딩 일기 : [Spring JDBC] 'UPDATE' 편

ybk·2024년 4월 22일

Spring

spring

목록 보기

16/55

🔔 'Spring JDBC를 활용한 DB에 데이터 수정하는 방법'에 대해서 알아보자!

💟 UPDATE

UPDATE : 데이터베이스 테이블의 기존 레코드를 수정하는 데 사용됩니다.

UPDATE 테이블명 SET 컬럼명 = 바꿀값, 컬렴명 = 바꿀값, ... WHERE 레코드의 조건

🟥 주의할 점 : 먼저 데이터를 수정하기 전에 조회를 해준 다음에 해당 데이터가 있다면 그 때 수정해주는 것이 좋습니다.

Controller30.java

@Controller
@RequestMapping("main30")
public class Controller30 {

    @Autowired
    private DataSource dataSource;

    @GetMapping("sub1")
    public void method1(Integer id, Model model) throws SQLException {
        // 고객 번호를 받은 후 조회한 다음에 지울 예정
        if (id !=  null){
            String sql = """
                    SELECT * FROM Customers WHERE CustomerID = ?
                    """;

            Connection conn = dataSource.getConnection();
            PreparedStatement pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1,id); //첫번째 물음표에 id 넣기
            ResultSet rs = pstmt.executeQuery();
            try (rs;pstmt;conn){
                if (rs.next()) {
                    MyBean254Customer bean = new MyBean254Customer();
                    bean.setId(rs.getInt(1));
                    bean.setName(rs.getString(2));
                    bean.setContactName(rs.getString(3));
                    bean.setAddress(rs.getString(4));
                    bean.setCity(rs.getString(5));
                    bean.setPostalCode(rs.getString(6));
                    bean.setCountry(rs.getString(7));

                    model.addAttribute("customer", bean);
                }
            }
        }
    }

    @PostMapping("sub1/update")
    public String update1(MyBean254Customer customer, RedirectAttributes rttr) throws SQLException {
        System.out.println(customer);
        String sql = """
                UPDATE Customers
                SET CustomerName = ?,
                    ContactName = ?,
                    Address = ?,
                    City = ?,
                    PostalCode = ?,
                    Country = ?
                WHERE CustomerID = ?
                """;

        Connection con = dataSource.getConnection();
        PreparedStatement pstmt = con.prepareStatement(sql);
        
        try (pstmt;con){
            pstmt.setString(1,customer.getName());
            pstmt.setString(2,customer.getContactName());
            pstmt.setString(3,customer.getAddress());
            pstmt.setString(4,customer.getCity());
            pstmt.setString(5,customer.getPostalCode());
            pstmt.setString(6,customer.getCountry());
            pstmt.setInt(7, customer.getId());


            int rowCount = pstmt.executeUpdate();
            if(rowCount > 0){
                rttr.addFlashAttribute("message",customer.getId() + "번 고객이 수정되었습니다.");
            }else{
                rttr.addFlashAttribute("message", "수정되지 않았습니다.");
            }
        }

        rttr.addAttribute("id", customer.getId());

        return "redirect:/main30/sub1";
    }
}

조회(SELECT) :
- "/main30/sub1"로의 GET 요청을 처리합니다. 제공된 고객 ID를 기반으로 데이터베이스에서 고객 데이터를 검색하고 모델 속성에 추가합니다.
- 데이터베이스와 연결하고 SQL 쿼리 실행을 위해 PreparedStatement객체 생성하고 SQL 쿼리의 매개변수에 사용될 값(?에 들어갈 값) 설정(set)하고 SQL 쿼리 실행하고 ResultSet 객체에 저장합니다.
수정(UPDATE) :
- "/mai30/sub1/update"로 POST 요청을 처리합니다. 직원 레코드를 삭제하고 삭제 결과에 따른 해당 메시지를 설정하고 리다이렉트를 합니다.
- 데이터베이스와 연결하고 SQL 쿼리 실행을 위해 PreparedStatement객체 생성하고 SQL 쿼리의 매개변수에 사용될 값(?에 들어갈 값) 설정(set)하고 executeUpdate() 메서드를 사용하여 UPDATE 쿼리를 실행하고, 삭제된 행의 수를 나타냅니다. 마지막으로 "/main30/sub1"로 리다이렉트하여 수정 작업 후의 결과를 표시하는 페이지로 이동합니다.
- 매개변수에 사용될 값(?에 들어갈 값) 설정할 때 수정된 값도 넣어야 하지만 수정되지 않은 값은 그대로 지정해주어야 합니다.

sub1.jsp

<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<%@ taglib prefix="c" uri="jakarta.tags.core" %>
<html>
<head>
    <title>Title</title>
</head>
<body>
<c:if test="${not empty message}">
    <div style="background-color: khaki; padding: 20px">${message}</div>
</c:if>


<h3>고객 정보 수정</h3>
<form action="">
    번호
    <input type="text" name="id">
    <button>조회</button>
</form>

<hr>
<form action="/main30/sub1/update" method="post" onsubmit="return confirm('정말로 수정하시겠습니까?')">
    <div>
        번호 <input type="text" name="id" value="${customer.id}">
    </div>
    <div>
        이름 <input type="text" name="name" value="${customer.name}">
    </div>
    <div>
        계약명 <input type="text" name="contactName" value="${customer.contactName}">
    </div>
    <div>
        주소 <input type="text" name="address" value="${customer.address}">
    </div>
    <div>
        도시 <input type="text" name="city" value="${customer.city}">
    </div>
    <div>
        우편번호 <input type="text" name="postalCode" value="${customer.postalCode}">
    </div>
    <div>
        국가 <input type="text" name="country" value="${customer.country}">
    </div>
    <div>
        <input type="submit" value="수정">
    </div>
</form>

</body>
</html>

고객 정보 조회

국가를 독일에서 Gremany로 수정

수정 컴펌

수정된 고객 다시 조회

💟 DAO 패턴 적용(Mapper, Repository)

//Mapper01.java
// Inversion Of Control (IOC)
@Component
public class Mapper01 {
    public MyBean254Customer getCustomerById(Integer id) throws SQLException {
        // 고객 번호를 받은 후 조회한 다음에 지울 예정
        if (id !=  null){
            String sql = """
                    SELECT * FROM Customers WHERE CustomerID = ?
                    """;

            Connection conn = DriverManager.getConnection("jdbc:mariadb://localhost:3306/w3schools", "root", "*****");
            PreparedStatement pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1,id); //첫번째 물음표에 id 넣기
            ResultSet rs = pstmt.executeQuery();
            try (rs;pstmt;conn){
                if (rs.next()) {
                    MyBean254Customer bean = new MyBean254Customer();
                    bean.setId(rs.getInt(1));
                    bean.setName(rs.getString(2));
                    bean.setContactName(rs.getString(3));
                    bean.setAddress(rs.getString(4));
                    bean.setCity(rs.getString(5));
                    bean.setPostalCode(rs.getString(6));
                    bean.setCountry(rs.getString(7));

                    return bean;
                }
            }
        }
        return null;
    }
}

//Controller30.java
@Autowired
    private Mapper01 mapper;


@GetMapping("sub1")
    public void method1(Integer id, Model model) throws SQLException {
        MyBean254Customer c = mapper.getCustomerById(id);
        model.addAttribute("customer", c);
    }

Mapper는 데이터베이스와 객체 간의 매핑을 수행하는 역할입니다.

Mapper01 클래스는 데이터베이스 연결 및 쿼리를 담당합니다. 이것은 @Component로 주석이 달린 스프링 빈으로 등록되어 스프링 컨테이너에 의해 관리됩니다.
Controller30 클래스에서는 Mapper01 클래스를 자동으로 주입받아 사용합니다. 이것은 스프링의 의존성 주입(Dependency Injection)을 통해 이루어집니다.
method1 메서드에서는 더 이상 데이터베이스와 직접 상호 작용하지 않습니다. 대신 Mapper01 클래스의 getCustomerById 메서드를 호출하여 데이터베이스 작업을 처리합니다.

ybk

개발자 준비생~

이전 포스트

💻 코딩 일기 : [Spring JDBC] 'DELETE' 편

다음 포스트