JSP 프로그래밍 - [MyBatis] 매핑(Mapping)/mapper 설정

MyBatis 객체의 스코프와 생명 주기

 

 

 

SqlSessionFactoryBuilder -> SqlSessionFactory -> SqlSession -> Mapper

 

 

SqlSessionFactoryBuilder

 

이 클래스는 인스턴스화 되어 사용되고 던져질 수 있다. SqlSessionFactory 를 생성한 후 유지할 필요는 없다. 그러므로 SqlSessionFactoryBuilder 인스턴스의 가장 좋은 스코프는 메소드 스코프(예를들면 메소드 지역변수)이다. 여러 개의 SqlSessionFactory 인스턴스를 빌드하기 위해 SqlSessionFactoryBuilder를 재사용할 수도 있지만 유지하지 않는 것이 가장 좋다.

 

 

SqlSessionFactory

 

한번 만든뒤 SqlSessionFactory는 애플리케이션을 실행하는 동안 존재해야만 한다. 그래서 삭제하거나 재생성할 필요가 없다. 애플리케이션이 실행되는 동안 여러 차례 SqlSessionFactory 를 다시 빌드하지 않는 것이 가장 좋은 형태이다. 재빌드하는 형태는 좋지 않다. 그러므로 SqlSessionFactory 의 가장 좋은 스코프는 애플리케이션 스코프이다. 애플리케이션 스코프로 유지하기 위한 다양한 방법이 존재한다. 가장 간단한 방법은 싱글턴 패턴이나 static 싱글턴 패턴을 사용하는 것이다. 또는 구글 쥬스나 스프링과 같은 의존성 삽입 컨테이너를 선호할 수도 있다. 이러한 프레임워크는 SqlSessionFactory의 생명주기를 싱글턴으로 관리할 것이다.

 

 

SqlSession

 

각각의 쓰레드는 자체적으로 SqlSession인스턴스를 가져야 한다. SqlSession인스턴스는 공유되지 않고 쓰레드에 안전하지도 않다. 그러므로 가장 좋은 스코프는 요청 또는 메소드 스코프이다. SqlSession 을 static 필드나 클래스의 인스턴스 필드로 지정해서는 안된다. 그리고 서블릿 프레임워크의 HttpSession 과 같은 관리 스코프에 둬서도 안된다. 어떠한 종류의 웹 프레임워크를 사용한다면 HTTP 요청과 유사한 스코프에 두는 것으로 고려해야 한다. 달리 말해서 HTTP 요청을 받을때마다 만들고 응답을 리턴할때마다 SqlSession 을 닫을 수 있다. SqlSession 을 닫는 것은 중요하다. 언제나 finally 블록에서 닫아야만 한다. 다음은 SqlSession을 닫는 것을 확인하는 표준적인 형태다.

 

try (SqlSession session = sqlSessionFactory.openSession()) {
	// do work 
}

코드전반에 이런 형태를 사용하는 것은 모든 데이터베이스 자원을 잘 닫는 것으로 보장하게 할 것이다.

 

 

Mapper 인스턴스

 

Mapper는 매핑된 구문을 바인딩 하기 위해 만들어야 할 인터페이스이다. mapper 인터페이스의 인스턴스는 SqlSession 에서 생성한다. 그래서 mapper 인스턴스의 가장 좋은 스코프는 SqlSession 과 동일하다. 어쨌든 mapper 인스턴스의 가장 좋은 스코프는 메소드 스코프이다. 사용할 메소드가 호출되면 생성되고 끝난다. 명시적으로 닫을 필요는 없다.

try (SqlSession session = sqlSessionFactory.openSession()) { 
	BlogMapper mapper = session.getMapper(BlogMapper.class); 
    // do work 
}

 

 

