SQL 의존 애플리케이션의 문제점과 JPA

Java·Servlet·JSP

SQL 의존 애플리케이션의 문제점과 JPA

Leica 2020. 3. 18. 17:41

SQL 의존 애플리케이션의 문제점과 JPA

개요

데이터베이스에 데이터를 관리하려면 SQL을 사용해야 하며 자바 애플리케이션은 JDBC API를 사용해서 SQL을 데이터베이스에 전달할 수 있다.

JPA를 사용했을 때의 이점이 무엇인지, SQL을 직접 다룰 때의 문제점은 무엇인지 알아보기 위해 자바와 관계형 데이터베이스를 사용해서 회원 관리 기능을 개발해보자.

회원 테이블은 이미 만들어져 있다고 가정하고 CRUD(등록, 조회, 수정, 삭제) 기능을 개발해보자.

JDBC 회원 관리 어플리케이션

Member(회원) 객체

자바에서 사용할 Member(회원) 객체를 만든다.

public class Member {

    private int no;
    private String email;
    private String name;

    public int getNo() {
        return no;
    }

    public void setNo(int no) {
        this.no = no;
    }

    public String getEmail() {
        return email;
    }

    public void setEmail(String email) {
        this.email = email;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }
}

DAO(Data Access Object, 데이터 접근 객체)

Member 객체를 데이터베이스에 관리할 목적으로 Member DAO를 만든다.

public class MemberDao {

    // 등록
    public int save(Member member) throws SQLException {

        try (Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3307/spms?user=leica&password=1234")) {
            String sql = "INSERT INTO MEMBERS (EMAIL, MNAME) VALUES (?, ?)";

            try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
                pstmt.setString(1, member.getEmail());
                pstmt.setString(2, member.getName());

                return pstmt.executeUpdate();

            }
        }
    }

    // 조회
    public Member find(int no) throws SQLException {

        try (Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3307/spms?user=leica&password=1234")) {
            String sql = "SELECT MNO, EMAIL, MNAME FROM MEMBERS WHERE MNO = ?";

            try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
                pstmt.setInt(1, no);

                try (ResultSet rs = pstmt.executeQuery()) {
                    if (rs.next()) {
                        Member member = new Member();

                        member.setNo(no);
                        member.setEmail(rs.getString("EMAIL"));
                        member.setName(rs.getString("MNAME"));

                        return member;
                    } else {
                        throw new SQLException();
                    }
                }
            }
        }
    }

    // 수정
    public int update(Member member) throws SQLException {

        try (Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3307/spms?user=leica&password=1234")) {
            String sql = "UPDATE MEMBERS SET EMAIL = ?, MNAME = ? WHERE MNO = ?";

            try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
                pstmt.setString(1, member.getEmail());
                pstmt.setString(2, member.getName());
                pstmt.setInt(3, member.getNo());

                return pstmt.executeUpdate();

            }
        }
    }

    // 삭제
    public int delete(int no) throws SQLException {

        try (Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3307/spms?user=leica&password=1234")) {
            String sql = "DELETE FROM MEMBERS WHERE MNO = ?";

            try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
                pstmt.setInt(1, no);

                return pstmt.executeUpdate();

            }
        }
    }
}

요구사항의 추가 - 회원 연락처

회원의 연락처를 함께 저장해달라는 요구사항이 추가되었다고 가정해보자.

스키마 변경

회원 테이블에 TEL 컬럼을 추가한다.

ALTER TABLE `spms`.`members` 
ADD COLUMN `TEL` VARCHAR(45) NULL AFTER `MNAME`;

Member 객체 변경

회원 객체에 tel 필드를 추가한다.

public class Member {

    private int no;
    private String email;
    private String name;
    private String tel; // 추가

    public int getNo() {
        return no;
    }

    public void setNo(int no) {
        this.no = no;
    }

    public String getEmail() {
        return email;
    }

    public void setEmail(String email) {
        this.email = email;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getTel() {
        return tel;
    }

    public void setTel(String tel) {
        this.tel = tel;
    }
}

DAO 변경

등록, 조회, 수정 SQL, JDBC API 코드를 변경한다.

public class MemberDao {

    // 등록
    public int save(Member member) throws SQLException {

        try (Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3307/spms?user=leica&password=1234")) {
            String sql = "INSERT INTO MEMBERS (EMAIL, MNAME, TEL) VALUES (?, ?, ?)";

            try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
                pstmt.setString(1, member.getEmail());
                pstmt.setString(2, member.getName());
                pstmt.setString(3, member.getTel());

                return pstmt.executeUpdate();

            }
        }
    }

