JAVA 자바 마이바티스 mybatis 동적SQL

🎯 자바 마이바티스 동적 SQL문을 알아본다.

 

 

 

 

마이바티스 홈페이지에서 동적sql 설명을 확인할 수 있다.

지난번 마이바티스 프로젝트를 사용해 연습해본다. 아래의 코드블럭 순서는 Mapper.xml -> Main -> Service -> DAO 클래스로 이어지며, 역순으로 실행결과를 리턴한 뒤 Main에서 실행을 종료한다.

 

 

selectDynamicDeptno

<select id ="selectDynamicDeptno" parameterType = "HashMap" resultType="Dept">
    select deptno, dname, loc from dept
    <if test="deptno != null">
        where deptno= #{deptno}
    </if>
</select>

쿼리문에 if태그를 사용해 조건을 붙일 수 있다. 조건이 true일 경우에 where절에 따라 쿼리문이 실행된다.

selectDynamicDeptno라는 id를 가진 이 select쿼리는 deptno를 해쉬맵으로 받아오고, 결과를 Dept 클래스에 저장할 것이다. 받아온 deptno가 null인 경우엔 저 조건문이 실행되지 않아서 모든 데이터가 출력된다.

Main

    int deptno = 10;
    HashMap<String, Integer> map = new HashMap<String, Integer>();
//    map.put("deptno", null);
    map.put("deptno", deptno);
    List<Dept> list = service.selectDynamicDeptno(map);
    for(Dept dept : list) {
    System.out.println(dept);
}

메인에서 부서번호는 10으로 지정해주고 해쉬맵 객체를 생성한다. 생성된 맵에 키값과 밸류값을 넣어주고 리스트를 만든 뒤 서비스의 함수를 호출하여 만들어진 맵을 전달한다.

Service

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

서비스의 셀렉함수는 호출된 메인에서 맵을 파라미터로 받아왔다. 이 함수의 리턴타입은 리스트이다.

세션을 연결하고 리스트를 만든 뒤 리스트에 dao의 셀렉함수를 호출하면서 세션과 받아온 맵을 전달해주고 session.close()로 세션을 반납한다. 그리고 리스트를 호출한 곳으로 리턴한다.

이 서비스 클래스는 세션만 연결하고 닫는 역할을 한다는 걸 알 수 있다.

DAO

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

dao에선 세션과 맵(메인에서 넘어온 키-밸류값)을 파라미터로 받아왔다. 리턴타입에 맞춰서 리턴할 리스트를 만든다.

SqlSession 의 selectList 메소드를 이용하면 쿼리 실행결과를 리스트로 받아올 수 있다. 인자의 첫번째 자리엔 Mapper.xml의 쿼리에서 지정한 id를 입력하고 두번재 자리에 받아온 해쉬맵을 적는다. 이 두개를 조합해서 리스트로 넣었으니 호출한 곳에 리스트를 리턴만 하면 된다. dao는 쿼리 결과를 담은 리스트 들고 서비스로 가고, 서비스는 리스트 들고 메인으로 간다. 메인은 리스트를 받아서 결과를 실행한다.

이전엔 서비스 클래스에서 커넥션을 받아오고 dao에서 쿼리를 작성한 후 메인으로 리턴하는 역할을 했는데, 이젠 매퍼로 쿼리를 분리했으니 dao는 세션과 쿼리를 받아와서 메인으로 리턴만 하는 역할을 하게 된다. 역할이 줄어들어서 코드가 짧아졌다.

 

 

selectDynamicChoose

<select id="selectDynamicChoose" parameterType = "HashMap" resultType="Dept">
    select deptno, dname, loc from dept
    <choose>
        <when test="dname != null">
            where dname = #{dname}
        </when>
        <when test="loc != null">
            where loc = #{loc}
        </when>
        <when test="dname != null and loc != null">
            where loc = #{loc} and dname #{dname}
        </when>
        <otherwise>
            where deptno = 10
        </otherwise>
    </choose>
</select>

자바의 if-else 문법처럼 조건을 여러개 사용할 때 마이바티스의 태그를 사용한다. when절을 if로, otherwiser를 else로 생각하면 된다.

