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 インタフェース内 SchemaMetaInfopublic boolean canSave()
canSave インタフェース内 SchemaMetaInfopublic boolean canCreate()
canCreate インタフェース内 SchemaMetaInfopublic boolean canDelete()
canDelete インタフェース内 SchemaMetaInfopublic boolean isLoadable(Key ptypeKey)
isLoadable インタフェース内 SchemaMetaInfoptypeKey - Key(現象型名)public java.util.Iterator getLoadables()
getLoadables インタフェース内 SchemaMetaInfopublic java.util.Set loadableSet()
loadableSet インタフェース内 SchemaMetaInfopublic boolean isStorable(Key ptypeKey)
isStorable インタフェース内 SchemaMetaInfopublic java.util.Iterator getStorables()
getStorables インタフェース内 SchemaMetaInfopublic java.util.Set storableSet()
storableSet インタフェース内 SchemaMetaInfopublic boolean isRemovable(Key ptypeKey)
isRemovable インタフェース内 SchemaMetaInfoptypeKey - Key(現象型名)public java.util.Iterator getRemovables()
getRemovables インタフェース内 SchemaMetaInfopublic java.util.Set removableSet()
removableSet インタフェース内 SchemaMetaInfopublic java.util.Iterator getCreatables()
getCreatables インタフェース内 SchemaMetaInfopublic java.util.Set creatableSet()
creatableSet インタフェース内 SchemaMetaInfopublic boolean isCreatable(Key ptypeKey)
isCreatable インタフェース内 SchemaMetaInfopublic Key getLockPhenomenonTypeNameKey()
getLockPhenomenonTypeNameKey インタフェース内 SchemaMetaInfopublic PhenomenonType getPrimaryPhenomenonTypeSchema()
getPrimaryPhenomenonTypeSchema インタフェース内 PrimaryObservableSchemapublic Key getPrimaryPhenomenonTypeNameKey()
public java.lang.String getPrimaryPhenomenonTypeName()
public Observable load(ObservableProxy observableProxy) throws PersistenceException, FatalException
load インタフェース内 PrimaryObservableSchemaobservableProxy - Observableを一意に特定するキーPersistenceExceptionFatalExceptionpublic Observable load(ObservableProxy observableProxy, ObservableFactory absFactory) throws PersistenceException, FatalException
load インタフェース内 PrimaryObservableSchemaobservableProxy - Observableを一意に特定するキーabsFactory - observableを作成する際に利用するfactoryPersistenceExceptionFatalExceptionpublic Observable load(Observable observable) throws PersistenceException, FatalException
load インタフェース内 PrimaryObservableSchemaobservable - Inspectableを取得可能な読み込み対象ObservablePersistenceExceptionFatalExceptionpublic Observable lock(ObservableProxy observableProxy) throws PersistenceException, FatalException
lock インタフェース内 PrimaryObservableSchemaobservableProxy - Observableを一意に特定するキーPersistenceExceptionFatalExceptionpublic Observable lock(Observable observable) throws PersistenceException, FatalException
lock インタフェース内 PrimaryObservableSchemaobservable - Inspectableを取得可能な読み込み対象ObservablePersistenceExceptionFatalExceptionpublic Observable lock(ObservableProxy observableProxy, java.lang.Integer versionNumber) throws PersistenceException, FatalException
lock インタフェース内 PrimaryObservableSchemaobservableProxy - Observableを一意に特定するキーversionNumber - 前回取得時のバージョン番号PersistenceExceptionFatalExceptionpublic Observable lock(Observable observable, java.lang.Integer versionNumber) throws PersistenceException, FatalException
lock インタフェース内 PrimaryObservableSchemaobservable - Inspectableを取得可能な設定対象ObservableversionNumber - 前回取得時のバージョン番号PersistenceExceptionFatalExceptionpublic void save(ObservableProxy observableProxy, Updatable updatable) throws PersistenceException, FatalException
save インタフェース内 PrimaryObservableSchemaobservableProxy - Observableを一意に特定するキーupdatable - 保存対象PersistenceExceptionFatalExceptionpublic void save(ObservableProxy proxy, java.util.Map observationMap) throws PersistenceException, FatalException
save インタフェース内 PrimaryObservableSchemaobservableProxy - Observableを一意に特定するキーobservationMap - Key(現象型名)-観測のマップPersistenceExceptionFatalExceptionpublic void create(java.util.Map observationMap) throws PersistenceException, FatalException
create インタフェース内 PrimaryObservableSchemaobservationMap - Key(現象型名)・生成対象観測マップPersistenceExceptionFatalExceptionpublic void create(Observable observable) throws PersistenceException, FatalException
create インタフェース内 PrimaryObservableSchemaobservable - Inspectableを取得可能な作成対象ObservablePersistenceExceptionFatalExceptionpublic void delete(ObservableProxy observableProxy, java.util.Map observationMap) throws PersistenceException, PersistenceException
delete インタフェース内 PrimaryObservableSchemaobservableProxy - Observableを一意に特定するキーobservationMap - Key(現象型名)・削除対象観測マップPersistenceExceptionpublic void delete(Observable observable) throws PersistenceException, PersistenceException
delete インタフェース内 PrimaryObservableSchemaObservable - 削除対象ObservablePersistenceExceptionpublic ObservableProxy findByObservableProxy(ObservableProxy proxy) throws FindException, FatalException
findByObservableProxy インタフェース内 PrimaryObservableSchemaobservableProxy - プライマリーキーFindException - 存在しないまたは、検索に失敗したFatalExceptionpublic java.util.Collection findByQuery(java.lang.String query) throws FindException, FatalException
findByQuery インタフェース内 PrimaryObservableSchemaquery - 抽出条件javax.ejb.FinderExceptionFindExceptionFatalExceptionpublic java.util.Collection findByQuery(java.lang.String query, SortRule[] sortRules, LimitRule limitRule) throws FindException, FatalException
PrimaryObservableSchemafindByQuery インタフェース内 PrimaryObservableSchemaquery - 抽出条件sortRules - ソート条件limitRule - 検索結果に対する制限条件FindExceptionFatalExceptionpublic java.util.Collection findByFilter(Filter filter) throws FindException, FatalException
findByFilter インタフェース内 PrimaryObservableSchemafilter - 抽出条件javax.ejb.FinderExceptionFindExceptionFatalExceptionpublic java.util.Collection findByFilter(Filter filter, SortRule[] sortRules, LimitRule limitRule) throws FindException, FatalException
PrimaryObservableSchemafindByFilter インタフェース内 PrimaryObservableSchemalimitRule - 検索結果に対する制限条件FindExceptionFatalExceptionpublic java.util.Collection findAll() throws FindException, FatalException
findAll インタフェース内 PrimaryObservableSchemaFindExceptionFatalExceptionpublic java.util.Collection findAll(SortRule[] sortRules, LimitRule limitRule) throws FindException, FatalException
PrimaryObservableSchemafindAll インタフェース内 PrimaryObservableSchemasortRules - ソート条件limitRule - 検索結果に対する制限条件FindExceptionFatalExceptionprotected 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
PrimaryObservableSchemaprepareSave インタフェース内 PrimaryObservableSchemaobservableProxy - Observableを一意に特定するキーPersistenceExceptionFatalExceptionpublic int prepareSave(Observable observable) throws PersistenceException, FatalException
PrimaryObservableSchemaprepareSave インタフェース内 PrimaryObservableSchemaobservable - 観測設定対象Observalbe,Inspectableを取得可能なObservableである必要があるPersistenceExceptionFatalExceptionpublic int prepareSave(ObservableProxy observableProxy, java.lang.Integer versionNumber) throws PersistenceException, FatalException
PrimaryObservableSchemaprepareSave インタフェース内 PrimaryObservableSchemaobservableProxy - Observableを一意に特定するキーversionNumber - 前回取得時のバージョン番号PersistenceExceptionFatalExceptionpublic int prepareSave(Observable observable, java.lang.Integer versionNumber) throws PersistenceException, FatalException
PrimaryObservableSchemaprepareSave インタフェース内 PrimaryObservableSchemaobservable - 観測設定対象Observalbe,Inspectableを取得可能なObservableである必要があるversionNumber - 前回取得時のバージョン番号PersistenceExceptionFatalExceptionpublic void save(ObservableProxy proxy, java.lang.Integer versionNumber, Updatable updatable) throws PersistenceException, FatalException
PrimaryObservableSchemasave インタフェース内 PrimaryObservableSchemaPersistenceException - versionNumberが不一致の場合はVersionNumberExceptionを送信するFatalException