$$config title: [Spring] Spring에서 DB연동하기 keywords: - JdbcTemplate - DataSource $$ # spring에서 DB연동하기 ## DB연동의 핵심! 1. xml파일에 정의한 dataSource관련 설정 2. memberDao클래스에 정의한 - JdbcTemplate클래스 객체를 참조하도록 선언한 코드 - memberDao의 객체가 처음 생성될 때 동작되는 코드로 DataSource클래스 객체를 매개변수로 전달받아 JdbcTemplate 객체를 생성하는 코드 ~~~java //JdbcTemplate클래스 객체를 참조하도록 선언한 코드 private JdbcTemplate jdbcTemplate; //DataSource클래스 객체를 매개변수로 전달받아 JdbcTemplate 객체를 생성하는 코드(memberDao의 생성자) public MemberDao(DataSource dataSource) { this.jdbcTemplate = new JdbcTemplate(dataSource); } ~~~ --- ### dataSource관련 설정 ![이미지](https://github.com/miruy/baekjoon/blob/master/%EC%8A%A4%ED%94%84%EB%A7%81%EC%97%90%EC%84%9C%20DB%EC%97%B0%EB%8F%992.png?raw=true) --- ### JdbcTemplate, memberDao관련 설정 ![이미지](https://github.com/miruy/baekjoon/blob/master/%EC%8A%A4%ED%94%84%EB%A7%81%EC%97%90%EC%84%9C%20DB%EC%97%B0%EB%8F%991.png?raw=true) --- ## DB연동 시 사용되는 주요개념 ### JdbcTemplate클래스 - spring-framework를 이용하여 웹 개발을 할 때 개발자의 편의를 위해 JDBC기능을 제공하는 클래스 - 개발자는 JDBC연동코드를 작성하지 않고 SQL구문만 관리하면 됨 > JDBC : Java DataBase Connection (자바와 DB의 연동 기술) - query(). update() 두가지를 이용해 간편하게 쿼리 전송 가능 ### RowMapper 인터페이스 - DB의 가로 행(insert내용)의 데이터를 꺼내 자바코드로 저장하는 인터페이스 > ex ) select쿼리 작성 시 List형태로 데이터를 가져오기 위해 while문을 이용하여 코드 작성(select 메서드 마다 작성) -> DB의 가로 행(Row)를 자바코드로 바로 매핑/저장(Mapper) - 개발자는 매핑/저장받을 타입만 정해주면 자동으로 spring이 매핑/저장 해줌 - 인터페이스의 객체는 생성이 불가능 하므로 익명중첩클래스로 생성해 사용 가능(예제 참고) #### 익명중첩클래스(예제 참고) - 하나의 클래스 안에 익명의 클래스가 있는 것 - 익명중첩클래스의 경우 추상적인 인터페이스, 추상클래스 등이 객체를 생성해야 할 때 만들어질 수 있음(기능만을 사용하기 위해) - 익명중첩클래스 생성 시 파일명이 (기존클래스명$1,2...)으로 표시 됨 - 익명중첩클래스의 코드 내용이 중복사용 될 경우 하나의 클래스로 생성하여 클래스 명(=함수)으로 대체하여 사용하는 방향을 지향 ### KeyHolder 인터페이스 - insert시 Key(시퀀스/PK 값)를 Holder(= kdyHolder객체의 변수)에 저장해놓는 인터페이스 > ex) 기존 시퀀스/PK(Key)값을 얻기 위해서는 데이터 등록(insert) - 해당 데이터 검색(select) -> 데이터 등록 시 바로 시퀀스/PK(Key)값을 Holder(kdyHolder객체)에 저장 (몇번째 값인지 꺼내올 수 있음) ## 스프링에서 DB연동하기 예제 - SqlDeveloper에서 테이블 생성 후 진행 ### MEMBER 테이블 생성 ~~~java drop sequence MEMBER_SEQ; drop table MEMBER cascade constraints; CREATE SEQUENCE MEMBER_SEQ START WITH 1 INCREMENT BY 1 MINVALUE 1 MAXVALUE 99999; create table MEMBER( ID number primary key, EMAIL varchar(255) unique, PASSWORD varchar(100), NAME varchar(100), REGDATE date ); insert into MEMBER (ID, EMAIL, PASSWORD, NAME, REGDATE) values(MEMBER_SEQ.nextval, 'garnet2929@naver.com', '1234', 'lkc', sysdate); commit; ~~~ --- ### Member객체 관리 클래스 (Dto) ~~~java public String getPassword() { return password; } public void setPassword(String password) { this.password = password; } public String getName() { return name; } public void setName(String name) { this.name = name; } public Date getRegisterDate() { return registerDate; } public void setRegisterDate(Date registerDate) { this.registerDate = registerDate; } //암호변경 기능을 구현하는 메서드 public void changePassword(String oldPassword, String newPassword) { if(!password.equals(oldPassword)) throw new IdPasswordNotMatchingException(); this.password = newPassword; } } ~~~ --- ### MemberDao 기능 클래스 (DB연동 핵심 코드 포함!) ~~~java package spring; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; import java.sql.Timestamp; import java.util.List; import javax.sql.DataSource; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.PreparedStatementCreator; import org.springframework.jdbc.support.GeneratedKeyHolder; import org.springframework.jdbc.support.KeyHolder; public class MemberDao { private JdbcTemplate jdbcTemplate; public MemberDao(DataSource dataSource) { this.jdbcTemplate = new JdbcTemplate(dataSource); } //RowMapper : DB의 가로 행(insert내용)의 데이터를 꺼내 자바코드로 저장하는 인터페이스 //-> 그냥 인터페이스는 객체생성이 부가능하므로 클래스안에 클래스를 만들어(익명중첩클래스)바로 정의해야함 //익명중첩클래스 : 클래스이름은 같지만 뒤에 $1, $2...이 붙으면서 익명중첩클래스가 됨 //하지만, 모든 메서드 또는 클래스에 RowMapper인터페이스를 구현하는 중첩클래스를 생성하면 중복이 많아지므로 //따로 RowMapper클래스를 생성하여 함수(=클래스 명)로 사용하는 방법을 지향함 // 이메일로 해당하는 정보 하나만 검색 메서드 // 반환 값이 있으므로 변수를 생성하여 쿼리 전송 public Member selectByEmail(String email) { List result = jdbcTemplate.query("select * from MEMBER where EMAIL = ?", new MemberRowMapper(), email); return result.isEmpty() ? null : result.get(0); } // 모든 정보 검색 메서드(반환행이 여러개면 List사용) public List selectAll() { List result = jdbcTemplate.query("select * from MEMBER", new MemberRowMapper()); return result; } // 이후, mapRow익명중첩클래스 부분이 중복되므로 MemberRowMapper클래스를 따로 생성하여 위의 코드 수정함 // 총 데이터 수 검색 메서드 // queryForObject : 결과 반환행이 하나 일 경우만 사용 가능 public int count() { Integer count = jdbcTemplate.queryForObject("select count(*) from MEMBER", Integer.class); return count; } // 수정 메서드 // 반환 값이 없으면 jdbcTemplat변수로 쿼리 전송 가능 public void update(Member member) { jdbcTemplate.update( "update MEMBER set NAME = ?, PASSWORD = ? where EMAIL = ?", member.getName(), member.getPassword(), member.getEmail()); } //등록 메서드, keyHolder클래스를 이용하여 자동으로 생성되는 키 값을 구하는 기능을 포함 // +추가 pstmt로 직접 세팅(경우의따라 직접 바인딩변수(?)를 직접 세팅할 수 있음) // createPreparedStatement(Connection con) 메서드를 가진 PreparedStatementCreator 인터페이스가 자바에 구현되어 있음 public void insert(final Member member) { //KeyHolder : pk, 시퀀스 값을 저장하여 insert시 알려주는 인터페이스 KeyHolder keyHolder = new GeneratedKeyHolder(); jdbcTemplate.update(new PreparedStatementCreator() { //직접 값을 세팅하기 위해 PreparedStatementCreator생성자를 매개변수로 전달 @Override public PreparedStatement createPreparedStatement(Connection con) throws SQLException { // 파라미터로 전달받은 Connection con을 이용해 PreparedStatement 생성 PreparedStatement pstmt = con.prepareStatement( "insert into MEMBER (ID, EMAIL, PASSWORD, NAME, REGDATE) values (MEMBER_SEQ.nextval, ?,?,?,?)", new String[] {"ID"}); // 인덱스 파라미터 값 설정 pstmt.setString(1, member.getEmail()); pstmt.setString(2, member.getPassword()); pstmt.setString(3, member.getName()); pstmt.setTimestamp(4, new Timestamp(member.getRegisterDate().getTime())); // 생성된 PreparedStatement 객체 반환 return pstmt; } }, keyHolder); //insert마다 pk,시쿼스를 keyHolder객체를 매개변수로 전달 Number keyValue = keyHolder.getKey(); //keyHolder객체에서 pk,시뭔스 값을 꺼내 keyValue변수에 저장 //keyValue변수에 저장한 pk,시퀀스값을 새로 insert되는 데이터(member)의 id(=pk,시퀀스)로 세팅 //xxxValue() : Number클래스로 받은 객체를 모든 기본타입형으로 변환할 수 있는 메서드 member.setId(keyValue.longValue()); //longValue() : long타입의 값 } } ~~~ --- ### appCtx.xml (xml파일 설정 - DB연동 핵심 코드 포함!) ~~~html