    // 조회
    public Member find(int no) throws SQLException {

        try (Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3307/spms?user=leica&password=1234")) {
            String sql = "SELECT MNO, EMAIL, MNAME, TEL FROM MEMBERS WHERE MNO = ?";

            try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
                pstmt.setInt(1, no);

                try (ResultSet rs = pstmt.executeQuery()) {
                    if (rs.next()) {
                        Member member = new Member();

                        member.setNo(no);
                        member.setEmail(rs.getString("EMAIL"));
                        member.setName(rs.getString("MNAME"));
                        member.setName(rs.getString("TEL"));

                        return member;
                    } else {
                        throw new SQLException();
                    }
                }
            }
        }
    }

    // 수정
    public int update(Member member) throws SQLException {

        try (Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3307/spms?user=leica&password=1234")) {
            String sql = "UPDATE MEMBERS SET EMAIL = ?, MNAME = ?, TEL = ? WHERE MNO = ?";

            try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
                pstmt.setString(1, member.getEmail());
                pstmt.setString(2, member.getName());
                pstmt.setString(3, member.getTel());
                pstmt.setInt(4, member.getNo());

                return pstmt.executeUpdate();

            }
        }
    }

    // 삭제
    public int delete(int no) throws SQLException {

        try (Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3307/spms?user=leica&password=1234")) {
            String sql = "DELETE FROM MEMBERS WHERE MNO = ?";

            try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
                pstmt.setInt(1, no);

                return pstmt.executeUpdate();

            }
        }
    }
}

요구사항의 추가 - 소속 팀

회원은 어떤 한 팀에 필수로 소속되어야 한다는 요구사항이 추가되었다고 가정해보자.

다시 스키마를 변경하고, Member 객체를 변경하고, DAO를 변경하는 과정을 반복해야 할것이다.

아래와 같이 Member 객체에 Team 필드를 추가한다.

public class Member {

    private int no;
    private String email;
    private String name;
    private String tel;
    private Team team;  // 추가
    ...

이 때 Member 객체가 Team 객체를 사용하기 위해서는 반드시 SQL을 변경해야 한다.

즉 데이터 접근 계층을 사용해서 SQL을 숨겨도 개발 과정에서 어쩔 수 없이 DAO를 열어 SQL을 확인하는 과정이 필요하다.

애플리케이션에서 SQL을 직접 다룰 때 발생하는 문제점

- 진정한 의미의 계층 분할이 어렵다.
- 엔티티를 신뢰할 수 없다.
- SQL에 의존적인 개발을 피하기 어렵다.

Member나 Team처럼 비즈니스 요구사항을 모델링한 객체를 엔티티라 하는데 지금처럼 SQL에 모든 것을 의존하는 상황에서는 개발자들이 엔티티를 신뢰하고 사용할 수 없다.

대신 DAO를 열어 어떤 SQL이 실행되고 어떤 객체들이 함께 조회되는지 일일이 확인해야 한다.

물리적으로 SQL과 JDBC API를 데이터 접근 계층에 숨길순 있어도 논리적으로는 엔티티와 아주 강한 의존 관계를 갖게 된다.

이런 강한 의존 관계 때문에 회원 객체에 필드를 하나 추가할 때도 DAO의 CRUD 코드와 SQL 대부분을 변경해야 하는 문제가 발생한다.

JPA와 문제 해결

JPA는 위와 같은 문제를 해결해줄 수 있다.

JPA를 사용하면 객체를 데이터베이스에 저장하고 관리할 때 개발자가 직접 SQL을 작성하는 것이 아니라 JPA가 제공하는 API를 사용한다.

그러면 JPA가 개발자 대신 적절한 SQL을 생성해서 데이터베이스에 전달한다.

JPA가 제공하는 CRUD API

저장 기능

jpa.persist(member);	// 저장

persist()는 객체를 데이터베이스에 저장한다.

JPA가 객체와 매핑 정보를 보고 INSERT SQL을 생성해서 데이터베이스에 전달한다.

조회 기능

String memberId = "helloId";
Member member = jpa.find(Member.class, memberId);	// 조회

find()는 객체 하나를 데이터베이스에서 조회한다.

JPA가 객체와 매핑 정보를 보고 SELECT SQL을 생성해서 데이터베이스에 전달하고 그 결과로 Member 객체를 생성해서 반환한다.

수정 기능

Member member = jpa.find(Member.class, memberId);
member.setName("이름변경");	// 수정

JPA는 별도의 수정 메소드를 제공하지 않는다.

대신 객체를 조회해서 값을 변경하기만 하면 트랜잭션을 커밋할 때 데이터베이스에 UPDATE SQL이 전달된다.

연관된 객체 조회

Member member = jpa.find(Member.class, memberId);
Team team = member.getTeam();	// 연관된 객체 조회

JPA는 연관된 객체를 사용하는 시점에 SELECT SQL을 실행한다.

References

📖 자바 ORM 표준 JPA 프로그래밍(에이콘, 2015, 김영한)