com.orientechnologies.orient.core.sql.parser

Class OExecutionPlanCache

java.lang.Object

com.orientechnologies.orient.core.sql.parser.OExecutionPlanCache

All Implemented Interfaces:

OMetadataUpdateListener

public class OExecutionPlanCache
extends Object
implements OMetadataUpdateListener

This class is an LRU cache for already prepared SQL execution plans. It stores itself in the storage as a resource. It also acts an an entry point for the SQL executor.

Author:

Luigi Dell'Aquila (l.dellaquila-(at)-orientdb.com)

Field Summary

Fields

Modifier and Type	Field and Description
protected long	lastInvalidation

Constructor Summary

Constructors

Constructor and Description
OExecutionPlanCache(int size)

Method Summary

Modifier and Type	Method and Description
boolean	contains(String statement)
static OExecutionPlan	get(String statement, OCommandContext ctx, ODatabaseDocumentInternal db) returns an already prepared SQL execution plan, taking it from the cache if it exists or creating a new one if it doesn't
OExecutionPlan	getInternal(String statement, OCommandContext ctx, ODatabaseDocumentInternal db)
static long	getLastInvalidation(ODatabaseDocumentInternal db)
static OExecutionPlanCache	instance(ODatabaseDocumentTx db)
void	invalidate()
void	onFunctionLibraryUpdate(String database)
void	onIndexManagerUpdate(String database, OIndexManagerAbstract indexManager)
void	onSchemaUpdate(String database, OSchemaShared schema)
void	onSequenceLibraryUpdate(String database)
void	onStorageConfigurationUpdate(String database, OStorageConfiguration update)
static void	put(String statement, OExecutionPlan plan, ODatabaseDocumentInternal db)
void	putInternal(String statement, OExecutionPlan plan, ODatabaseDocument db)

Methods inherited from class java.lang.Object

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

Field Detail

lastInvalidation

protected long lastInvalidation

Constructor Detail

OExecutionPlanCache

public OExecutionPlanCache(int size)

Parameters:

size - the size of the cache

Method Detail

getLastInvalidation

public static long getLastInvalidation(ODatabaseDocumentInternal db)

contains

public boolean contains(String statement)

Parameters:

statement - an SQL statement

Returns:

true if the corresponding executor is present in the cache

get

public static OExecutionPlan get(String statement,
                                 OCommandContext ctx,
                                 ODatabaseDocumentInternal db)

returns an already prepared SQL execution plan, taking it from the cache if it exists or creating a new one if it doesn't

Parameters:

statement - the SQL statement

ctx -

db - the current DB instance

Returns:

a statement executor from the cache

put

public static void put(String statement,
                       OExecutionPlan plan,
                       ODatabaseDocumentInternal db)

putInternal

public void putInternal(String statement,
                        OExecutionPlan plan,
                        ODatabaseDocument db)

getInternal

public OExecutionPlan getInternal(String statement,
                                  OCommandContext ctx,
                                  ODatabaseDocumentInternal db)

Parameters:

statement - an SQL statement

ctx -

Returns:

the corresponding executor, taking it from the internal cache, if it exists

invalidate

public void invalidate()

onSchemaUpdate

public void onSchemaUpdate(String database,
                           OSchemaShared schema)

Specified by:

onSchemaUpdate in interface OMetadataUpdateListener

onIndexManagerUpdate

public void onIndexManagerUpdate(String database,
                                 OIndexManagerAbstract indexManager)

Specified by:

onIndexManagerUpdate in interface OMetadataUpdateListener

onFunctionLibraryUpdate

public void onFunctionLibraryUpdate(String database)

Specified by:

onFunctionLibraryUpdate in interface OMetadataUpdateListener

onSequenceLibraryUpdate

public void onSequenceLibraryUpdate(String database)

Specified by:

onSequenceLibraryUpdate in interface OMetadataUpdateListener

onStorageConfigurationUpdate

public void onStorageConfigurationUpdate(String database,
                                         OStorageConfiguration update)

Specified by:

onStorageConfigurationUpdate in interface OMetadataUpdateListener

instance

public static OExecutionPlanCache instance(ODatabaseDocumentTx db)