| Modifier and Type | Field and Description |
|---|---|
| private Column[] | |
| private DataChangeDeltaTable. | |
| private ResultTarget | |
| private HashMap | duplicateKeyAssignmentMap
For MySQL-style INSERT ... |
| private boolean | ignore
For MySQL-style INSERT IGNORE and PostgreSQL-style ON CONFLICT DO NOTHING. |
| private boolean | |
| private Value[] | |
| private Boolean | |
| private Query | |
| private long | |
| private Table |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| public void | addAssignmentForDuplicate(Column
the column column, Expression the expression expression)Keep a collection of the columns to pass to update if a duplicate key happens, for MySQL-style INSERT ... |
| public void | addRow(Value...
the values values)Implements org. Add the row to the result set. |
| public void | collectDependencies(HashSet<DbObject>
collection of dependencies to populate dependencies)Overrides org. Find and collect all DbObjects, this Prepared depends on. |
| pack-priv void | |
| public Value | Returns: the valuethe column index columnIndex)Get the value to use for the specified column in case of a duplicate key. |
| public StringBuilder | getPlanSQL(StringBuilder
string builder builder, int formatting flags sqlFlags)Overrides org. Appends the SQL statement with the execution plan. |
| public long | |
| public String | getStatementName()
Implements abstract org. Return the name of this statement. |
| public Table | getTable()
Implements abstract org. Return the target table. |
| public int | getType()
Implements abstract org. Get the command type as defined in CommandInterface |
| private boolean | Returns: true if row was updated, false if row was ignoredduplicate key exception de, Value[] current row values (optional) currentRow)
|
| private long | |
| public boolean | |
| public void | limitsWereApplied()
Implements org. A hint that sorting, offset and limit may be ignored by this result because they were applied during the query. |
| private Expression | |
| public void | |
| public void | setCommand(Command
the new command command)Overrides org. Set the command. |
| public void | setIgnore(boolean
ignore duplicates ignore)Sets MySQL-style INSERT IGNORE mode or PostgreSQL-style ON CONFLICT DO NOTHING. |
| public void | |
| public void | |
| public void | |
| public void | |
| public long | update(ResultTarget
target result deltaChangeCollector, DataChangeDeltaTable.collection mode deltaChangeCollectionModeImplements abstract org. Execute the statement with specified delta change collector and collection mode. |
| columns | back to summary |
|---|---|
| private Column[] columns | |
| deltaChangeCollectionMode | back to summary |
|---|---|
| private DataChangeDeltaTable. | |
| deltaChangeCollector | back to summary |
|---|---|
| private ResultTarget deltaChangeCollector | |
| duplicateKeyAssignmentMap | back to summary |
|---|---|
| private HashMap<Column, Expression> duplicateKeyAssignmentMap For MySQL-style INSERT ... ON DUPLICATE KEY UPDATE .... | |
| ignore | back to summary |
|---|---|
| private boolean ignore For MySQL-style INSERT IGNORE and PostgreSQL-style ON CONFLICT DO NOTHING. | |
| insertFromSelect | back to summary |
|---|---|
| private boolean insertFromSelect | |
| onDuplicateKeyRow | back to summary |
|---|---|
| private Value[] onDuplicateKeyRow | |
| overridingSystem | back to summary |
|---|---|
| private Boolean overridingSystem | |
| query | back to summary |
|---|---|
| private Query query | |
| rowNumber | back to summary |
|---|---|
| private long rowNumber | |
| table | back to summary |
|---|---|
| private Table table | |
| Insert | back to summary |
|---|---|
| public Insert(SessionLocal session) | |
| addAssignmentForDuplicate | back to summary |
|---|---|
| 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 ....
| |
| addRow | back to summary |
|---|---|
| public void addRow(Value... values) Implements org. Doc from org. Add the row to the result set. | |
| collectDependencies | back to summary |
|---|---|
| public void collectDependencies(HashSet<DbObject> dependencies) Overrides org. Doc from org. Find and collect all DbObjects, this Prepared depends on. | |
| doPrepare | back to summary |
|---|---|
| pack-priv void doPrepare() Implements abstract org.
| |
| getOnDuplicateKeyValue | back to summary |
|---|---|
| public Value getOnDuplicateKeyValue(int columnIndex) Get the value to use for the specified column in case of a duplicate key.
| |
| getPlanSQL | back to summary |
|---|---|
| public StringBuilder getPlanSQL(StringBuilder builder, int sqlFlags) Overrides org. Doc from org. Appends the SQL statement with the execution plan.
| |
| getRowCount | back to summary |
|---|---|
| public long getRowCount() Implements org. Doc from org. Get the number of rows.
| |
| getStatementName | back to summary |
|---|---|
| public String getStatementName() Implements abstract org. Doc from org. Return the name of this statement. | |
| getTable | back to summary |
|---|---|
| public Table getTable() Implements abstract org. Doc from org. Return the target table. | |
| getType | back to summary |
|---|---|
| public int getType() Implements abstract org. Doc from org. Get the command type as defined in CommandInterface
| |
| handleOnDuplicate | back to summary |
|---|---|
private boolean handleOnDuplicate(DbException de, Value[] currentRow)
| |
| insertRows | back to summary |
|---|---|
| private long insertRows() | |
| isCacheable | back to summary |
|---|---|
| public boolean isCacheable() Overrides org.
| |
| limitsWereApplied | back to summary |
|---|---|
| public void limitsWereApplied() Implements org. Doc from org. 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.
| |
| prepareUpdateCondition | back to summary |
|---|---|
| private Expression prepareUpdateCondition(Index foundIndex, Expression[] row) | |
| setColumns | back to summary |
|---|---|
| public void setColumns(Column[] columns) | |
| setCommand | back to summary |
|---|---|
| public void setCommand(Command command) Overrides org. Doc from org. Set the command. | |
| setIgnore | back to summary |
|---|---|
| public void setIgnore(boolean ignore) Sets MySQL-style INSERT IGNORE mode or PostgreSQL-style ON CONFLICT DO NOTHING.
| |
| setInsertFromSelect | back to summary |
|---|---|
| public void setInsertFromSelect(boolean value) | |
| setOverridingSystem | back to summary |
|---|---|
| public void setOverridingSystem(Boolean overridingSystem) | |
| setQuery | back to summary |
|---|---|
| public void setQuery(Query query) | |
| setTable | back to summary |
|---|---|
| public void setTable(Table table) | |
| update | back to summary |
|---|---|
| public long update(ResultTarget deltaChangeCollector, DataChangeDeltaTable. Implements abstract org. Doc from org. Execute the statement with specified delta change collector and collection mode.
| |