Class DistinctScalarAggregateResultSet

java.lang.Object

org.apache.derby.impl.sql.execute.BasicNoPutResultSetImpl

org.apache.derby.impl.sql.execute.NoPutResultSetImpl

org.apache.derby.impl.sql.execute.GenericAggregateResultSet

org.apache.derby.impl.sql.execute.ScalarAggregateResultSet

org.apache.derby.impl.sql.execute.DistinctScalarAggregateResultSet

All Implemented Interfaces:

CursorResultSet, NoPutResultSet, ResultSet, RowLocationRetRowSource, RowSource

class DistinctScalarAggregateResultSet
extends ScalarAggregateResultSet

This ResultSet evaluates scalar aggregates where 1 (or more, in the future) of the aggregates are distinct. It will scan the entire source result set and calculate the scalar aggregates when scanning the source during the first call to next().

Nested Class Summary

Nested classes/interfaces inherited from class BasicNoPutResultSetImpl

BasicNoPutResultSetImpl.FieldComparator

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	dropDistinctAggSort
private int	maxRowSize
private ColumnOrdering[]	order
private ScanController	scanController
private boolean	sorted
private long	sortId
private ExecIndexRow	sortResultRow

Fields inherited from class ScalarAggregateResultSet

countOfRows, isInSortedOrder, rowsInput, singleInputRow, sourceExecIndexRow

Fields inherited from class GenericAggregateResultSet

aggInfoList, aggregates, originalSource, source

Fields inherited from class NoPutResultSetImpl

checkNullCols, clonedExecRow, cncLen, resultSetNumber, targetResultSet

Fields inherited from class BasicNoPutResultSetImpl

activation, beginTime, closeTime, compactRow, constructorTime, currentRow, endExecutionTime, finished, isOpen, isTopResultSet, nextTime, numOpens, openTime, optimizerEstimatedCost, optimizerEstimatedRowCount, resultDescription, rowsFiltered, rowsSeen, startExecutionTime, subqueryTrackingArray

Fields inherited from interface NoPutResultSet

ABSOLUTE, FIRST, LAST, NEXT, PREVIOUS, RELATIVE, TEMPORARY_RESULT_SET_NUMBER

Fields inherited from interface ResultSet

CURRENT_RESULTSET_ONLY, ENTIRE_RESULTSET_TREE, ISAFTERLAST, ISBEFOREFIRST, ISFIRST, ISLAST

Constructor Summary

Constructors

Constructor	Description
DistinctScalarAggregateResultSet(NoPutResultSet s, boolean isInSortedOrder, int aggregateItem, int orderingItem, Activation a, int ra, int maxRowSize, int resultSetNumber, boolean singleInputRow, double optimizerEstimatedRowCount, double optimizerEstimatedCost)	Constructor

Method Summary

Modifier and Type	Method	Description
void	close()	If the result set has been opened, close the open scan.
protected void	closeSource()	Close the source of whatever we have been scanning.
ExecRow	getNextRowCore()	Return the next row.
ExecIndexRow	getRowFromResultSet(boolean doClone)	Get a row from the sorter.
private ScanController	loadSorter()	Load up the sorter.
void	openCore()	Open the scan.
void	reopenCore()	reopen a scan on the table. scan parameters are evaluated at each open, so there is probably some way of altering their values...

Methods inherited from class ScalarAggregateResultSet

accumulateScalarAggregation, getCurrentRow, getRowLocation, getTimeSpent

Methods inherited from class GenericAggregateResultSet

finish, finishAggregation, getRowTemplate, getSortAggregators, toXML

Methods inherited from class NoPutResultSetImpl

clearCurrentRow, clearOrderableCache, closeRowSource, getCursorName, getNextRowFromRowSource, getResultDescription, getValidColumns, isForUpdate, markRowAsDeleted, needsRowLocation, needsRowLocationForDeferredCheckConstraints, needsToClone, offendingRowLocation, positionScanAtRowLocation, printQualifiers, resultSetNumber, rowLocation, setCurrentRow, setHasDeferrableChecks, setNeedsRowLocation, setTargetResultSet, skipRow, skipScan, unpackHashValue, updateRow

Methods inherited from class BasicNoPutResultSetImpl

