MyBatis系列：（5）动态SQL
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+"行数据");
}
}
页:
[1]