org.apache.shardingsphere.underlying.merge.impl

Class MemoryMergedResult<T extends BaseRule>

java.lang.Object

org.apache.shardingsphere.underlying.merge.impl.MemoryMergedResult<T>

Type Parameters:

T - type of rule

All Implemented Interfaces:

MergedResult

public abstract class MemoryMergedResult<T extends BaseRule>
extends Object
implements MergedResult

Memory merged result.

Author:

zhangliang

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MemoryMergedResult(T rule, RelationMetas relationMetas, SQLStatementContext sqlStatementContext, List<QueryResult> queryResults)

Method Summary

Modifier and Type	Method and Description
Object	getCalendarValue(int columnIndex, Class<?> type, Calendar calendar) Get calendar value.
InputStream	getInputStream(int columnIndex, String type) Get InputStream.
Object	getValue(int columnIndex, Class<?> type) Get data value.
protected abstract List<MemoryQueryResultRow>	init(T rule, RelationMetas relationMetas, SQLStatementContext sqlStatementContext, List<QueryResult> queryResults)
boolean	next() Iterate next data.
boolean	wasNull() Judge ResultSet is null or not.

Methods inherited from class java.lang.Object

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

Constructor Detail

MemoryMergedResult

protected MemoryMergedResult(T rule,
                             RelationMetas relationMetas,
                             SQLStatementContext sqlStatementContext,
                             List<QueryResult> queryResults)
                      throws SQLException

Throws:

SQLException

Method Detail

init

protected abstract List<MemoryQueryResultRow> init(T rule,
                                                   RelationMetas relationMetas,
                                                   SQLStatementContext sqlStatementContext,
                                                   List<QueryResult> queryResults)
                                            throws SQLException

Throws:

SQLException

next

public final boolean next()

Description copied from interface: MergedResult

Iterate next data.

Specified by:

next in interface MergedResult

Returns:

has next data

getValue

public final Object getValue(int columnIndex,
                             Class<?> type)
                      throws SQLException

Description copied from interface: MergedResult

Get data value.

Specified by:

getValue in interface MergedResult

Parameters:

columnIndex - column index

type - class type of data value

Returns:

data value

Throws:

SQLException - SQL Exception

getCalendarValue

public final Object getCalendarValue(int columnIndex,
                                     Class<?> type,
                                     Calendar calendar)

Description copied from interface: MergedResult

Get calendar value.

Specified by:

getCalendarValue in interface MergedResult

Parameters:

columnIndex - column index

type - class type of data value

calendar - calendar

Returns:

calendar value

getInputStream

public final InputStream getInputStream(int columnIndex,
                                        String type)
                                 throws SQLException

Description copied from interface: MergedResult

Get InputStream.

Specified by:

getInputStream in interface MergedResult

Parameters:

columnIndex - column index

type - class type of data value

Returns:

InputStream

Throws:

SQLException - SQL Exception

wasNull

public final boolean wasNull()

Description copied from interface: MergedResult

Judge ResultSet is null or not.

Specified by:

wasNull in interface MergedResult

Returns:

ResultSet is null or not