请教Mybatis中如何在程序中获取Mapper中定义的SQL语句

请教Mybatis中如何在程序中获取Mapper中定义的SQL语句,第1张

可以用对应Mapper类,里面的方法名是对应的sql语句的ID名,这个可以去调用;还有一种,就是不用Mapper类,可以直接用xml的文件名id名获取的方式,这个方式要有像SqlSessionTemplate这样的类,提前定义好方法获取方式,然后调用就可以了

<select id="DAO接口方法名称" parameterType="参数类型" resultType="返回结果类型">

select from 表 where 。。。

</select>

resultType 可以是任意Object对象,如果多条数据,这这个方法返回的是List<Object>,

如果确认是单条数据,可以直接 Object (); 。

没有封装成对象时,默认返回的是List<Map<字段名称String,列值Object>>这样的数据。

Dao接口:

List<Map<String,Object>> list(Integer id);

SQL:

<select id="list" parameterType="Integer" resultType="Map">

select from aaa

<where>

<if test="null!=id">

id >#{id}

深入了解MyBatis二级缓存

一、创建Cache的完整过程

我们从SqlSessionFactoryBuilder解析mybatis-configxml配置文件开始:

Reader reader = ResourcesgetResourceAsReader("mybatis-configxml");

SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder()build(reader);

然后是:

XMLConfigBuilder parser = new XMLConfigBuilder(inputStream, environment, properties);

return build(parserparse());

看parserparse()方法:

parseConfiguration(parserevalNode("/configuration"));

看处理Mapperxml文件的位置:

mapperElement(rootevalNode("mappers"));

看处理Mapperxml的XMLMapperBuilder:

XMLMapperBuilder mapperParser = new XMLMapperBuilder(inputStream, configuration,

resource, configurationgetSqlFragments());

mapperParserparse();

继续看parse方法:

configurationElement(parserevalNode("/mapper"));

到这里:

String namespace = contextgetStringAttribute("namespace");

if (namespaceequals("")) {

throw new BuilderException("Mapper's namespace cannot be empty");

}

builderAssistantsetCurrentNamespace(namespace);

cacheRefElement(contextevalNode("cache-ref"));

cacheElement(contextevalNode("cache"));

从这里看到namespace就是xml中<mapper>元素的属性。然后下面是先后处理的cache-ref和cache,后面的cache会覆盖前面的cache-ref,但是如果一开始cache-ref没有找到引用的cache,他就不会被覆盖,会一直到最后处理完成为止,最后如果存在cache,反而会被cache-ref覆盖。这里是不是看着有点晕、有点乱看所以千万别同时配置这两个,实际上也很少有人会这么做。

看看MyBatis如何处理<cache/>:

private void cacheElement(XNode context) throws Exception {

if (context != null) {

String type = contextgetStringAttribute("type", "PERPETUAL");

Class< extends Cache> typeClass = typeAliasRegistryresolveAlias(type);

String eviction = contextgetStringAttribute("eviction", "LRU");

Class< extends Cache> evictionClass = typeAliasRegistryresolveAlias(eviction);

Long flushInterval = contextgetLongAttribute("flushInterval");

Integer size = contextgetIntAttribute("size");

boolean readWrite = !contextgetBooleanAttribute("readOnly", false);

boolean blocking = contextgetBooleanAttribute("blocking", false);

Properties props = contextgetChildrenAsProperties();

builderAssistantuseNewCache(typeClass, evictionClass,

flushInterval, size, readWrite, blocking, props);

}

}

从源码可以看到MyBatis读取了那些属性,而且很容易可以到这些属性的默认值。

创建Java的cache对象方法为builderAssistantuseNewCache,我们看看这段代码:

public Cache useNewCache(Class< extends Cache> typeClass,

Class< extends Cache> evictionClass,

Long flushInterval,

Integer size,

boolean readWrite,

boolean blocking,

Properties props) {

typeClass = valueOrDefault(typeClass, PerpetualCacheclass);

evictionClass = valueOrDefault(evictionClass, LruCacheclass);

Cache cache = new CacheBuilder(currentNamespace)

implementation(typeClass)

addDecorator(evictionClass)

clearInterval(flushInterval)

size(size)

readWrite(readWrite)

blocking(blocking)

properties(props)

build();

configurationaddCache(cache);

currentCache = cache;

return cache;

}

从调用该方法的地方,我们可以看到并没有使用返回值cache,在后面的过程中创建MappedStatement的时候使用了currentCache。

二、使用Cache过程

在系统中,使用Cache的地方在CachingExecutor中:

@Override

