JAVA 자바 마이바티스 mybatis 사용하기

🎯 자바 마이바티스를 사용해서 JDBC 프로그래밍을 연습해본다.

 

 

 

 

마이바티스 (MyBatis)

마이바티스는 퍼시스턴스 프레임워크(Persistence Framework)이다. 이 프레임워크를 사용하면 JDBC 프로그래밍을 좀 더 간단하게 작업할 수 있다.

 

 

마이바티스 연습해보기

프로젝트 구성

 

 

0. Test 클래스의 main 함수 실행 전

0-1. 오라클 드라이버 jar파일과 mybatis 드라이버 jar파일을 빌드패스에 추가한다.

0-2. com.config 패키지의 MySqlSessionFactory 클래스

#MySqlSessionFactory

public class MySqlSessionFactory {
	static SqlSessionFactory sqlSessionFactory = null;
	static {// 초기화
		// jdbc.properties파일 사용
		String resource = "Configuration.xml";
		InputStream inputStream = null;
		try {
			inputStream = Resources.getResourceAsStream(resource);
			System.out.println("초기화 성공");
		} catch (IOException e) {
			e.printStackTrace();
		}
		sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
	}// end static

	// SqlSession 반환
	public static SqlSession getSqlSession() {
		SqlSession session = sqlSessionFactory.openSession();
		return session;
	}
}

JDBC 커넥션을 담당하던 탬플릿 클래스의 역할을 MySqlSessionFactory 클래스가 담당한다. 이 클래스는 제일 먼저 static 블럭을 읽어오면서 어떤 파일을 저장할 것인지 확인한다. resuorce 변수에 담긴 'Configuration.xml'파일에 jdbc연결에 필요한 4가지 정보를 담는다.

#MySqlSessionFactory

InputStream inputStream=null;
		try {
			inputStream = Resources.getResourceAsStream(resource);
		} catch (IOException e) {
			e.printStackTrace();
		}
	 sqlSessionFactory =
		new SqlSessionFactoryBuilder().build(inputStream);

이 부분은 파일에서 데이터를 읽어와야하기 때문에 인풋스트림을 사용한 것이다. 최종적으로 커넥션을 얻어가는 클래스가 된다.

#MySqlSessionFactory

//SqlSession 반환해주는 메서드
	// MySqlSessionFactory.getSession()으로 호출 사용
	public static SqlSession getSession() {
		SqlSession session = sqlSessionFactory.openSession();
		//실제 사용자가 사용할 connection과 비슷한 객체
		return session;
	}

getSession을 통해서 db에 접속하고 사용한다. SqlSession이 JDBC의 Connection이라고 생각하면 된다.

0-3. XML에서 SqlSessionFactory 빌드하기

<?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="POOLED">
        <property name="driver" value="${driver}"/>
        <property name="url" value="${url}"/>
        <property name="username" value="${username}"/>
        <property name="password" value="${password}"/>
      </dataSource>
    </environment>
  </environments>
  <mappers>
    <mapper resource="org/mybatis/example/BlogMapper.xml"/>
  </mappers>
</configuration>

Configuration.xml 파일은 이렇게 생겼다. 마이바티스 홈페이지에서 빌드 형식을 그대로 붙여넣은 xml 파일을 만들고 필요한 드라이버 정보만 수정한다.

#드라이버 기본 정보 설정

<property name="driver" value="oracle.jdbc.driver.OracleDriver"/>
<property name="url" value="jdbc:oracle:thin:@localhost:1521:orcl"/>
<property name="username" value="scott"/>
<property name="password" value="tiger"/>

property 태그에 4가지 기본정보를 추가한다.

# 실행할 시퀄문을 가진 xml파일 지정

<mappers>
    <mapper resource="DeptMapper.xml"/>
  </mappers>

sql 쿼리는 매퍼라는 xml 파일에 작성한다.

 

** 만약 xml 문서가 올바르게 나오지 않으면 콘솔창 근처에 있는 source를 클릭한다.

 

 

1. Test 클래스의 main 함수 실행

#main

OracleMyBatisService service = new OracleMyBatisService();
List<Dept> list = service.select();
for (Dept dept : list) {
	System.out.println(dept);
}

