Spring JDBC 작성 실습 (Select)
Role.java
select 해오기 위해서는 데이터의 이동이 필요하므로 DTO를 생성한다.
package kr.or.connect.daoexam.dto;
public class Role {
private int roleId;
private String description;
public int getRoleId() {
return roleId;
}
public void setRoleId(int roleId) {
this.roleId = roleId;
}
public String getDescription() {
return description;
}
public void setDescription(String description) {
this.description = description;
}
@Override
public String toString() {
return "Role [roleId=" + roleId + ", description=" + description + "]";
}
}
RoleDaoSqls.java
쿼리문을 작성하기 위한 클래스이다. 쿼리문의 수정을 쉽게하기 위해 여기에 쿼리문을 모아둔다.
상수(모두 대문자, 언더바로 구분하는 것이 관례)로 지정한다.
package kr.or.connect.daoexam.dao;
public class RoleDaoSqls {
public static final String SELECT_ALL = "SELECT role_id, description FROM role order by role_id";
}
RoleDao.java
컴포넌트, 서비스, 레파지토리, 컨트롤러 어노테이션 중에 @Repository를 이용하여 저장소의 역할을 한다고 표시한다.
Named~(바인딩 할 때 ? 말고 문자열을 사용하기 위해), Simple~ 객체를 사용한다.
생성자 부분에서는 DataSource를 파라미터로 받아들이고 있다. @Bean으로 등록했던 datasource가 파라미터로 전달된다.
RoleDaoSqls의 쿼리문을 사용하기 위해서는 import static을 해주어야 한다.
BeanPropertyRowMapper 객체를 이용해서 컬럼의 값을 자동으로 DTO에 담아주게 된다.
* 자바와 데이터베이스는 이름 규칙이 다른데, BeanPropertyRowMapper는 자동으로 다른 이름 규칙을 맞추어준다.
package kr.or.connect.daoexam.dao;
import static kr.or.connect.daoexam.dao.RoleDaoSqls.*;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import javax.sql.DataSource;
import org.springframework.dao.EmptyResultDataAccessException;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.core.namedparam.BeanPropertySqlParameterSource;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
import org.springframework.jdbc.core.namedparam.SqlParameterSource;
import org.springframework.jdbc.core.simple.SimpleJdbcInsert;
import org.springframework.stereotype.Repository;
import kr.or.connect.daoexam.dto.Role;
@Repository
public class RoleDao {
private NamedParameterJdbcTemplate jdbc;
private SimpleJdbcInsert insertAction;
private RowMapper<Role> rowMapper = BeanPropertyRowMapper.newInstance(Role.class);
public RoleDao(DataSource dataSource) {
this.jdbc = new NamedParameterJdbcTemplate(dataSource);
this.insertAction = new SimpleJdbcInsert(dataSource)
.withTableName("role");
}
public List<Role> selectAll(){
return jdbc.query(SELECT_ALL, Collections.emptyMap(), rowMapper);
}
}
ApplicationConfig.java 에 추가하기
ComponentScan으로 읽어낼 것이라는 설정을 해주어야 한다. 그래야 설정파일을 읽어낼 때 약속 된 어노테이션이 붙어있는 객체들을 찾아서 작업을 진행하기 때문이다.
때문에 자동으로 RoleDao에 @Repository 어노테이션이 붙어있는 클래스를 빈으로 등록해준다.
@ComponentScan(basePackages = { "kr.or.connect.daoexam.dao" })
SelectAllTest.java
Select를 테스트 할 수 있는 클래스
package kr.or.connect.daoexam.main;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import kr.or.connect.daoexam.config.ApplicationConfig;
import kr.or.connect.daoexam.dao.RoleDao;
import kr.or.connect.daoexam.dto.Role;
public class SelectAllTest {
public static void main(String[] args) {
ApplicationContext ac = new AnnotationConfigApplicationContext(ApplicationConfig.class);
RoleDao roleDao =ac.getBean(RoleDao.class);
List<Role> list = roleDao.selectAll();
for(Role role: list) {
System.out.println(role);
}
}
}Spring JDBC 작성 실습 (Insert, Update)
RoleDaoSqls.java에 쿼리문 추가하기
public static final String UPDATE = "UPDATE role SET description = :description WHERE ROLE_ID = :roleId";RoleDao.java
insert문에서는 SimpleJdbcInsert가 필요하므로 이 객체를 생성하는 코드를 추가한다.
withTableName은 어떤 테이블에 넣을 것인지를 설정하는 것이다.
jdbc.update 할 때 첫번째 파라미터는 sql, 두번째 파라미터는 맵 객체이다.
package kr.or.connect.daoexam.dao;
import static kr.or.connect.daoexam.dao.RoleDaoSqls.*;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import javax.sql.DataSource;
import org.springframework.dao.EmptyResultDataAccessException;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.core.namedparam.BeanPropertySqlParameterSource;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
import org.springframework.jdbc.core.namedparam.SqlParameterSource;
import org.springframework.jdbc.core.simple.SimpleJdbcInsert;
import org.springframework.stereotype.Repository;
import kr.or.connect.daoexam.dto.Role;
@Repository
public class RoleDao {
private NamedParameterJdbcTemplate jdbc;
private SimpleJdbcInsert insertAction;
private RowMapper<Role> rowMapper = BeanPropertyRowMapper.newInstance(Role.class);
public RoleDao(DataSource dataSource) {
this.jdbc = new NamedParameterJdbcTemplate(dataSource);
this.insertAction = new SimpleJdbcInsert(dataSource)
.withTableName("role");
}
public int insert(Role role) {
SqlParameterSource params = new BeanPropertySqlParameterSource(role);
return insertAction.execute(params);
}
public int update(Role role) {
SqlParameterSource params = new BeanPropertySqlParameterSource(role);
return jdbc.update(UPDATE, params);
}
}
JDBCTest.java
insert 테스트
insert 하기 전에 DTO 객체인 Role에 값이 들어있어야 하므로 set 해준다.
package kr.or.connect.daoexam.main;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import kr.or.connect.daoexam.config.ApplicationConfig;
import kr.or.connect.daoexam.dao.RoleDao;
import kr.or.connect.daoexam.dto.Role;
public class JDBCTest {
public static void main(String[] args) {
ApplicationContext ac = new AnnotationConfigApplicationContext(ApplicationConfig.class);
RoleDao roleDao = ac.getBean(RoleDao.class);
Role role = new Role();
role.setRoleId(201);
role.setDescription("PROGRAMMER");
int count = roleDao.insert(role);
System.out.println(count + "건 입력하였습니다.");
int count = roleDao.update(role);
System.out.println(count + " 건 수정하였습니다.");
}
}Spring JDBC 작성 실습 (1건 Select, Delete)
RoleDaoSqls.java에 추가하기
public static final String SELECT_BY_ROLE_ID = "SELECT role_id, description FROM role where role_id = :roleId";
public static final String DELETE_BY_ROLE_ID = "DELETE FROM role WHERE role_id = :roleId";RoleDao.java에 추가하기
SqlParameterSource를 이용해서 객체를 이용해 map으로 바꿔도 되지만, delete는 값이 하나만 들어올 것이므로 Collections.singletonMap을 이용해보자.
해당 조건에 맞는 조건이 없을 때를 고려하여 예외처리를 해주어야 한다.
package kr.or.connect.daoexam.dao;
import static kr.or.connect.daoexam.dao.RoleDaoSqls.*;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import javax.sql.DataSource;
import org.springframework.dao.EmptyResultDataAccessException;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.core.namedparam.BeanPropertySqlParameterSource;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
import org.springframework.jdbc.core.namedparam.SqlParameterSource;
import org.springframework.jdbc.core.simple.SimpleJdbcInsert;
import org.springframework.stereotype.Repository;
import kr.or.connect.daoexam.dto.Role;
@Repository
public class RoleDao {
private NamedParameterJdbcTemplate jdbc;
private SimpleJdbcInsert insertAction;
private RowMapper<Role> rowMapper = BeanPropertyRowMapper.newInstance(Role.class);
public RoleDao(DataSource dataSource) {
this.jdbc = new NamedParameterJdbcTemplate(dataSource);
this.insertAction = new SimpleJdbcInsert(dataSource)
.withTableName("role");
}
public int deleteById(Integer id) {
Map<String, ?> params = Collections.singletonMap("roleId", id);
return jdbc.update(DELETE_BY_ROLE_ID, params);
}
public Role selectById(Integer id) {
try {
Map<String, ?> params = Collections.singletonMap("roleId", id);
return jdbc.queryForObject(SELECT_BY_ROLE_ID, params, rowMapper);
}catch(EmptyResultDataAccessException e) {
return null;
}
}
}
JDBCTest.java에 추가하기
Role resultRole = roleDao.selectById(201);
System.out.println(resultRole);
int deleteCount = roleDao.deleteById(500);
System.out.println(deleteCount + "건 삭제하였습니다.");
Role resultRole2 = roleDao.selectById(500);
System.out.println(resultRole2);
| #03. BE - Spring MVC 실습 (0) | 2018.08.03 |
|---|---|
| #03. BE - Spring MVC 개념과 동작흐름 (0) | 2018.08.03 |
| #03. BE - Java Config로 의존성주입 설정하기 (0) | 2018.08.02 |
| #03. BE - xml파일을 이용하여 의존성주입 설정하기 (0) | 2018.08.02 |
| #03. BE - Spring Framework 기초 (0) | 2018.07.20 |