MyBatis保姆级理解与使用，动态SQL（核心）

<!– List select ByCondition(Emp emp); –>

select emp_id,emp_name,emp_salary from sys_emp

<!– where标签会自动去掉“标签体内前面、后面多余的and/or” –>

<!– 使用if标签，让我们可以有选择的加入SQL语句的片段。这个SQL语句片段是否要加入整个SQL语句，就看if标签判断的结果是否为true –>

<!– 在if标签的test属性中，可以访问实体类的属性，不可以访问数据库表的字段 –>

<!– 在if标签内部，需要访问接口的参数时还是正常写#{} –>

or emp_name=#{empName}

2000″>

or emp_salary>#{empSalary}

<!–

第一种情况：所有条件都满足 WHERE emp_name=? or emp_salary>?

第二种情况：部分条件满足 WHERE emp_salary>?

第三种情况：所有条件都不满足 没有where子句

–>

<!– void updateeDynamic(Empemp) –>

update sys_emp

<!– 使用set标签动态管理set子句，并且动态去掉两端多余的逗号 –>

emp_name=#{empName},

<iftest="empSalary

emp_salary=#{empSalary},

where emp_id=#{empId}

<!– List selectByConditionByTrim(Emp emp) –>

select emp_id,emp_name,emp_age,emp_salary,emp_gender

from sys_emp

<!– prefix属性指定要动态添加的前缀 –>

<!– suffix属性指定要动态添加的后缀 –>

<!– prefixOverrides属性指定要动态去掉的前缀，使用“|”分隔有可能的多个值 –>

<!– suffixOverrides属性指定要动态去掉的后缀，使用“|”分隔有可能的多个值 –>

<!– 当前例子用where标签实现更简洁，但是trim标签更灵活，可以用在任何有需要的地方 –>

emp_name=#{empName} and

<iftest="empSalary >3000″>

emp_salary > #{empSalary} and

<iftest="empAge

emp_age=#{empAge} or

emp_gender=#{empGender}

<!– List selectByConditionByChoose(Emp emp) –>

select emp_id,emp_name,emp_salary from sys_emp

where

emp_name=#{empName}

3000″>emp_salary >3000

1=1

<!–

第一种情况：第一个when满足条件 where emp_name=?

第二种情况：第二个when满足条件 where emp_salary < 3000

第三种情况：两个when都不满足 where 1=1 执行了otherwise

–>

<!–

INSERT INTO `sys_emp` VALUES (null, ‘李冰冰‘, ‘lbb‘, ‘f’, 300,default,2),

(null, ‘张彬彬‘, ‘zbb‘, ‘m’, 599,default,3),

(null, ‘万茜‘, ‘wq‘, ‘m’, 4000,default,1),

(null, ‘李若彤‘, ‘lrt‘, ‘m’, 5000.8,default,1)

–>

<insertid=“insertBatch”>

INSERT INTO `sys_emp`(emp_id,emp_name,emp_gender)

<foreachcollection=“empList”item=“emp”separator=“,”open=“VALUES”>