이 쿼리문의 파라미터 타입은 해쉬맵으로 받고 결과는 Dept에 저장한다. 위에서 했던거와 달리 이번엔 검사할 조건이 여러개다. 이 모든 조건에 해당하지 않으면 10번부서 정보 출력한다.

HashMap<String, String> map2 = new HashMap<String, String>();
        map2.put("deptno", "제주");
        map2.put("dname", "영업");
        List<Dept> list1 = service.selectDynamicChoose(map2);
        for(Dept dept : list) {
            System.out.println(dept);
        }

dname과 loc를 조건으로 검사하기로 했으니까 해쉬맵 타입은 모두 스트링으로 받아오는 객체를 생성한다. 맵에 키 밸류 값을 넣어주고 리스트를 만들어서 서비스의 셀렉함수를 호출하면서 맵을 인자로 전달한다.

HashMap<String, String> map2 = new HashMap<String, String>();
        map2.put("deptno", "제주");
        map2.put("dname", "영업");
        List<Dept> list1 = service.selectDynamicChoose(map2);
        for(Dept dept : list) {
            System.out.println(dept);
        }

dname과 loc를 조건으로 검사하기로 했으니까 해쉬맵 타입은 모두 스트링으로 받아오는 객체를 생성한다. 맵에 키 밸류 값을 넣어주고 리스트를 만들어서 서비스의 셀렉함수를 호출하면서 맵을 인자로 전달한다.

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

서비스의 셀렉함수는 맵을 잘 받아왔다. 세션연결 먼저 해주고 리턴할 리스트 만든 다음에 dao의 셀렉함수 호출하면서 인자로 자신이 만든 세션이랑 메인에서 받아온 맵을 담아서 보내준다. 그러고 세션닫고 받아온 리스트 리턴하고 자기 할일을 끝냈다.

public List<Dept> selectDynamicChoose(SqlSession session, HashMap<String, String> map) {
        List<Dept> list = session.selectList("com.dept.DeptMapper3.selectDynamicChoose", map);
        return list;
    }

dao로 가보자. dao는 서비스에서 호출받은 대로 세션과 맵을 인자로 받아왔다. 서비스로 리턴할 리스트에 세션의 셀렉리스트 함수를 사용하여 xml의 쿼리문 아이디와 받아온 맵을 전달하고 쿼리문 실행된걸 받아와서 리스트에 담고 그걸 리턴한다. 이제 이걸 들고 서비스 가고 메인 가서 메인에서 결과출력하고 끝난다.

 

 

multiSelect

<select id="multiSelect" parameterType="java.util.List" resultType="Dept">
    select deptno, dname, loc from dept where deptno In
    <foreach item="item" index="index" collection="list" open="("
    separator="," close=")">
        #{item}
    </foreach>
</select>

 

foreach 태그는 는 컬렉션에 담아온 데이터를 in절에 모두 추가할 경우 주로 사용된다. 반복 돌릴 각 항목들의 매개변수 이름은 item이고 컬렉션 타입, 반환값의 시작과 끝 형태, 반복문 돌 때마다 붙여줄 구분자를 지정할 수 있다. 

deptno를 리스트로 여러개의 넘버를 받아와서 해당하는 정보를 셀렉하는 쿼리문을 작성한다. 파라미터를 리스트로 받았기 때문에 컬렉션도 리스트로 지정했다. in연산자 뒤는 (괄호)로 묶어주기 때문에 오픈과 클로즈를 괄호로 지정했다.

System.out.println("=========================");
    List<Integer> deptnoes = Arrays.asList(10,12,13); 
    List<Dept> list2 = service.multiSelect(deptnoes);
    for (Dept dept : list2) {
        System.out.println(dept);
    }

 

정수만 받는 리스트 타입의 변수 deptnoes에 배열을 넣을거다. 일단 10, 12, 13이 배열인데 이걸 리스트로 반환해서 리스트에 넣어준다. (Arrays.asList는 배열을 리스트로 반환해 준다.) 그리고 dept만 받는 리스트 타입의 리스트2에 서비스의 멀티셀렉함수를 호출해서 인자로 위에서 넣은 deptnoes를 전달한다.

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

멀티셀렉트는 메인에서 deptnoes를 파라미터로 받아왔다. 세션연결하고 리스트 만든 다음에 리스트에 dao의 멀티셀렉함수 호출해서 세션이랑 받아온 부서넘버리스트 전달하고 세션닫고 받아온 리스트 반환한다.

