/*
Derby - Class org.apache.derby.impl.sql.execute.GenericResultSetFactory
Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements. See the NOTICE file distributed with
this work for additional information regarding copyright ownership.
The ASF licenses this file to you under the Apache License, Version 2.0
(the "License"); you may not use this file except in compliance with
the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package org.apache.derby.impl.sql.execute;
import org.apache.derby.catalog.UUID;
import org.apache.derby.iapi.error.StandardException;
import org.apache.derby.iapi.services.loader.GeneratedMethod;
import org.apache.derby.shared.common.sanity.SanityManager;
import org.apache.derby.iapi.sql.Activation;
import org.apache.derby.iapi.sql.ResultSet;
import org.apache.derby.iapi.sql.conn.Authorizer;
import org.apache.derby.iapi.sql.conn.LanguageConnectionContext;
import org.apache.derby.iapi.sql.execute.NoPutResultSet;
import org.apache.derby.iapi.sql.execute.ResultSetFactory;
import org.apache.derby.iapi.store.access.Qualifier;
import org.apache.derby.iapi.store.access.StaticCompiledOpenConglomInfo;
import org.apache.derby.iapi.types.DataValueDescriptor;
/**
* ResultSetFactory provides a wrapper around all of
* the result sets used in this execution implementation.
* This removes the need of generated classes to do a new
* and of the generator to know about all of the result
* sets. Both simply know about this interface to getting
* them.
*
* In terms of modularizing, we can create just an interface
* to this class and invoke the interface. Different implementations
* would get the same information provided but could potentially
* massage/ignore it in different ways to satisfy their
* implementations. The practicality of this is to be seen.
*
* The cost of this type of factory is that once you touch it,
* you touch *all* of the possible result sets, not just
* the ones you need. So the first time you touch it could
* be painful ... that might be a problem for execution.
*
*/
public class GenericResultSetFactory implements ResultSetFactory
{
//
// ResultSetFactory interface
//
public GenericResultSetFactory()
{
}
/**
@see ResultSetFactory#getInsertResultSet
@exception StandardException thrown on error
*/
public ResultSet getInsertResultSet(NoPutResultSet source,
GeneratedMethod generationClauses,
GeneratedMethod checkGM,
int fullTemplate,
String schemaName,
String tableName)
throws StandardException
{
Activation activation = source.getActivation();
getAuthorizer(activation).authorize(activation, Authorizer.SQL_WRITE_OP);
return new InsertResultSet(source,
generationClauses,
checkGM,
fullTemplate,
schemaName,
tableName,
activation);
}
/**
@see ResultSetFactory#getInsertVTIResultSet
@exception StandardException thrown on error
*/
public ResultSet getInsertVTIResultSet(NoPutResultSet source,
NoPutResultSet vtiRS
)
throws StandardException
{
Activation activation = source.getActivation();
getAuthorizer(activation).authorize(activation, Authorizer.SQL_WRITE_OP);
return new InsertVTIResultSet(source, vtiRS, activation );
}
/**
@see ResultSetFactory#getDeleteVTIResultSet
@exception StandardException thrown on error
*/
public ResultSet getDeleteVTIResultSet(NoPutResultSet source)
throws StandardException
{
Activation activation = source.getActivation();
getAuthorizer(activation).authorize(activation, Authorizer.SQL_WRITE_OP);
return new DeleteVTIResultSet(source, activation);
}
/**
@see ResultSetFactory#getDeleteResultSet
@exception StandardException thrown on error
*/
public ResultSet getDeleteResultSet(NoPutResultSet source)
throws StandardException
{
Activation activation = source.getActivation();
getAuthorizer(activation).authorize(activation, Authorizer.SQL_WRITE_OP);
return new DeleteResultSet(source, activation );
}
/**
@see ResultSetFactory#getMergeResultSet
@exception StandardException thrown on error
*/
public ResultSet getMergeResultSet(NoPutResultSet drivingLeftJoin)
throws StandardException
{
Activation activation = drivingLeftJoin.getActivation();
getAuthorizer( activation ).authorize( activation, Authorizer.SQL_WRITE_OP );
return new MergeResultSet( drivingLeftJoin, activation );
}
/**
@see ResultSetFactory#getDeleteCascadeResultSet
@exception StandardException thrown on error
*/
public ResultSet getDeleteCascadeResultSet(NoPutResultSet source,
int constantActionItem,
ResultSet[] dependentResultSets,
String resultSetId)
throws StandardException
{
Activation activation = source.getActivation();
getAuthorizer(activation).authorize(activation, Authorizer.SQL_WRITE_OP);
return new DeleteCascadeResultSet(source, activation,
constantActionItem,
dependentResultSets,
resultSetId);
}
/**
@see ResultSetFactory#getUpdateResultSet
@exception StandardException thrown on error
*/
public ResultSet getUpdateResultSet(NoPutResultSet source, GeneratedMethod generationClauses,
GeneratedMethod checkGM)
throws StandardException
{
Activation activation = source.getActivation();
//The stress test failed with null pointer exception in here once and then
//it didn't happen again. It can be a jit problem because after this null
//pointer exception, the cleanup code in UpdateResultSet got a null
//pointer exception too which can't happen since the cleanup code checks
//for null value before doing anything.
//In any case, if this ever happens again, hopefully the following
//assertion code will catch it.
if (SanityManager.DEBUG)
{
SanityManager.ASSERT(getAuthorizer(activation) != null, "Authorizer is null");
}
getAuthorizer(activation).authorize(activation, Authorizer.SQL_WRITE_OP);
return new UpdateResultSet(source, generationClauses, checkGM, activation);
}
/**
@see ResultSetFactory#getUpdateVTIResultSet
@exception StandardException thrown on error
*/
public ResultSet getUpdateVTIResultSet(NoPutResultSet source)
throws StandardException
{
Activation activation = source.getActivation();
getAuthorizer(activation).authorize(activation, Authorizer.SQL_WRITE_OP);
return new UpdateVTIResultSet(source, activation);
}
/**
@see ResultSetFactory#getDeleteCascadeUpdateResultSet
@exception StandardException thrown on error
*/
public ResultSet getDeleteCascadeUpdateResultSet(NoPutResultSet source,
GeneratedMethod generationClauses,
GeneratedMethod checkGM,
int constantActionItem,
int rsdItem)
throws StandardException
{
Activation activation = source.getActivation();
getAuthorizer(activation).authorize(activation, Authorizer.SQL_WRITE_OP);
return new UpdateResultSet(source, generationClauses, checkGM, activation,
constantActionItem, rsdItem);
}
/**
@see ResultSetFactory#getCallStatementResultSet
@exception StandardException thrown on error
*/
public ResultSet getCallStatementResultSet(GeneratedMethod methodCall,
Activation activation)
throws StandardException
{
getAuthorizer(activation).authorize(activation, Authorizer.SQL_CALL_OP);
return new CallStatementResultSet(methodCall, activation);
}
/**
@see ResultSetFactory#getProjectRestrictResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getProjectRestrictResultSet(NoPutResultSet source,
GeneratedMethod restriction,
GeneratedMethod projection, int resultSetNumber,
GeneratedMethod constantRestriction,
int mapRefItem,
int cloneMapItem,
boolean reuseResult,
boolean doesProjection,
boolean validatingCheckConstraint,
String validatingBaseTableUUIDString,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
throws StandardException
{
UUID validatingBaseTableUUID = UUID.NULL.equals( validatingBaseTableUUIDString ) ?
null :
source.getActivation()
.getLanguageConnectionContext()
.getDataDictionary()
.getUUIDFactory()
.recreateUUID( validatingBaseTableUUIDString );
return new ProjectRestrictResultSet(source, source.getActivation(),
restriction, projection, resultSetNumber,
constantRestriction, mapRefItem, cloneMapItem,
reuseResult,
doesProjection,
validatingCheckConstraint,
validatingBaseTableUUID,
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
/**
@see ResultSetFactory#getHashTableResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getHashTableResultSet(NoPutResultSet source,
GeneratedMethod singleTableRestriction,
Qualifier[][] equijoinQualifiers,
GeneratedMethod projection, int resultSetNumber,
int mapRefItem,
boolean reuseResult,
int keyColItem,
boolean removeDuplicates,
long maxInMemoryRowCount,
int initialCapacity,
float loadFactor,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
throws StandardException
{
return new HashTableResultSet(source, source.getActivation(),
singleTableRestriction,
equijoinQualifiers,
projection, resultSetNumber,
mapRefItem,
reuseResult,
keyColItem, removeDuplicates,
maxInMemoryRowCount,
initialCapacity,
loadFactor,
true, // Skip rows with 1 or more null key columns
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
/**
@see ResultSetFactory#getSortResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getSortResultSet(NoPutResultSet source,
boolean distinct,
boolean isInSortedOrder,
int orderItem,
int rowAllocator,
int maxRowSize,
int resultSetNumber,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
throws StandardException
{
return new SortResultSet(source,
distinct,
isInSortedOrder,
orderItem,
source.getActivation(),
rowAllocator,
maxRowSize,
resultSetNumber,
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
/**
@see ResultSetFactory#getScalarAggregateResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getScalarAggregateResultSet(NoPutResultSet source,
boolean isInSortedOrder,
int aggregateItem,
int orderItem,
int rowAllocator,
int maxRowSize,
int resultSetNumber,
boolean singleInputRow,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
throws StandardException
{
return new ScalarAggregateResultSet(
source, isInSortedOrder, aggregateItem, source.getActivation(),
rowAllocator, resultSetNumber, singleInputRow,
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
/**
@see ResultSetFactory#getDistinctScalarAggregateResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getDistinctScalarAggregateResultSet(NoPutResultSet source,
boolean isInSortedOrder,
int aggregateItem,
int orderItem,
int rowAllocator,
int maxRowSize,
int resultSetNumber,
boolean singleInputRow,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
throws StandardException
{
return new DistinctScalarAggregateResultSet(
source, isInSortedOrder, aggregateItem, orderItem, source.getActivation(),
rowAllocator, maxRowSize, resultSetNumber, singleInputRow,
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
/**
@see ResultSetFactory#getGroupedAggregateResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getGroupedAggregateResultSet(NoPutResultSet source,
boolean isInSortedOrder,
int aggregateItem,
int orderItem,
int rowAllocator,
int maxRowSize,
int resultSetNumber,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost,
boolean isRollup)
throws StandardException
{
return new GroupedAggregateResultSet(
source, isInSortedOrder, aggregateItem, orderItem, source.getActivation(),
rowAllocator, maxRowSize, resultSetNumber, optimizerEstimatedRowCount,
optimizerEstimatedCost, isRollup);
}
/**
@see ResultSetFactory#getDistinctGroupedAggregateResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getDistinctGroupedAggregateResultSet(NoPutResultSet source,
boolean isInSortedOrder,
int aggregateItem,
int orderItem,
int rowAllocator,
int maxRowSize,
int resultSetNumber,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost,
boolean isRollup)
throws StandardException
{
return new DistinctGroupedAggregateResultSet(
source, isInSortedOrder, aggregateItem, orderItem, source.getActivation(),
rowAllocator, maxRowSize, resultSetNumber, optimizerEstimatedRowCount,
optimizerEstimatedCost, isRollup);
}
/**
@see ResultSetFactory#getAnyResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getAnyResultSet(NoPutResultSet source,
GeneratedMethod emptyRowFun, int resultSetNumber,
int subqueryNumber, int pointOfAttachment,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
throws StandardException
{
return new AnyResultSet(source,
source.getActivation(), emptyRowFun, resultSetNumber,
subqueryNumber, pointOfAttachment,
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
/**
@see ResultSetFactory#getOnceResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getOnceResultSet(NoPutResultSet source,
GeneratedMethod emptyRowFun,
int cardinalityCheck, int resultSetNumber,
int subqueryNumber, int pointOfAttachment,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
throws StandardException
{
return new OnceResultSet(source,
source.getActivation(), emptyRowFun,
cardinalityCheck, resultSetNumber,
subqueryNumber, pointOfAttachment,
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
/**
@see ResultSetFactory#getRowResultSet
*/
public NoPutResultSet getRowResultSet(Activation activation, GeneratedMethod row,
boolean canCacheRow,
int resultSetNumber,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
{
return new RowResultSet(activation, row, canCacheRow, resultSetNumber,
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
/**
@see ResultSetFactory#getVTIResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getVTIResultSet(Activation activation, int row,
int resultSetNumber,
GeneratedMethod constructor,
String javaClassName,
Qualifier[][] pushedQualifiers,
int erdNumber,
boolean version2,
boolean reuseablePs,
int ctcNumber,
boolean isTarget,
int scanIsolationLevel,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost,
boolean isDerbyStyleTableFunction,
int returnTypeNumber,
int vtiProjectionNumber,
int vtiRestrictionNumber,
String vtiSchema,
String vtiName
)
throws StandardException
{
return new VTIResultSet(activation, row, resultSetNumber,
constructor,
javaClassName,
pushedQualifiers,
erdNumber,
version2, reuseablePs,
ctcNumber,
isTarget,
scanIsolationLevel,
optimizerEstimatedRowCount,
optimizerEstimatedCost,
isDerbyStyleTableFunction,
returnTypeNumber,
vtiProjectionNumber,
vtiRestrictionNumber,
vtiSchema,
vtiName
);
}
/**
a hash scan generator, for ease of use at present.
@see ResultSetFactory#getHashScanResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getHashScanResultSet(
Activation activation,
long conglomId,
int scociItem,
int resultRowTemplate,
int resultSetNumber,
GeneratedMethod startKeyGetter,
int startSearchOperator,
GeneratedMethod stopKeyGetter,
int stopSearchOperator,
boolean sameStartStopPosition,
Qualifier[][] scanQualifiers,
Qualifier[][] nextQualifiers,
int initialCapacity,
float loadFactor,
int maxCapacity,
int hashKeyColumn,
String tableName,
String userSuppliedOptimizerOverrides,
String indexName,
boolean isConstraint,
boolean forUpdate,
int colRefItem,
int indexColItem,
int lockMode,
boolean tableLocked,
int isolationLevel,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
throws StandardException
{
StaticCompiledOpenConglomInfo scoci = (StaticCompiledOpenConglomInfo)(activation.getPreparedStatement().
getSavedObject(scociItem));
return new HashScanResultSet(
conglomId,
scoci,
activation,
resultRowTemplate,
resultSetNumber,
startKeyGetter,
startSearchOperator,
stopKeyGetter,
stopSearchOperator,
sameStartStopPosition,
scanQualifiers,
nextQualifiers,
initialCapacity,
loadFactor,
maxCapacity,
hashKeyColumn,
tableName,
userSuppliedOptimizerOverrides,
indexName,
isConstraint,
forUpdate,
colRefItem,
lockMode,
tableLocked,
isolationLevel,
true, // Skip rows with 1 or more null key columns
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
/**
a distinct scan generator, for ease of use at present.
@see ResultSetFactory#getHashScanResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getDistinctScanResultSet(
Activation activation,
long conglomId,
int scociItem,
int resultRowTemplate,
int resultSetNumber,
int hashKeyColumn,
String tableName,
String userSuppliedOptimizerOverrides,
String indexName,
boolean isConstraint,
int colRefItem,
int lockMode,
boolean tableLocked,
int isolationLevel,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
throws StandardException
{
StaticCompiledOpenConglomInfo scoci = (StaticCompiledOpenConglomInfo)(activation.getPreparedStatement().
getSavedObject(scociItem));
return new DistinctScanResultSet(
conglomId,
scoci,
activation,
resultRowTemplate,
resultSetNumber,
hashKeyColumn,
tableName,
userSuppliedOptimizerOverrides,
indexName,
isConstraint,
colRefItem,
lockMode,
tableLocked,
isolationLevel,
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
/**
a minimal table scan generator, for ease of use at present.
@see ResultSetFactory#getTableScanResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getTableScanResultSet(
Activation activation,
long conglomId,
int scociItem,
int resultRowTemplate,
int resultSetNumber,
GeneratedMethod startKeyGetter,
int startSearchOperator,
GeneratedMethod stopKeyGetter,
int stopSearchOperator,
boolean sameStartStopPosition,
Qualifier[][] qualifiers,
String tableName,
String userSuppliedOptimizerOverrides,
String indexName,
boolean isConstraint,
boolean forUpdate,
int colRefItem,
int indexColItem,
int lockMode,
boolean tableLocked,
int isolationLevel,
boolean oneRowScan,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
throws StandardException
{
StaticCompiledOpenConglomInfo scoci = (StaticCompiledOpenConglomInfo)(activation.getPreparedStatement().
getSavedObject(scociItem));
return new TableScanResultSet(
conglomId,
scoci,
activation,
resultRowTemplate,
resultSetNumber,
startKeyGetter,
startSearchOperator,
stopKeyGetter,
stopSearchOperator,
sameStartStopPosition,
qualifiers,
tableName,
userSuppliedOptimizerOverrides,
indexName,
isConstraint,
forUpdate,
colRefItem,
indexColItem,
lockMode,
tableLocked,
isolationLevel,
1, // rowsPerRead is 1 if not a bulkTableScan
oneRowScan,
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
public NoPutResultSet getValidateCheckConstraintResultSet(
Activation activation,
long conglomId,
int scociItem,
int resultRowTemplate,
int resultSetNumber,
GeneratedMethod startKeyGetter,
int startSearchOperator,
GeneratedMethod stopKeyGetter,
int stopSearchOperator,
boolean sameStartStopPosition,
Qualifier[][] qualifiers,
String tableName,
String userSuppliedOptimizerOverrides,
String indexName,
boolean isConstraint,
boolean forUpdate,
int colRefItem,
int indexColItem,
int lockMode,
boolean tableLocked,
int isolationLevel,
boolean oneRowScan,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
throws StandardException
{
StaticCompiledOpenConglomInfo scoci =
(StaticCompiledOpenConglomInfo)(activation.getPreparedStatement().
getSavedObject(scociItem));
return new ValidateCheckConstraintResultSet(
conglomId,
scoci,
activation,
resultRowTemplate,
resultSetNumber,
startKeyGetter,
startSearchOperator,
stopKeyGetter,
stopSearchOperator,
sameStartStopPosition,
qualifiers,
tableName,
userSuppliedOptimizerOverrides,
indexName,
isConstraint,
forUpdate,
colRefItem,
indexColItem,
lockMode,
tableLocked,
isolationLevel,
1, // rowsPerRead is 1 if not a bulkTableScan
oneRowScan,
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
/**
Table/Index scan where rows are read in bulk
@see ResultSetFactory#getBulkTableScanResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getBulkTableScanResultSet(
Activation activation,
long conglomId,
int scociItem,
int resultRowTemplate,
int resultSetNumber,
GeneratedMethod startKeyGetter,
int startSearchOperator,
GeneratedMethod stopKeyGetter,
int stopSearchOperator,
boolean sameStartStopPosition,
Qualifier[][] qualifiers,
String tableName,
String userSuppliedOptimizerOverrides,
String indexName,
boolean isConstraint,
boolean forUpdate,
int colRefItem,
int indexColItem,
int lockMode,
boolean tableLocked,
int isolationLevel,
int rowsPerRead,
boolean disableForHoldable,
boolean oneRowScan,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
throws StandardException
{
//Prior to Cloudscape 10.0 release, holdability was false by default. Programmers had to explicitly
//set the holdability to true using JDBC apis. Since holdability was not true by default, we chose to disable the
//prefetching for RR and Serializable when holdability was explicitly set to true.
//But starting Cloudscape 10.0 release, in order to be DB2 compatible, holdability is set to true by default.
//Because of that, we can not continue to disable the prefetching for RR and Serializable, since it causes
//severe performance degradation - bug 5953.
StaticCompiledOpenConglomInfo scoci = (StaticCompiledOpenConglomInfo)(activation.getPreparedStatement().
getSavedObject(scociItem));
return new BulkTableScanResultSet(
conglomId,
scoci,
activation,
resultRowTemplate,
resultSetNumber,
startKeyGetter,
startSearchOperator,
stopKeyGetter,
stopSearchOperator,
sameStartStopPosition,
qualifiers,
tableName,
userSuppliedOptimizerOverrides,
indexName,
isConstraint,
forUpdate,
colRefItem,
indexColItem,
lockMode,
tableLocked,
isolationLevel,
rowsPerRead,
disableForHoldable,
oneRowScan,
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
/**
Multi-probing scan that probes an index for specific values contained
in the received probe list.
All index rows for which the first column equals probeVals[0] will
be returned, followed by all rows for which the first column equals
probeVals[1], and so on. Assumption is that we only get here if
probeVals has at least one value.
@see ResultSetFactory#getMultiProbeTableScanResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getMultiProbeTableScanResultSet(
Activation activation,
long conglomId,
int scociItem,
int resultRowTemplate,
int resultSetNumber,
GeneratedMethod startKeyGetter,
int startSearchOperator,
GeneratedMethod stopKeyGetter,
int stopSearchOperator,
boolean sameStartStopPosition,
Qualifier[][] qualifiers,
DataValueDescriptor [] probeVals,
int sortRequired,
String tableName,
String userSuppliedOptimizerOverrides,
String indexName,
boolean isConstraint,
boolean forUpdate,
int colRefItem,
int indexColItem,
int lockMode,
boolean tableLocked,
int isolationLevel,
boolean oneRowScan,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
throws StandardException
{
StaticCompiledOpenConglomInfo scoci = (StaticCompiledOpenConglomInfo)
activation.getPreparedStatement().getSavedObject(scociItem);
return new MultiProbeTableScanResultSet(
conglomId,
scoci,
activation,
resultRowTemplate,
resultSetNumber,
startKeyGetter,
startSearchOperator,
stopKeyGetter,
stopSearchOperator,
sameStartStopPosition,
qualifiers,
probeVals,
sortRequired,
tableName,
userSuppliedOptimizerOverrides,
indexName,
isConstraint,
forUpdate,
colRefItem,
indexColItem,
lockMode,
tableLocked,
isolationLevel,
oneRowScan,
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
/**
@see ResultSetFactory#getIndexRowToBaseRowResultSet
@exception StandardException Thrown on error
*/
public NoPutResultSet getIndexRowToBaseRowResultSet(
long conglomId,
int scociItem,
NoPutResultSet source,
int resultRowAllocator,
int resultSetNumber,
String indexName,
int heapColRefItem,
int allColRefItem,
int heapOnlyColRefItem,
int indexColMapItem,
GeneratedMethod restriction,
boolean forUpdate,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost,
int baseColumnCount )
throws StandardException
{
return new IndexRowToBaseRowResultSet(
conglomId,
scociItem,
source.getActivation(),
source,
resultRowAllocator,
resultSetNumber,
indexName,
heapColRefItem,
allColRefItem,
heapOnlyColRefItem,
indexColMapItem,
restriction,
forUpdate,
optimizerEstimatedRowCount,
optimizerEstimatedCost,
baseColumnCount);
}
/**
@see ResultSetFactory#getWindowResultSet
@exception StandardException Thrown on error
*/
public NoPutResultSet getWindowResultSet(
Activation activation,
NoPutResultSet source,
int rowAllocator,
int resultSetNumber,
int erdNumber,
GeneratedMethod restriction,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
throws StandardException
{
return new WindowResultSet(
activation,
source,
rowAllocator,
resultSetNumber,
erdNumber,
restriction,
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
/**
@see ResultSetFactory#getNestedLoopJoinResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getNestedLoopJoinResultSet(NoPutResultSet leftResultSet,
int leftNumCols,
NoPutResultSet rightResultSet,
int rightNumCols,
GeneratedMethod joinClause,
int resultSetNumber,
boolean oneRowRightSide,
boolean notExistsRightSide,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost,
String userSuppliedOptimizerOverrides)
throws StandardException
{
return new NestedLoopJoinResultSet(leftResultSet, leftNumCols,
rightResultSet, rightNumCols,
leftResultSet.getActivation(), joinClause,
resultSetNumber,
oneRowRightSide,
notExistsRightSide,
optimizerEstimatedRowCount,
optimizerEstimatedCost,
userSuppliedOptimizerOverrides);
}
/**
@see ResultSetFactory#getHashJoinResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getHashJoinResultSet(NoPutResultSet leftResultSet,
int leftNumCols,
NoPutResultSet rightResultSet,
int rightNumCols,
GeneratedMethod joinClause,
int resultSetNumber,
boolean oneRowRightSide,
boolean notExistsRightSide,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost,
String userSuppliedOptimizerOverrides)
throws StandardException
{
return new HashJoinResultSet(leftResultSet, leftNumCols,
rightResultSet, rightNumCols,
leftResultSet.getActivation(), joinClause,
resultSetNumber,
oneRowRightSide,
notExistsRightSide,
optimizerEstimatedRowCount,
optimizerEstimatedCost,
userSuppliedOptimizerOverrides);
}
/**
@see ResultSetFactory#getNestedLoopLeftOuterJoinResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getNestedLoopLeftOuterJoinResultSet(NoPutResultSet leftResultSet,
int leftNumCols,
NoPutResultSet rightResultSet,
int rightNumCols,
GeneratedMethod joinClause,
int resultSetNumber,
GeneratedMethod emptyRowFun,
boolean wasRightOuterJoin,
boolean oneRowRightSide,
boolean notExistsRightSide,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost,
String userSuppliedOptimizerOverrides)
throws StandardException
{
return new NestedLoopLeftOuterJoinResultSet(leftResultSet, leftNumCols,
rightResultSet, rightNumCols,
leftResultSet.getActivation(), joinClause,
resultSetNumber,
emptyRowFun,
wasRightOuterJoin,
oneRowRightSide,
notExistsRightSide,
optimizerEstimatedRowCount,
optimizerEstimatedCost,
userSuppliedOptimizerOverrides);
}
/**
@see ResultSetFactory#getHashLeftOuterJoinResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getHashLeftOuterJoinResultSet(NoPutResultSet leftResultSet,
int leftNumCols,
NoPutResultSet rightResultSet,
int rightNumCols,
GeneratedMethod joinClause,
int resultSetNumber,
GeneratedMethod emptyRowFun,
boolean wasRightOuterJoin,
boolean oneRowRightSide,
boolean notExistsRightSide,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost,
String userSuppliedOptimizerOverrides)
throws StandardException
{
return new HashLeftOuterJoinResultSet(leftResultSet, leftNumCols,
rightResultSet, rightNumCols,
leftResultSet.getActivation(), joinClause,
resultSetNumber,
emptyRowFun,
wasRightOuterJoin,
oneRowRightSide,
notExistsRightSide,
optimizerEstimatedRowCount,
optimizerEstimatedCost,
userSuppliedOptimizerOverrides);
}
/**
@see ResultSetFactory#getSetTransactionResultSet
@exception StandardException thrown when unable to create the
result set
*/
public ResultSet getSetTransactionResultSet(Activation activation)
throws StandardException
{
getAuthorizer(activation).authorize(activation, Authorizer.SQL_ARBITARY_OP);
return new SetTransactionResultSet(activation);
}
/**
@see ResultSetFactory#getMaterializedResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getMaterializedResultSet(NoPutResultSet source,
int resultSetNumber,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
throws StandardException
{
return new MaterializedResultSet(source, source.getActivation(),
resultSetNumber,
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
/**
@see ResultSetFactory#getScrollInsensitiveResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getScrollInsensitiveResultSet(NoPutResultSet source,
Activation activation, int resultSetNumber,
int sourceRowWidth,
boolean scrollable,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
throws StandardException
{
/* ResultSet tree is dependent on whether or not this is
* for a scroll insensitive cursor.
*/
if (scrollable)
{
return new ScrollInsensitiveResultSet(source, activation,
resultSetNumber,
sourceRowWidth,
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
else
{
return source;
}
}
/**
@see ResultSetFactory#getNormalizeResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getNormalizeResultSet(NoPutResultSet source,
int resultSetNumber,
int erdNumber,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost,
boolean forUpdate)
throws StandardException
{
return new NormalizeResultSet(source, source.getActivation(),
resultSetNumber, erdNumber,
optimizerEstimatedRowCount,
optimizerEstimatedCost, forUpdate);
}
/**
@see ResultSetFactory#getCurrentOfResultSet
*/
public NoPutResultSet getCurrentOfResultSet(String cursorName,
Activation activation, int resultSetNumber)
{
return new CurrentOfResultSet(cursorName, activation, resultSetNumber);
}
/**
@see ResultSetFactory#getDDLResultSet
@exception StandardException thrown on error
*/
public ResultSet getDDLResultSet(Activation activation)
throws StandardException
{
getAuthorizer(activation).authorize(activation, Authorizer.SQL_DDL_OP);
return getMiscResultSet( activation);
}
/**
@see ResultSetFactory#getMiscResultSet
@exception StandardException thrown on error
*/
public ResultSet getMiscResultSet(Activation activation)
throws StandardException
{
getAuthorizer(activation).authorize(activation, Authorizer.SQL_ARBITARY_OP);
return new MiscResultSet(activation);
}
/**
a minimal union scan generator, for ease of use at present.
@see ResultSetFactory#getUnionResultSet
@exception StandardException thrown on error
*/
public NoPutResultSet getUnionResultSet(NoPutResultSet leftResultSet,
NoPutResultSet rightResultSet,
int resultSetNumber,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
throws StandardException
{
return new UnionResultSet(leftResultSet, rightResultSet,
leftResultSet.getActivation(),
resultSetNumber,
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
public NoPutResultSet getSetOpResultSet( NoPutResultSet leftSource,
NoPutResultSet rightSource,
Activation activation,
int resultSetNumber,
long optimizerEstimatedRowCount,
double optimizerEstimatedCost,
int opType,
boolean all,
int intermediateOrderByColumnsSavedObject,
int intermediateOrderByDirectionSavedObject,
int intermediateOrderByNullsLowSavedObject)
throws StandardException
{
return new SetOpResultSet( leftSource,
rightSource,
activation,
resultSetNumber,
optimizerEstimatedRowCount,
optimizerEstimatedCost,
opType,
all,
intermediateOrderByColumnsSavedObject,
intermediateOrderByDirectionSavedObject,
intermediateOrderByNullsLowSavedObject);
}
/**
* A last index key sresult set returns the last row from
* the index in question. It is used as an ajunct to max().
*
* @param activation the activation for this result set,
* which provides the context for the row allocation operation.
* @param resultSetNumber The resultSetNumber for the ResultSet
* @param resultRowTemplate The saved item for result row template
* @param conglomId the conglomerate of the table to be scanned.
* @param tableName The full name of the table
* @param userSuppliedOptimizerOverrides Overrides specified by the user on the sql
* @param indexName The name of the index, if one used to access table.
* @param colRefItem An saved item for a bitSet of columns that
* are referenced in the underlying table. -1 if
* no item.
* @param lockMode The lock granularity to use (see
* TransactionController in access)
* @param tableLocked Whether or not the table is marked as using table locking
* (in sys.systables)
* @param isolationLevel Isolation level (specified or not) to use on scans
* @param optimizerEstimatedRowCount Estimated total # of rows by
* optimizer
* @param optimizerEstimatedCost Estimated total cost by optimizer
*
* @return the scan operation as a result set.
*
* @exception StandardException thrown when unable to create the
* result set
*/
public NoPutResultSet getLastIndexKeyResultSet
(
Activation activation,
int resultSetNumber,
int resultRowTemplate,
long conglomId,
String tableName,
String userSuppliedOptimizerOverrides,
String indexName,
int colRefItem,
int lockMode,
boolean tableLocked,
int isolationLevel,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost
) throws StandardException
{
return new LastIndexKeyResultSet(
activation,
resultSetNumber,
resultRowTemplate,
conglomId,
tableName,
userSuppliedOptimizerOverrides,
indexName,
colRefItem,
lockMode,
tableLocked,
isolationLevel,
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
/**
* a referential action dependent table scan generator.
* @see ResultSetFactory#getTableScanResultSet
* @exception StandardException thrown on error
*/
public NoPutResultSet getRaDependentTableScanResultSet(
Activation activation,
long conglomId,
int scociItem,
int resultRowTemplate,
int resultSetNumber,
GeneratedMethod startKeyGetter,
int startSearchOperator,
GeneratedMethod stopKeyGetter,
int stopSearchOperator,
boolean sameStartStopPosition,
Qualifier[][] qualifiers,
String tableName,
String userSuppliedOptimizerOverrides,
String indexName,
boolean isConstraint,
boolean forUpdate,
int colRefItem,
int indexColItem,
int lockMode,
boolean tableLocked,
int isolationLevel,
boolean oneRowScan,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost,
String parentResultSetId,
long fkIndexConglomId,
int fkColArrayItem,
int rltItem)
throws StandardException
{
StaticCompiledOpenConglomInfo scoci = (StaticCompiledOpenConglomInfo)(activation.getPreparedStatement().
getSavedObject(scociItem));
return new DependentResultSet(
conglomId,
scoci,
activation,
resultRowTemplate,
resultSetNumber,
startKeyGetter,
startSearchOperator,
stopKeyGetter,
stopSearchOperator,
sameStartStopPosition,
qualifiers,
tableName,
userSuppliedOptimizerOverrides,
indexName,
isConstraint,
forUpdate,
colRefItem,
lockMode,
tableLocked,
isolationLevel,
1,
oneRowScan,
optimizerEstimatedRowCount,
optimizerEstimatedCost,
parentResultSetId,
fkIndexConglomId,
fkColArrayItem,
rltItem);
}
/**
* @see ResultSetFactory#getRowCountResultSet
*/
public NoPutResultSet getRowCountResultSet(
NoPutResultSet source,
Activation activation,
int resultSetNumber,
GeneratedMethod offsetMethod,
GeneratedMethod fetchFirstMethod,
boolean hasJDBClimitClause,
double optimizerEstimatedRowCount,
double optimizerEstimatedCost)
throws StandardException
{
return new RowCountResultSet(source,
activation,
resultSetNumber,
offsetMethod,
fetchFirstMethod,
hasJDBClimitClause,
optimizerEstimatedRowCount,
optimizerEstimatedCost);
}
static private Authorizer getAuthorizer(Activation activation)
{
LanguageConnectionContext lcc = activation.getLanguageConnectionContext();
return lcc.getAuthorizer();
}
/////////////////////////////////////////////////////////////////
//
// PUBLIC MINIONS
//
/////////////////////////////////////////////////////////////////
}
Ads help maintain this website.