(null,#{emp.empName},#{emp.empGender})

<!– 使用sql标签抽取重复出现的SQL片段 –>

select emp_id,emp_name,emp_age,emp_salary,emp_gender from t_emp

<!– 使用include标签引用声明的SQL片段 –>

packagecom.hy.mybatis.test;

importjava.io.IOException;

importorg.apache.ibatis.io.Resources;

importorg.apache.ibatis.session.SqlSession;

importorg.apache.ibatis.session.SqlSessionFactory;

importorg.apache.ibatis.session.SqlSessionFactoryBuilder;

importorg.junit.Before;

importorg.junit.Test;

importcom.hy.bean.Emp;

importcom.hy.mapper.EmpMapper;

publicclassTestLevelOneCache1 {

privateSqlSessionFactory sqlSessionFactory;

privateLogger logger= null;

@Before

publicvoidinit() throwsIOException {

logger= LoggerFactory.getLogger(this.getClass());

sqlSessionFactory= newSqlSessionFactoryBuilder().build(Resources.getResourceAsStream(“mybatis-config.xml”));

}

@Test

publicvoidtestLevelOneCache1_01() throwsIOException {

SqlSession session= sqlSessionFactory.openSession();

EmpMapper empMapper= session.getMapper(EmpMapper.class);

Emp emp1= empMapper.selectById(1);

Emp emp2= empMapper.selectById(1); // 第二次是从缓存中查询出来的。

logger.info(“是否相等:”+ (emp1== emp2)); //true

session.commit();

session.close();

}

}

1、就是获取缓存之前会先进行判断用户是否配置了flushCache=true属性（参考一级缓存的创建代码截图），如果配置了则会清除一级缓存。

2、MyBatis全局配置属性localCacheScope配置为Statement时，那么完成一次查询就会清除缓存。

publicclassTestLevelCache1 {

privateSqlSessionFactory sqlSessionFactory;

privateLogger logger= null;

@Before

publicvoidinit() throwsIOException {

logger= LoggerFactory.getLogger(this.getClass());

sqlSessionFactory= newSqlSessionFactoryBuilder().build(Resources.getResourceAsStream(“mybatis-config.xml”));

}

//1) 同一个SqlSession两次查询期间提交了事务

//1.1 没有提交事务，使用一级缓存

@Test

publicvoidtestLevelOneCache1_01() throwsIOException {

SqlSession session= sqlSessionFactory.openSession();

EmpMapper empMapper= session.getMapper(EmpMapper.class);

Emp emp1= empMapper.selectById(1);

Emp emp2= empMapper.selectById(1); // 第二次是从缓存中查询出来的。

logger.info(“是否相等:”+ (emp1== emp2)); //true

session.commit();

session.close();

}

//1.2 两次查询中间，提交了事务，清空一级缓存

@Test

publicvoidtestLevelOneCache1_02() throwsIOException {

SqlSession session= sqlSessionFactory.openSession();

EmpMapper empMapper= session.getMapper(EmpMapper.class);

Emp emp1= empMapper.selectById(1);

session.commit();

Emp emp2= empMapper.selectById(1); // 由于进行了事务的提交，所以又发送了一条查询语句。

logger.info(“是否相等:”+ (emp1== emp2)); //false

session.close();

}

}

@Test

publicvoidtestLevelOneCache01_4() {

SqlSession sqlSession= sqlSessionFactory.openSession();

EmpMapper empMapper= sqlSession.getMapper(EmpMapper.class);

Emp emp1= empMapper.selectById(1);

//EmpnewEmp = new Emp(2L, “范冰冰ILoveYou”, null, null, null, null);

//empMapper.updateById(newEmp); //更新但是不提交事务

empMapper.deleteById(8); //执行了删除没有，提交事务也，重新一遍

Emp emp2= empMapper.selectById(1);

//logger.debug(emp2.toString());

logger.debug(“是否相等:”+ (emp1== emp2));

sqlSession.commit();

sqlSession.close();

}

// 2.2

@Test

publicvoidtestLevelOneCache2_02() throwsIOException {

SqlSession session= sqlSessionFactory.openSession();

EmpMapper empMapper= session.getMapper(EmpMapper.class);

Emp emp1= empMapper.selectById(1); //查询后，将对象放入一级缓存

empMapper.deleteById(7); //执行了delete操作，但是并没有提交

session.commit();

Emp emp11= empMapper.selectById(1); //提交了事务，一级缓存清空

logger.info(“是否相等:”+ (emp1== emp11)); //false

session.commit();

session.close();

}

// 3. 同一个SqlSession但是查询条件发生了变化

@Test

publicvoidtestLevelOneCache3_01() throwsIOException {

SqlSession session= sqlSessionFactory.openSession();

EmpMapper empMapper= session.getMapper(EmpMapper.class);

Emp emp1= empMapper.selectById(1); //查询后，将对象放入一级缓存

//查询的是emp_id为2的员工信息，一级缓存中并没有所以重新发出一条SQL语句

Emp emp2= empMapper.selectById(2);

session.commit();

session.close();

}

// 4）同一个SqlSession两次查询期间手动清空了缓存

@Test

publicvoidtestLevelOneCache4() throwsIOException {

SqlSession session= sqlSessionFactory.openSession();

EmpMapper empMapper= session.getMapper(EmpMapper.class);

Emp emp1= empMapper.selectById(1);

session.clearCache();

Emp emp2= empMapper.selectById(1); // 由于两次查询中间清空了一级缓存，所以又发送了一条查询语句。

logger.info(“是否相等:”+ (emp1== emp2)); //false

session.commit();

session.close();

}

// 5）不是同一个SqlSession

@Test

publicvoidtestLevelOneCache1_05() throwsIOException {

SqlSession session01= sqlSessionFactory.openSession();

SqlSession session02= sqlSessionFactory.openSession();

EmpMapper empMapper01= session01.getMapper(EmpMapper.class);

EmpMapper empMapper02= session02.getMapper(EmpMapper.class);

Emp emp1= empMapper01.selectById(1);

// 由于是不同的SqlSession，所以又发送了一条查询语句。各自有各自的一级缓存。

Emp emp2= empMapper02.selectById(1);

logger.info(“是否相等:”+ (emp1== emp2)); //false

session01.commit();

session02.commit();

session01.close();

session02.close();

}

@Test

publicvoidtestLevelTwoCache() {

// 测试二级缓存存在：使用两个不同SqlSession执行查询

// 说明：SqlSession提交事务时才会将查询到的数据存入二级缓存

// 所以本例并没有能够成功从二级缓存获取到数据

SqlSession sqlSession01= sqlSessionFactory.openSession();

SqlSession sqlSession02= sqlSessionFactory.openSession();

EmpMapper empMapper01= sqlSession01.getMapper(EmpMapper.class);

EmpMapper empMapper02= sqlSession02.getMapper(EmpMapper.class);

//[00:01:07.699] [DEBUG] [main] [com.hy.mapper.EmpMapper] [Cache Hit Ratio [com.hy.mapper.EmpMapper]: 0.0]

Emp emp01= empMapper01.selectById(1);

//[00:01:07.746] [DEBUG] [main] [com.hy.mapper.EmpMapper] [Cache Hit Ratio [com.hy.mapper.EmpMapper]: 0.0]

Emp emp02= empMapper02.selectById(1);

logger.info(“是否相等:”+ (emp1== emp2)); //false

sqlSession01.commit();

sqlSession01.close();

sqlSession02.commit();

sqlSession02.close();

}

@Test

publicvoidtestSecondLevelCache2() {

SqlSession sqlSession01= sqlSessionFactory.openSession();

SqlSession sqlSession02= sqlSessionFactory.openSession();

EmpMapper empMapper01= sqlSession01.getMapper(EmpMapper.class);

EmpMapper empMapper02= sqlSession02.getMapper(EmpMapper.class);

Emp emp01= empMapper01.selectById(1);

sqlSession01.commit();

sqlSession01.close();

Emp emp02= empMapper02.selectById(1);

//false注意，从二级缓存中new了一个新的对象，所以emp01和emp02不是同一个对象

logger.info(“是否相等:”+ (emp1== emp2));

sqlSession02.commit();

sqlSession02.close();

}

@Test

publicvoidtestLevelTwoCache01_03() {

SqlSession sqlSession1= sqlSessionFactory.openSession();

SqlSession sqlSession2= sqlSessionFactory.openSession();

SqlSession sqlSession3= sqlSessionFactory.openSession();

EmpMapper empMapper1= sqlSession1.getMapper(EmpMapper.class);

EmpMapper empMapper2= sqlSession2.getMapper(EmpMapper.class);

EmpMapper empMapper3= sqlSession3.getMapper(EmpMapper.class);

Emp emp1= empMapper1.selectById(1);

logger.info(emp1.toString());

sqlSession1.commit(); //清空一级缓存，加入二级缓存

Emp emp2= empMapper2.selectById(1);

logger.info(emp2.toString()); //从二级缓存中查询出来

logger.info(“是否是同一个对象:”+(emp1==emp2));

sqlSession2.commit();

Emp newEmp= newEmp(1L,”垃圾张文宏“,null,null,null,null);

empMapper3.updateById(newEmp);

sqlSession3.commit();

Emp emp22= empMapper2.selectById(1);

logger.info(emp22.toString()); //从二级缓存中查询出来

logger.info(“是否是同一个对象:”+(emp1==emp22));

sqlSession2.commit();

sqlSession1.close();

sqlSession2.close();

}

1) 每个增删改标签都有默认清空缓存配置：flushCache=”true”，不过这是默认的是一级和二级缓存都清空

