public class CsvObservableSchema extends java.lang.Object implements ObservableSchema
修飾子とタイプ | フィールドと説明 |
---|---|
protected boolean |
canSave |
protected java.util.Set |
creatableSet |
protected ObservableFactory |
factory |
static Key |
KEY_FilterFactory |
protected java.util.Set |
loadableSet |
protected Resource |
manager |
protected CsvRowSchema |
obsSchema |
protected CsvRowSchema[] |
obsSchemaArray |
protected Key |
primaryPtypeKey |
protected java.util.Map |
ptypeSchemaMap |
protected java.util.Set |
removableSet |
protected java.util.Set |
storableSet |
コンストラクタと説明 |
---|
CsvObservableSchema(Resource manager,
CsvRowSchema obsSchema,
CsvRowSchema[] obsSchemaArray)
コンストラクタ。
|
修飾子とタイプ | メソッドと説明 |
---|---|
boolean |
canCreate()
永続化ストレージに観測を生成可能かどうかを返す。
|
boolean |
canDelete()
永続化ストレージから観測を削除可能かどうかを返す。
|
boolean |
canLoad()
永続化ストレージから観測を取得可能かどうかを返す。
|
boolean |
canSave()
永続化ストレージに観測を保存可能かどうかを返す。
|
java.lang.Long |
count(Filter filter)
条件に一致したデータの件数を返す。
|
java.util.Set |
creatableSet()
生成時に指定可能なKey(現象型名)のSetを返す。
|
int |
delete(Filter filter)
Filter条件に合致したObservableを削除する。
|
int |
delete(java.lang.String query)
Filter条件に合致したObservableを削除する。
|
protected boolean |
getCanSaveFlag() |
java.util.Iterator |
getCreatables()
生成時に指定可能なKey(現象型名)のIteratorを返す。
|
java.util.List |
getList(Filter filter)
条件に一致したObservableのリストを読み出す。
|
java.util.List |
getList(Filter filter,
ObservableFactory factory)
Observable読み出しクラスを指定して条件に一致したObservableのListを読み出す。
|
java.util.List |
getList(Filter filter,
ObservableFactory factory,
SortRule[] sortRules,
LimitRule limitRule)
Observable読み出しクラスを指定して条件に一致したObservableのListを読み出す。
|
java.util.List |
getList(Filter filter,
SortRule[] sortRules,
LimitRule limitRule)
条件に一致したObservableを読み出す。
|
protected java.util.List |
getList(java.util.List l,
ObservableFactory factory)
Observable読み出しクラスを指定してlistプライマリ値に一致したObservableのListを読み出す。
|
java.util.List |
getList(java.lang.String query)
条件に一致したObservableを読み出す。
|
java.util.List |
getList(java.lang.String query,
ObservableFactory factory)
Observable読み出しクラスを指定して条件に一致したObservableのListを読み出す。
|
java.util.List |
getList(java.lang.String query,
ObservableFactory factory,
SortRule[] sortRules,
LimitRule limitRule)
Observable読み出しクラスを指定して条件に一致したObservableのListを読み出す。
|
java.util.List |
getList(java.lang.String query,
SortRule[] sortRules,
LimitRule limitRule)
条件に一致したObservableを読み出す。
|
java.util.Iterator |
getLoadables()
読み出し可能なKey(現象型名)の一覧を返す。
|
Key |
getLockPhenomenonTypeNameKey()
Lockの際に利用するKey(現象型名)を返す。
|
protected java.util.Map |
getObservationsMap(java.lang.Object primaryValue,
java.util.Map map)
スキーマに連結するオブザベーションマップを取得する。
|
protected java.util.Map |
getObservationsMap(java.lang.Object primaryValue,
java.util.Map map,
ObservableFactory factory)
スキーマに連結するオブザベーションマップを取得する。
|
PhenomenonType |
getPrimaryPhenomenonTypeSchema()
プライマリ現象型スキーマを返す。
|
java.util.Map |
getPtypeSchemaMap() |
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(現象型名)が更新可能かどうかを表す。
|
java.util.Collection |
load(java.io.BufferedReader in,
Filter filter)
条件に一致したObservableを読み出す。
|
java.util.Collection |
load(Filter filter)
条件に一致したObservableを読み出す。
|
java.util.Collection |
load(Filter filter,
ObservableFactory factory)
Observable読み出しクラスを指定して条件に一致したObservableを読み出す。
|
java.util.Collection |
load(Filter filter,
ObservableFactory factory,
SortRule[] sortRules,
LimitRule limitRule)
Observable読み出しクラスを指定して条件に一致したObservableを読み出す。
|
java.util.Collection |
load(Filter filter,
SortRule[] sortRules,
LimitRule limitRule)
条件に一致したObservableを読み出す。
|
java.util.Collection |
load(java.lang.String query)
条件に一致したObservableを読み出す。
|
java.util.Collection |
load(java.lang.String query,
ObservableFactory factory)
Observable読み出しクラスを指定して条件に一致したObservableを読み出す。
|
java.util.Collection |
load(java.lang.String query,
ObservableFactory factory,
SortRule[] sortRules,
LimitRule limitRule)
Observable読み出しクラスを指定して条件に一致したObservableを読み出す。
|
java.util.Collection |
load(java.lang.String query,
SortRule[] sortRules,
LimitRule limitRule)
条件に一致したObservableを読み出す。
|
java.util.Set |
loadableSet()
読み出し可能なKey(現象型名)のSetを返す。
|
java.util.Collection |
lock(Filter filter)
条件に一致したObservableをlockして読み出す。
|
java.util.Collection |
lock(Filter filter,
ObservableFactory factory)
Observable読み出しクラスを指定して条件に一致したObservableをlockして読み出す。
|
java.util.Collection |
lock(java.lang.String query)
条件に一致したObservableをlockして読み出す。
|
java.util.Collection |
lock(java.lang.String query,
ObservableFactory factory)
Observable読み出しクラスを指定して条件に一致したObservableをlockして読み出す。
|
int |
prepareSave(Filter filter)
条件に一致したObservableをlockして読み出す。
|
int |
prepareSave(java.lang.String query)
条件に一致したObservableをlockして読み出す。
|
java.util.Set |
removableSet()
Null値を設定可能なKey(現象型名)のSetを返す。
|
int |
save(Filter filter,
java.util.Map observationMap)
条件に合致したObservableを更新する
|
int |
save(Filter filter,
java.util.Map observationMap,
boolean versionnuberUpFlag)
条件に合致したObservableを更新する
|
int |
save(java.lang.String query,
java.util.Map observationMap)
条件に合致したObservableを更新する
|
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 Key primaryPtypeKey
protected java.util.Map ptypeSchemaMap
public CsvObservableSchema(Resource manager, CsvRowSchema obsSchema, CsvRowSchema[] obsSchemaArray)
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
インタフェース内 ObservableSchema
public java.util.Map getPtypeSchemaMap()
public java.lang.Long count(Filter filter) throws PersistenceException, FatalException
count
インタフェース内 ObservableSchema
filter
- 抽出条件PersistenceException
FatalException
public java.util.Collection load(Filter filter) throws PersistenceException, FatalException
load
インタフェース内 ObservableSchema
filter
- 条件PersistenceException
FatalException
public java.util.Collection load(java.io.BufferedReader in, Filter filter) throws PersistenceException, FatalException
filter
- 条件PersistenceException
FatalException
public java.util.Collection load(Filter filter, SortRule[] sortRules, LimitRule limitRule) throws PersistenceException, FatalException
load
インタフェース内 ObservableSchema
filter
- 条件sortRules
- ソート条件limitRule
- 検索結果に対する制限条件PersistenceException
FatalException
public java.util.Collection load(java.lang.String query) throws PersistenceException, FatalException
load
インタフェース内 ObservableSchema
query
- 条件PersistenceException
FatalException
public java.util.Collection load(java.lang.String query, SortRule[] sortRules, LimitRule limitRule) throws PersistenceException, FatalException
load
インタフェース内 ObservableSchema
query
- 条件sortRules
- ソート条件limitRule
- 検索結果に対する制限条件PersistenceException
FatalException
public java.util.List getList(Filter filter) throws PersistenceException, FatalException
getList
インタフェース内 ObservableSchema
filter
- 条件PersistenceException
FatalException
public java.util.List getList(Filter filter, SortRule[] sortRules, LimitRule limitRule) throws PersistenceException, FatalException
getList
インタフェース内 ObservableSchema
filter
- 条件sortRules
- ソート条件limitRule
- 検索結果に対する制限条件PersistenceException
FatalException
public java.util.List getList(java.lang.String query) throws PersistenceException, FatalException
getList
インタフェース内 ObservableSchema
query
- 条件PersistenceException
FatalException
public java.util.List getList(java.lang.String query, SortRule[] sortRules, LimitRule limitRule) throws PersistenceException, FatalException
getList
インタフェース内 ObservableSchema
query
- 条件sortRules
- ソート条件limitRule
- 検索結果に対する制限条件PersistenceException
FatalException
public java.util.Collection load(Filter filter, ObservableFactory factory) throws PersistenceException, FatalException
filter
- 条件factory
- Observable生成時に利用するFactoryクラスPersistenceException
FatalException
public java.util.Collection load(Filter filter, ObservableFactory factory, SortRule[] sortRules, LimitRule limitRule) throws PersistenceException, FatalException
load
インタフェース内 ObservableSchema
filter
- 条件factory
- Observable生成時に利用するFactoryクラスsortRules
- ソート条件limitRule
- 検索結果に対する制限条件PersistenceException
FatalException
public java.util.Collection load(java.lang.String query, ObservableFactory factory) throws PersistenceException, FatalException
query
- 条件factory
- Observable生成時に利用するFactoryクラスPersistenceException
FatalException
public java.util.Collection load(java.lang.String query, ObservableFactory factory, SortRule[] sortRules, LimitRule limitRule) throws PersistenceException, FatalException
load
インタフェース内 ObservableSchema
query
- 条件factory
- Observable生成時に利用するFactoryクラスsortRules
- ソート条件limitRule
- 検索結果に対する制限条件PersistenceException
FatalException
public java.util.List getList(Filter filter, ObservableFactory factory) throws PersistenceException, FatalException
filter
- 条件factory
- Observable生成時に利用するFactoryクラスPersistenceException
FatalException
public java.util.List getList(Filter filter, ObservableFactory factory, SortRule[] sortRules, LimitRule limitRule) throws PersistenceException, FatalException
getList
インタフェース内 ObservableSchema
filter
- 条件factory
- Observable生成時に利用するFactoryクラスsortRules
- ソート条件limitRule
- 検索結果に対する制限条件PersistenceException
FatalException
public java.util.List getList(java.lang.String query, ObservableFactory factory) throws PersistenceException, FatalException
query
- 条件factory
- Observable生成時に利用するFactoryクラスPersistenceException
FatalException
public java.util.List getList(java.lang.String query, ObservableFactory factory, SortRule[] sortRules, LimitRule limitRule) throws PersistenceException, FatalException
getList
インタフェース内 ObservableSchema
query
- 条件factory
- Observable生成時に利用するFactoryクラスsortRules
- ソート条件limitRule
- 検索結果に対する制限条件PersistenceException
FatalException
protected java.util.List getList(java.util.List l, ObservableFactory factory) throws PersistenceException, FatalException
l
- ベースとなるオブザベーションマップリストfactory
- Observable生成時に利用するFactoryクラスPersistenceException
FatalException
public java.util.Collection lock(Filter filter) throws PersistenceException, FatalException
lock
インタフェース内 ObservableSchema
filter
- 条件PersistenceException
FatalException
public java.util.Collection lock(java.lang.String query) throws PersistenceException, FatalException
lock
インタフェース内 ObservableSchema
query
- 条件PersistenceException
FatalException
public java.util.Collection lock(Filter filter, ObservableFactory factory) throws PersistenceException, FatalException
lock
インタフェース内 ObservableSchema
filter
- 条件factory
- Observable生成時に利用するFactoryクラスPersistenceException
FatalException
public java.util.Collection lock(java.lang.String query, ObservableFactory factory) throws PersistenceException, FatalException
lock
インタフェース内 ObservableSchema
query
- 条件factory
- Observable生成時に利用するFactoryクラスPersistenceException
FatalException
public int save(Filter filter, java.util.Map observationMap) throws PersistenceException, FatalException
save
インタフェース内 ObservableSchema
filter
- 条件observationMap
- Key(現象型名)・観測のマップPersistenceException
FatalException
public int save(Filter filter, java.util.Map observationMap, boolean versionnuberUpFlag) throws PersistenceException, FatalException
save
インタフェース内 ObservableSchema
filter
- 条件observationMap
- Key(現象型名)・観測のマップversionnuberUpFlag
- VersionNumberを+1する(true:+1する、false:+1しない)PersistenceException
FatalException
public int save(java.lang.String query, java.util.Map observationMap) throws PersistenceException, FatalException
save
インタフェース内 ObservableSchema
query
- 条件observationMap
- Key(現象型名)・観測のマップPersistenceException
FatalException
public int delete(Filter filter) throws PersistenceException, FatalException
delete
インタフェース内 ObservableSchema
PersistenceException
FatalException
public int delete(java.lang.String query) throws PersistenceException, FatalException
delete
インタフェース内 ObservableSchema
PersistenceException
FatalException
protected boolean getCanSaveFlag()
protected java.util.Map getObservationsMap(java.lang.Object primaryValue, java.util.Map map) throws PersistenceException, FatalException
primaryValue
- 連結するキー値map
- スキーマのマップPersistenceException
FatalException
protected java.util.Map getObservationsMap(java.lang.Object primaryValue, java.util.Map map, ObservableFactory factory) throws PersistenceException, FatalException
primaryValue
- 連結するキー値map
- スキーマのマップfactory
- Observable生成時に利用するFactoryクラスPersistenceException
FatalException
protected void setCsvFilePath(Filter filter)
filter
- CSVファイルパスを含むフィルタ条件public int prepareSave(Filter filter) throws PersistenceException, FatalException
ObservableSchema
prepareSave
インタフェース内 ObservableSchema
filter
- 条件PersistenceException
FatalException
public int prepareSave(java.lang.String query) throws PersistenceException, FatalException
ObservableSchema
prepareSave
インタフェース内 ObservableSchema
query
- 条件PersistenceException
FatalException