net.ymate.platform.persistence.jdbc.base.impl

Class DefaultProcedureOperator<T>

java.lang.Object

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

net.ymate.platform.persistence.jdbc.base.impl.DefaultProcedureOperator<T>

Type Parameters:

T - 元素类型

All Implemented Interfaces:

IOperator, IProcedureOperator<T>

public class DefaultProcedureOperator<T>
extends AbstractOperator
implements IProcedureOperator<T>

数据库存储过程操作器接口实现

Author:

刘镇 (suninformation@163.com) on 16/12/8 上午1:04

Nested Class Summary

Nested classes/interfaces inherited from interface net.ymate.platform.persistence.jdbc.base.IProcedureOperator

IProcedureOperator.IOutResultProcessor

Field Summary

Fields inherited from class net.ymate.platform.persistence.jdbc.base.AbstractOperator

executed, expenseTime, sql

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
IProcedureOperator<T>	addOutParameter(Integer sqlParamType) 添加输出参数
IProcedureOperator<T>	addParameter(Object parameter) 添加SQL参数，若参数为NULL则将默认向SQL传递NULL值对象
IProcedureOperator<T>	addParameter(SQLParameter parameter) 添加SQL参数，若参数为NULL则忽略
protected String	doBuildCallSql() 构建存储过程CALL语句(根据不同的数据库, 可由子类重新实现)
protected int	doExecute() 执行具体的操作过程
protected void	doRegisterOutParams(CallableStatement statement) 注册存储过程输出的参数(从最后一个输入参数后开始, 根据不同的数据库，可由子类重新实现)
void	execute() 执行操作
IProcedureOperator<T>	execute(IProcedureOperator.IOutResultProcessor resultProcessor) 执行存储过程
IProcedureOperator<T>	execute(IResultSetHandler<T> resultSetHandler) 执行存储过程
List<List<T>>	getResultSets() 获取执行结果集合
IProcedureOperator<T>	setOutResultProcessor(IProcedureOperator.IOutResultProcessor outResultProcessor) 设置输出参数结果处理器
IProcedureOperator<T>	setResultSetHandler(IResultSetHandler<T> resultSetHandler) 设置结果集数据处理器

Methods inherited from class net.ymate.platform.persistence.jdbc.base.AbstractOperator

doAppendStackTraces, doSetParameters, getAccessorConfig, getConnectionHolder, getExpenseTime, getParameters, getSQL, isExecuted, serializeParameters, setAccessorConfig

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.ymate.platform.persistence.jdbc.base.IOperator

getAccessorConfig, getConnectionHolder, getExpenseTime, getParameters, getSQL, isExecuted, setAccessorConfig

Constructor Detail

DefaultProcedureOperator

public DefaultProcedureOperator(String sql,
                                IDatabaseConnectionHolder connectionHolder)

DefaultProcedureOperator

public DefaultProcedureOperator(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

Overrides:

execute in class AbstractOperator

Throws:

Exception - 可能产生的异常

execute

public IProcedureOperator<T> execute(IResultSetHandler<T> resultSetHandler)
                              throws Exception

Description copied from interface: IProcedureOperator

执行存储过程

Specified by:

execute in interface IProcedureOperator<T>

Parameters:

resultSetHandler - 结果集数据处理器

Returns:

返回当前操作器

Throws:

Exception - 可能产生的任何异常

execute

public IProcedureOperator<T> execute(IProcedureOperator.IOutResultProcessor resultProcessor)
                              throws Exception

Description copied from interface: IProcedureOperator

执行存储过程

Specified by:

execute in interface IProcedureOperator<T>

Parameters:

resultProcessor - 输出参数结果处理器

Returns:

返回当前操作器

Throws:

Exception - 可能产生的任何异常

doExecute

protected int doExecute()
                 throws Exception

Description copied from class: AbstractOperator

执行具体的操作过程

Specified by:

doExecute in class AbstractOperator

Returns:

返回影响行数

Throws:

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

doBuildCallSql

protected String doBuildCallSql()

构建存储过程CALL语句(根据不同的数据库, 可由子类重新实现)

Returns:

返回CALL语句

doRegisterOutParams

protected void doRegisterOutParams(CallableStatement statement)
                            throws SQLException

注册存储过程输出的参数(从最后一个输入参数后开始, 根据不同的数据库，可由子类重新实现)

Parameters:

statement - CallableStatement

Throws:

SQLException - 可能产生的任何异常

addParameter

public IProcedureOperator<T> addParameter(SQLParameter parameter)

Description copied from interface: IOperator

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

Specified by:

addParameter in interface IOperator

Specified by:

addParameter in interface IProcedureOperator<T>

Overrides:

addParameter in class AbstractOperator

Parameters:

parameter - SQL参数对象

Returns:

返回当前操作器对象

addParameter

public IProcedureOperator<T> addParameter(Object parameter)

Description copied from interface: IOperator

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

Specified by:

addParameter in interface IOperator

Specified by:

addParameter in interface IProcedureOperator<T>

Overrides:

addParameter in class AbstractOperator

Parameters:

parameter - SQL参数值

Returns:

返回当前操作器对象

addOutParameter

public IProcedureOperator<T> addOutParameter(Integer sqlParamType)

Description copied from interface: IProcedureOperator

添加输出参数

Specified by:

addOutParameter in interface IProcedureOperator<T>

Parameters:

sqlParamType - SQL参数类型(参考java.sql.Types)

Returns:

返回当前操作器

setOutResultProcessor

public IProcedureOperator<T> setOutResultProcessor(IProcedureOperator.IOutResultProcessor outResultProcessor)

Description copied from interface: IProcedureOperator

设置输出参数结果处理器

Specified by:

setOutResultProcessor in interface IProcedureOperator<T>

Parameters:

outResultProcessor - 输出参数结果处理器

Returns:

返回当前操作器

setResultSetHandler

public IProcedureOperator<T> setResultSetHandler(IResultSetHandler<T> resultSetHandler)

Description copied from interface: IProcedureOperator

设置结果集数据处理器

Specified by:

setResultSetHandler in interface IProcedureOperator<T>

Parameters:

resultSetHandler - 结果集数据处理器

Returns:

返回当前操作器

getResultSets

public List<List<T>> getResultSets()

Description copied from interface: IProcedureOperator

获取执行结果集合

Specified by:

getResultSets in interface IProcedureOperator<T>

Returns:

返回结果集合