Spring Boot 배치프로그램 개발 4 (MySQL + logback)

배치를 개발하였으니, 이제 MyBatis를 붙여서 DB 작업을 붙여보도록 하자

Spring에서 지원하는 MyBatis Annotaion과 MySQL을 사용하여 DB를 붙여 보도록 하자

 

우선 접속할 DB는 로컬에 설치한 MySQL이다.

아래와 같이 테이블을 생성한다

 

CREATE TABLE TEST ( first VARCHAR(50) ,second VARCHAR(50) , third VARCHAR(50) );

 

우선 TEST 테이블을 만들었다. 인덱스 없이 단순 테스트만 사용하기 위해,  만들었다.

 

로컬 데이터베이스에 접속하기 위한 정보를 입력하기 위해 DB정보를 매핑한다

Resource 아래에 application.properties 에 아래와 같이 입력하고, 개인 DB정보를 입력한다

 

 

datasource.driverClassName=com.mysql.jdbc.Driver datasource.url=jdbc:mysql://localhost:3306/test datasource.username=test datasource.password=test datasource.initSQL=SELECT 1

 

이제 DB를 처리하기위한 MyBatis Configuration 설정 파일과 설정 클래스를 만들어 보자

해당 클래스는 Database를 접속하기 위한 DataSource를 생성하고,

Transaction처리를 위한 Transaction Manager 클래스를 생성한다

 

 