이전에 jsp로 작성한 회원가입/로그인, 게시판, 파일게시판 (member, board, file 

 

com.java.myBatis 패키지를 추가해서 SqlCofig.xml, SqlManager.java 파일을 작성한다.

 

SqlConfig.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>
  <environments default="development">
    <environment id="development">
      <transactionManager type="JDBC"/>
      <dataSource type="UNPOOLED">
        <property name="driver" value="oracle.jdbc.driver.OracleDriver"/>
        <property name="url" value="jdbc:oracle:thin:@localhost:1521:xe"/>
        <property name="username" value="mvc"/>
        <property name="password" value="1234"/>
      </dataSource>
    </environment>
  </environments>
  <mappers>
    <mapper resource="/com/java/member/model/mapper/MemberMapper.xml"/>
    <mapper resource="/com/java/board/model/mapper/BoardMapper.xml"/>
  </mappers>
</configuration>

 

SqlManager.java

package com.java.myBatis;

import java.io.IOException;
import java.io.InputStream;

import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

public class SqlManager {
    private static SqlSessionFactory sqlSessionFactory;
    
    public static SqlSessionFactory getInstance() {
	
	try {
	    String resource = "com/java/myBatis/SqlConfig.xml";
	    InputStream inputStream = Resources.getResourceAsStream(resource);
	    sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
	} catch (IOException e) {
	    e.printStackTrace();
	}
	return sqlSessionFactory;
    }
}

 

com.java.member.model.mapping 패키지를 추가해서 MemberMapping.xml 파일을 작성한다.

 

MemberMapping.xml 

<?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="com.java.member.model.mapper.MemberMapper">
	<resultMap type="com.java.member.model.MemberDto" id="member_dto">
		<result column="num" property="num"/>
		<result column="id" property="id"/>
		<result column="password" property="password"/>
		<result column="name" property="name"/>
		<result column="jumin1" property="jumin1"/>
		<result column="jumin2" property="jumin2"/>
		<result column="email" property="email"/>
		
		<result column="zipcode" property="zipcode"/>
		<result column="address" property="address"/>
		<result column="job" property="job"/>
		<result column="mailing" property="mailing"/>
		<result column="interest" property="interest"/>
		<result column="member_level" property="memberLevel"/>
		<result column="register_date" property="registerDate"/>
	</resultMap>

<!-- 들어오는 것은 parameterType 나가는 것은 resultType id는 식별자, insert는 resultType 생략 -->
	<insert id="member_insert" parameterType="com.java.member.model.MemberDto">
		insert into member values(
				member_num_seq.nextval,
				#{id},
				#{password},
				#{name},
				#{jumin1},
				#{jumin2},
				#{email},
				#{zipcode},
				#{address},
				#{job},
				#{mailing},
				#{interest},
				#{memberLevel},
				sysdate
		)
	</insert>
	
	<select id="id_check" parameterType="java.lang.String" resultType="java.lang.String">
		select id from member 
				  where id = #{id}
	</select>
	
	<select id="member_zipcode" parameterType="String" resultType="com.java.member.model.MemberDto">
		select * from zipcode 
				 where dong = ${checkDong}		
	</select>
	
	<select id="member_login" parameterType="java.util.Map" resultType="String">
		select member_level from member 
							where id = #{id}
							and password = #{password}
	</select>
	
	<select id="member_select" parameterType="String" resultMap="member_dto">
		select * from member 
				 where id = #{id}
	</select>
	
	<update id="member_update" parameterType="com.java.member.model.MemberDto">
		update member set password = #{password}, 
						  email = #{email}, 
						  zipcode = #{zipcode}, 
						  address = #{address}, 
						  job = #{job}, 
						  mailing = #{mailing}, 
						  interest = #{interest} 
					  where num = #{num}
	</update>
	<delete id="member_delete" parameterType="java.util.Map">
		delete from member where id = #{id} and password = #{password}
	</delete>
</mapper>

 

 

BoardDao.java

package com.java.board.model;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;

import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;

import com.java.database.ConnectionProvider;
import com.java.database.jdbcUtil;
import com.java.myBatis.SqlManager;

public class BoardDao {
    private static SqlSessionFactory sqlSessionFactory = SqlManager.getInstance();
    private SqlSession session;
    
    private static BoardDao instance = new BoardDao();

    public static BoardDao getInstance() {
	return instance;
    }

    public int insert(BoardDto boardDto) {
	Connection conn = null;
	PreparedStatement pstmt = null;
	int value = 0;

	writeNumber(boardDto);
	
	try {	    
	    session = sqlSessionFactory.openSession();
	    value = session.insert("board_insert", boardDto);
	    session.commit();
	} catch (Exception e) {
	    e.printStackTrace();
	} finally {
	    session.close();
	}
	return value;
    }

    public void writeNumber(BoardDto boardDto) {
	// 그룹번호(ROOT), 글순서(자식), 글레벨(자식)
	int boardNumber = boardDto.getBoardNumber(); // 0
	int groupNumber = boardDto.getGroupNumber(); // 1
	int sequenceNumber = boardDto.getSequenceNumber(); // 0
	int sequenceLevel = boardDto.getSequenceLevel(); // 0

	try {
	    if (boardNumber == 0) { // ROOT : 그룹번호
		session = sqlSessionFactory.openSession();
		int max = session.selectOne("board_group_number_max");
		
		if(max!=0) boardDto.setGroupNumber(max+1);

	    } else { // 답글 : 글 순서, 글 레벨
		  HashMap<String, Integer> hMap = new HashMap<String, Integer>();
		  
		  session = sqlSessionFactory.openSession();
		  hMap.put("sequenceNumber", sequenceNumber);
		  hMap.put("sequenceLevel", sequenceLevel);
		  session.update("board_sequence_number", hMap);
		  
		  sequenceNumber = sequenceNumber + 1; 
		  sequenceLevel = sequenceLevel + 1;
		  
		  boardDto.setSequenceNumber(sequenceNumber);
		  boardDto.setSequenceLevel(sequenceLevel);
		 
	    }
	} catch (Exception e) {
	    e.printStackTrace();
	} finally {
	    session.close();
	}
    }

    public int getCount() {
	int value = 0;

	try {
	    session = sqlSessionFactory.openSession();
	    value = session.selectOne("board_count");
	    
	} catch (Exception e) {
	    e.printStackTrace();
	} finally {
	    session.close();
	}
	return value;
    }

    public List<BoardDto> getBoardList(int startRow, int endRow) {
	HashMap<String, Integer> hMap = new HashMap<String, Integer>();
	hMap.put("startRow", startRow);
	hMap.put("endRow", endRow);
	List<BoardDto> boardList = null;

	try {
	    session = sqlSessionFactory.openSession();
	    boardList = session.selectList("board_list", hMap);
	    
	} catch (Exception e) {
	    e.printStackTrace();
	} finally {
	    session.close();
	}
	return boardList;
    }

    public BoardDto read(int boardNumber) {
	BoardDto boardDto = null;
	
	try {
	    session = sqlSessionFactory.openSession();
	    session.update("board_update_count", boardNumber);
	    boardDto = session.selectOne("board_read", boardNumber);
	    session.commit();
	}catch (Exception e) {
	    e.printStackTrace();
	    session.rollback();
	}finally {
	    session.close();
	}
	return boardDto;
    }

    public int delete(int boardNumber, String password) {
	HashMap<String, Object> hMap = new HashMap<String, Object>();
	int value = 0;
	
	try {
	    session = sqlSessionFactory.openSession();
	    hMap.put("boardNumber", boardNumber);
	    hMap.put("password", password);
	    
	    value = session.delete("board_delete", hMap);
	    session.commit();
	} catch (Exception e) {
	    e.printStackTrace();
	    session.rollback();
	} finally {
	    session.close();
	}
	return value;
    }

    public BoardDto getContentList(int boardNumber) {
	BoardDto boardDto = null;
	
	try {
	    session = sqlSessionFactory.openSession();
	    boardDto = session.selectOne("board_select", boardNumber);
	} catch (Exception e) {
	    e.printStackTrace();
	} finally {
	    session.close();
	}
	return boardDto;
    }
    
    public int update(int boardNumber, BoardDto boardDto) {
	HashMap<String, Object> hMap = new HashMap<String, Object>();
	int value = 0;
	
	try {
	   session = sqlSessionFactory.openSession();
	   hMap.put("boardNumber", boardNumber);
	   hMap.put("boardDto", boardDto);
	   value = session.update("board_update", hMap);
	   session.commit();
	    
	} catch (Exception e) {
	    e.printStackTrace();
	    session.rollback();
	} finally {
	    session.close();
	}
	return value;
    }
}

ArrayList로 작성했던 것을 List로 업캐스팅 해주고 ListCommand.java 파일에서도 List로 바꿔준다.

 

BoardMapping.xml

<?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="com.java.board.model.mapper.BoardMapper">
	<resultMap type="com.java.board.model.BoardDto" id="board_dto">
		<result column="board_number" property="boardNumber"/>
			<result column="num" property="num"/>
			<result column="id" property="id"/>
			<result column="password" property="password"/>
			<result column="name" property="name"/>
			<result column="jumin1" property="jumin1"/>
			<result column="jumin2" property="jumin2"/>
			<result column="email" property="email"/>
			
			<result column="zipcode" property="zipcode"/>
			<result column="address" property="address"/>
			<result column="job" property="job"/>
			<result column="mailing" property="mailing"/>
			<result column="interest" property="interest"/>
			<result column="member_level" property="memberLevel"/>
			<result column="register_date" property="registerDate"/>
	</resultMap>
	
	<select id="board_group_number_max" resultType="int">
		select nvl(max(group_number), 0) from board
	</select>
	<update id="board_sequence_number" parameterType="java.util.HashMap">
		update board set sequence_number = sequence_number+1
		  			 where group_number = #{sequenceLevel} 
		  			 and sequence_number > #{sequenceNumber}
	</update>
	<select id="board_insert" parameterType="com.java.board.model.BoardDto">
		insert into board(
						board_number, 
						writer, 
						subject, 
						email, 
						content, 
						password,
						write_date, 
						read_count, 
						group_number, 
						sequence_number, 
						sequence_level)
		       values (board_number_seq.nextval,
		       			#{writer},
		       			#{subject},
		       			#{email},
		       			#{content},
		       			#{password},
		       			#{writeDate},
		       			#{readCount},
		       			#{groupNumber},
		       			#{sequenceNumber},
		       			#{sequenceLevel})
	</select>
	<select id="board_count" resultType="int">
		select count(*) from board
	</select>
	<select id="board_list" parameterType="java.util.HashMap" resultMap="board_dto">
		<!-- 쿼리문 안에 특수문자가 많은 경우에 명령어로 인식해서 에러가 나기때문에 필요 -->
		<![CDATA[
		select * from
		         (select rownum as rnum, a.* from 
		         							(select * FROM board 
		         							          order by group_number desc, 
		         							                    sequence_number asc) a) b 
		    	 where b.rnum >= #{startRow} and b.rnum <= #{endRow}
		]]>
	</select>
	<update id="board_update_count" parameterType="int">
		<![CDATA[
		update board set read_count = read_count+1
	    			 where board_number = #{boardNumber}
	    ]]>
	</update>
	<select id="board_read" parameterType="int" resultMap="board_dto">
		select * from board
				 where board_number = #{boardNumber}
	</select>
	<delete id="board_delete" parameterType="java.util.HashMap">
		delete from board 
			   where board_number = #{boardNumber} 
			   and password = #{password}
	</delete>
	<select id="board_select" parameterType="int" resultMap="board_dto">
		select * from board 
			     where board_number = #{boardNumber} 
	</select>
	<update id="board_update" parameterType="java.util.HashMap">
		update board set subject = #{boardDto.subject},
		    		 	 email = #{boardDto.email},
		    		 	 content = #{boardDto.content},
		    		 	 password = #{boardDto.password},
		    		 	 write_date = #{boardDto.writeDate}
	    			 where board_number = #{boardDto.boardNumber}
	</update>
</mapper>

---

int,String,float은 java.lang 패키지명 안써두 됨.