Apache Derby Database Engine and Embedded JDBC Driver 10.17.1.0 · org.apache.derby.impl.sql.execute.InsertResultSet

Modifier and Type	Field and Description
private ConglomerateController	bulkHeapCC
private ScanController	bulkHeapSC
protected boolean	bulkInsert
private BulkInsertCounter[]	bulkInsertCounters
pack-priv boolean	bulkInsertPerformed
private boolean	bulkInsertReplace
private GeneratedMethod	checkGM
private int[][]	collation
pack-priv InsertConstantAction	constants
protected DataDictionary	dd
private BackingStoreHashtable	deferredChecks
private boolean	firstExecute
private boolean	firstRow
private RISetChecker	fkChecker
private FKInfo[]	fkInfoArray
private final int	fullTemplateId
private GeneratedMethod	generationClauses
private boolean	hasBeforeRowTrigger
private long	heapConglom
private Hashtable<Long, Long>	indexConversionTable
private FormatableBitSet	indexedCols
private ExecIndexRow[]	indexRows
private boolean[]	needToDropSort
private int	numOpens
private ColumnOrdering[][]	ordering
private RowLocation	rl
private ExecRow	row
private RowChanger	rowChanger
private TemporaryRowHolderImpl	rowHolder
private RowLocationRetRowSource[]	rowSources
pack-priv NoPutResultSet	savedSource
private final String	schemaName
private SortController[]	sorters
private long[]	sortIds
private final String	tableName
private BulkTableScanResultSet	tableScan
private TransactionController	tc
protected TableDescriptor	td
private TriggerEventActivator	triggerActivator
private TriggerInfo	triggerInfo
pack-priv boolean	userSpecifiedBulkInsert
private List<UUID>	violatingCheckConstraints

Access	Constructor and Description
pack-priv	InsertResultSet(NoPutResultSet source, GeneratedMethod generationClauses, GeneratedMethod checkGM, int fullTemplate, String schemaName, String tableName, Activation activation)

Method Summary

