Top Description Inners Fields Constructors Methods
org.h2.mvstore.db

public Class MVPrimaryIndex

extends MVIndex<Long, SearchRow>
Class Inheritance
Imports
java.math.BigDecimal, java.util.List, .Map.Entry, java.util.concurrent.atomic.AtomicLong, org.h2.api.ErrorCode, org.h2.command.query.AllColumnsForPlan, org.h2.engine.Database, .SessionLocal, org.h2.index.Cursor, .IndexType, .SingleRowCursor, org.h2.message.DbException, org.h2.mvstore.MVMap, .MVStoreException, org.h2.mvstore.tx.Transaction, .TransactionMap, .TransactionMap.TMIterator, org.h2.mvstore.type.LongDataType, org.h2.result.Row, .SearchRow, .SortOrder, org.h2.table.Column, .IndexColumn, .TableFilter, org.h2.value.Value, .ValueDecfloat, .ValueLob, .VersionedValue
A table stored in a MVStore.

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
MVPrimaryIndex.MVStoreCursor

A cursor.

Field Summary

Modifier and TypeField and Description
private final TransactionMap<Long, SearchRow>
dataMap

private final AtomicLong
lastKey

private int
mainIndexColumn

private final String
mapName

private final MVTable
mvTable

Constructor Summary

AccessConstructor and Description
public
MVPrimaryIndex(Database db, MVTable table, int id, IndexColumn[] columns, IndexType indexType)

Method Summary

Modifier and TypeMethod and Description
public void
add(SessionLocal
the session to use
session, Row
the row to add
row)

Implements abstract org.h2.index.Index.add.

Add a row to the index.

public void
addBufferedRows(List<String>
the names of the temporary storage
bufferNames)

Implements abstract org.h2.mvstore.db.MVIndex.addBufferedRows.

Add all the index data from the buffers to the index.

public void
addRowsToBuffer(List<Row>
the rows
rows, String
the name of the temporary storage
bufferName)

Implements abstract org.h2.mvstore.db.MVIndex.addRowsToBuffer.

Add the rows to a temporary storage (not to the index yet).

public boolean
canGetFirstOrLast()

Overrides org.h2.index.Index.canGetFirstOrLast.

Check if the index can directly look up the lowest or highest value of a column.

public void
close(SessionLocal
the session used to write data
session)

Implements abstract org.h2.index.Index.close.

Close this index.

public Cursor
find(SessionLocal
the session
session, SearchRow
the first row, or null for no limit
first, SearchRow
the last row, or null for no limit
last, boolean
if true, iterate in reverse (descending) order
reverse)

Implements abstract org.h2.index.Index.find.

Find a row or a list of rows and create a cursor to iterate over the result.

public Cursor
findFirstOrLast(SessionLocal
the session
session, boolean
true if the first (lowest for ascending indexes) or last value should be returned
first)

Overrides org.h2.index.Index.findFirstOrLast.

Find the first (or last) value of this index.

public int
getColumnIndex(Column
the column
col)

Overrides org.h2.index.Index.getColumnIndex.

Get the index of a column in the list of index columns

public double
getCost(SessionLocal
the session
session, int[]
per-column comparison bit masks, null means 'always false', see constants in IndexCondition
masks, TableFilter[]
all joined table filters
filters, int
the current table filter index
filter, SortOrder
the sort order
sortOrder, AllColumnsForPlan
the set of all columns
allColumnsSet)

Implements abstract org.h2.index.Index.getCost.

Estimate the cost to search for rows given the search mask.

public String
getCreateSQL()

Overrides org.h2.index.Index.getCreateSQL.

Construct the CREATE ...

public int
getMainIndexColumn()

pack-priv TransactionMap<Long, SearchRow>

Returns:

the map
getMap(SessionLocal
the session
session)

Get the map to store the data.

public String
getMapName()

public MVMap<Long, VersionedValue<SearchRow>>
getMVMap()

Implements abstract org.h2.mvstore.db.MVIndex.getMVMap.

public String
getPlanSQL()

Overrides org.h2.index.Index.getPlanSQL.

Get the message to show in a EXPLAIN statement.

public Row
getRow(SessionLocal
the session
session, long
the unique key
key)

Overrides org.h2.index.Index.getRow.

Get the row with the given key.

public long
getRowCount(SessionLocal
the session
session)

Implements abstract org.h2.index.Index.getRowCount.

Get the row count of this table, for the given session.

public long
getRowCountApproximation(SessionLocal
the session
session)

Implements abstract org.h2.index.Index.getRowCountApproximation.

