Package org.h2.command.dml
Class Insert
- java.lang.Object
-
- org.h2.command.Prepared
-
- org.h2.command.dml.DataChangeStatement
-
- org.h2.command.dml.CommandWithValues
-
- org.h2.command.dml.Insert
-
- All Implemented Interfaces:
ResultTarget
public final class Insert extends CommandWithValues implements ResultTarget
This class represents the statement INSERT
-
-
Field Summary
Fields Modifier and Type Field Description private Column[]
columns
private DataChangeDeltaTable.ResultOption
deltaChangeCollectionMode
private ResultTarget
deltaChangeCollector
private java.util.HashMap<Column,Expression>
duplicateKeyAssignmentMap
For MySQL-style INSERT ...private boolean
ignore
For MySQL-style INSERT IGNORE and PostgreSQL-style ON CONFLICT DO NOTHING.private boolean
insertFromSelect
private Value[]
onDuplicateKeyRow
private java.lang.Boolean
overridingSystem
private Query
query
private long
rowNumber
private Table
table
-
Fields inherited from class org.h2.command.dml.CommandWithValues
valuesExpressionList
-
Fields inherited from class org.h2.command.Prepared
create, parameters, prepareAlways, session, sqlStatement, sqlTokens
-
-
Constructor Summary
Constructors Constructor Description Insert(SessionLocal session)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addAssignmentForDuplicate(Column column, Expression expression)
Keep a collection of the columns to pass to update if a duplicate key happens, for MySQL-style INSERT ...void
addRow(Value... values)
Add the row to the result set.void
collectDependencies(java.util.HashSet<DbObject> dependencies)
Find and collect all DbObjects, this Prepared depends on.Value
getOnDuplicateKeyValue(int columnIndex)
Get the value to use for the specified column in case of a duplicate key.java.lang.String
getPlanSQL(int sqlFlags)
Get the SQL statement with the execution plan.long
getRowCount()
Get the number of rows.java.lang.String
getStatementName()
Return the name of this statement.Table
getTable()
Return the target table.int
getType()
Get the command type as defined in CommandInterfaceprivate boolean
handleOnDuplicate(DbException de, Value[] currentRow)
private long
insertRows()
boolean
isCacheable()
void
limitsWereApplied()
A hint that sorting, offset and limit may be ignored by this result because they were applied during the query.void
prepare()
Prepare this statement.private Expression
prepareUpdateCondition(Index foundIndex, Expression[] row)
void
setColumns(Column[] columns)
void
setCommand(Command command)
Set the command.void
setIgnore(boolean ignore)
Sets MySQL-style INSERT IGNORE mode or PostgreSQL-style ON CONFLICT DO NOTHING.void
setInsertFromSelect(boolean value)
void
setOverridingSystem(java.lang.Boolean overridingSystem)
void
setQuery(Query query)
void
setTable(Table table)
long
update(ResultTarget deltaChangeCollector, DataChangeDeltaTable.ResultOption deltaChangeCollectionMode)
Execute the statement with specified delta change collector and collection mode.-
Methods inherited from class org.h2.command.dml.CommandWithValues
addRow
-
Methods inherited from class org.h2.command.dml.DataChangeStatement
isTransactional, queryMeta, update
-
Methods inherited from class org.h2.command.Prepared
checkCanceled, checkParameters, getCteCleanups, getCurrentRowNumber, getObjectId, getParameters, getPersistedObjectId, getSession, getSimpleSQL, getSQL, getSQLTokens, isQuery, isReadOnly, needRecompile, query, setCteCleanups, setCurrentRowNumber, setParameterList, setPersistedObjectId, setPrepareAlways, setRow, setSession, setSQL, toString
-
-
-
-
Field Detail
-
table
private Table table
-
columns
private Column[] columns
-
query
private Query query
-
rowNumber
private long rowNumber
-
insertFromSelect
private boolean insertFromSelect
-
overridingSystem
private java.lang.Boolean overridingSystem
-
duplicateKeyAssignmentMap
private java.util.HashMap<Column,Expression> duplicateKeyAssignmentMap
For MySQL-style INSERT ... ON DUPLICATE KEY UPDATE ....
-
onDuplicateKeyRow
private Value[] onDuplicateKeyRow
-
ignore
private boolean ignore
For MySQL-style INSERT IGNORE and PostgreSQL-style ON CONFLICT DO NOTHING.
-
deltaChangeCollector
private ResultTarget deltaChangeCollector
-
deltaChangeCollectionMode
private DataChangeDeltaTable.ResultOption deltaChangeCollectionMode
-
-
Constructor Detail
-
Insert
public Insert(SessionLocal session)
-
-
Method Detail
-
setCommand
public void setCommand(Command command)
Description copied from class:Prepared
Set the command.- Overrides:
setCommand
in classPrepared
- Parameters:
command
- the new command
-
getTable
public Table getTable()
Description copied from class:DataChangeStatement
Return the target table.- Specified by:
getTable
in classDataChangeStatement
- Returns:
- the target table
-
setTable
public void setTable(Table table)
-
setColumns
public void setColumns(Column[] columns)
-
setIgnore
public void setIgnore(boolean ignore)
Sets MySQL-style INSERT IGNORE mode or PostgreSQL-style ON CONFLICT DO NOTHING.- Parameters:
ignore
- ignore duplicates
-
setQuery
public void setQuery(Query query)
-
setOverridingSystem
public void setOverridingSystem(java.lang.Boolean overridingSystem)
-
addAssignmentForDuplicate
public void addAssignmentForDuplicate(Column column, Expression expression)
Keep a collection of the columns to pass to update if a duplicate key happens, for MySQL-style INSERT ... ON DUPLICATE KEY UPDATE ....- Parameters:
column
- the columnexpression
- the expression
-
update
public long update(ResultTarget deltaChangeCollector, DataChangeDeltaTable.ResultOption deltaChangeCollectionMode)
Description copied from class:DataChangeStatement
Execute the statement with specified delta change collector and collection mode.- Specified by:
update
in classDataChangeStatement
- Parameters:
deltaChangeCollector
- target resultdeltaChangeCollectionMode
- collection mode- Returns:
- the update count
-
insertRows
private long insertRows()
-
addRow
public void addRow(Value... values)
Description copied from interface:ResultTarget
Add the row to the result set.- Specified by:
addRow
in interfaceResultTarget
- Parameters:
values
- the values
-
getRowCount
public long getRowCount()
Description copied from interface:ResultTarget
Get the number of rows.- Specified by:
getRowCount
in interfaceResultTarget
- Returns:
- the number of rows
-
limitsWereApplied
public void limitsWereApplied()
Description copied from interface:ResultTarget
A hint that sorting, offset and limit may be ignored by this result because they were applied during the query. This is useful for WITH TIES clause because result may contain tied rows above limit.- Specified by:
limitsWereApplied
in interfaceResultTarget
-
getPlanSQL
public java.lang.String getPlanSQL(int sqlFlags)
Description copied from class:Prepared
Get the SQL statement with the execution plan.- Overrides:
getPlanSQL
in classPrepared
- Parameters:
sqlFlags
- formatting flags- Returns:
- the execution plan
-
prepare
public void prepare()
Description copied from class:Prepared
Prepare this statement.
-
getType
public int getType()
Description copied from class:Prepared
Get the command type as defined in CommandInterface
-
getStatementName
public java.lang.String getStatementName()
Description copied from class:DataChangeStatement
Return the name of this statement.- Specified by:
getStatementName
in classDataChangeStatement
- Returns:
- the short name of this statement.
-
setInsertFromSelect
public void setInsertFromSelect(boolean value)
-
isCacheable
public boolean isCacheable()
- Overrides:
isCacheable
in classDataChangeStatement
-
handleOnDuplicate
private boolean handleOnDuplicate(DbException de, Value[] currentRow)
- Parameters:
de
- duplicate key exceptioncurrentRow
- current row values (optional)- Returns:
true
if row was updated,false
if row was ignored
-
prepareUpdateCondition
private Expression prepareUpdateCondition(Index foundIndex, Expression[] row)
-
getOnDuplicateKeyValue
public Value getOnDuplicateKeyValue(int columnIndex)
Get the value to use for the specified column in case of a duplicate key.- Parameters:
columnIndex
- the column index- Returns:
- the value
-
collectDependencies
public void collectDependencies(java.util.HashSet<DbObject> dependencies)
Description copied from class:Prepared
Find and collect all DbObjects, this Prepared depends on.- Overrides:
collectDependencies
in classPrepared
- Parameters:
dependencies
- collection of dependencies to populate
-
-