오라클 Scott 계정에 있는 Dept테이블을 JDBC 연동에 사용할 것이다. 먼저 select() 메소드로 연습을 시작한다. 메인에서는 서비스 클래스만 사용한다. 서비스 클래스의 객체를 먼저 생성하고 Dept제너릭타입의 list 변수에 service.select()를 호출한다.

 

 

2. 서비스 클래스

public class OracleMyBatisService {

	OracleMybatisDAO dao;
	public OracleMyBatisService() {
		dao = new OracleMybatisDAO();
	}
	public List<Dept> select() {
		SqlSession session = MySqlSessionFactory.getSession();
		List<Dept> list = null;  //반환값을 준비
		try {
			list = dao.selectAll(session); //dao에 SqlSession 전송
		}finally {
			session.close(); //connection.close()와 비슷, 모든 함수마다 닫기
		}return list;
	}// end class

생성자에서 DAO객체를 생성하면 메인에서 service클래스의 객체를 생성하면서 dao객체도 생성할 수 있다.

2-1. 메소드 안에서 SqlSession을 얻어온다. (connection 얻어오기와 비슷하다)

2-2. 리스트를 만들어서 리스트에 dao의 셀렉함수를 호출하고 연결된 세션을 인자로 보낸다. 세션 사용 후 close()로 잘 닫아주고 호출로 받아온 list를 리턴한다.

 

 

3. DAO 클래스

public class OracleMybatisDAO {
	public List<Dept> selectAll(SqlSession session) {
		List<Dept> list = session.selectList("selectAll");
		return list;
	}
}

3-1. dao클래스의 코드는 간단하다. 서비스 클래스를 통해 세션을 받았으니 이제 데이터를 가져오기 위해 쿼리만 작성하면 된다. 쿼리는 매퍼 xml 파일에서 사용한다. 여기서 sqlsession 객체의 결과가 여러개인 select을 실행시 selectList 함수를 사용한다. 그리고 sql 쿼리를 호출하기 위해서 con.preparestatement(sql) 했던 것처럼 sql문을 매퍼에서 지정한 아이디로 호출한다.

 

 

4. Maper.xml 파일을 만든다.

5. sql select문을 select 태그 안에 작성한다.

6. 결과를 resultType에 저장한다. 결과를 담을 모델 클래스는 Dept로 지정한다.

# DTDMapper.xml

<mapper namespace="org.mybatis.example.BlogMapper">
	<select id="selectAll" resultType="com.dto.Dept">
	<!-- id=selectAll 실행 후 결과를 resultType으로 저장 -->
		select deptno, dname, loc from dept
	</select>
</mapper>

resultSet에 while문으로 하나하나 꺼내오던 작업이 사라지고 결과를 담을 모델클래스를 지정한 것이다.

public class Dept {

