public class Store
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static interface |
Store.SyncHook
For unit testing.
|
Modifier and Type | Field and Description |
---|---|
static boolean |
expectFlush |
static java.lang.String |
NAME_SEPARATOR |
Constructor and Description |
---|
Store(Environment env,
java.lang.String storeName,
StoreConfig config,
boolean rawAccess) |
Modifier and Type | Method and Description |
---|---|
boolean |
attemptRefresh()
Attempts to refresh metadata and returns whether a refresh occurred.
|
(package private) void |
checkEntitySubclassSecondaries(EntityMetadata entityMeta,
java.lang.String subclassName)
Checks that all secondary indexes defined in the given entity metadata
are already open.
|
void |
close() |
void |
closeClass(java.lang.Class entityClass) |
EvolveStats |
evolve(EvolveConfig config) |
(package private) TransactionConfig |
getAutoCommitTxnConfig() |
StoreConfig |
getConfig() |
(package private) java.lang.String |
getDbNameMessage(java.lang.String[] names)
Creates a message identifying the database from the pair of strings
returned by parseDbName.
|
Environment |
getEnvironment() |
EntityModel |
getModel() |
Mutations |
getMutations() |
DatabaseConfig |
getPrimaryConfig(java.lang.Class entityClass) |
<PK,E> PrimaryIndex<PK,E> |
getPrimaryIndex(java.lang.Class<PK> primaryKeyClass,
java.lang.String primaryKeyClassName,
java.lang.Class<E> entityClass,
java.lang.String entityClassName)
A getPrimaryIndex with extra parameters for opening a raw store.
|
SecondaryConfig |
getSecondaryConfig(java.lang.Class entityClass,
java.lang.String keyName) |
<SK,PK,E1,E2 extends E1> |
getSecondaryIndex(PrimaryIndex<PK,E1> primaryIndex,
java.lang.Class<E2> entityClass,
java.lang.String entityClassName,
java.lang.Class<SK> keyClass,
java.lang.String keyClassName,
java.lang.String keyName)
A getSecondaryIndex with extra parameters for opening a raw store.
|
Sequence |
getSequence(java.lang.String name) |
SequenceConfig |
getSequenceConfig(java.lang.String name) |
java.lang.String |
getStoreName() |
static java.util.Set<java.lang.String> |
getStoreNames(Environment env) |
boolean |
isReplicaUpgradeMode()
For unit testing.
|
(package private) static java.lang.String |
makePriDbName(java.lang.String storePrefix,
java.lang.String entityClsName) |
(package private) static java.lang.String |
makeSecDbName(java.lang.String storePrefix,
java.lang.String entityClsName,
java.lang.String keyName) |
java.lang.String[] |
parseDbName(java.lang.String wholeName)
Parses a whole DB name and returns an array of 2 strings where element 0
is the file name (always null for JE, always non-null for DB core) and
element 1 is the logical DB name (always non-null for JE, may be null
for DB core).
|
static java.lang.String[] |
parseDbName(java.lang.String wholeName,
DatabaseNamer namer)
Allows passing a namer to a static method for testing.
|
(package private) PersistCatalog |
refresh(PersistCatalog oldCatalog,
int errorFormatId,
RefreshException cause)
Called via RefreshException.refresh when handling the RefreshException
in the binding methods, when a Replica detects that its in-memory
metadata is stale.
|
void |
setPrimaryConfig(java.lang.Class entityClass,
DatabaseConfig config) |
void |
setSecondaryConfig(java.lang.Class entityClass,
java.lang.String keyName,
SecondaryConfig config) |
void |
setSequenceConfig(java.lang.String name,
SequenceConfig config) |
static void |
setSyncHook(Store.SyncHook hook)
For unit testing.
|
void |
sync() |
void |
truncateClass(java.lang.Class entityClass) |
void |
truncateClass(Transaction txn,
java.lang.Class entityClass) |
public static final java.lang.String NAME_SEPARATOR
public static boolean expectFlush
public Store(Environment env, java.lang.String storeName, StoreConfig config, boolean rawAccess) throws StoreExistsException, StoreNotFoundException, IncompatibleClassException, DatabaseException
public Environment getEnvironment()
public StoreConfig getConfig()
public java.lang.String getStoreName()
public static java.util.Set<java.lang.String> getStoreNames(Environment env) throws DatabaseException
DatabaseException
public boolean isReplicaUpgradeMode()
public EntityModel getModel()
public Mutations getMutations()
public <PK,E> PrimaryIndex<PK,E> getPrimaryIndex(java.lang.Class<PK> primaryKeyClass, java.lang.String primaryKeyClassName, java.lang.Class<E> entityClass, java.lang.String entityClassName) throws DatabaseException, IndexNotAvailableException
public <SK,PK,E1,E2 extends E1> SecondaryIndex<SK,PK,E2> getSecondaryIndex(PrimaryIndex<PK,E1> primaryIndex, java.lang.Class<E2> entityClass, java.lang.String entityClassName, java.lang.Class<SK> keyClass, java.lang.String keyClassName, java.lang.String keyName) throws DatabaseException, IndexNotAvailableException
void checkEntitySubclassSecondaries(EntityMetadata entityMeta, java.lang.String subclassName) throws DatabaseException
java.lang.IllegalArgumentException
- if a secondary is not open.DatabaseException
public void sync() throws DatabaseException
DatabaseException
public void truncateClass(java.lang.Class entityClass) throws DatabaseException
DatabaseException
public void truncateClass(Transaction txn, java.lang.Class entityClass) throws DatabaseException
DatabaseException
public void closeClass(java.lang.Class entityClass) throws DatabaseException
DatabaseException
public void close() throws DatabaseException
DatabaseException
public Sequence getSequence(java.lang.String name) throws DatabaseException
DatabaseException
public SequenceConfig getSequenceConfig(java.lang.String name)
public void setSequenceConfig(java.lang.String name, SequenceConfig config)
public DatabaseConfig getPrimaryConfig(java.lang.Class entityClass)
public void setPrimaryConfig(java.lang.Class entityClass, DatabaseConfig config)
public SecondaryConfig getSecondaryConfig(java.lang.Class entityClass, java.lang.String keyName)
public void setSecondaryConfig(java.lang.Class entityClass, java.lang.String keyName, SecondaryConfig config)
static java.lang.String makePriDbName(java.lang.String storePrefix, java.lang.String entityClsName)
static java.lang.String makeSecDbName(java.lang.String storePrefix, java.lang.String entityClsName, java.lang.String keyName)
public java.lang.String[] parseDbName(java.lang.String wholeName)
public static java.lang.String[] parseDbName(java.lang.String wholeName, DatabaseNamer namer)
java.lang.String getDbNameMessage(java.lang.String[] names)
public EvolveStats evolve(EvolveConfig config) throws DatabaseException
DatabaseException
public static void setSyncHook(Store.SyncHook hook)
public boolean attemptRefresh()
PersistCatalog refresh(PersistCatalog oldCatalog, int errorFormatId, RefreshException cause)
TransactionConfig getAutoCommitTxnConfig()
Copyright (c) 2004-2012 Oracle. All rights reserved.