net.ymate.platform.persistence.jdbc.base

Class AbstractOperator

java.lang.Object

net.ymate.platform.persistence.jdbc.base.AbstractOperator

All Implemented Interfaces:

IOperator

Direct Known Subclasses:

BatchUpdateOperator, DefaultProcedureOperator, DefaultQueryOperator, DefaultUpdateOperator

public abstract class AbstractOperator
extends Object
implements IOperator

数据库操作器接口抽象实现

Author:

刘镇 (suninformation@163.com) on 2011-9-22 下午10:19:53

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	executed 是否已执行
protected long	expenseTime
protected String	sql

Constructor Summary

Constructors

Constructor and Description
AbstractOperator(String sql, IDatabaseConnectionHolder connectionHolder)
AbstractOperator(String sql, IDatabaseConnectionHolder connectionHolder, IAccessorConfig accessorConfig)

Method Summary

Modifier and Type	Method and Description
IOperator	addParameter(Object parameter) 添加SQL参数，若参数为NULL则将默认向SQL传递NULL值对象
IOperator	addParameter(SQLParameter parameter) 添加SQL参数，若参数为NULL则忽略
protected void	doAppendStackTraces(IDatabaseDataSourceConfig dataSourceConfig, StringBuilder stackBuilder)
protected abstract int	doExecute() 执行具体的操作过程
protected void	doSetParameters(PreparedStatement statement)
void	execute() 执行操作
IAccessorConfig	getAccessorConfig() 获取访问器配置
IDatabaseConnectionHolder	getConnectionHolder() 获取当前使用的数据库连接对象
long	getExpenseTime() 获取本次操作所消耗的时间（单位：毫秒值）
List<SQLParameter>	getParameters() 获取SQL参数集合
String	getSQL() 获取预执行SQL字符串
boolean	isExecuted() 判断当前操作器是否已执行
protected String	serializeParameters()
void	setAccessorConfig(IAccessorConfig accessorConfig) 设置访问器配置

Methods inherited from class java.lang.Object

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

Field Detail

sql

protected String sql

expenseTime

protected long expenseTime

executed

protected boolean executed

是否已执行

Constructor Detail

AbstractOperator

public AbstractOperator(String sql,
                        IDatabaseConnectionHolder connectionHolder)

AbstractOperator

public AbstractOperator(String sql,
                        IDatabaseConnectionHolder connectionHolder,
                        IAccessorConfig accessorConfig)

Method Detail

execute

public void execute()
             throws Exception

Description copied from interface: IOperator

执行操作

Specified by:

execute in interface IOperator

Throws:

Exception - 可能产生的异常

doAppendStackTraces

protected void doAppendStackTraces(IDatabaseDataSourceConfig dataSourceConfig,
                                   StringBuilder stackBuilder)

serializeParameters

protected String serializeParameters()

doExecute

protected abstract int doExecute()
                          throws Exception

执行具体的操作过程

Returns:

返回影响行数

Throws:

Exception - 执行过程中产生的异常

doSetParameters

protected void doSetParameters(PreparedStatement statement)
                        throws SQLException

Throws:

SQLException

isExecuted

public boolean isExecuted()

Description copied from interface: IOperator

判断当前操作器是否已执行

Specified by:

isExecuted in interface IOperator

Returns:

返回true表示已执行

getSQL

public String getSQL()

Description copied from interface: IOperator

获取预执行SQL字符串

Specified by:

getSQL in interface IOperator

Returns:

返回SQL字符串

getAccessorConfig

public IAccessorConfig getAccessorConfig()

Description copied from interface: IOperator

获取访问器配置

Specified by:

getAccessorConfig in interface IOperator

Returns:

返回访问器配置

setAccessorConfig

public void setAccessorConfig(IAccessorConfig accessorConfig)

Description copied from interface: IOperator

设置访问器配置

Specified by:

setAccessorConfig in interface IOperator

Parameters:

accessorConfig - 访问器配置对象

getConnectionHolder

public IDatabaseConnectionHolder getConnectionHolder()

Description copied from interface: IOperator

获取当前使用的数据库连接对象

Specified by:

getConnectionHolder in interface IOperator

Returns:

返回数据库连接对象

getExpenseTime

public long getExpenseTime()

Description copied from interface: IOperator

获取本次操作所消耗的时间（单位：毫秒值）

Specified by:

getExpenseTime in interface IOperator

Returns:

返回时间毫秒值

getParameters

public List<SQLParameter> getParameters()

Description copied from interface: IOperator

获取SQL参数集合

Specified by:

getParameters in interface IOperator

Returns:

返回SQL参数集合

addParameter

public IOperator addParameter(SQLParameter parameter)

Description copied from interface: IOperator

添加SQL参数，若参数为NULL则忽略

Specified by:

addParameter in interface IOperator

Parameters:

parameter - SQL参数对象

Returns:

返回当前操作器对象

addParameter

public IOperator addParameter(Object parameter)

Description copied from interface: IOperator

添加SQL参数，若参数为NULL则将默认向SQL传递NULL值对象

Specified by:

addParameter in interface IOperator

Parameters:

parameter - SQL参数值

Returns:

返回当前操作器对象