org.nutz.plugins.cache.dao

Class CachedNutDaoExecutor

java.lang.Object

org.nutz.dao.impl.sql.run.NutDaoExecutor

org.nutz.plugins.cache.dao.CachedNutDaoExecutor

All Implemented Interfaces:

org.nutz.dao.impl.DaoExecutor

Direct Known Subclasses:

DaoCacheInterceptor

public class CachedNutDaoExecutor
extends org.nutz.dao.impl.sql.run.NutDaoExecutor

基于sql的缓存DaoExecutor. 使用Druid的sql处理器. 要配置需要缓存的表及数据库类型!!!!

Author:

wendal(wendal1985@gmail.com)

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	cache4Null 是否缓存空值
protected String	cacheClearMark 禁止清除缓存的标志,在Sql.getContext()中配置
protected Pattern	cachedTableNamePatten 需要缓存的数据库表名称的正则表达式
protected Set<String>	cachedTableNames 需要缓存的数据库表
protected DaoCacheProvider	cacheProvider 缓存实现提供者,默认是MemoryDaoCacheProvider
static String	CacheSkipMark 跳过缓存的标记
protected org.nutz.dao.DB	db 数据库类型,当前仅支持 MYSQL, ORACLE, PSQL, 默认MYSQL
static boolean	DEBUG 是否打印详细的log,默认为关
protected boolean	enable 是否启用,全局开关,默认为true
protected boolean	enableWhenTrans 在事务环境下是否启动,默认禁用

Fields inherited from class org.nutz.dao.impl.sql.run.NutDaoExecutor

expert, meta

Constructor Summary

Constructors

Constructor and Description
CachedNutDaoExecutor()

Method Summary

Modifier and Type	Method and Description
protected void	_exec(Connection conn, org.nutz.dao.sql.DaoStatement st)
void	addCachedTableName(String name)
void	exec(Connection conn, org.nutz.dao.sql.DaoStatement st)
protected String	genCacheName(String tableName) 生成特定Cache名.
protected String	genKey(org.nutz.dao.sql.DaoStatement st, String prepareSql, Object[][] params) 缓存key的生成机制,默认是 hash:pagerNum:pagerSize:sql:param1:param2:....
DaoCacheProvider	getCacheProvider()
protected boolean	isCache4Table(String tableName) 是否对表进行缓存.
void	setCache4Null(boolean cache4Null)
void	setCachedTableNamePatten(Pattern cachedTableNamePatten)
void	setCachedTableNamePatten(String cachedTableNamePatten)
void	setCachedTableNames(Set<String> cachedTableNames)
void	setCacheProvider(DaoCacheProvider cacheProvider)
void	setEnable(boolean enable)
void	setEnableWhenTrans(boolean enableWhenTrans)
void	setMeta(org.nutz.dao.DatabaseMeta meta)
protected com.alibaba.druid.sql.parser.SQLStatementParser	sqlParser(String sql) 根据数据库类型解析sql

Methods inherited from class org.nutz.dao.impl.sql.run.NutDaoExecutor

_runExec, printSQL, setExpert

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

cacheProvider

protected DaoCacheProvider cacheProvider

缓存实现提供者,默认是MemoryDaoCacheProvider

enableWhenTrans

protected boolean enableWhenTrans

在事务环境下是否启动,默认禁用

cacheClearMark

protected String cacheClearMark

禁止清除缓存的标志,在Sql.getContext()中配置

CacheSkipMark

public static final String CacheSkipMark

跳过缓存的标记

See Also:

Constant Field Values

cachedTableNames

protected Set<String> cachedTableNames

需要缓存的数据库表

cachedTableNamePatten

protected Pattern cachedTableNamePatten

需要缓存的数据库表名称的正则表达式

DEBUG

public static boolean DEBUG

是否打印详细的log,默认为关

cache4Null

protected boolean cache4Null

是否缓存空值

enable

protected boolean enable

是否启用,全局开关,默认为true

db

protected org.nutz.dao.DB db

数据库类型,当前仅支持 MYSQL, ORACLE, PSQL, 默认MYSQL

Constructor Detail

CachedNutDaoExecutor

public CachedNutDaoExecutor()

Method Detail

exec

public void exec(Connection conn,
                 org.nutz.dao.sql.DaoStatement st)

Specified by:

exec in interface org.nutz.dao.impl.DaoExecutor

Overrides:

exec in class org.nutz.dao.impl.sql.run.NutDaoExecutor

genKey

protected String genKey(org.nutz.dao.sql.DaoStatement st,
                        String prepareSql,
                        Object[][] params)

缓存key的生成机制,默认是 hash:pagerNum:pagerSize:sql:param1:param2:....

子类可覆盖本方法实现更有效的key生成

genCacheName

protected String genCacheName(String tableName)

生成特定Cache名. 子类可覆盖实现所需要的Cache名

sqlParser

protected com.alibaba.druid.sql.parser.SQLStatementParser sqlParser(String sql)

根据数据库类型解析sql

setCacheProvider

public void setCacheProvider(DaoCacheProvider cacheProvider)

setEnableWhenTrans

public void setEnableWhenTrans(boolean enableWhenTrans)

setCachedTableNames

public void setCachedTableNames(Set<String> cachedTableNames)

addCachedTableName

public void addCachedTableName(String name)

setCachedTableNamePatten

public void setCachedTableNamePatten(Pattern cachedTableNamePatten)

setCachedTableNamePatten

public void setCachedTableNamePatten(String cachedTableNamePatten)

isCache4Table

protected boolean isCache4Table(String tableName)

是否对表进行缓存. 子类可以扩展该方法实现更复杂的配置

getCacheProvider

public DaoCacheProvider getCacheProvider()

setCache4Null

public void setCache4Null(boolean cache4Null)

setEnable

public void setEnable(boolean enable)

setMeta

public void setMeta(org.nutz.dao.DatabaseMeta meta)

Overrides:

setMeta in class org.nutz.dao.impl.sql.run.NutDaoExecutor

_exec

protected void _exec(Connection conn,
                     org.nutz.dao.sql.DaoStatement st)