2）每个select标签都默认配置了useCache=”true”：
如果useCache= false：则表示不使用缓存（一级缓存依然使用，二级缓存不使用）

@Test

publicvoidtestLevelTwoCache04() {

SqlSession sqlSession01= sqlSessionFactory.openSession();

SqlSession sqlSession02= sqlSessionFactory.openSession();

SqlSession sqlSession03= sqlSessionFactory.openSession();

EmpMapper empMapper01= sqlSession01.getMapper(EmpMapper.class);

EmpMapper empMapper02= sqlSession02.getMapper(EmpMapper.class);

EmpMapper empMapper03= sqlSession03.getMapper(EmpMapper.class);

Emp emp01= empMapper01.selectById(1);

System.out.println(emp01);

Emp newEmp= newEmp(1L, “范冰冰“, “fbbfbb”, null, null, null, null,null);

empMapper02.updateByCondition(newEmp);

sqlSession02.commit();

sqlSession02.close();

Emp emp02= empMapper01.selectById(1);

System.out.println(emp02);

System.out.println(emp01== emp02);

}

[com.hy.mapper.EmpMapper] [Cache Hit Ratio [com.hy.mapper.EmpMapper]: 0.0]

[com.hy.mapper.EmpMapper.selectById] [==> Preparing: select * from sys_emp where emp_id = ?]