~~~ --- ### RowMapper인터페이스를 구현한 MemberRowMapper클래스 - 익명중첩클래스로 사용한 내용의 코드가 MemberDao 의 각 기능 메서드에 중복 사용되어 따로 생성한 클래스 ~~~java package spring; import java.sql.ResultSet; import java.sql.SQLException; import org.springframework.jdbc.core.RowMapper; public class MemberRowMapper implements RowMapper{ @Override //command+option+s public Member mapRow(ResultSet rs, int rowNum) throws SQLException{ Member member = new Member( rs.getString("EMAIL"), rs.getString("PASSWORD"), rs.getString("NAME"), rs.getTimestamp("REGDATE")); member.setId(rs.getLong("ID")); return member; } } ~~~ --- ### Main클래스 ~~~java package main; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; import org.springframework.context.support.AbstractApplicationContext; import org.springframework.context.support.GenericXmlApplicationContext; import spring.Member; import spring.MemberDao; public class MainForMemberDao { private static MemberDao memberDao; public static void main(String[] args) { AbstractApplicationContext ctx = new GenericXmlApplicationContext("classpath:addCtx.xml"); memberDao = ctx.getBean("memberDao", MemberDao.class); selectAll(); updateMember(); insertMember(); selectAll(); ctx.close(); } private static void insertMember() { System.out.println("-----insertMember"); SimpleDateFormat dateFormat = new SimpleDateFormat("MMddHHmmss"); //날짜 출력 형식을 지정하는 객체 생성(원하는 출력모양으로) String prefix = dateFormat.format(new Date()); //오늘 날짜를 구하는 클래스 객체 생성(날짜를 구해 원하는 출력모양으로 저장) Member member = new Member(prefix + "@test.com", //랜덤으로 insert하기위해 이메일 형식 데이터 입력 prefix, prefix, new Date()); memberDao.insert(member); System.out.println(member.getId() + " 데이터 추가"); } private static void updateMember() { System.out.println("-----selectAll"); Member member = memberDao.selectByEmail("garnet2929@naver.com"); String oldPw = member.getPassword(); String newPw = Double.toHexString(Math.random()); member.changePassword(oldPw, newPw); memberDao.update(member); System.out.println("암호 변경 : " + oldPw + " > " + newPw); } private static void selectAll() { System.out.println("-----updateMember"); int total = memberDao.count(); System.out.println("전체 데이터 : " + total); List members = (List)memberDao.selectAll(); for(Member m : members) { System.out.println( m.getId() + " : " + m.getEmail() + " : " + m.getName()); } } } ~~~ — ### update 기능에 사용한 비밀번호 변경 예외처리 클래스 ~~~java package spring; public class IdPasswordNotMatchingException extends RuntimeException{ //암호변경을 위해 새로운 암호 입력했을 때 기존비밀번호와 맞지 않으면 //표시할 에외처리 생성 } ~~~ — ### 출력화면 ![이미지](https://github.com/miruy/baekjoon/blob/master/%EC%8A%A4%ED%81%AC%EB%A6%B0%EC%83%B7%202022-02-23%20%EC%98%A4%EC%A0%84%2012.28.48.png?raw=true) —