Get the approximated row count for this table.

public long

Returns:

the maximum number of rows
getRowCountMax()

The maximum number of rows, including uncommitted rows of any session.

public MVTable
getTable()

Overrides org.h2.index.Index.getTable.

Get the table on which this index is based.

public boolean
isFirstColumn(Column
the column
column)

Overrides org.h2.index.Index.isFirstColumn.

Check if the given column is the first for this index

public boolean
isRowIdIndex()

Overrides org.h2.index.Index.isRowIdIndex.

Does this index support lookup by row id?

pack-priv Row

Returns:

row object if it exists
lockRow(SessionLocal
database session
session, Row
to lock
row, int
timeout in milliseconds, -1 for default, -2 to skip locking if row is already locked by another session
timeoutMillis)

Lock a single row.

private Row
lockRow(TransactionMap<Long, SearchRow> map, long key, int timeoutMillis)

public boolean
needRebuild()

Implements abstract org.h2.index.Index.needRebuild.

Check if the index needs to be rebuilt.

public void
remove(SessionLocal
the session
session, Row
the row
row)

Implements abstract org.h2.index.Index.remove.

Remove a row from the index.

public void
remove(SessionLocal
the session
session)

Implements abstract org.h2.index.Index.remove.

Remove the index.

public void
setMainIndexColumn(int mainIndexColumn)

private static Row
setRowKey(Row row, long key)

public void
truncate(SessionLocal
the session
session)

Implements abstract org.h2.index.Index.truncate.

Remove all rows from the index.

public void
update(SessionLocal
the session
session, Row
row before the update
oldRow, Row
row after the update
newRow)

Overrides org.h2.index.Index.update.

Update index after row change.

Inherited from org.h2.mvstore.db.MVIndex:
getDiskSpaceUsed

Field Detail

dataMapback to summary
private final TransactionMap<Long, SearchRow> dataMap
lastKeyback to summary
private final AtomicLong lastKey
mainIndexColumnback to summary
private int mainIndexColumn
mapNameback to summary
private final String mapName
mvTableback to summary
private final MVTable mvTable

Constructor Detail

MVPrimaryIndexback to summary
public MVPrimaryIndex(Database db, MVTable table, int id, IndexColumn[] columns, IndexType indexType)

Method Detail

addback to summary
public void add(SessionLocal session, Row row)

Implements abstract org.h2.index.Index.add.

Doc from org.h2.index.Index.add.

Add a row to the index.

Parameters
session:SessionLocal

the session to use

row:Row

the row to add

Annotations
@Override
addBufferedRowsback to summary
public void addBufferedRows(List<String> bufferNames)

Implements abstract org.h2.mvstore.db.MVIndex.addBufferedRows.

Doc from org.h2.mvstore.db.MVIndex.addBufferedRows.

Add all the index data from the buffers to the index. The index will typically use merge sort to add the data more quickly in sorted order.

Parameters
bufferNames:List<String>

the names of the temporary storage

Annotations
@Override
addRowsToBufferback to summary
public void addRowsToBuffer(List<Row> rows, String bufferName)

Implements abstract org.h2.mvstore.db.MVIndex.addRowsToBuffer.

Doc from org.h2.mvstore.db.MVIndex.addRowsToBuffer.

Add the rows to a temporary storage (not to the index yet). The rows are sorted by the index columns. This is to more quickly build the index.

Parameters
rows:List<Row>

the rows

bufferName:String

the name of the temporary storage

Annotations
@Override
canGetFirstOrLastback to summary
public boolean canGetFirstOrLast()

Overrides org.h2.index.Index.canGetFirstOrLast.

Doc from org.h2.index.Index.canGetFirstOrLast.

Check if the index can directly look up the lowest or highest value of a column.

Returns:boolean

true if it can

Annotations
@Override
closeback to summary
public void close(SessionLocal session)

Implements abstract org.h2.index.Index.close.

Doc from org.h2.index.Index.close.

Close this index.

Parameters
session:SessionLocal

the session used to write data

Annotations
@Override
findback to summary
public Cursor find(SessionLocal session, SearchRow first, SearchRow last, boolean reverse)

Implements abstract org.h2.index.Index.find.

Doc from org.h2.index.Index.find.

Find a row or a list of rows and create a cursor to iterate over the result.

Parameters
session:SessionLocal

the session

first:SearchRow

the first row, or null for no limit

last:SearchRow

the last row, or null for no limit

reverse:boolean

if true, iterate in reverse (descending) order

Returns:Cursor

the cursor to iterate over the results