public List<Dept> multiSelect(SqlSession session, List<Integer> deptnoes) {
        List<Dept> list = session.selectList("com.dept.DeptMapper4.multiSelect", deptnoes);
        return list;
    }

dao는 세션이랑 부서넘버리스트 잘 전달 받아서 리스트 만들고 쿼리문에 쿼리문아이디랑 부서넘버를 전달한다. 받아온 리스트를 리턴하고 메인까지 데려가서 메인에서 반복문 돌려 출력한다.

 

 

multiDelte

<delete id="multiDelte" parameterType="java.util.List">
    delete from dept where loc in
    <foreach  item="item" index="index" collection="list"
        open="(" separator="," close=")">
        #{item}
    </foreach>
</delete>

Delete를 수행할 이 쿼리문은 리스트 타입으로 loc를 받아올거다.

List<String> loc = Arrays.asList("판교", "경기");
service.multiDelete(loc);

여러개의 지역정보를 리스트에 담고 서비스의 딜리트 함수를 호출하고 리스트를 보내준다.

public void multiDelete(List<String> loc) {
        SqlSession session = MySqlSessionFactory.getSqlSession();
        try {
            dao.multiDelete(session, loc);
            session.commit();
        } finally {
            session.close();
        }
    }

DML은 수행만 하고 반환값 없어도 되니까 리턴타입은 void로 하고 파라미터로 리스트를 받아왔다.

세션연결하고 dao의 멀티딜릿 함수를 호출하고 세션, 리스트를 전달한다. DML은 트랜잭션 자동발생이라 커밋 해주고 자원 반납하고 끝났다.

public void multiDelete(SqlSession session, List<String> loc) {
    System.out.println(loc);
    int num = session.delete("com.dept.DeptMapper4.multiDelte", loc);
    System.out.println(num);
}

dao도 리턴타입은 void로 설정하고 파라미터로 세션, 리스트 받아왔다. 실행횟수 출력을 위해 num 변수 만들어주고 딜리트 쿼리로 아이디랑 리스트 전달해주고 쿼리 실행해온 결과를 num에 넣어서 횟수 출력한다. 메인으로 가서 실행하면 판교, 경기 지역의 부서 레코드가 삭제된 걸 볼 수 있다.

 

 

multiDelte2

<delete id="multiDelte2" parameterType="java.util.List">
    delete from dept where deptno in
    <foreach  item="item" index="index" collection="list"
        open="(" separator="," close=")">
        #{item.deptno} <!-- dept객체의 deptno 사용 -->
    </foreach>
</delete>

deptno를 받아와서 그 부서의 레코드를 삭제한다.