package kr.kyoungjin.config; import javax.sql.DataSource; import org.apache.ibatis.session.SqlSessionFactory; import org.apache.tomcat.jdbc.pool.PoolProperties; import org.mybatis.spring.SqlSessionFactoryBean; import org.mybatis.spring.SqlSessionTemplate; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.core.io.support.PathMatchingResourcePatternResolver; import org.springframework.jdbc.datasource.DataSourceTransactionManager; import org.springframework.transaction.annotation.EnableTransactionManagement; import net.sf.log4jdbc.Log4jdbcProxyDataSource; import net.sf.log4jdbc.tools.Log4JdbcCustomFormatter; import net.sf.log4jdbc.tools.LoggingType; @Configuration @EnableTransactionManagement public class DBConfig { /** * @return */ @Bean @ConfigurationProperties(prefix="datasource") public PoolProperties getPoolProperties() { return new PoolProperties(); } /** DataSource 생성 * @param dataSource * @return * @throws Exception */ @Bean public DataSource getDataSource() { org.apache.tomcat.jdbc.pool.DataSource dataSource = new org.apache.tomcat.jdbc.pool.DataSource(getPoolProperties()) ; //return dataSource; //DataSource Log4jdbcProxyDataSource ljpds = new Log4jdbcProxyDataSource(dataSource); Log4JdbcCustomFormatter formatter = new Log4JdbcCustomFormatter(); LoggingType loggingType = LoggingType.MULTI_LINE; formatter.setLoggingType(loggingType); formatter.setSqlPrefix("SQL : "); ljpds.setLogFormatter(formatter); return (Log4jdbcProxyDataSource)ljpds; } /** SqlSessionFactory 생성 * @param dataSource * @return * @throws Exception */ @Bean public SqlSessionFactory getSqlSessionFactory(DataSource dataSource) throws Exception { SqlSessionFactoryBean sqlSessionFactory = new SqlSessionFactoryBean(); sqlSessionFactory.setDataSource(dataSource); sqlSessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:/mapper/*.xml")); sqlSessionFactory.setConfigLocation( new PathMatchingResourcePatternResolver().getResource("classpath:/mapper/config/mybatis-config.xml")); return (SqlSessionFactory) sqlSessionFactory.getObject(); } /** sql SqlSessionTemplate 생성 * @param sqlSessionFactory * @return */ @Bean(name="sqlSessionTemplate") public SqlSessionTemplate sqlSession(SqlSessionFactory sqlSessionFactory) throws Exception { //return new SqlSessionTemplate( sqlSessionFactory ); SqlSessionTemplate temple = new SqlSessionTemplate( getSqlSessionFactory(getDataSource()) ); //return new SqlSessionTemplate( getSqlSessionFactory(getDataSource()) ); return temple; } /** transaction 호출 * @return */ @Bean public DataSourceTransactionManager transactionManager() { DataSourceTransactionManager manager = new DataSourceTransactionManager(getDataSource()) ; return manager; } }

 

위의 소스는 어려운 부분이 없다. @Configuration 애노테이션은 bean를 생성하기 위한 클래스임을 선언한다

@Bean 애노테이션은 말 그대로 빈즈를 생성하는 클래스이다

기존 스프링에서 XML Configuration을 자바로 표현하였다

 

이제 MyBatis Configuration 파일과 Mapper 파일을 만들것이다

Configuration은 Resource 패키지 아래에서 mapper 를 생성하고, mapper 아래에 config 패키지를 생성하고

mybatis-config.xml  파일을 생성하고 아래 내용을 복사하도록 하자

 

 

<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd"> <configuration> <settings> <setting name="defaultExecutorType" value="REUSE" /> <setting name="defaultStatementTimeout" value="20000" /> <setting name="mapUnderscoreToCamelCase" value="true" /> </settings> <typeAliases> <typeAlias alias="testVo" type="kr.kyoungjin.vo.TestVo" /> </typeAliases> </configuration>

 

mapper 패키지에 쿼리를 사용하기 위한 매퍼파일을 생성한다

 

 

<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="kr.kyoungjin.dao.TestDao"> <select id="getTestInfo" parameterType="testVo" resultType="testVo"> SELECT first , second , third FROM TEST <where> <if test="first != null">first = #{first}</if> </where> </select> </mapper>

 

DB연결과 DB커넥션을 생성하였으니 DAO 와 데이터 처리를 위한 오브젝트 VO 를 만들어 보자

기본 패키지에서 dao 패키지와 vo 패키지를 생성하도록 하고 아래 자바 파일을 생성하자

 

dao 파일은 위의 매퍼에서 지정한 매퍼의 네임스페이스 위치와 동일해야 하므로 항상 유의 해야 한다

 

package kr.kyoungjin.dao; import kr.kyoungjin.vo.TestVo; public interface TestDao { public TestVo getTestInfo(TestVo vo) throws Exception; }

 

vo 파일은 모든 매퍼에서 사용하기 위해 mybatis configuration 파일에서 alias를 선언하였다

내용을 확인하고 위치를 정의 해주어야 한다

 

 

package kr.kyoungjin.vo; public class TestVo { private String first; private String second; private String third; public String getFirst() { return first; } public void setFirst(String first) { this.first = first; } public String getSecond() { return second; } public void setSecond(String second) { this.second = second; } public String getThird() { return third; } public void setThird(String third) { this.third = third; } }

 

위와 같이 소스를 모두 입력하고 나면 DB관련 파일은 모두 입력하였다

앞 강의에서 보여주었던 스케쥴 테스크 프로그램을 다시 확인해보자

 

@Component public class ScheduledTasks { private static final Logger log = LoggerFactory.getLogger(ScheduledTasks.class); private static final SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss"); @Autowired private TestDao testDao; private TestVo vo; //5초마다 로그를 뿌린다 @Scheduled(fixedRate = 5000) public void reportCurrentTime() { log.info("The time is now {}", dateFormat.format(new Date())); if( vo == null ) { vo = new TestVo(); } try { testDao.getTestInfo(vo); } catch( Exception e) { e.printStackTrace(); } } }

 

위에서 작성한 TestDao를 @Autowired 애노테이션으로 선언해 주었고

reportCurrentTime 메소드에서 testDao.getTestInfo(vo); 메소드를 호출하도록 하였다.

이제 5초마다 getTestInfo 에 호출된 쿼리를 호출하게 될 것이다

 

이제 결과를 확인해 보도록 하자