	private int deptno;
	private String dname;
	private String loc;

모델 클래스 Dept는 멤버변수 이름이 dept 테이블의 컬럼이름과 일치해야 한다. 또한 반드시 기본 생성자를 만들어야 한다. 생성자와 getter setter메소드를 만들고 toString까지 오버라이딩 해준다.

 

7. 맵퍼에서 dao로 리턴

8. dao에서 서비스로 리턴

9. 서비스에서 메인으로 리턴

10. 메인에서 리턴값 출력

 

마우스를 올려보면 리턴값이 넘어온 걸 볼 수 있다

 

 

 

SQL문 추가해서 마이바티스 연습하기

1. selectByDeptno

<select id="selectByDeptno" resultType="com.dto.Dept">
	select deptno, dname, loc from dept where deptno=10
</select>

#dao

public Dept selectByDeptno(SqlSession session){
		 Dept dept = session.selectOne("selectByDeptno");
		 return dept;
	}

#service

public Dept selectByDeptno() {
		SqlSession session = MySqlSessionFactory.getSession();
		Dept dept = null;
		try {
			dept = dao.selectByDeptno(session);
		} finally {
			// TODO: handle exception
		}return dept;
	}

#main

Dept dept = service.selectByDeptno();
System.out.println(dept);

 

 

2. selectByDeptnoUse

이번엔 deptno를 지정해주지 않고 메인함수에서 인자로 받아온다. 받아올 파라미터 타입을 여기서 미리 정해준다.

<select id="selectByDeptnoUse" parameterType="int" resultType="com.dto.Dept">
	select deptno, dname, loc from dept where deptno = #{deptno}
</select>

#dao

public Dept selectByDeptnoUse(SqlSession session, int deptno) {
		Dept dept = session.selectOne("selectByDeptnoUse", deptno);
		return dept;
	}

#service

public Dept selectByDeptnoUse(int deptno) {
	SqlSession session = MySqlSessionFactory.getSession();
	Dept dept = null;
	try {
		dept = dao.selectByDeptnoUse(session, deptno);
	} finally {
		session.close();
	}return dept;
}

#main

Dept dept2 = service.selectByDeptnoUse(40);
System.out.println(dept2);

 

 

3. deptInsert

DML 명령문은 트랜잭션을 자동 발생하기 때문에 커밋, 롤백 등으로 종료를 해야한다. 마이바티스는 오토커밋이 안된다. 기본이 false로 되어있기 때문에 dml문이 끝나면 커밋을 해야한다.

<insert id="deptInsert" parameterType="com.dto.Dept">
  	insert into dept (deptno, dname, loc) values
  	(#{deptno}, #{dname}, #{loc})
</insert>

dao

public void insert(SqlSession session, Dept dept) {
	int num = session.insert("deptInsert", dept);
	System.out.println("추가된 레코드 ====" + num);
}

service

public void insert(Dept dept) {
	SqlSession session = MySqlSessionFactory.getSqlSession();
	try {
		dao.insert(session, dept);
		session.commit();//명시적으로 꼭 해주어야 함. 
	} finally {
		session.close();
	}
}

service.insert(new Dept(99, "개발","강남"));

 

 

4. deptDelete

mapper

<delete id="deptDelete" parameterType="com.dto.Dept">
  	delete from dept where deptno = #{deptno}
  </delete>

dao

public void delete(SqlSession session,int deptno) {
	int num= session.delete("deptDelete", deptno);
	System.out.println("삭제된 갯수 ===="+ num);
}

service

public void delete(int deptno) {
	SqlSession session = MySqlSessionFactory.getSqlSession();
	try {
		dao.delete(session, deptno);
		session.commit();// 명시적으로 꼭 해주어야 함.
	} finally {
		session.close();
	}
}

Main

OracleMyBatisService service = new OracleMyBatisService();
List<Dept> list = service.selectAll();
for (Dept dept : list) {
	System.out.println(dept);
}		
Dept dept= service.selectByDeptno(99);
System.out.println(dept);
service.insert(new Dept(99, "개발","강남"));
service.update(new Dept(99,"영업", "서울"));
service.delete(99);

 

 

5. deptRecordCount

dept 테이블의 전체 레코드 개수를 출력한다.

<select id="deptRecordCount" resultType="int">
  	select count(*) from dept
  </select>

public int deptRecordCount(SqlSession session) {
		int num = session.selectOne("deptRecordCount");
		return num;
	}

public int deptRecordCount() {
		SqlSession session = MySqlSessionFactory.getSqlSession();
		int num = 0;
		try {
			num = dao.deptRecordCount(session);
		} finally {
			session.close();
		}return num;
	}

System.out.println(service.deptRecordCount());

 

 

6. selectByHashMap

select 결과를 해쉬맵으로 받는다. 조건문 검색에 between a and b연산자를 사용한다.

<select id="selectByHashMap" parameterType="HashMap" resultType="Dept">
 	select * from dept where deptno between #{a} and #{b}
</select>

public List<Dept> selectByHashMap(SqlSession session, HashMap<String, Integer> map){
		List<Dept> list= session.selectList("selectByHashMap", map);
		return list;
	}

public List<Dept> selectByHashMap(HashMap<String, Integer> map){
		SqlSession session = MySqlSessionFactory.getSqlSession();
		List<Dept> list = null;
		try {
			list = dao.selectByHashMap(session, map);
		} finally {
			session.close();
		}return list;
}

HashMap<String, Integer> map = new HashMap<> ();
map.put("a", 1);
map.put("b", 50);
List<Dept> list = service.selectByHashMap(map);
for (Dept dept : list) {
	System.out.println(dept);
}

 

 

7. selectInHashMap()

<select id="selectInHashMap" parameterType="HashMap"
		resultType="Dept">
		select * from dept where deptno in (#{a},#{b},#{c})
	</select>

public List<Dept> selectInHashMap (SqlSession session, HashMap<String,Integer> map){
		List<Dept> list= session.selectList("selectInHashMap", map);
		return list;
	}

public List<Dept> selectInHashMap(HashMap<String,Integer> map){
		SqlSession session = MySqlSessionFactory.getSqlSession();
		List<Dept> list = null;
		try {
			list = dao.selectInHashMap(session, map);
		} finally {
			session.close();
		}return list;
	}

map.put("a", 10);
		map.put("b", 70);
		map.put("c", 90);
		list=service.selectInHashMap(map);
		for (Dept d : list) {
			System.out.println(d);
		}

 

 

8. selectByDeptnoHashMap

<select id="selectByDeptnoHashMap" parameterType="int"
				resultType="HashMap">
	select * from dept where deptno=#{deptno}
</select>

public HashMap selectByDeptnoHashMap(SqlSession session,int empno) {
	HashMap map = session.selectOne("selectByDeptnoHashMap",empno);
	return map;
}

public HashMap selectByDeptnoHashMap(int deptno) {
	SqlSession session = MySqlSessionFactory.getSqlSession();
	HashMap map=null;
	try {
		map = dao.selectByDeptnoHashMap(session, deptno);
	} finally {
		session.close();
	}return map;
}

HashMap map2  = service.selectByDeptnoHashMap(10);
System.out.println(map2);
Set<String> keys = map2.keySet();
System.out.println(map2.get("DNAME"));
System.out.println(keys);

 

 

 

프로퍼티 만들기

앞으로 오라클 연동을 위한 4가지 기본정보는 properties로 등록한 후 키값만 바꿔서 쉽게 사용할 것이다. 나중에 DB가 바뀌면 여기 와서 수정하면 된다.

프로젝트에서 오른쪽마우스를 클릭하고 new -> file을 선택한다.

 

이제 configuration.xml파일에 가서 작성했던 정보를 수정한다.

<!--  jdbc.properties파일 등록 -->
<properties resource="jdbc.properties"/>
  <environments default="development">
    <environment id="development">
      <transactionManager type="JDBC"/>
      <dataSource type="POOLED">
      	<property name="driver" value="${oracle.jdbc.driver.OracleDriver}"/>
      	<property name="url" value="${jdbc:oracle:thin:@localhost:1521:orcl}"/>
      	<property name="userid" value="${soctt}"/>
      	<property name="passwd" value="${tiger}"/>
      <!--  기존 사용하던 4가지 정보
        <property name="driver" value="oracle.jdbc.driver.OracleDriver"/>
        <property name="url" value="jdbc:oracle:thin:@localhost:1521:orcl"/>
        <property name="username" value="scott"/>
        <property name="password" value="tiger"/> -->

기존에 작성했던 정보는 주석처리하고 프로퍼티에서 썼던 내용을 추가해준다.

 

 

 

매퍼.xml 파일을 여러개 사용하기

<mappers>
    <mapper resource="DeptMapper.xml"/>
    <mapper resource="DeptMapper2.xml"/>
  </mappers>

프로젝트 안에 매퍼를 또 하나 만든 뒤 configuration.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.dept.DeptMapper2">

 <select id="deptRecordCount" resultType="int">
  	select count(*) from dept
  </select>
<select id="selectAll" resultType="com.dto.Dept"><!-- 결과를 Dept의 List형태로 -->
    select deptno, dname, loc from dept
  </select>
</mapper>

 

<mapper namespace="com.dept.DeptMapper2">

매퍼의 네임스페이스도 수정해주기.

이렇게 매퍼를 여러개 등록할 경우 나중에 매퍼1의 내용을 사용하고 싶을 때 쿼리 아이디 + 매퍼 네임스페이스까지 같이 사용하게 된다.

 <!--  typealias 등록 -->
<typeAliases>
	<typeAlias type="com.dto.Dept" alias="Dept"></typeAlias>
</typeAliases>

이럴 경우 configuration.xmp 에서 간단한 별칭을 지정하고 사용할 수 있다. 별칭 지정 후 매퍼에서 다 수정한 뒤 사용해야한다.

 

 

 

😜 NEXT : 마이바티스 연습문제 풀어보기