public <E> List<E> query(

MappedStatement ms, Object parameterObject,

RowBounds rowBounds, ResultHandler resultHandler,

CacheKey key, BoundSql boundSql) throws SQLException {

Cache cache = msgetCache();

获取cache后,先判断是否有二级缓存

只有通过<cache/>,<cache-ref/>或@CacheNamespace,@CacheNamespaceRef标记使用缓存的Mapperxml或Mapper接口(同一个namespace,不能同时使用)才会有二级缓存。

if (cache != null) {

如果cache存在,那么会根据sql配置(<insert>,<select>,<update>,<delete>的flushCache属性来确定是否清空缓存。

flushCacheIfRequired(ms);

然后根据xml配置的属性useCache来判断是否使用缓存(resultHandler一般使用的默认值,很少会null)。

if (msisUseCache() && resultHandler == null) {

确保方法没有Out类型的参数,mybatis不支持存储过程的缓存,所以如果是存储过程,这里就会报错。

ensureNoOutParams(ms, parameterObject, boundSql);

没有问题后,就会从cache中根据key来取值:

@SuppressWarnings("unchecked")

List<E> list = (List<E>) tcmgetObject(cache, key);

如果没有缓存,就会执行查询,并且将查询结果放到缓存中。

if (list == null) {

list = delegate<E>query(ms, parameterObject,

rowBounds, resultHandler, key, boundSql);

tcmputObject(cache, key, list); // issue #578 and #116

}

返回结果

return list;

}

}

没有缓存时,直接执行查询

return delegate<E>query(ms, parameterObject, rowBounds, resultHandler, key, boundSql);

}

在上面的代码中tcmputObject(cache, key, list);这句代码是缓存了结果。但是实际上直到sqlsession关闭,MyBatis才以序列化的形式保存到了一个Map(默认的缓存配置)中。

三、Cache使用时的注意事项

1 只能在只有单表 *** 作的表上使用缓存

不只是要保证这个表在整个系统中只有单表 *** 作,而且和该表有关的全部 *** 作必须全部在一个namespace下。

2 在可以保证查询远远大于insert,update,delete *** 作的情况下使用缓存

这一点不需要多说,所有人都应该清楚。记住,这一点需要保证在1的前提下才可以!

四、避免使用二级缓存

可能会有很多人不理解这里,二级缓存带来的好处远远比不上他所隐藏的危害。

缓存是以namespace为单位的,不同namespace下的 *** 作互不影响。

insert,update,delete *** 作会清空所在namespace下的全部缓存。

通常使用MyBatis Generator生成的代码中,都是各个表独立的,每个表都有自己的namespace。

为什么避免使用二级缓存

在符合Cache使用时的注意事项的要求时,并没有什么危害。

其他情况就会有很多危害了。

针对一个表的某些 *** 作不在他独立的namespace下进行。

例如在UserMapperxml中有大多数针对user表的 *** 作。但是在一个XXXMapperxml中,还有针对user单表的 *** 作。

这会导致user在两个命名空间下的数据不一致。如果在UserMapperxml中做了刷新缓存的 *** 作,在XXXMapperxml中缓存仍然有效,如果有针对user的单表查询,使用缓存的结果可能会不正确。

更危险的情况是在XXXMapperxml做了insert,update,delete *** 作时,会导致UserMapperxml中的各种 *** 作充满未知和风险。

有关这样单表的 *** 作可能不常见。但是你也许想到了一种常见的情况。

多表 *** 作一定不能使用缓存

为什么不能看

首先不管多表 *** 作写到那个namespace下,都会存在某个表不在这个namespace下的情况。

例如两个表:role和user_role,如果我想查询出某个用户的全部角色role,就一定会涉及到多表的 *** 作。

<select id="selectUserRoles" resultType="UserRoleVO">

select from user_role a,role b where aroleid = broleid and auserid = #{userid}

</select>123123

像上面这个查询,你会写到那个xml中呢看看

不管是写到RoleMapperxml还是UserRoleMapperxml,或者是一个独立的XxxMapperxml中。如果使用了二级缓存,都会导致上面这个查询结果可能不正确。

如果你正好修改了这个用户的角色,上面这个查询使用缓存的时候结果就是错的。

这点应该很容易理解。

在我看来,就以MyBatis目前的缓存方式来看是无解的。多表 *** 作根本不能缓存。

如果你让他们都使用同一个namespace(通过<cache-ref>)来避免脏数据,那就失去了缓存的意义。

看到这里,实际上就是说,二级缓存不能用。整篇文章介绍这么多也没什么用了。

五、挽救二级缓存看

想更高效率的使用二级缓存是解决不了了。

但是解决多表 *** 作避免脏数据还是有法解决的。解决思路就是通过拦截器判断执行的sql涉及到那些表(可以用jsqlparser解析),然后把相关表的缓存自动清空。但是这种方式对缓存的使用效率是很低的。

设计这样一个插件是相当复杂的,既然我没想着去实现,就不废话了。

最后还是建议,放弃二级缓存,在业务层使用可控制的缓存代替更好。

以上就是关于请教Mybatis中如何在程序中获取Mapper中定义的SQL语句全部的内容,包括:请教Mybatis中如何在程序中获取Mapper中定义的SQL语句、java使用mybatis执行sql脚本,怎么获取sql脚本的结果、mybatis怎么开启二级缓存等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!

欢迎分享,转载请注明来源:内存溢出

原文地址:https://54852.com/web/9302679.html

(0)
打赏 微信扫一扫微信扫一扫 支付宝扫一扫支付宝扫一扫
上一篇 2023-04-26
下一篇2023-04-26

发表评论

登录后才能评论

评论列表(0条)

    保存