이번 시간에는
진짜 애플리케이션에서 DB연동을 하여
애플리케이션에 기존 메모리가 아닌 DB에 쿼리를
날려 데이터를 관리하는 것을 해보았다.
발전 과정을 알아보기위해
옛날 방식으로 해보았다.!
dependencies {
implementation 'org.springframework.boot:spring-boot-starter-thymeleaf'
implementation 'org.springframework.boot:spring-boot-starter-web'
testImplementation 'org.springframework.boot:spring-boot-starter-test'
implementation 'org.springframework.boot:spring-boot-starter-jdbc'
runtimeOnly 'com.h2database:h2'
}일단 build.gradle 파일에 dependencies에
JDBC , H2 관련 라이브러리를 추가해준다.
spring.datasource.url=jdbc:h2:tcp://localhost/~/test
spring.datasource.driver-class-name=org.h2.Driver
spring.datasource.username=sa또한
resources/application.properties 이곳에
스프링 부트 데이터베이스 연결설정을 추가해준다.
이렇게 되면 데이터베이스에 접근하기 위한 준비가 다 되었다.
이제 JDBC API를 가지고 개발을 해보았다.
package hello.hellospring.repository; import hello.hellospring.domain.Member;
import org.springframework.jdbc.datasource.DataSourceUtils;
import javax.sql.DataSource;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
public class JdbcMemberRepository implements MemberRepository {
private final DataSource dataSource;
public JdbcMemberRepository(DataSource dataSource)
{ this.dataSource = dataSource;
}
@Override
public Member save(Member member) {
String sql = "insert into member(name) values(?)";
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
try {
conn = getConnection();
pstmt = conn.prepareStatement(sql,
Statement.RETURN_GENERATED_KEYS); pstmt.setString(1, member.getName());
pstmt.executeUpdate();
rs = pstmt.getGeneratedKeys();
if (rs.next()) { member.setId(rs.getLong(1));
} else {
throw new SQLException("id 조회 실패");
}
return member;
} catch (Exception e) {
throw new IllegalStateException(e);
} finally {
close(conn, pstmt, rs);
} }
@Override
public Optional<Member> findById(Long id) {
String sql = "select * from member where id = ?";
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
try {
conn = getConnection();
pstmt = conn.prepareStatement(sql); pstmt.setLong(1, id);
rs = pstmt.executeQuery();
if(rs.next()) {
Member member = new Member(); member.setId(rs.getLong("id")); member.setName(rs.getString("name")); return Optional.of(member);
} else {
return Optional.empty();
}
} catch (Exception e) {
throw new IllegalStateException(e);
} finally {
close(conn, pstmt, rs);
} }
@Override
public List<Member> findAll() {
String sql = "select * from member";
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
try {
conn = getConnection();
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
List<Member> members = new ArrayList<>(); while(rs.next()) {
Member member = new Member(); member.setId(rs.getLong("id")); member.setName(rs.getString("name")); members.add(member);
}
return members;
} catch (Exception e) {
throw new IllegalStateException(e);
} finally {
close(conn, pstmt, rs);
}
}
@Override
public Optional<Member> findByName(String name) {
String sql = "select * from member where name = ?";
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
try {
conn = getConnection();
pstmt = conn.prepareStatement(sql); pstmt.setString(1, name);
rs = pstmt.executeQuery();
if(rs.next()) {
Member member = new Member(); member.setId(rs.getLong("id")); member.setName(rs.getString("name")); return Optional.of(member);
}
return Optional.empty(); } catch (Exception e) {
throw new IllegalStateException(e);
} finally {
close(conn, pstmt, rs);
}
}
private Connection getConnection() {
return DataSourceUtils.getConnection(dataSource);
}
private void close(Connection conn, PreparedStatement pstmt, ResultSet rs)
{
try {
if (rs != null) {
rs.close(); }
} catch (SQLException e) { e.printStackTrace();
} try {
if (pstmt != null) { pstmt.close();
}
} catch (SQLException e) {
e.printStackTrace(); }
try {
if (conn != null) {
close(conn);
}
} catch (SQLException e) { e.printStackTrace();
} }
private void close(Connection conn) throws SQLException { DataSourceUtils.releaseConnection(conn, dataSource);
} }
package hello.hellospring;
import hello.hellospring.repository.JdbcMemberRepository;
import hello.hellospring.repository.MemberRepository;
import hello.hellospring.repository.MemoryMemberRepository;
import hello.hellospring.service.MemberService;
import org.springframework.beans.factory.annotation.Configurable;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.sql.DataSource;
@Configuration
public class SpringConfig {
private DataSource dataSource;
public SpringConfig(DataSource dataSource){
this.dataSource = dataSource;
}
@Bean
public MemberService memberService(){
return new MemberService(memberRepository());
}
@Bean
public MemberRepository memberRepository(){
//return new MemoryMemberRepository();
return new JdbcMemberRepository(dataSource);
}
}
기존에 MemoryMemberRepository() 를 반환하던것을
JdbcMemberRepository에 dataSource를 넣어주는 것 만으로
db를 이용하게끔 바꾸는 것이 가능해졌다. 다른 코드는 건들지 않고
jdbc연동 클래스 하나와 설정 파일 변경을 하였는데 치환하는 것이 가능하였다!
정상적으로 들어가는지 확인!
사실 중요한 것은 스프링을 왜쓰냐?
객체지향적인 설계가 왜 좋은가?
다형성을 활용! 인터페이스를 두고 구현체를 바꿔 끼우기를
굉장히 편리하게 되도록 스프링컨테이너가 지원을 해주기 때문!
의존성 주입 덕분에 편리하게 가능하다.
MemberService는 MemberRepository를 의존하고 있고
MemberRepository는 구현체로 MemoryMemberRepository 와 JdbcMemberRepository가 있다.
기존에는 memory를 스프링빈으로 등록했다면 이것을 빼고
jdbc를 등록하였다.
이것을 개방 폐쇄 원칙이라고 한다. 정보처리기사 공부할때 나왔던 내용이다.
SOLID 에 개방-폐쇄 원칙 이란
확장에는 열려있고, 수정에는 닫혀있다
스프링의 DI를 사용하면 '기존 코드를 전혀 손대지 않고, 설정만으로 구현 클래스를 변경 할 수있다.'
'웹프로그래밍 > Spring 입문' 카테고리의 다른 글
| 18. 스프링 JDBC Template (0) | 2021.06.29 |
|---|---|
| 17. 스프링 통합 테스트 (0) | 2021.06.29 |
| 15. H2 데이터베이스 설치 (0) | 2021.06.24 |
| 14. 회원 웹 기능 - 조회 (0) | 2021.06.24 |
| 13. 회원 웹 기능 - 등록 (0) | 2021.06.23 |