Annotations
@Override
findFirstOrLastback to summary
public Cursor findFirstOrLast(SessionLocal session, boolean first)

Overrides org.h2.index.Index.findFirstOrLast.

Doc from org.h2.index.Index.findFirstOrLast.

Find the first (or last) value of this index. The cursor returned is positioned on the correct row, or on null if no row has been found.

Parameters
session:SessionLocal

the session

first:boolean

true if the first (lowest for ascending indexes) or last value should be returned

Returns:Cursor

a cursor (never null)

Annotations
@Override
getColumnIndexback to summary
public int getColumnIndex(Column col)

Overrides org.h2.index.Index.getColumnIndex.

Doc from org.h2.index.Index.getColumnIndex.

Get the index of a column in the list of index columns

Parameters
col:Column

the column

Returns:int

the index (0 meaning first column)

Annotations
@Override
getCostback to summary
public double getCost(SessionLocal session, int[] masks, TableFilter[] filters, int filter, SortOrder sortOrder, AllColumnsForPlan allColumnsSet)

Implements abstract org.h2.index.Index.getCost.

Doc from org.h2.index.Index.getCost.

Estimate the cost to search for rows given the search mask. There is one element per column in the search mask. For possible search masks, see IndexCondition.

Parameters
session:SessionLocal

the session

masks:int[]

per-column comparison bit masks, null means 'always false', see constants in IndexCondition

filters:TableFilter[]

all joined table filters

filter:int

the current table filter index

sortOrder:SortOrder

the sort order

allColumnsSet:AllColumnsForPlan

the set of all columns

Returns:double

the estimated cost

Annotations
@Override
getCreateSQLback to summary
public String getCreateSQL()

Overrides org.h2.index.Index.getCreateSQL.

Doc from org.h2.engine.DbObject.getCreateSQL.

Construct the CREATE ... SQL statement for this object.

Returns:String

the SQL statement

Annotations
@Override
getMainIndexColumnback to summary
public int getMainIndexColumn()
getMapback to summary
pack-priv TransactionMap<Long, SearchRow> getMap(SessionLocal session)

Get the map to store the data.

Parameters
session:SessionLocal

the session

Returns:TransactionMap<Long, SearchRow>

the map

getMapNameback to summary
public String getMapName()
getMVMapback to summary
public MVMap<Long, VersionedValue<SearchRow>> getMVMap()

Implements abstract org.h2.mvstore.db.MVIndex.getMVMap.

Annotations
@Override
getPlanSQLback to summary
public String getPlanSQL()

Overrides org.h2.index.Index.getPlanSQL.

Doc from org.h2.index.Index.getPlanSQL.

Get the message to show in a EXPLAIN statement.

Returns:String

the plan

Annotations
@Override
getRowback to summary
public Row getRow(SessionLocal session, long key)

Overrides org.h2.index.Index.getRow.

Doc from org.h2.index.Index.getRow.

Get the row with the given key.

Parameters
session:SessionLocal

the session

key:long

the unique key

Returns:Row

the row

Annotations
@Override
getRowCountback to summary
public long getRowCount(SessionLocal session)

Implements abstract org.h2.index.Index.getRowCount.

Doc from org.h2.index.Index.getRowCount.

Get the row count of this table, for the given session.

Parameters
session:SessionLocal

the session

Returns:long

the row count

Annotations
@Override
getRowCountApproximationback to summary
public long getRowCountApproximation(SessionLocal session)

Implements abstract org.h2.index.Index.getRowCountApproximation.

Doc from org.h2.index.Index.getRowCountApproximation.

Get the approximated row count for this table.

Parameters
session:SessionLocal

the session

Returns:long

the approximated row count

Annotations
@Override
getRowCountMaxback to summary
public long getRowCountMax()

The maximum number of rows, including uncommitted rows of any session.

Returns:long

the maximum number of rows

getTableback to summary
public MVTable getTable()

Overrides org.h2.index.Index.getTable.

Doc from org.h2.index.Index.getTable.

Get the table on which this index is based.

Returns:MVTable

the table

Annotations
@Override
isFirstColumnback to summary
public boolean isFirstColumn(Column column)

Overrides org.h2.index.Index.isFirstColumn.

Doc from org.h2.index.Index.isFirstColumn.

Check if the given column is the first for this index

Parameters
column:Column

the column

Returns:boolean

true if the given columns is the first

Annotations
@Override
isRowIdIndexback to summary
public boolean isRowIdIndex()

Overrides org.h2.index.Index.isRowIdIndex.

Doc from org.h2.index.Index.isRowIdIndex.

Does this index support lookup by row id?

