MyBatis系列：（5）动态SQL

gznz12345

package com.rk.dao;　　

　　
import java.util.ArrayList;
　　
import java.util.HashMap;
　　
import java.util.List;
　　
import java.util.Map;
　　

　　
import org.apache.ibatis.session.SqlSession;
　　
import org.junit.Test;
　　

　　
import com.rk.entity.Emp;
　　
import com.rk.utils.MyBatisUtils;
　　

　　
public class EmpDao {
　　
    /**
　　
     * 动态SQL之SELECT
　　
     */
　　
    public List dynamicFind(Integer id,String name,Double sal){
　　
        SqlSession sqlSession = null;
　　
        try {
　　
            Map map = new HashMap();
　　
            map.put("pid", id);
　　
            map.put("pname", name != null ? "%"+name+"%" : null);
　　
            map.put("psal", sal);
　　
            sqlSession = MyBatisUtils.getSqlSession();
　　

　　
            return sqlSession.selectList(Emp.class.getName() + ".dynamicFind", map);
　　
        } catch (Exception e) {
　　
            e.printStackTrace();
　　
            sqlSession.rollback();
　　
        }
　　
        finally{
　　
            MyBatisUtils.closeSqlSession();
　　
        }
　　
        return null;
　　
    }
　　

　　
    @Test
　　
    public void testDynamicFind(){
　　
        EmpDao dao = new EmpDao();
　　
        //List list = dao.dynamicFind(1,null, null);
　　
        //List list = dao.dynamicFind(null,"tom", null);
　　
        //List list = dao.dynamicFind(null,null, 350D);
　　
        List list = dao.dynamicFind(null,"tom", 350D);
　　
//        List list = dao.dynamicFind(0,"tom", 25D);
　　
        if(list != null && list.size()>0){
　　
            for(Emp emp : list){
　　
                System.out.println( emp.getName() + ":"+emp.getSal());
　　
            }
　　
        }
　　
    }
　　

　　
    /**
　　
     * 动态SQL之UPDATE
　　
     */
　　
    public int dynamicUpdate(Integer id,String name,Double sal){
　　
        SqlSession sqlSession = null;
　　
        try {
　　
            Map map = new HashMap();
　　
            map.put("pid", id);
　　
            map.put("pname", name);
　　
            map.put("psal", sal);
　　
            sqlSession = MyBatisUtils.getSqlSession();
　　

　　
            int i=sqlSession.update(Emp.class.getName() + ".dynamicUpdate", map);
　　
            sqlSession.commit();
　　
            return i;
　　
        } catch (Exception e) {
　　
            e.printStackTrace();
　　
            sqlSession.rollback();
　　
        }
　　
        finally{
　　
            MyBatisUtils.closeSqlSession();
　　
        }
　　
        return 0;
　　
    }
　　
    @Test
　　
    public void testDynamicUpdate(){
　　
        int i = dynamicUpdate(3,"Lucy",null);
　　
        System.out.println("本次操作影响"+i+"行数据");
　　
    }
　　

　　
    /**
　　
     * 动态SQL之DELETE（数组版本）
　　
     */
　　
    public int dynamicDeleteArray(int... ids){
　　
        SqlSession sqlSession = null;
　　
        try {
　　
            sqlSession = MyBatisUtils.getSqlSession();
　　
            int i=sqlSession.update(Emp.class.getName() + ".dynamicDeleteArray", ids);
　　
            sqlSession.commit();
　　
            return i;
　　
        } catch (Exception e) {
　　
            e.printStackTrace();
　　
            sqlSession.rollback();
　　
        }
　　
        finally{
　　
            MyBatisUtils.closeSqlSession();
　　
        }
　　
        return 0;
　　
    }
　　

　　
    @Test
　　
    public void testDynamicDeleteArray(){
　　
        int i = dynamicDeleteArray(3,2);
　　
        System.out.println("本次操作影响"+i+"行数据");
　　
    }
　　

　　
    /**
　　
     * 动态SQL之DELETE（集合版本）
　　
     */
　　
    public int dynamicDeleteList(List ids){
　　
        SqlSession sqlSession = null;
　　
        try {
　　
            sqlSession = MyBatisUtils.getSqlSession();
　　
            int i=sqlSession.update(Emp.class.getName() + ".dynamicDeleteList", ids);
　　
            sqlSession.commit();
　　
            return i;
　　
        } catch (Exception e) {
　　
            e.printStackTrace();
　　
            sqlSession.rollback();
　　
        }
　　
        finally{
　　
            MyBatisUtils.closeSqlSession();
　　
        }
　　
        return 0;
　　
    }
　　

　　
    @Test
　　
    public void testDynamicDeleteList(){
　　
        List ids = new ArrayList();
　　
        ids.add(1);
　　
        ids.add(4);
　　
        int i = dynamicDeleteList(ids);
　　
        System.out.println("本次操作影响"+i+"行数据");
　　
    }
　　

　　
    /**
　　
     * 动态SQL之INSERT
　　
     */
　　
    public int dynamicInsert(Emp emp){
　　
        SqlSession sqlSession = null;
　　
        try {
　　
            sqlSession = MyBatisUtils.getSqlSession();
　　
            int i=sqlSession.insert(Emp.class.getName() + ".dynamicInsert", emp);
　　
            sqlSession.commit();
　　
            return i;
　　
        } catch (Exception e) {
　　
            e.printStackTrace();
　　
            sqlSession.rollback();
　　
        }
　　
        finally{
　　
            MyBatisUtils.closeSqlSession();
　　
        }
　　
        return 0;
　　
    }
　　

　　
    @Test
　　
    public void testDynamicInsert(){
　　
        Emp emp = new Emp(1, null, 30D);
　　
        int i = dynamicInsert(emp);
　　
        System.out.println("本次操作影响"+i+"行数据");
　　
    }
　　
}