参考资料
执行
加载mybatis配置，创建sqlSessionFactory
public static void setUp() throws Exception {
Connection conn = null;
try {
Class.forName("org.hsqldb.jdbcDriver");
conn = DriverManager.getConnection("jdbc:hsqldb:mem:multidb", "sa", "");
Reader reader = Resources.getResourceAsReader("org/apache/ibatis/submitted/multidb/CreateDB.sql");
ScriptRunner runner = new ScriptRunner(conn);
runner.setLogWriter(null);
runner.setErrorLogWriter(null);
runner.runScript(reader);
conn.commit();
reader.close();
reader = Resources.getResourceAsReader("org/apache/ibatis/submitted/multidb/MultiDbConfig.xml");
sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader);
reader.close();
} finally {
if (conn != null) {
conn.close();
}
}
}
- 以Mapper类执行sql
SqlSession sqlSession = sqlSessionFactory.openSession();
MultiDbMapper mapper = sqlSession.getMapper(MultiDbMapper.class);
- 直接调用。
sqlSession.insert("org.apache.ibatis.submitted.selectkey.Table1.insert", parms);
sqlSession.select,update,delete
使用
基于xml和java注解的方式做映射。
这些属性都是可外部配置且可动态替换的，既可以在典型的 Java 属性文件中配置，亦可通过 properties 元素的子元素来传递。例如：
<properties resource="org/mybatis/example/config.properties">
<property name="username" value="dev_user"/>
<property name="password" value="F2Fa3!33TYyg"/>
</properties>
也可以把username和password 配置在config.properties文件中。
其中的属性就可以在整个配置文件中使用来替换需要动态配置的属性值。比如:
<dataSource type="POOLED">
<property name="driver" value="${driver}"/>
<property name="url" value="${url}"/>
<property name="username" value="${username}"/>
<property name="password" value="${password}"/>
</dataSource>
如果属性在不只一个地方进行了配置，那么 MyBatis 将按照下面的顺序来加载：
- 在 properties 元素体内指定的属性首先被读取。
- 然后根据 properties 元素中的 resource 属性读取类路径下属性文件或根据 url 属性指定的路径读取属性文件，并覆盖已读取的同名属性。
- 最后读取作为方法参数传递的属性，并覆盖已读取的同名属性。
因此，通过方法参数传递的属性具有最高优先级，resource/url 属性中指定的配置文件次之，最低优先级的是 properties 属性中指定的属性。
sql重用(字符串替换)，sql 包含(include)
<select id="select" resultType="map">
SELECT
${field_name}1, ${field_name}2, ${field_name}3
from
<include refid="sometable">
<property name="prefix" value="Some"/>
</include>
</select>
如上，字符串替换的 ${field_name} 需要配置在配置文件<configuration>的<properties>中：
<properties>
<property name="field_name" value="field"/>
</properties>
如上的 <include refid="sometable"> 需要卸载<sql>中，同时通过属性prefix传递了值Some：
<sql id="sometable">
${prefix}Table
</sql>
参数
#{property,javaType=int,jdbcType=NUMERIC}
参数类型由javaType确定
如果 null 被当作值来传递，对于所有可能为空的列，jdbcType 是需要的
缓存
- 映射语句文件中的所有 select 语句将会被缓存。
- 映射语句文件中的所有 insert,update 和 delete 语句会刷新缓存。
- 缓存会使用 Least Recently Used(LRU,最近最少使用的)算法来收回。
- 根据时间表(比如 no Flush Interval,没有刷新间隔), 缓存不会以任何时间顺序 来刷新。
- 缓存会存储列表集合或对象(无论查询方法返回什么)的 1024 个引用。
- 缓存会被视为是 read/write(可读/可写)的缓存,意味着对象检索不是共享的,而 且可以安全地被调用者修改,而不干扰其他调用者或线程所做的潜在修改。
参考文章:
- MyBatis的缓存
-
深入了解MyBatis二级缓存
- 针对一个表的某些操作不在他独立的namespace下进行 ,不能用二级缓存，否则会有脏数据
<cache
eviction="FIFO" // 缓存策略
flushInterval="60000" // 刷新间隔60秒
size="512" // 最大引用个数
readOnly="true"/>
写在mapper里
<mapper namespace="org.apache.ibatis.submitted.cacheorder.Mapper">
<!--cache-ref 引用另一个mapper文件-->
<!--<cache-ref namespace="org.apache.ibatis.submitted.cacheorder.Mapper2"/>-->
<cache/>
<select id="getUser" resultType="org.apache.ibatis.submitted.cacheorder.User">
select * from users
</select>
</mapper>
自定义缓存测试：
@Test
public void testMyCache() {
System.out.println("---------select------------");
SqlSession session = sqlSessionFactory.openSession(true);
User user = session.selectOne("org.apache.ibatis.submitted.cacheorder.Mapper.getUser");
System.out.println(user);
session.commit();
// System.out.println("----------update----------");
// session = sqlSessionFactory.openSession(true);
// session.update("org.apache.ibatis.submitted.cacheorder.Mapper.update");
// session.commit();
System.out.println("--------select----------");
session = sqlSessionFactory.openSession(true);
User user2 = session.selectOne("org.apache.ibatis.submitted.cacheorder.Mapper.getUser");
System.out.println(user2);
session.commit();
}
public class MyCache implements Cache {
private ConcurrentHashMap<Object, Object> cache = new ConcurrentHashMap<>(10);
private ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
private String id;
public MyCache(String id) {
this.id = id;
}
@Override
public String getId() {
System.out.println("getId = " + id);
return id;
}
@Override
public void putObject(Object key, Object value) {
System.out.println("put ["+key+"] value="+value);
cache.put(key, value);
}
@Override
public Object getObject(Object key) {
System.out.println("get objkey="+key+" "+cache.get(key));
return cache.get(key);
}
@Override
public Object removeObject(Object key) {
System.out.println("remove obj");
return cache.remove(key);
}
@Override
public void clear() {
cache.clear();
}
@Override
public synchronized int getSize() {
System.out.println("getsize");
return cache.size();
}
@Override
public ReadWriteLock getReadWriteLock() {
return lock;
}
}
配置
<cache type="org.apache.ibatis.submitted.cacheorder.MyCache"/>
我们一般会在自定义Cache里面使用Redis或者其他第三方存储介质来存数据。来提高性能，或统一管理。
mybatis缓存分为一级缓存和二级缓存
SqlSession commit或close之后，二级缓存才会生效这个问题
二级缓存的作用域是全局的(跨session的)
一级缓存的作用域是一个session
缓存流程：
- 查询数据的话，先从二级缓存中拿数据，如果没有的话，去一级缓存中拿，一级缓存也没有的话再查询数据库。
- SqlSession commit或close之后，二级缓存才会生效。
缓存执行流程
DefaultSqlSession#selectList：
CachingExecutor#query： 获取二级缓存，查二级缓存。查到直接返回
2.1 从TransactionalCache的entriesToAddOnCommit中找查不到则去父类BaseExecutor查：
3.1 查一级缓存(localCache 是PerpetualCache)。
3.2 一级缓存拿不到，数据库拿。
3.3 TransactionalCacheManager：事务缓存管理，将需要一个事务(session)的数据缓存在TransactionalCache中的
Map<Object, Object> entriesToAddOnCommit中。SqlSession commit或close之后 ，调用flushPendingEntries方法将entriesToAddOnCommit中的缓存数据put到实现了Cache接口的缓存中(调用putObject)。所以二级缓存的作用域是全局的(跨session的)
4.1 删除一级缓存clearLocalCache。即把PerpetualCache的mapper数据删除。所以一级缓存的作用域是一个session
Cache接口采用装饰者设计模式
动态sql
<!-- 等效于 WHERE description LIKE concat('%',#{parameter},'%') _parameter表示输入参数 -->
<!-- 等效于 WHERE description LIKE '${'%' + _parameter + '%'}'-->
<select id="selectLike" resultType="map" parameterType="string">
<bind name="pattern" value="'%' + _parameter + '%'" />
SELECT *
FROM ibtest.names
WHERE description LIKE #{pattern}
ORDER BY id
</select>
<bind>的value值会使用OGNL计算。
注解
- @SelectKey 可以用来获取自动增长的id的返回值，或者实现自动增长id