Returns:boolean

true if it does

Annotations
@Override
lockRowback to summary
pack-priv Row lockRow(SessionLocal session, Row row, int timeoutMillis)

Lock a single row.

Parameters
session:SessionLocal

database session

row:Row

to lock

timeoutMillis:int

timeout in milliseconds, -1 for default, -2 to skip locking if row is already locked by another session

Returns:Row

row object if it exists

lockRowback to summary
private Row lockRow(TransactionMap<Long, SearchRow> map, long key, int timeoutMillis)
needRebuildback to summary
public boolean needRebuild()

Implements abstract org.h2.index.Index.needRebuild.

Doc from org.h2.index.Index.needRebuild.

Check if the index needs to be rebuilt. This method is called after opening an index.

Returns:boolean

true if a rebuild is required.

Annotations
@Override
removeback to summary
public void remove(SessionLocal session, Row row)

Implements abstract org.h2.index.Index.remove.

Doc from org.h2.index.Index.remove.

Remove a row from the index.

Parameters
session:SessionLocal

the session

row:Row

the row

Annotations
@Override
removeback to summary
public void remove(SessionLocal session)

Implements abstract org.h2.index.Index.remove.

Doc from org.h2.index.Index.remove.

Remove the index.

Parameters
session:SessionLocal

the session

Annotations
@Override
setMainIndexColumnback to summary
public void setMainIndexColumn(int mainIndexColumn)
setRowKeyback to summary
private static Row setRowKey(Row row, long key)
truncateback to summary
public void truncate(SessionLocal session)

Implements abstract org.h2.index.Index.truncate.

Doc from org.h2.index.Index.truncate.

Remove all rows from the index.

Parameters
session:SessionLocal

the session

Annotations
@Override
updateback to summary
public void update(SessionLocal session, Row oldRow, Row newRow)

Overrides org.h2.index.Index.update.

Doc from org.h2.index.Index.update.

Update index after row change.

Parameters
session:SessionLocal

the session

oldRow:Row

row before the update

newRow:Row

row after the update

Annotations
@Override
org.h2.mvstore.db back to summary

pack-priv final Class MVPrimaryIndex.MVStoreCursor

extends Object
implements Cursor
Class Inheritance
All Implemented Interfaces
org.h2.index.Cursor
A cursor.

Field Summary

Modifier and TypeField and Description
private Map.Entry<Long, SearchRow>
current

private final TransactionMap.TMIterator<Long, SearchRow, Map.Entry<Long, SearchRow>>
it

private Row
row

Constructor Summary

AccessConstructor and Description
public
MVStoreCursor(TransactionMap.TMIterator<Long, SearchRow, Map.Entry<Long, SearchRow>> it)

Method Summary

Modifier and TypeMethod and Description
public Row
get()

Implements org.h2.index.Cursor.get.

Get the complete current row.

public SearchRow
getSearchRow()

Implements org.h2.index.Cursor.getSearchRow.

Get the current row.

public boolean
next()

Implements org.h2.index.Cursor.next.

Skip to the next row if one is available.

public boolean
previous()

Implements org.h2.index.Cursor.previous.

Skip to the previous row if one is available.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

currentback to summary
private Map.Entry<Long, SearchRow> current
itback to summary
private final TransactionMap.TMIterator<Long, SearchRow, Map.Entry<Long, SearchRow>> it
rowback to summary
private Row row

Constructor Detail

MVStoreCursorback to summary
public MVStoreCursor(TransactionMap.TMIterator<Long, SearchRow, Map.Entry<Long, SearchRow>> it)

Method Detail

getback to summary
public Row get()

Implements org.h2.index.Cursor.get.

Doc from org.h2.index.Cursor.get.

Get the complete current row. All column are available.

Returns:Row

the complete row

Annotations
@Override
getSearchRowback to summary
public SearchRow getSearchRow()

Implements org.h2.index.Cursor.getSearchRow.

Doc from org.h2.index.Cursor.getSearchRow.

Get the current row. Only the data for indexed columns is available in this row.

Returns:SearchRow

the search row

Annotations
@Override
nextback to summary
public boolean next()

Implements org.h2.index.Cursor.next.

Doc from org.h2.index.Cursor.next.

Skip to the next row if one is available.

Returns:boolean

true if another row is available

Annotations
@Override
previousback to summary
public boolean previous()

Implements org.h2.index.Cursor.previous.

Doc from org.h2.index.Cursor.previous.

Skip to the previous row if one is available. No filtering is made here.

Returns:boolean

true if another row is available

Annotations
@Override