List<Dept> depts = Arrays.asList(new Dept(12, "", ""), new Dept(13, "", ""));
        service.multiDelete2(depts);
        List<Dept> list = service.selectAll();
        for (Dept dept : list) {
            System.out.println(dept);

Dept 타입만 받는 리스트 안에 부서 번호만 담은 dept 생성자 두개를 리스트로 넣어준다. 그 다음 서비스의 딜리트 함수를 호출해서 리스트를 전달한다. 삭제를 수행하고 나서 전에 만들었던 selectAll 함수를 호출해서 남은 데이터들을 출력해볼 수 있다.

public void multiDelete2(List<Dept> depts) {
        SqlSession session = MySqlSessionFactory.getSqlSession();
        try {
            dao.multiDelete2(session, depts);
            session.commit();
        } finally {
            session.close();
        }
    }

서비스는 리스트 전달받아 왔고, 세션을 연결한다. 연결된 거 dao로 리스트랑 보내고, 커밋하고, 세션을 닫는다.

public void multiDelete2(SqlSession session, List<Dept> depts) {
        int num = session.delete("com.dept.DeptMapper4.multiDelte", depts);
        System.out.println("삭제된 갯수"+num);
    }

dao는 세션이랑 리스트 받아오고, 받은거 세션으로 넘겨서 쿼리문 수행해오고, 횟수 담아서 출력한다.

 

 

multiDelte3

<delete id="multiDelte3" parameterType="java.util.List">
    delete from dept where loc in
    <foreach  item="item" index="index" collection="list"
        open="(" separator="," close=")">
        #{item.loc}
    </foreach>
</delete>

loc를 받아와서 그 지역의 레코드를 삭제한다.

Dept dept1 = new Dept();
Dept dept2 = new Dept();
dept1.setLoc("부산");
dept2.setLoc("제주");
List<Dept> depts = Arrays.asList(dept1, dept2);
//List<Dept> depts = Arrays.asList(new Dept(12, "", ""), new Dept(13, "", ""));
service.multiDelete3(depts);
List<Dept> list = service.selectAll();
for (Dept dept : list) {
    System.out.println(dept);
}

이번에는 dept 객체를 각각 생성하고 각각 값을 넣어주고 리스트에 담는다. 주석처리 친 부분을 뜯어보면 저렇게 구성되어 있다. 서비스의 delete 함수를 호출해서 리스트를 전달한다.

public void multiDelete3(List<Dept> depts) {
        SqlSession session = MySqlSessionFactory.getSqlSession();
        try {
            dao.multiDelete3(session, depts);
            session.commit();
        } finally {
            session.close();
        }
    }

하는 일은 위와 똑같다.

public void multiDelete3(SqlSession session, List<Dept> depts) {
        System.out.println(depts);
        int num = session.delete("com.dept.DeptMapper4.multiDelte3", depts);
        System.out.println("삭제된 갯수"+num);
    }

delete를 수행하고 횟수를 출력한다.

 

 

multiInsert

<insert id="multiInsert" parameterType="arrayList">
    insert all 
    <foreach  item="item" index="index" collection="list">
            into dept (deptno, dname, loc) 
            values (#{item.deptno}, #{item.dname}, #{item.loc})
    </foreach>
    select * from dual
</insert>

무조건 insert all을 사용한다. 파라미터 타입은 리스트로 받는다. 여러 개 리스트를 가져올 부분은 foreach로 묶어주고 그 밖에 서브쿼리가 붙어있다. 임의 테이블에서 가져온 모든 정보를 dept테이블에 삽입한다.

dept1 = new Dept (13,"영업","판교");
dept2 = new Dept(22, "개발", "경기");
depts = Arrays.asList(dept1, dept2);
service.multiInsert(depts);

인서트할 정보를 리스트에 담고 서비스에 전달한다.

public void multiInsert(List<Dept> depts) {
        SqlSession session = MySqlSessionFactory.getSqlSession();
        try {
            dao.multiInsert(session, depts);
            session.commit();
        } finally {
            session.close();
        }
    }

서비스는 세션연결하고 받아온 거랑 같이 dao에 넘기고 커밋하고 클로즈한다.

public void multiInsert(SqlSession session, List<Dept> depts) {
        int num = session.insert("com.dept.DeptMapper4.multiInsert", depts);
        System.out.println("업데이트 갯수"+num);
    }

dao는 받아온거 세션에 전달해서 쿼리 수행하고 삭제 개수를 출력한다.

 

 

multiUpdate

<update id="multiUpdate" parameterType="java.util.List" >
    update dept set loc='제주' where deptno in
    <foreach  item="item" index="index" collection="list"
        open="(" separator="," close=")">
        #{item}
    </foreach>
</update>

deptno를 리스트로 받아와서 그 부서의 위치를 "제주"로 업뎃한다.

List<Integer> deptnoes = Arrays.asList(80, 88, 90);
service.multiUpdate(deptnoes);

정수만 받는 리스트 타입으로 부서번호 여러개 넣어주고 서비스의 업뎃함수 호출하고 인자를 전달한다.

public void multiUpdate(List<Integer> deptnoes) {
        SqlSession session = MySqlSessionFactory.getSqlSession();
        try {
            dao.multiUpdate(session, deptnoes);
            session.commit();
        } finally {
            session.close();
        }
    }

세션연결하고 세션,리스트 전달. 커밋. 클로즈.

public void multiUpdate(SqlSession session, List<Integer> deptnoes) {
        int num = session.update("com.dept.DeptMapper4.multiUpdate", deptnoes);
        System.out.println("update 갯수"+num);
    }

세션에 받아온거 전달해서 쿼리 실행하고 넘에 담아서 횟수를 출력한다.