public class CsvPrimaryObservableSchema extends java.lang.Object implements PrimaryObservableSchema
修飾子とタイプ | フィールドと説明 |
---|---|
protected boolean |
canSave |
protected java.util.Set |
creatableSet |
protected ObservableFactory |
factory |
protected FilterFactory |
filterFactory |
static Key |
KEY_FilterFactory |
protected java.util.Set |
loadableSet |
protected Resource |
manager |
protected CsvObservableSchema |
observableSchema |
protected CsvRowSchema |
obsSchema |
protected CsvRowSchema[] |
obsSchemaArray |
protected Key |
primaryPtypeKey |
protected java.util.Map |
ptypeSchemaMap |
protected java.util.Set |
removableSet |
protected java.util.Set |
storableSet |
コンストラクタと説明 |
---|
CsvPrimaryObservableSchema(Resource manager,
CsvRowSchema obsSchema,
CsvRowSchema[] obsSchemaArray)
コンストラクタ。
|
CsvPrimaryObservableSchema(Resource manager,
CsvRowSchema obsSchema,
CsvRowSchema[] obsSchemaArray,
ObservableFactory factory) |
修飾子とタイプ | メソッドと説明 |
---|---|
boolean |
canCreate()
永続化ストレージに観測を生成可能かどうかを返す。
|
boolean |
canDelete()
永続化ストレージから観測を削除可能かどうかを返す。
|
boolean |
canLoad()
永続化ストレージから観測を取得可能かどうかを返す。
|
boolean |
canSave()
永続化ストレージに観測を保存可能かどうかを返す。
|
java.util.Set |
creatableSet()
生成時に指定可能なKey(現象型名)のSetを返す。
|
void |
create(java.util.Map observationMap)
観測を永続化ストレージ上に生成する。
|
void |
create(Observable observable)
観測を永続化ストレージ上に生成する。
|
void |
delete(Observable observable)
永続化ストレージからプライマリーキーに対応した観測を削除する。
|
void |
delete(ObservableProxy observableProxy,
java.util.Map observationMap)
永続化ストレージからプライマリーキーに対応した観測を削除する。
|
java.util.Collection |
findAll()
全てのObservableのObservablePrxoyを返す。
|
java.util.Collection |
findAll(SortRule[] sortRules,
LimitRule limitRule)
すべてのObservableProxyをソートして返す。
|
java.util.Collection |
findByFilter(Filter filter)
Filterに合致するObservableのObservableProxyを検索する。
|
java.util.Collection |
findByFilter(Filter filter,
SortRule[] sortRules,
LimitRule limitRule)
Filterに合致するObservableProxyのCollectionをソートして返す。
|
ObservableProxy |
findByObservableProxy(ObservableProxy proxy)
ObservableProxyに合致するEntityのObservableProxyを返す。
|
java.util.Collection |
findByQuery(java.lang.String query)
Filterに合致するObservableのObservableProxyを検索する。
|
java.util.Collection |
findByQuery(java.lang.String query,
SortRule[] sortRules,
LimitRule limitRule)
queryに合致するObservableのObservableProxyをソートして返す。
|
protected boolean |
getCanSaveFlag() |
java.util.Iterator |
getCreatables()
生成時に指定可能なKey(現象型名)のIteratorを返す。
|
protected CsvObservableSchema |
getCsvObservableSchema()
オブザーブルスキーマを取得する
|
protected FilterFactory |
getFilterFactory() |
java.util.Iterator |
getLoadables()
読み出し可能なKey(現象型名)の一覧を返す。
|
Key |
getLockPhenomenonTypeNameKey()
Lockの際に利用するKey(現象型名)を返す。
|
protected java.util.Map |
getObservationsMap(ObservableProxy proxy,
java.util.Map map) |
java.lang.String |
getPrimaryPhenomenonTypeName()
Primary現象型名を返す。
|
Key |
getPrimaryPhenomenonTypeNameKey()
Key(Primary現象型名)を返す。
|
PhenomenonType |
getPrimaryPhenomenonTypeSchema()
Primary現象型メタ情報を取得する
|
java.util.Iterator |
getRemovables()
Null値を設定可能かKey(現象型名)の一覧を返す。
|
java.util.Iterator |
getStorables()
保存可能なKey(現象型名)の一覧を返す。
|
boolean |
isCreatable(Key ptypeKey)
指定されたKey(現象型名)が生成時に指定可能かどうかを表す。
|
boolean |
isLoadable(Key ptypeKey)
指定されたKey(現象型名)が読み出し可能かどうかを表す。
|
boolean |
isRemovable(Key ptypeKey)
引数で指定したKey(現象型名)がNull値を設定可能かどうかを判断する。
|
boolean |
isStorable(Key ptypeKey)
指定されたKey(現象型名)が更新可能かどうかを表す。
|
Observable |
load(Observable observable)
永続化ストレージからObservableを取得する。
|
Observable |
load(ObservableProxy observableProxy)
永続化ストレージからObservableを取得する。
|
Observable |
load(ObservableProxy observableProxy,
ObservableFactory absFactory)
永続化ストレージからObservableを取得する。
|
java.util.Set |
loadableSet()
読み出し可能なKey(現象型名)のSetを返す。
|
java.util.Map |
loadMap(ObservableProxy proxy)
Key(現象型名)・観測のマップの配列を読み出す。
|
Observable |
lock(Observable observable)
永続化ストレージからObservableをロック(VersionNumber + 1)して取得する
|
Observable |
lock(Observable observable,
java.lang.Integer versionNumber)
永続化ストレージからObservableが、パラメータで与えられた
バージョン番号と一致する場合、ロックして取得する。
|
Observable |
lock(ObservableProxy observableProxy)
永続化ストレージからObservableをロックして取得する
|
Observable |
lock(ObservableProxy observableProxy,
java.lang.Integer versionNumber)
永続化ストレージからObservableが、パラメータで与えられた
バージョン番号と一致する場合、ロックして取得する。
|
int |
prepareSave(Observable observable)
永続化ストレージからObservableをロック(VersionNumber + 1)する
|
int |
prepareSave(Observable observable,
java.lang.Integer versionNumber)
永続化ストレージからObservableが、パラメータで与えられた
バージョン番号と一致する場合、ロック(VersionNumber + 1)する。
|
int |
prepareSave(ObservableProxy observableProxy)
永続化ストレージからObservableをロック(VersionNumber + 1)する
|
int |
prepareSave(ObservableProxy observableProxy,
java.lang.Integer versionNumber)
永続化ストレージからObservableが、パラメータで与えられた
バージョン番号と一致する場合、ロック(VersionNumber + 1)する。
|
java.util.Set |
removableSet()
Null値を設定可能なKey(現象型名)のSetを返す。
|
void |
save(ObservableProxy proxy,
java.lang.Integer versionNumber,
Updatable updatable)
versionNumberと現在のversionNumberの値が一致した場合は、更新を行う
|
void |
save(ObservableProxy proxy,
java.util.Map observationMap)
観測を永続化ストレージに保存する。
|
void |
save(ObservableProxy observableProxy,
Updatable updatable)
観測を永続化ストレージに保存する。
|
protected void |
setCsvFilePath(Filter filter)
CSVファイルパスをセットする
|
java.util.Set |
storableSet()
保存可能なKey(現象型名)のSetを返す。
|
public static final Key KEY_FilterFactory
protected Resource manager
protected ObservableFactory factory
protected CsvRowSchema obsSchema
protected CsvRowSchema[] obsSchemaArray
protected boolean canSave
protected java.util.Set creatableSet
protected java.util.Set loadableSet
protected java.util.Set storableSet
protected java.util.Set removableSet
protected java.util.Map ptypeSchemaMap
protected FilterFactory filterFactory
protected CsvObservableSchema observableSchema
protected Key primaryPtypeKey
public CsvPrimaryObservableSchema(Resource manager, CsvRowSchema obsSchema, CsvRowSchema[] obsSchemaArray)
public CsvPrimaryObservableSchema(Resource manager, CsvRowSchema obsSchema, CsvRowSchema[] obsSchemaArray, ObservableFactory factory)
public boolean canLoad()
canLoad
インタフェース内 SchemaMetaInfo
public boolean canSave()
canSave
インタフェース内 SchemaMetaInfo
public boolean canCreate()
canCreate
インタフェース内 SchemaMetaInfo
public boolean canDelete()
canDelete
インタフェース内 SchemaMetaInfo
public boolean isLoadable(Key ptypeKey)
isLoadable
インタフェース内 SchemaMetaInfo
ptypeKey
- Key(現象型名)public java.util.Iterator getLoadables()
getLoadables
インタフェース内 SchemaMetaInfo
public java.util.Set loadableSet()
loadableSet
インタフェース内 SchemaMetaInfo
public boolean isStorable(Key ptypeKey)
isStorable
インタフェース内 SchemaMetaInfo
public java.util.Iterator getStorables()
getStorables
インタフェース内 SchemaMetaInfo
public java.util.Set storableSet()
storableSet
インタフェース内 SchemaMetaInfo
public boolean isRemovable(Key ptypeKey)
isRemovable
インタフェース内 SchemaMetaInfo
ptypeKey
- Key(現象型名)public java.util.Iterator getRemovables()
getRemovables
インタフェース内 SchemaMetaInfo
public java.util.Set removableSet()
removableSet
インタフェース内 SchemaMetaInfo
public java.util.Iterator getCreatables()
getCreatables
インタフェース内 SchemaMetaInfo
public java.util.Set creatableSet()
creatableSet
インタフェース内 SchemaMetaInfo
public boolean isCreatable(Key ptypeKey)
isCreatable
インタフェース内 SchemaMetaInfo
public Key getLockPhenomenonTypeNameKey()
getLockPhenomenonTypeNameKey
インタフェース内 SchemaMetaInfo
public PhenomenonType getPrimaryPhenomenonTypeSchema()
getPrimaryPhenomenonTypeSchema
インタフェース内 PrimaryObservableSchema
public Key getPrimaryPhenomenonTypeNameKey()
public java.lang.String getPrimaryPhenomenonTypeName()
public Observable load(ObservableProxy observableProxy) throws PersistenceException, FatalException
load
インタフェース内 PrimaryObservableSchema
observableProxy
- Observableを一意に特定するキーPersistenceException
FatalException
public Observable load(ObservableProxy observableProxy, ObservableFactory absFactory) throws PersistenceException, FatalException
load
インタフェース内 PrimaryObservableSchema
observableProxy
- Observableを一意に特定するキーabsFactory
- observableを作成する際に利用するfactoryPersistenceException
FatalException
public Observable load(Observable observable) throws PersistenceException, FatalException
load
インタフェース内 PrimaryObservableSchema
observable
- Inspectableを取得可能な読み込み対象ObservablePersistenceException
FatalException
public Observable lock(ObservableProxy observableProxy) throws PersistenceException, FatalException
lock
インタフェース内 PrimaryObservableSchema
observableProxy
- Observableを一意に特定するキーPersistenceException
FatalException
public Observable lock(Observable observable) throws PersistenceException, FatalException
lock
インタフェース内 PrimaryObservableSchema
observable
- Inspectableを取得可能な読み込み対象ObservablePersistenceException
FatalException
public Observable lock(ObservableProxy observableProxy, java.lang.Integer versionNumber) throws PersistenceException, FatalException
lock
インタフェース内 PrimaryObservableSchema
observableProxy
- Observableを一意に特定するキーversionNumber
- 前回取得時のバージョン番号PersistenceException
FatalException
public Observable lock(Observable observable, java.lang.Integer versionNumber) throws PersistenceException, FatalException
lock
インタフェース内 PrimaryObservableSchema
observable
- Inspectableを取得可能な設定対象ObservableversionNumber
- 前回取得時のバージョン番号PersistenceException
FatalException
public void save(ObservableProxy observableProxy, Updatable updatable) throws PersistenceException, FatalException
save
インタフェース内 PrimaryObservableSchema
observableProxy
- Observableを一意に特定するキーupdatable
- 保存対象PersistenceException
FatalException
public void save(ObservableProxy proxy, java.util.Map observationMap) throws PersistenceException, FatalException
save
インタフェース内 PrimaryObservableSchema
observableProxy
- Observableを一意に特定するキーobservationMap
- Key(現象型名)-観測のマップPersistenceException
FatalException
public void create(java.util.Map observationMap) throws PersistenceException, FatalException
create
インタフェース内 PrimaryObservableSchema
observationMap
- Key(現象型名)・生成対象観測マップPersistenceException
FatalException
public void create(Observable observable) throws PersistenceException, FatalException
create
インタフェース内 PrimaryObservableSchema
observable
- Inspectableを取得可能な作成対象ObservablePersistenceException
FatalException
public void delete(ObservableProxy observableProxy, java.util.Map observationMap) throws PersistenceException, PersistenceException
delete
インタフェース内 PrimaryObservableSchema
observableProxy
- Observableを一意に特定するキーobservationMap
- Key(現象型名)・削除対象観測マップPersistenceException
public void delete(Observable observable) throws PersistenceException, PersistenceException
delete
インタフェース内 PrimaryObservableSchema
Observable
- 削除対象ObservablePersistenceException
public ObservableProxy findByObservableProxy(ObservableProxy proxy) throws FindException, FatalException
findByObservableProxy
インタフェース内 PrimaryObservableSchema
observableProxy
- プライマリーキーFindException
- 存在しないまたは、検索に失敗したFatalException
public java.util.Collection findByQuery(java.lang.String query) throws FindException, FatalException
findByQuery
インタフェース内 PrimaryObservableSchema
query
- 抽出条件javax.ejb.FinderException
FindException
FatalException
public java.util.Collection findByQuery(java.lang.String query, SortRule[] sortRules, LimitRule limitRule) throws FindException, FatalException
PrimaryObservableSchema
findByQuery
インタフェース内 PrimaryObservableSchema
query
- 抽出条件sortRules
- ソート条件limitRule
- 検索結果に対する制限条件FindException
FatalException
public java.util.Collection findByFilter(Filter filter) throws FindException, FatalException
findByFilter
インタフェース内 PrimaryObservableSchema
filter
- 抽出条件javax.ejb.FinderException
FindException
FatalException
public java.util.Collection findByFilter(Filter filter, SortRule[] sortRules, LimitRule limitRule) throws FindException, FatalException
PrimaryObservableSchema
findByFilter
インタフェース内 PrimaryObservableSchema
limitRule
- 検索結果に対する制限条件FindException
FatalException
public java.util.Collection findAll() throws FindException, FatalException
findAll
インタフェース内 PrimaryObservableSchema
FindException
FatalException
public java.util.Collection findAll(SortRule[] sortRules, LimitRule limitRule) throws FindException, FatalException
PrimaryObservableSchema
findAll
インタフェース内 PrimaryObservableSchema
sortRules
- ソート条件limitRule
- 検索結果に対する制限条件FindException
FatalException
protected boolean getCanSaveFlag()
protected FilterFactory getFilterFactory()
public java.util.Map loadMap(ObservableProxy proxy) throws PersistenceException, FatalException
protected java.util.Map getObservationsMap(ObservableProxy proxy, java.util.Map map) throws PersistenceException, FatalException
protected CsvObservableSchema getCsvObservableSchema()
protected void setCsvFilePath(Filter filter)
filter
- CSVファイルパスを含むフィルタ条件public int prepareSave(ObservableProxy observableProxy) throws PersistenceException, FatalException
PrimaryObservableSchema
prepareSave
インタフェース内 PrimaryObservableSchema
observableProxy
- Observableを一意に特定するキーPersistenceException
FatalException
public int prepareSave(Observable observable) throws PersistenceException, FatalException
PrimaryObservableSchema
prepareSave
インタフェース内 PrimaryObservableSchema
observable
- 観測設定対象Observalbe,Inspectableを取得可能なObservableである必要があるPersistenceException
FatalException
public int prepareSave(ObservableProxy observableProxy, java.lang.Integer versionNumber) throws PersistenceException, FatalException
PrimaryObservableSchema
prepareSave
インタフェース内 PrimaryObservableSchema
observableProxy
- Observableを一意に特定するキーversionNumber
- 前回取得時のバージョン番号PersistenceException
FatalException
public int prepareSave(Observable observable, java.lang.Integer versionNumber) throws PersistenceException, FatalException
PrimaryObservableSchema
prepareSave
インタフェース内 PrimaryObservableSchema
observable
- 観測設定対象Observalbe,Inspectableを取得可能なObservableである必要があるversionNumber
- 前回取得時のバージョン番号PersistenceException
FatalException
public void save(ObservableProxy proxy, java.lang.Integer versionNumber, Updatable updatable) throws PersistenceException, FatalException
PrimaryObservableSchema
save
インタフェース内 PrimaryObservableSchema
PersistenceException
- versionNumberが不一致の場合はVersionNumberExceptionを送信するFatalException