org.nutz.dao

Class DaoInterceptorChain

java.lang.Object

org.nutz.dao.DaoInterceptorChain

All Implemented Interfaces:

ConnCallback

public class DaoInterceptorChain
extends Object
implements ConnCallback

Dao执行拦截器链.

Author:

wendal

See Also:

DaoLogInterceptor, DaoTimeInterceptor

Field Summary

Fields

Modifier and Type	Field and Description
protected int	autoTransLevel
protected Connection	connection
protected int	current
protected DaoStatement	daoStatement
protected DaoExecutor	executor
protected String	id
protected List<DaoInterceptor>	interceptors
protected DaoStatement[]	sts
protected int	updateCount

Constructor Summary

Constructors

Constructor and Description
DaoInterceptorChain(DaoStatement... sts) 新建一个DaoInterceptorChain.

Method Summary

Modifier and Type	Method and Description
DaoInterceptorChain	doChain() 继续下一个拦截器,如果已经是最后一个拦截器,那么执行executor.exec
int	getAutoTransLevel() 获取当前自动事务级别,DaoRunner中使用强制事务时会使用之.拦截器不能修改,即使修改也不会生效
Connection	getConnection() 获取当前数据库连接
DaoStatement	getDaoStatement() 当前执行的DaoStatement
DaoStatement[]	getDaoStatements() 全部DaoStatement,可能不止一条
String	getId() 拦截器链的id, 为一个uu32识别符.
List<DaoInterceptor>	getInterceptors() 拦截器列表(暂不开放修改)
SqlContext	getSqlContext() 获取当前DaoStatement的上下文,注意,一个拦截器链可能包含多个DaoStatement
int	getUpdateCount() 更新总数,用于DaoSupport(NutDao)获取更新总数.
boolean	hasNext() 是否还有下一个拦截器
void	invoke(Connection conn) 这是DaoExecutor会执行的方法,拦截器内不要执行这个方法!! 这里也是拦截器开始生效的地方.
DaoInterceptor	next() 获取下一个拦截器.
void	setAutoTransLevel(int autoTransLevel) 设置强制事务的级别,对拦截器来说无意义.
void	setConnection(Connection connection) 设置当前使用的数据库连接
void	setCurrent(int current) 设置当前拦截器索引.
void	setDaoStatement(DaoStatement daoStatement) 替换当前执行的DaoStatement
void	setExecutor(DaoExecutor executor) 设置DaoExecutor.
void	setInterceptors(List<DaoInterceptor> interceptors) 设置新的拦截器列表.

Methods inherited from class java.lang.Object

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

Field Detail

autoTransLevel

protected int autoTransLevel

connection

protected Connection connection

current

protected int current

daoStatement

protected DaoStatement daoStatement

executor

protected DaoExecutor executor

interceptors

protected List<DaoInterceptor> interceptors

updateCount

protected int updateCount

sts

protected DaoStatement[] sts

id

protected String id

Constructor Detail

DaoInterceptorChain

public DaoInterceptorChain(DaoStatement... sts)

新建一个DaoInterceptorChain.

Parameters:

sts - 将要进行的Dao操作(不一定是SQL操作,有可能是EL)

Method Detail

doChain

public DaoInterceptorChain doChain()
                            throws DaoException

继续下一个拦截器,如果已经是最后一个拦截器,那么执行executor.exec

Returns:

本对象,用于链式操作

Throws:

Exception

DaoException

getAutoTransLevel

public int getAutoTransLevel()

获取当前自动事务级别,DaoRunner中使用强制事务时会使用之.拦截器不能修改,即使修改也不会生效

Returns:

当前自动(强制)事务级别

getDaoStatement

public DaoStatement getDaoStatement()

当前执行的DaoStatement

Returns:

当前执行的DaoStatement

getDaoStatements

public DaoStatement[] getDaoStatements()

全部DaoStatement,可能不止一条

Returns:

全部DaoStatement

getInterceptors

public List<DaoInterceptor> getInterceptors()

拦截器列表(暂不开放修改)

Returns:

全体拦截器列表

getUpdateCount

public int getUpdateCount()

更新总数,用于DaoSupport(NutDao)获取更新总数.

Returns:

更新记录总数

hasNext

public boolean hasNext()

是否还有下一个拦截器

Returns:

true,如果还有拦截器要执行

invoke

public void invoke(Connection conn)
            throws Exception

这是DaoExecutor会执行的方法,拦截器内不要执行这个方法!! 这里也是拦截器开始生效的地方.

Specified by:

invoke in interface ConnCallback

Throws:

Exception

next

public DaoInterceptor next()

获取下一个拦截器. 调用前必须先调用hasNext进行判断

Returns:

下一个拦截器

setAutoTransLevel

public void setAutoTransLevel(int autoTransLevel)

设置强制事务的级别,对拦截器来说无意义.

Parameters:

autoTransLevel - 与DaoSupport(NutDao)内的值一致

setCurrent

public void setCurrent(int current)

设置当前拦截器索引. 若设置值大于拦截器列表的大小,那么效果就等同于跳过剩余拦截器,直接执行DaoStatement

Parameters:

current -

setExecutor

public void setExecutor(DaoExecutor executor)

设置DaoExecutor. 典型应用是在拦截器中替换成daocache提供的DaoExecutor

Parameters:

executor - 新的DaoExecutor,不可以是null

setInterceptors

public void setInterceptors(List<DaoInterceptor> interceptors)

设置新的拦截器列表.

Parameters:

interceptors - 新的拦截器列表

setConnection

public void setConnection(Connection connection)

设置当前使用的数据库连接

Parameters:

connection - 新的数据库连接,不可以是null

getConnection

public Connection getConnection()

获取当前数据库连接

Returns:

当前数据库连接

getSqlContext

public SqlContext getSqlContext()

获取当前DaoStatement的上下文,注意,一个拦截器链可能包含多个DaoStatement

Returns:

当前DaoStatement的上下文

getId

public String getId()

拦截器链的id, 为一个uu32识别符.

Returns:

本拦截器链的id

setDaoStatement

public void setDaoStatement(DaoStatement daoStatement)

替换当前执行的DaoStatement

Parameters:

daoStatement -