Modifier and Type	Method and Description
private void	bulkInsertCore(LanguageConnectionContext lcc, ExecRow fullTemplate, long oldHeapConglom)
private void	bulkValidateForeignKeys(TransactionController tc, ContextManager cm, ExecRow fullTemplate) Bulk Referential Integrity Checker
private void	bulkValidateForeignKeysCore(TransactionController tc, ContextManager cm, FKInfo fkInfo, long fkConglom, long pkConglom, String fkConstraintName, ExecRow fullTemplate)
public void	changedRow(ExecRow The changed row. execRow, RowLocation The row location of the row. rowLocation) Implements org.apache.derby.iapi.sql.execute.TargetResultSet.changedRow. Pass a changed row and the row location for that row to the target result set.
public void	cleanUp() Implements org.apache.derby.iapi.sql.ResultSet.cleanUp. Tells the system to clean up on an error.
public void	close() Implements org.apache.derby.iapi.sql.ResultSet.close. Clean up resources and call close on data members.
private void	emptyIndexes(long newHeapConglom, InsertConstantAction constants, TableDescriptor td, DataDictionary dd, ExecRow fullTemplate) Empty the indexes after doing a bulk insert replace where the table has 0 rows after the replace.
private boolean	evaluateCheckConstraints() Run the check constraints against the current row.
public void	finish() Overrides org.apache.derby.impl.sql.execute.NoRowsResultSetImpl.finish. Implements org.apache.derby.iapi.sql.ResultSet.finish. Tells the system that there will be no more access to any database information via this result set; in particular, no more calls to open().
private int[]	generatedColumnPositionsArray() If user didn't provide columns list for auto-generated columns, then only include columns with auto-generated values in the resultset.
private String[]	getColumnNames(int[] baseColumnPositions)
private boolean	Returns: Whether or not bulkInsert is allowed on this table. getExclusiveTableLock() Get an exclusive table lock on the target table (and check to see if the table is populated if this is not a bulk insert replace).
protected ExecRow	getNextRowCore(NoPutResultSet SourceResultSet Also look at Track#2432/change 12433 source) Overrides org.apache.derby.impl.sql.execute.DMLWriteResultSet.getNextRowCore. Get next row from the source result set.
private void	getOldStyleBulkInsertValue(int 0-based index into aiCache index, long increment) Identity generation logic for bulk-insert used in pre-10.11 databases.
private NumberDataValue	getOldStyleIdentityValue(int 0-based index into aiCache index) Identity generation logic used in pre-10.11 databases.
public NumberDataValue	getSetAutoincrementValue(int position of the column in the table (1-based) columnPosition, long amount of increment. increment) Overrides org.apache.derby.impl.sql.execute.DMLWriteGeneratedColumnsResultSet.getSetAutoincrementValue. getSetAutoincrementValue will get the autoincrement value of the columnPosition specified for the target table.
private BulkTableScanResultSet	getTableScanResultSet(long conglomId) Get me a table scan result set, preferably a bulk table scan, thank you.
protected void	initializeAIcache(RowLocation[] rla)
private boolean	isSingleRowResultSet()
private boolean	isSourceRowResultSet()
private ExecRow	makeIndexTemplate(FKInfo fkInfo, ExecRow fullTemplate, ContextManager cm) Make a template row with the correct columns.
private void	normalInsertCore(LanguageConnectionContext lcc, boolean firstExecute)
public void	offendingRowLocation(RowLocation rl, long constainerId) Implements org.apache.derby.iapi.sql.execute.TargetResultSet.offendingRowLocation.
public void	open() Implements org.apache.derby.iapi.sql.ResultSet.open. Needs to be called before the result set will do anything.
public ExecRow	Returns: The preprocessed source row. preprocessSourceRow(ExecRow The source row. execRow) Implements org.apache.derby.iapi.sql.execute.TargetResultSet.preprocessSourceRow. Preprocess the source row.
private ExecRow	processMergeRow(NoPutResultSet sourceRS, ExecRow row) Special handling if this is an INSERT action of a MERGE statement.
public void	rememberConstraint(UUID cid) Overrides org.apache.derby.impl.sql.execute.DMLWriteResultSet.rememberConstraint.
private void	setEstimatedRowCount(long Conglomerate number for the heap heapConglom) Set the estimated row count for this table.
private void	setUpAllSorts(ExecRow sourceRow, RowLocation rl) Set up to update all of the indexes on a table when doing a bulk insert on an empty table.
private void	updateAllIndexes(long newHeapConglom, InsertConstantAction constants, TableDescriptor td, DataDictionary dd, ExecRow fullTemplate) Update all of the indexes on a table when doing a bulk insert on an empty table.
protected boolean	Returns: Whether or not bulkInsert is allowed on this table. verifyBulkInsert() Verify that bulkInsert is allowed on this table.

Inherited from org.apache.derby.impl.sql.execute.DMLWriteGeneratedColumnsResultSet:: firstExecuteSpecialHandlingAutoGen getAutoGeneratedKeysResultset getCompactRow saveAIcacheInformation verifyAutoGeneratedRScolumnsList

Field Detail

bulkHeapCC	back to summary
private ConglomerateController bulkHeapCC

bulkHeapSC	back to summary
private ScanController bulkHeapSC

bulkInsert	back to summary
protected boolean bulkInsert

bulkInsertCounters	back to summary
private BulkInsertCounter[] bulkInsertCounters

bulkInsertPerformed	back to summary
pack-priv boolean bulkInsertPerformed

bulkInsertReplace	back to summary
private boolean bulkInsertReplace

checkGM	back to summary
private GeneratedMethod checkGM

collation	back to summary
private int[][] collation

constants	back to summary
pack-priv InsertConstantAction constants

dd	back to summary
protected DataDictionary dd

deferredChecks	back to summary
private BackingStoreHashtable deferredChecks

firstExecute	back to summary
private boolean firstExecute

firstRow	back to summary
private boolean firstRow

fkChecker	back to summary
private RISetChecker fkChecker

fkInfoArray	back to summary
private FKInfo[] fkInfoArray

fullTemplateId	back to summary
private final int fullTemplateId

generationClauses	back to summary
private GeneratedMethod generationClauses

hasBeforeRowTrigger	back to summary
private boolean hasBeforeRowTrigger

heapConglom	back to summary
private long heapConglom

indexConversionTable	back to summary
private Hashtable<Long, Long> indexConversionTable

indexedCols	back to summary
private FormatableBitSet indexedCols

indexRows	back to summary
private ExecIndexRow[] indexRows

needToDropSort	back to summary
private boolean[] needToDropSort

numOpens	back to summary
private int numOpens

ordering	back to summary
private ColumnOrdering[][] ordering

rl	back to summary
private RowLocation rl

row	back to summary
private ExecRow row

rowChanger	back to summary
private RowChanger rowChanger

rowHolder	back to summary
private TemporaryRowHolderImpl rowHolder

rowSources	back to summary
private RowLocationRetRowSource[] rowSources

savedSource	back to summary
pack-priv NoPutResultSet savedSource

schemaName	back to summary
private final String schemaName

sorters	back to summary
private SortController[] sorters

sortIds	back to summary
private long[] sortIds

tableName	back to summary
private final String tableName

tableScan	back to summary
private BulkTableScanResultSet tableScan

tc	back to summary
private TransactionController tc

td	back to summary
protected TableDescriptor td

triggerActivator	back to summary
private TriggerEventActivator triggerActivator

triggerInfo	back to summary
private TriggerInfo triggerInfo

userSpecifiedBulkInsert	back to summary
pack-priv boolean userSpecifiedBulkInsert

violatingCheckConstraints	back to summary
private List<UUID> violatingCheckConstraints

Constructor Detail

InsertResultSet	back to summary
pack-priv InsertResultSet(NoPutResultSet source, GeneratedMethod generationClauses, GeneratedMethod checkGM, int fullTemplate, String schemaName, String tableName, Activation activation) throws StandardException Exceptions StandardException: Thrown on error

Method Detail

bulkInsertCore	back to summary
private void bulkInsertCore(LanguageConnectionContext lcc, ExecRow fullTemplate, long oldHeapConglom) throws StandardException

bulkValidateForeignKeys	back to summary
private void bulkValidateForeignKeys(TransactionController tc, ContextManager cm, ExecRow fullTemplate) throws StandardException Bulk Referential Integrity Checker

bulkValidateForeignKeysCore	back to summary
private void bulkValidateForeignKeysCore(TransactionController tc, ContextManager cm, FKInfo fkInfo, long fkConglom, long pkConglom, String fkConstraintName, ExecRow fullTemplate) throws StandardException

changedRow back to summary

changedRow	back to summary
public void changedRow(ExecRow execRow, RowLocation rowLocation) throws StandardException Implements org.apache.derby.iapi.sql.execute.TargetResultSet.changedRow. Doc from org.apache.derby.iapi.sql.execute.TargetResultSet.changedRow. Pass a changed row and the row location for that row to the target result set. Parameters execRow:ExecRow The changed row. rowLocation:RowLocation The row location of the row. Exceptions StandardException: thrown if cursor finish ed. See Also `TargetResultSet#changedRow`

public void changedRow(ExecRow execRow, RowLocation rowLocation) throws StandardException

Implements org.apache.derby.iapi.sql.execute.TargetResultSet.changedRow.

Doc from org.apache.derby.iapi.sql.execute.TargetResultSet.changedRow.

Pass a changed row and the row location for that row to the target result set.

Parameters

execRow:ExecRow: The changed row.
rowLocation:RowLocation: The row location of the row.

Exceptions

StandardException:: thrown if cursor finish ed.

See Also

TargetResultSet#changedRow

cleanUp back to summary

public void cleanUp() throws StandardException

Implements org.apache.derby.iapi.sql.ResultSet.cleanUp.

Doc from org.apache.derby.iapi.sql.ResultSet.cleanUp.

Tells the system to clean up on an error.

Exceptions

StandardException:: Thrown on error

See Also

ResultSet#cleanUp

back to summary

public void close() throws StandardException

Implements org.apache.derby.iapi.sql.ResultSet.close.

Clean up resources and call close on data members.

Exceptions

StandardException:

Doc from org.apache.derby.iapi.sql.ResultSet.close.

Thrown on error.

emptyIndexes

back to summary

private void emptyIndexes(long newHeapConglom, InsertConstantAction constants, TableDescriptor td, DataDictionary dd, ExecRow fullTemplate) throws StandardException

Empty the indexes after doing a bulk insert replace where the table has 0 rows after the replace.

Resolve

This method is ugly! Prior to 2.0, we simply scanned back across the table to build the indexes. We changed this in 2.0 to populate the sorters via a call back as we populated the table. Doing a 0 row replace into a table with indexes is a degenerate case, hence we allow ugly and unoptimized code.

Exceptions

StandardException:: Thrown on failure

evaluateCheckConstraints

back to summary

private boolean evaluateCheckConstraints() throws StandardException

Run the check constraints against the current row. Raise an error if a check constraint is violated, unless all the offending checks are deferred, in which case a false value will be returned. A NULL value will be interpreted as success (not violation).

Exceptions

StandardException:: thrown on error

finish

back to summary

public void finish() throws StandardException

Overrides org.apache.derby.impl.sql.execute.NoRowsResultSetImpl.finish.

Implements org.apache.derby.iapi.sql.ResultSet.finish.

Doc from org.apache.derby.iapi.sql.ResultSet.finish.

Tells the system that there will be no more access to any database information via this result set; in particular, no more calls to open(). Will close the result set if it is not already closed.

Annotations

@Override

Exceptions

StandardException:: on error

generatedColumnPositionsArray	back to summary
private int[] generatedColumnPositionsArray() throws StandardException If user didn't provide columns list for auto-generated columns, then only include columns with auto-generated values in the resultset. Those columns would be ones with default value defined.

getColumnNames	back to summary
private String[] getColumnNames(int[] baseColumnPositions)

getExclusiveTableLock

back to summary

private boolean getExclusiveTableLock() throws StandardException

Get an exclusive table lock on the target table (and check to see if the table is populated if this is not a bulk insert replace).

Returns:boolean

Whether or not bulkInsert is allowed on this table.

Exceptions

StandardException:: Thrown on error

getNextRowCore

back to summary

protected ExecRow getNextRowCore(NoPutResultSet source) throws StandardException

Overrides org.apache.derby.impl.sql.execute.DMLWriteResultSet.getNextRowCore.

Doc from org.apache.derby.impl.sql.execute.DMLWriteResultSet.getNextRowCore.

Get next row from the source result set.

Parameters

source:NoPutResultSet: SourceResultSet Also look at Track#2432/change 12433

Returns:ExecRow

The next row in the result set

Annotations

@Override

Exceptions

StandardException:: Standard error policy

getOldStyleBulkInsertValue

back to summary

private void getOldStyleBulkInsertValue(int index, long increment) throws StandardException

Identity generation logic for bulk-insert used in pre-10.11 databases.

Parameters

index:int: 0-based index into aiCache

getOldStyleIdentityValue

back to summary

private NumberDataValue getOldStyleIdentityValue(int index) throws StandardException

Identity generation logic used in pre-10.11 databases.

Parameters

index:int: 0-based index into aiCache

getSetAutoincrementValue

back to summary

public NumberDataValue getSetAutoincrementValue(int columnPosition, long increment) throws StandardException

Overrides org.apache.derby.impl.sql.execute.DMLWriteGeneratedColumnsResultSet.getSetAutoincrementValue.

getSetAutoincrementValue will get the autoincrement value of the columnPosition specified for the target table. If increment is non-zero we will also update the autoincrement value.

Parameters

columnPosition:int: position of the column in the table (1-based)
increment:long: amount of increment.

Exceptions

StandardException:: if anything goes wrong.

getTableScanResultSet	back to summary
private BulkTableScanResultSet getTableScanResultSet(long conglomId) throws StandardException Get me a table scan result set, preferably a bulk table scan, thank you. If we already have one, reopen it.

initializeAIcache	back to summary
protected void initializeAIcache(RowLocation[] rla) throws StandardException

isSingleRowResultSet	back to summary
private boolean isSingleRowResultSet()

isSourceRowResultSet	back to summary
private boolean isSourceRowResultSet()

makeIndexTemplate	back to summary
private ExecRow makeIndexTemplate(FKInfo fkInfo, ExecRow fullTemplate, ContextManager cm) throws StandardException Make a template row with the correct columns.

normalInsertCore	back to summary
private void normalInsertCore(LanguageConnectionContext lcc, boolean firstExecute) throws StandardException

offendingRowLocation	back to summary
public void offendingRowLocation(RowLocation rl, long constainerId) throws StandardException Implements org.apache.derby.iapi.sql.execute.TargetResultSet.offendingRowLocation.

open

back to summary

public void open() throws StandardException

Implements org.apache.derby.iapi.sql.ResultSet.open.

Doc from org.apache.derby.iapi.sql.ResultSet.open.

Needs to be called before the result set will do anything. Need to call before getNextRow(), or for a result set that doesn't return rows, this is the call that will cause all the work to be done.

Exceptions

StandardException:: Standard Derby error policy

preprocessSourceRow

back to summary

public ExecRow preprocessSourceRow(ExecRow execRow) throws StandardException

Implements org.apache.derby.iapi.sql.execute.TargetResultSet.preprocessSourceRow.

Preprocess the source row. Apply any check constraints here. Do an inplace cloning of all key columns. For triggers, if we have a before row trigger, we fire it here if we can. This is useful for bulk insert where the store stands between the source and us.

Parameters

execRow:ExecRow: The source row.

Returns:ExecRow

The preprocessed source row.

Exceptions

StandardException:: thrown on error

processMergeRow	back to summary
private ExecRow processMergeRow(NoPutResultSet sourceRS, ExecRow row) throws StandardException Special handling if this is an INSERT action of a MERGE statement.

rememberConstraint

back to summary

public void rememberConstraint(UUID cid) throws StandardException

Overrides org.apache.derby.impl.sql.execute.DMLWriteResultSet.rememberConstraint.

Annotations

@Override

setEstimatedRowCount

back to summary

private void setEstimatedRowCount(long heapConglom) throws StandardException

Set the estimated row count for this table.

Parameters

heapConglom:long: Conglomerate number for the heap

Exceptions

StandardException:: Thrown on failure

setUpAllSorts

back to summary

private void setUpAllSorts(ExecRow sourceRow, RowLocation rl) throws StandardException

Set up to update all of the indexes on a table when doing a bulk insert on an empty table.

Exceptions

StandardException:: thrown on error

updateAllIndexes

back to summary

private void updateAllIndexes(long newHeapConglom, InsertConstantAction constants, TableDescriptor td, DataDictionary dd, ExecRow fullTemplate) throws StandardException

Update all of the indexes on a table when doing a bulk insert on an empty table.

Exceptions

StandardException:: thrown on error

verifyBulkInsert

back to summary

protected boolean verifyBulkInsert() throws StandardException

Verify that bulkInsert is allowed on this table. The execution time check to see if bulkInsert is allowed simply consists of checking to see if this is not a deferred mode insert and that the table is empty if this is not replace. A side effect of calling this method is to get an exclusive table lock on the table.

Returns:boolean

Whether or not bulkInsert is allowed on this table.

Exceptions

StandardException:: Thrown on error

pack-priv Class InsertResultSet

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail