[JAVA] MyBatis 시작하기 (with Delegation Pattern)

Mybatis 란?

자바 객체와 SQL 을 연결해주는 SQL 매퍼 프레임워크이다.
JDBC 를 직접 사용해서 개발하는 것과 달리 SQL 문과 자바 프로그래밍을 구분해서 작성하기 때문에 가독성이 높다.
자바 파일이 아닌 XML에 쿼리문을 작성하기 때문에 쿼리문이 변경될 때마다 컴파일을 하지 않아도 된다는 장점이 있다.

1. maven project 생성, Mybatis dependency(pom.xml) 작성

<project xmlns="http://maven.apache.org/POM/4.0.0"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<groupId>Mybatis01</groupId>
	<artifactId>Mybatis01</artifactId>
	<version>0.0.1-SNAPSHOT</version>

	<dependencies>
		<!-- https://mvnrepository.com/artifact/commons-dbcp/commons-dbcp -->
		<dependency>
			<groupId>commons-dbcp</groupId>
			<artifactId>commons-dbcp</artifactId>
			<version>1.4</version>
		</dependency>

		<!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
		<dependency>
			<groupId>mysql</groupId>
			<artifactId>mysql-connector-java</artifactId>
			<version>8.0.26</version>
		</dependency>

		<!-- https://mvnrepository.com/artifact/org.mybatis/mybatis -->
		<dependency>
			<groupId>org.mybatis</groupId>
			<artifactId>mybatis</artifactId>
			<version>3.5.7</version>
		</dependency>

		<dependency>
			<groupId>org.apache.maven.plugins</groupId>
			<artifactId>maven-compiler-plugin</artifactId>
			<version>3.8.1</version>
		</dependency>
	</dependencies>
</project>

2. src/main/resources 에 mybatis-config.xml 작성

참고 : https://mybatis.org/mybatis-3/ko/getting-started.html

<?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="com.mysql.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/db01"/>
        <property name="username" value="mysql 아이디"/>
        <property name="password" value="mysql 비번"/>
      </dataSource>
    </environment>
  </environments>
  <mappers>
    <mapper resource="Mapper.xml"/>
  </mappers>
</configuration>

mysql 과 연동할 Connection 정보를 property에 입력
Mapper.xml 에 쿼리문 작성

