io.shardingsphere.core.merger.dql.common

Class StreamMergedResult

java.lang.Object

io.shardingsphere.core.merger.dql.common.StreamMergedResult

All Implemented Interfaces:

MergedResult

Direct Known Subclasses:

IteratorStreamMergedResult, OrderByStreamMergedResult

public abstract class StreamMergedResult
extends Object
implements MergedResult

流式归并结果集.

Author:

thor zhangliang

Constructor Summary

Constructors

Constructor and Description
StreamMergedResult()

Method Summary

Modifier and Type	Method and Description
Object	getCalendarValue(int columnIndex, Class<?> type, Calendar calendar) Get calendar value.
Object	getCalendarValue(String columnLabel, Class<?> type, Calendar calendar) Get calendar value.
protected QueryResult	getCurrentQueryResult()
InputStream	getInputStream(int columnIndex, String type) Get InputStream.
InputStream	getInputStream(String columnLabel, String type) Get InputStream.
Object	getValue(int columnIndex, Class<?> type) Get data value.
Object	getValue(String columnLabel, Class<?> type) Get data value.
boolean	wasNull() Adjust ResultSet is null or not.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.shardingsphere.core.merger.MergedResult

next

Constructor Detail

StreamMergedResult

public StreamMergedResult()

Method Detail

getCurrentQueryResult

protected QueryResult getCurrentQueryResult()
                                     throws SQLException

Throws:

SQLException

getValue

public 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

getValue

public Object getValue(String columnLabel,
                       Class<?> type)
                throws SQLException

Description copied from interface: MergedResult

Get data value.

Specified by:

getValue in interface MergedResult

Parameters:

columnLabel - column label

type - class type of data value

Returns:

data value

Throws:

SQLException - SQL Exception

getCalendarValue

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

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

Throws:

SQLException - SQL Exception

getCalendarValue

public Object getCalendarValue(String columnLabel,
                               Class<?> type,
                               Calendar calendar)
                        throws SQLException

Description copied from interface: MergedResult

Get calendar value.

Specified by:

getCalendarValue in interface MergedResult

Parameters:

columnLabel - column label

type - class type of data value

calendar - calendar

Returns:

calendar value

Throws:

SQLException - SQL Exception

getInputStream

public 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

getInputStream

public InputStream getInputStream(String columnLabel,
                                  String type)
                           throws SQLException

Description copied from interface: MergedResult

Get InputStream.

Specified by:

getInputStream in interface MergedResult

Parameters:

columnLabel - column label

type - class type of data value

Returns:

InputStream

Throws:

SQLException - SQL Exception

wasNull

public boolean wasNull()

Description copied from interface: MergedResult

Adjust ResultSet is null or not.

Specified by:

wasNull in interface MergedResult

Returns:

ResultSet is null or not