addWarning, attachStatementContext, checkCancellationFlag, checkRowPosition, childrenToXML, cleanUp, dumpTimeStats, finishAndRTS, getAbsoluteRow, getActivation, getAutoGeneratedKeysResultset, getBeginExecutionTimestamp, getCompactRow, getCurrentTimeMillis, getElapsedMillis, getEndExecutionTimestamp, getEstimatedRowCount, getExecuteTime, getExecutionFactory, getFirstRow, getLanguageConnectionContext, getLastRow, getNextRow, getPointOfAttachment, getPreviousRow, getRelativeRow, getRowNumber, getScanIsolationLevel, getSubqueryTrackingArray, getTransactionController, getWarnings, isClosed, isXplainOnlyMode, markAsTopResultSet, modifiedRowCount, open, recordConstructorTime, requiresRelocking, returnsRows, setAfterLastRow, setBeforeFirstRow, setCompactRow, setCompatRow, toXML

Methods inherited from class Object

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

Methods inherited from interface ResultSet

addWarning, checkRowPosition, cleanUp, clearCurrentRow, finish, getAbsoluteRow, getActivation, getAutoGeneratedKeysResultset, getBeginExecutionTimestamp, getCursorName, getEndExecutionTimestamp, getExecuteTime, getFirstRow, getLastRow, getNextRow, getPreviousRow, getRelativeRow, getResultDescription, getRowNumber, getSubqueryTrackingArray, getWarnings, isClosed, modifiedRowCount, open, returnsRows, setAfterLastRow, setBeforeFirstRow, toXML

Field Details

order

private ColumnOrdering[] order

maxRowSize

private int maxRowSize

dropDistinctAggSort

private boolean dropDistinctAggSort

sortId

private long sortId

scanController

private ScanController scanController

sortResultRow

private ExecIndexRow sortResultRow

sorted

private boolean sorted

Constructor Details

DistinctScalarAggregateResultSet

DistinctScalarAggregateResultSet(NoPutResultSet s,
 boolean isInSortedOrder,
 int aggregateItem,
 int orderingItem,
 Activation a,
 int ra,
 int maxRowSize,
 int resultSetNumber,
 boolean singleInputRow,
 double optimizerEstimatedRowCount,
 double optimizerEstimatedCost)
                          throws StandardException

Constructor

Parameters:

s - input result set

isInSortedOrder - true if the source results are in sorted order

aggregateItem - indicates the number of the SavedObject off of the PreparedStatement that holds the AggregatorInfoList used by this routine.

a - activation

ra - saved object that builds an empty output row

resultSetNumber - The resultSetNumber for this result set

Throws:

StandardException - Thrown on error

Method Details

openCore

public void openCore()
              throws StandardException

Open the scan. Load the sorter and prepare to get rows from it.

Specified by:

openCore in interface NoPutResultSet

Overrides:

openCore in class ScalarAggregateResultSet

Throws:

StandardException - thrown if cursor finished.

getNextRowCore

public ExecRow getNextRowCore()
                       throws StandardException

Return the next row. If it is a scalar aggregate scan

Specified by:

getNextRowCore in interface NoPutResultSet

Overrides:

getNextRowCore in class ScalarAggregateResultSet

Returns:

the next row in the result

Throws:

StandardException - thrown on failure.

StandardException - ResultSetNotOpen thrown if not yet open.

See Also:

• NoPutResultSet.getNextRowCore()

reopenCore

public void reopenCore()
                throws StandardException

reopen a scan on the table. scan parameters are evaluated at each open, so there is probably some way of altering their values...

Specified by:

reopenCore in interface NoPutResultSet

Overrides:

reopenCore in class ScalarAggregateResultSet

Throws:

StandardException - thrown if cursor finished.

See Also:

• NoPutResultSet.openCore()

close

public void close()
           throws StandardException

If the result set has been opened, close the open scan.

Specified by:

close in interface ResultSet

Overrides:

close in class ScalarAggregateResultSet

Throws:

StandardException - thrown on error

getRowFromResultSet

public ExecIndexRow getRowFromResultSet(boolean doClone)
                                 throws StandardException

Get a row from the sorter. Side effects: sets currentRow.

Overrides:

getRowFromResultSet in class ScalarAggregateResultSet

Parameters:

doClone - - true of the row should be cloned

Throws:

StandardException - Thrown on error

closeSource

protected void closeSource()
                    throws StandardException

Close the source of whatever we have been scanning.

Throws:

StandardException - thrown on error

loadSorter

private ScanController loadSorter()
                           throws StandardException

Load up the sorter. Feed it every row from the source scan. If we have a vector aggregate, initialize the aggregator for each source row. When done, close the source scan and open the sort. Return the sort scan controller.

Returns:

the sort controller

Throws:

StandardException - thrown on failure.