3. src/main/resources 에 Mapper.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="Mapper">
	<insert id="test01" parameterType="map">
		insert into table01(age, fullname) values (#{age}, #{fullname})
	</insert>
	<insert id="test011" parameterType="int">
		insert into table02 values (#{age})
	</insert>
	<delete id="test02" parameterType="int">
		delete from table01 where age=#{age}
	</delete>
	<update id="test03" parameterType="map">
		update table01 set age=#{age} where fullname=#{fullname}
	</update>
	<update id="test033" parameterType="int">
		update table02 set age=age+10 where age=#{age}
	</update>
	<select id="test04" resultType="map">
		select * from table01
	</select>
	<select id="test044" resultType="int">
		select * from table02
	</select>
</mapper>

insert 태그 안에 insert 쿼리문 작성
id 는 해당 함수를 부를 이름, 나중에 메인 파일에서 해당 쿼리문을 실행할 때 입력한다.
전달할 파라미터가 2개 이상일 경우 parameterType 을 map 으로 설정
select 는 전달할 파라미터가 없고 db 데이터를 가져오는 함수이기 때문에 parameterType이 아닌 resultType 으로 설정

4. Hello.java 작성

package Pack01;
import java.io.InputStream;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

public class Hello {
	public static void main(String[] args) {
		SqlSessionFactory ssf = null;
		SqlSession session = null;
		InputStream is = null;
		
		System.out.println(1);
		try {
			is = Resources.getResourceAsStream("mybatis-config.xml");
		} catch (Exception e) {
			e.printStackTrace();
		}
		ssf = new SqlSessionFactoryBuilder().build(is);
		
		System.out.println(2);
		session = ssf.openSession();
		
		try {
//			Map<String, Object> param = new HashMap(); 
//			param.put("age", 20); 
//			param.put("fullname", "젊은이");
//			int result = session.insert("test01", param);
//			int result = session.delete("test02", 9999);
//			Map<String, Object> param = new HashMap();
//			param.put("age", 23);
//			param.put("fullname", "홍길동");
//			int result = session.update("test03", param);
			List<Integer> mm = session.selectList("test04");
			for(Integer item : mm) {
				System.out.println(item+" ");
			}
			System.out.println();
//			System.out.println("result: "+result);
//			if(result > 0) {
//				session.commit();
//			}
			session.close();
		} catch (Exception e) {
			e.printStackTrace();
		}
		
		System.out.println(3);
	}

}

Resources.getResourceAsStream("mybatis-config.xml") 으로 mysql db 연결
ssf = new SqlSessionFactoryBuilder().build(is); 으로 db 연동한 세션 열어주기
session.insert("test01", 9999); 으로 앞서 만들어둔 insert 함수인 test01에 접근하고 insert 문 수행
insert 됐으면 session.commit() 하고 close
session.commit() 은 데이터를 저장하는 용도이므로 select 실행 할 때는 필요 없다.

단일 매개변수, insert / select / update 함수로 구분

package Pack01;
import java.io.InputStream;
import java.util.List;

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

class UserDao{
	SqlSessionFactory ssf;
	
	UserDao(){
		try {
			InputStream is = Resources.getResourceAsStream("mybatis-config.xml");
			ssf = new SqlSessionFactoryBuilder().build(is);
		} catch (Exception e) {
			e.printStackTrace();
		}
		//session = ssf.openSession();
	}
	
	void insert(int num) {
		SqlSession session = ssf.openSession();
		try {
			int result = session.insert("test011", num);
			System.out.println("result: "+result);
			if(result > 0) {
				session.commit();
			}
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			session.close();
		}
	}
	
	void update(int num) {
		SqlSession session = ssf.openSession();
		try {
			int result = session.insert("test033", num);
			System.out.println("result: "+result);
			if(result > 0) {
				session.commit();
			}
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			session.close();
		}
	}
	
	void showAge() {
		SqlSession session = ssf.openSession();
		try {
			List<Integer> mm = session.selectList("test044");
			for(Integer item : mm) {
				System.out.println(item+" ");
			}
			System.out.println();
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			session.close();
		}
	}
	
}

public class Hello {
	public static void main(String[] args) {
		UserDao dao = new UserDao();
//		dao.insert(1234);
		dao.update(80);
		dao.showAge();
	}
}

UserDao 라는 객체를 생성해서 그 내부에 insert, update, select 와 같은 SQL 함수를 작성하여 사용할 때마다 main 함수에서 불러온다.

여러 매개변수

package Pack01;
import java.io.InputStream;
import java.util.List;
import java.util.Map;
import java.util.HashMap;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

class UserDao{
	SqlSessionFactory ssf;

	UserDao(){
		try {
			InputStream is = Resources.getResourceAsStream("mybatis-config.xml");
			ssf = new SqlSessionFactoryBuilder().build(is);
		} catch (Exception e) {
			e.printStackTrace();
		}
		//session = ssf.openSession();
	}

	void insert(int num) {
		SqlSession session = ssf.openSession();
		try {
			Map<String, Object> param = new HashMap();
			param.put("age", 10);
			param.put("fullname","냥이");
			int result = session.insert("test01", param);
			System.out.println("result: "+result);
			if(result > 0) {
				session.commit();
			}
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			session.close();
		}
	}

	void update(int num) {
		SqlSession session = ssf.openSession();
		try {
			Map<String, Object> param = new HashMap();
			param.put("age", 28);
			param.put("fullname","청년");
			int result = session.update("test03", param);
			System.out.println("result: "+result);
			if(result > 0) {
				session.commit();
			}
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			session.close();
		}
	}

	void showAge() {
		SqlSession session = ssf.openSession();
		try {
			Map<String, Object> mm = session.selectMap("test04","fullname","age");
			System.out.println(mm);
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			session.close();
		}
	}

}

public class Hello {
	public static void main(String[] args) {
		UserDao dao = new UserDao();
		//		dao.insert(1234);
		//dao.update(80);
		dao.showAge();
	}
}

단일 파라미터가 아닌 map 을 이용해서 여러 파라미터 받아오기

Delegation 패턴으로 리팩토링

Delegation Pattern 이란?

인터페이스가 직접 일을 처리하는 것이 아니라 인터페이스가 가리키는 메서드가 그 일을 받아서 처리한다.
처리되는 메서드 중 특정 부분의 메서드를 유동적으로 변경 가능하게 하려는 경우 Delegation Pattern 은 용이하다.
코드 유지 보수에 용이하다.
반복해서 사용되는 코드를 줄이고 재사용 가능한 코드 작성이 가능하다.

package Pack01;


class Tiger{
	void m1() { System.out.println(1); }
	void m2() { System.out.println(2); }
	void m3() { System.out.println(3); }
	void m4() { System.out.println(4); }
	void m5() { System.out.println(5); }
}

interface Delegate {
	void delegate(Tiger t);
}

class Proxy {
	void command(Delegate d) {
		Tiger t = new Tiger();
		t.m1();
		d.delegate(t);
		t.m5();
	}
}

public class World {
	public static void main(String[] args) {
		Proxy proxy = new Proxy();
		proxy.command(new Delegate() {
			public void delegate(Tiger t) {
				t.m3();
			}
		});
		System.out.println("-------------------------------");
		proxy.command(new Delegate() {
			public void delegate(Tiger t) {
				t.m2();
			}
		});
		System.out.println("-------------------------------");
		proxy.command(new Delegate() {
			public void delegate(Tiger t) {
				t.m4();
			}
		});
	}
}

Delegation Pattern 실습

package Pack01;
import java.io.InputStream;
import java.util.List;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

class Tiger{
	SqlSessionFactory ssf;
	SqlSession session;
	void m1(){
		try {
			InputStream is = Resources.getResourceAsStream("mybatis-config.xml");
			ssf = new SqlSessionFactoryBuilder().build(is);
		} catch (Exception e) {
			e.printStackTrace();
		}
		session = ssf.openSession();
	}
	
	void m5(int r) {
		try {
			int result = r;
			System.out.println("result: "+result);
			if(result > 0) {
				session.commit();
			}
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			session.close();
		}
	}
	
	int insert() { 	
		int result = session.insert("test011", 1234);
		System.out.println("insert");
		return result;
	}
	int update() { 
		int result = session.update("test033", 7777);
		System.out.println("update");
		return result;
	}
}

interface Delegate {
	int delegate(Tiger t);
}

class Proxy {
	void command(Delegate d) {
		Tiger t = new Tiger();
		t.m1();
		int result = d.delegate(t);
		t.m5(result);
	}
}

public class World {
	public static void main(String[] args) {
		Proxy proxy = new Proxy();
		proxy.command(new Delegate() {
			public int delegate(Tiger t) {
				return t.insert();
			}
		});
		System.out.println("-------------------------------");
		
		proxy.command(new Delegate() {
			public int delegate(Tiger t) {
				return t.update();
			}
		});

	}
}

Tiger 클래스의 m1 메서드와 m5 메서드는 고정이다.
m1()은 첫 번째로 실행되는 메서드이고 m5() 은 마지막으로 실행되는 메서드이다.
insert() 와 update() 는 int 타입을 리턴하는 메서드로 main 함수에서 Proxy 객체 내에서 인터페이스인 Delegate의 delegate 메서드가 실행되어 t.insert() 와 t.update() 를 리턴할 경우 Proxy 객체의 command 함수에서 그 리턴값을 받아서 m1 과 m5 메서드 사이에 insert와 update 를 넣어주는 방식이다.

Delegation Pattern 리팩토링

package Pack01;
import java.io.InputStream;
import java.util.List;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

class UserDao{
	SqlSession session;
	SqlSessionFactory ssf;
	
	UserDao(){
		try {
			InputStream is = Resources.getResourceAsStream("mybatis-config.xml");
			ssf = new SqlSessionFactoryBuilder().build(is);
		} catch (Exception e) {
			e.printStackTrace();
		}
		this.session = ssf.openSession();
	}

	void insert(final int num) { 	
		Proxy.command(this, new Delegate() {
			public int delegate(SqlSession session) {
				return session.insert("test011", num);
			}
		});
	}

	void update(final int num) {
		Proxy.command(this, new Delegate() {
			public int delegate(SqlSession session) {
				return session.update("test033", num);
			}
		});
	}
} 

interface Delegate {
	int delegate(SqlSession session);
}

class Proxy {
	static void command(UserDao dao, Delegate d) {
		SqlSession session = dao.ssf.openSession();
		try {
			int result = d.delegate(session);
			System.out.println("result: "+result);
			if(result > 0) {
				session.commit();
			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			session.close();
		}
	}
}

public class World {
	public static void main(String[] args) {
		UserDao dao = new UserDao();
		dao.insert(40);
		System.out.println("-------------------------------");
		dao.update(20);


	}
}

헤맸던 부분

main() 메서드에서 dao.insert() 메서드가 실행이 되면 UserDao 클래스 내의 insert() 메서드가 수행된다. 이때 Proxy.command() 메서드 내에서 delegate가 수행되면 SqlSession 객체를 delegate() 메서드에 매개 변수로 전달해서 session 의 open / close 상태를 넘기는 방식으로 session의 상태 유지를 해야 정상적으로 open과 close 가 되는데 그 부분을 생각하지 못하고 하나의 session 객체를 계속 불러오다보니 insert 와 update 메서드 중에서 먼저 실행되는 메서드만 정상 실행이 되고 뒤에 불러지는 메서드는 실행이 되지 않았다. executor was closed 에러가 자꾸 발생해서 뭐가 문제인가 보다가 session 상태 유지가 문제라는 것을 알게 되었다. 때문에 SqlSession session 을 delegate() 메서드에 매개변수로 줘서 insert()가 실행되면 session 을 부여해주고 open 부터 close 까지 정상적으로 실행되게끔 한 다음 update()가 실행되면 다시 session 을 부여해줘서 open 부터 close 까지 정상적으로 실행되게 만들었다.

'JAVA > MyBatis' 카테고리의 다른 글

[Java] MyBatis xml 작성 (0)	2023.09.18
[JAVA] Spring에서 Mybatis 연동 (0)	2021.09.24

[JAVA] MyBatis 시작하기 (with Delegation Pattern)

Mybatis 란?

Delegation 패턴으로 리팩토링

'JAVA > MyBatis' 카테고리의 다른 글

댓글

티스토리툴바

[JAVA] MyBatis 시작하기 (with Delegation Pattern)

Mybatis 란?

Delegation 패턴으로 리팩토링

'JAVA > MyBatis' 카테고리의 다른 글

관련글

댓글

티스토리툴바