org.apache.ignite.internal.processors.query.h2.dml

Class UpdatePlan

java.lang.Object

org.apache.ignite.internal.processors.query.h2.dml.UpdatePlan

public final class UpdatePlan
extends Object

Update plan - where to take data to update cache from and how to construct new keys and values, if needed.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	UpdatePlan.DistributedPlanInfo Additional information about distributed update plan.

Field Summary

Fields

Modifier and Type	Field and Description
String[]	colNames Column names to set or update.
int[]	colTypes Expected column types to set or insert/merge.
UpdatePlan.DistributedPlanInfo	distributed Additional info for distributed update.
FastUpdateArguments	fastUpdateArgs Arguments for fast UPDATE or DELETE.
boolean	isLocSubqry Subquery flag - true if selectQry is an actual subquery that retrieves data from some cache.
int	keyColIdx Index of key column, if it's explicitly mentioned in column list of MERGE or INSERT, ignored for UPDATE and DELETE.
KeyValueSupplier	keySupplier Method to create key for INSERT or MERGE, ignored for UPDATE and DELETE.
UpdateMode	mode Initial statement to drive the rest of the logic.
int	rowsNum Number of rows in rows based MERGE or INSERT.
String	selectQry SELECT statement built upon initial DML statement.
GridH2Table	tbl Target table to be affected by initial DML statement.
int	valColIdx Index of value column, if it's explicitly mentioned in column list.
KeyValueSupplier	valSupplier Method to create value to put to cache, ignored for DELETE.

Method Summary

Methods

Modifier and Type	Method and Description
static UpdatePlan	forDelete(GridH2Table tbl, String selectQry, UpdatePlan.DistributedPlanInfo distributed)
static UpdatePlan	forFastUpdate(UpdateMode mode, GridH2Table tbl, FastUpdateArguments fastUpdateArgs)
static UpdatePlan	forInsert(GridH2Table tbl, String[] colNames, int[] colTypes, KeyValueSupplier keySupplier, KeyValueSupplier valSupplier, int keyColIdx, int valColIdx, String selectQry, boolean isLocSubqry, int rowsNum, UpdatePlan.DistributedPlanInfo distributed)
static UpdatePlan	forMerge(GridH2Table tbl, String[] colNames, int[] colTypes, KeyValueSupplier keySupplier, KeyValueSupplier valSupplier, int keyColIdx, int valColIdx, String selectQry, boolean isLocSubqry, int rowsNum, UpdatePlan.DistributedPlanInfo distributed)
static UpdatePlan	forUpdate(GridH2Table tbl, String[] colNames, int[] colTypes, KeyValueSupplier valSupplier, int valColIdx, String selectQry, UpdatePlan.DistributedPlanInfo distributed)

Methods inherited from class java.lang.Object

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

Field Detail

mode

public final UpdateMode mode

Initial statement to drive the rest of the logic.

tbl

public final GridH2Table tbl

Target table to be affected by initial DML statement.

colNames

public final String[] colNames

Column names to set or update.

colTypes

public final int[] colTypes

Expected column types to set or insert/merge.

See Also:

Value

keySupplier

public final KeyValueSupplier keySupplier

Method to create key for INSERT or MERGE, ignored for UPDATE and DELETE.

valSupplier

public final KeyValueSupplier valSupplier

Method to create value to put to cache, ignored for DELETE.

keyColIdx

public final int keyColIdx

Index of key column, if it's explicitly mentioned in column list of MERGE or INSERT, ignored for UPDATE and DELETE.

valColIdx

public final int valColIdx

Index of value column, if it's explicitly mentioned in column list. Ignored for UPDATE and DELETE.

selectQry

public final String selectQry

SELECT statement built upon initial DML statement.

isLocSubqry

public final boolean isLocSubqry

Subquery flag - true if selectQry is an actual subquery that retrieves data from some cache.

rowsNum

public final int rowsNum

Number of rows in rows based MERGE or INSERT.

fastUpdateArgs

public final FastUpdateArguments fastUpdateArgs

Arguments for fast UPDATE or DELETE.

distributed

public final UpdatePlan.DistributedPlanInfo distributed

Additional info for distributed update.

Method Detail

forMerge

public static UpdatePlan forMerge(GridH2Table tbl,
                  String[] colNames,
                  int[] colTypes,
                  KeyValueSupplier keySupplier,
                  KeyValueSupplier valSupplier,
                  int keyColIdx,
                  int valColIdx,
                  String selectQry,
                  boolean isLocSubqry,
                  int rowsNum,
                  UpdatePlan.DistributedPlanInfo distributed)

forInsert

public static UpdatePlan forInsert(GridH2Table tbl,
                   String[] colNames,
                   int[] colTypes,
                   KeyValueSupplier keySupplier,
                   KeyValueSupplier valSupplier,
                   int keyColIdx,
                   int valColIdx,
                   String selectQry,
                   boolean isLocSubqry,
                   int rowsNum,
                   UpdatePlan.DistributedPlanInfo distributed)

forUpdate

public static UpdatePlan forUpdate(GridH2Table tbl,
                   String[] colNames,
                   int[] colTypes,
                   KeyValueSupplier valSupplier,
                   int valColIdx,
                   String selectQry,
                   UpdatePlan.DistributedPlanInfo distributed)

forDelete

public static UpdatePlan forDelete(GridH2Table tbl,
                   String selectQry,
                   UpdatePlan.DistributedPlanInfo distributed)

forFastUpdate

public static UpdatePlan forFastUpdate(UpdateMode mode,
                       GridH2Table tbl,
                       FastUpdateArguments fastUpdateArgs)