[com.hy.mapper.EmpMapper.selectById] [==> Parameters: 1(Long)]

[com.hy.mapper.EmpMapper.selectById] [<== Total: 1]

Emp [empId=1, empName=范冰冰222, empPwd=fbb, empGender=f, empSalary=30000.0, empStatus=y

[com.hy.mapper.EmpMapper.updateByCondition] [==> Preparing: update sys_emp SET emp_name = ? where emp_id = ?]

[com.hy.mapper.EmpMapper.updateByCondition] [==> Parameters: 范冰冰(String), 1(Long)]

[com.hy.mapper.EmpMapper.updateByCondition] [<== Updates: 1]

[com.hy.mapper.EmpMapper] [Cache Hit Ratio [com.hy.mapper.EmpMapper]: 0.0]

Emp [empId=1, empName=范冰冰222, empPwd=fbb, empGender=f, empSalary=30000.0, empStatus=y

true

<!– MybatisEHCache整合包 –>

org.mybatis.caches

mybatis-ehcache

1.2.1

ch.qos.logback

logback-classic

1.2.3

<projectxmlns=“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 http://maven.apache.org/xsd/maven-4.0.0.xsd”>

4.0.0

com.hy

springmvc006

0.0.1

war

UTF-8

UTF-8

UTF-8

org.projectlombok

lombok

1.18.20

<!– 数据库连接池 –>

com.alibaba

druid

1.2.9

com.fasterxml.jackson.core

jackson-databind

2.12.1

<!– mybaits相关jar包 –>

org.mybatis

mybatis

3.5.6

<!– MybatisEHCache整合包 –>

org.mybatis.caches

mybatis-ehcache

1.2.1

<!–

logback日志

slf4j日志门面的一个具体实现

–>

ch.qos.logback

logback-classic

1.2.3

junit

junit

4.12

test

mysql

mysql-connector-java

5.1.49

<!– mybaits相关jar包 –>

<!– 指定jdk，防止update project –>

org.apache.maven.plugins

maven-compiler-plugin

1.8

1.8

<!– 项目编码 –>

UTF-8

<?xmlversion=“1.0”encoding=“utf-8”?>

<ehcachexmlns:xsi=“http://www.w3.org/2001/XMLSchema-instance”

xsi:noNamespaceSchemaLocation=“../config/ehcache.xsd”>

<!– 磁盘保存路径 –>

<diskStorepath=“f:\hy\ehcache”/>

<defaultCache

maxElementsInMemory=“1000”

maxElementsOnDisk=“10000000”

eternal=“false”

overflowToDisk=“true”

timeToIdleSeconds=“120”

timeToLiveSeconds=“120”

diskExpiryThreadIntervalSeconds=“120”

memoryStoreEvictionPolicy=“LRU”>

<?xmlversion=“1.0”encoding=“UTF-8”?>

<configurationdebug=“true”>

<!– 指定日志输出的位置 –>

<appendername=“STDOUT”

class=“ch.qos.logback.core.ConsoleAppender”>

<!– 日志输出的格式 –>

<!– 按照顺序分别是：时间、日志级别、线程名称、打印日志的类、日志主体内容、换行 –>

[%d{HH:mm:ss.SSS}] [%-5level] [%thread] [%logger] [%msg]%n

<!– 设置全局日志级别。日志级别按顺序分别是：TRACE > DEBUG > INFO > WARN > ERROR > FATAL –>

<!– 指定任何一个日志级别都只打印当前级别和后面级别的日志。 –>

<rootlevel=“DEBUG“>

<!– 指定打印日志的appender，这里通过“STDOUT”引用了前面配置的appender –>

<appender-refref=“STDOUT”/>

<!– 根据特殊需求指定局部日志级别 –>

<loggername=“com.hy.mapper”level=“DEBUG”/>