Class ItemStoreRepository<T extends TaskTideModel<T>>

java.lang.Object

org.tasktide.core.repository.AbstractRepository<T>

org.tasktide.core.repository.ItemStoreRepository<T>

Type Parameters:

T - of TaskTideModel

All Implemented Interfaces:

TaskTideRepository<T>

Direct Known Subclasses:

ItemStoreJobEnvironmentRepository, ItemStoreMetricDataRepository, ItemStoreMetricProfileRepository, ItemStoreStepRepository, ItemStoreWorkflowRepository, ItemStoreWorkItemRepository

public abstract class ItemStoreRepository<T extends TaskTideModel<T>>
extends AbstractRepository<T>

Utilize RocksDB as a TaskTideRepository through the ItemStore

Field Summary

Fields inherited from class AbstractRepository

COLLECTION_CLASS, collectionName, modelType, repoType, resultSetSize

Constructor Summary

Constructors

Constructor	Description
ItemStoreRepository(TaskTideModelType modelType, ItemStore itemStore, Class<T> modelClass, String collectionName)	Construct with ItemStore

Method Summary

Modifier and Type	Method	Description
void	clear()	Removes prototype
boolean	deleteModel(String id)	Delete record from DB
boolean	extendModel(List<T> toAdd)	Add record list to repo
List<T>	filterByAnnotation(String key, Object value)	Filters records with provided annotation key and value
List<T>	filterByAnnotation(CustomAnnotation anno)	Filters records with provided CustomAnnotation
List<T>	findAll()	Retrieve all records
List<T>	findByField(String field, Object value)	Fetch records where value of target field matches queried
List<T>	findByFieldForGroup(String field, Object value, String group, Object groupVal)	Find TaskTideModel from backend with field and group having specified value.
List<T>	findByFieldForGroupWithAnno(String field, Object value, String group, Object groupVal, String annoKey, Object annoValue)	Extends collection, state query with annotation filtering
List<T>	findByFieldForGroupWithAnno(String field, Object value, String group, Object groupVal, CustomAnnotation anno)	Extends collection, state query with annotation filtering
Optional<T>	findById(String id)	Find TaskTideModel from ItemStore with provided id
String	getCollectionName()	Return collection name
Map<String,String>	getRepositoryMetaData()	Provide a map of repository meta data reference class, repository type (NoSQL, RocksDB etc), collecion name
int	getResultSetSize()	Get results set size
List<T>	hasAnnotationField(String key)	Filter records which have provided annotation key
T	insertModel(T model)	Insert record into repo, providing inserted record
List<T>	load()	Open connection to both master and prototype
int	save()	Commit prototype cache to master
void	setResultSetSize(int nRecords)	Set results set size
T	updateModel(T model)	Update provided model in backend DB

Methods inherited from class AbstractRepository

getCollectionClass, getRepoType, validateQueryFieldName

Methods inherited from class Object

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

Constructor Details

ItemStoreRepository

public ItemStoreRepository(TaskTideModelType modelType,
 ItemStore itemStore,
 Class<T> modelClass,
 String collectionName)

Construct with ItemStore

Parameters:

modelType -

itemStore -

modelClass -

collectionName -

Method Details

getRepositoryMetaData

public Map<String,String> getRepositoryMetaData()

Provide a map of repository meta data reference class, repository type (NoSQL, RocksDB etc), collecion name

Specified by:

getRepositoryMetaData in interface TaskTideRepository<T extends TaskTideModel<T>>

Overrides:

getRepositoryMetaData in class AbstractRepository<T extends TaskTideModel<T>>

Returns:

Map-String, String

findById

public Optional<T> findById(String id)

Find TaskTideModel from ItemStore with provided id

Parameters:

id -

Returns:

Optional-T of TaskTideModel

insertModel

public T insertModel(T model)

Insert record into repo, providing inserted record

Parameters:

model -

Returns:

T of TaskTideModel

updateModel

public T updateModel(T model)

Update provided model in backend DB

Parameters:

model -

Returns:

T of TaskTideModel

filterByAnnotation

public List<T> filterByAnnotation(CustomAnnotation anno)

Filters records with provided CustomAnnotation

Specified by:

filterByAnnotation in interface TaskTideRepository<T extends TaskTideModel<T>>

Overrides:

filterByAnnotation in class AbstractRepository<T extends TaskTideModel<T>>

Parameters:

anno -

Returns:

List-TaskTideModel

filterByAnnotation

public List<T> filterByAnnotation(String key,
 Object value)

Filters records with provided annotation key and value

Specified by:

filterByAnnotation in interface TaskTideRepository<T extends TaskTideModel<T>>

Overrides:

filterByAnnotation in class AbstractRepository<T extends TaskTideModel<T>>

Parameters:

key -

value -

Returns:

List-TaskTideModel

hasAnnotationField

public List<T> hasAnnotationField(String key)

Filter records which have provided annotation key

Specified by:

hasAnnotationField in interface TaskTideRepository<T extends TaskTideModel<T>>

Overrides:

hasAnnotationField in class AbstractRepository<T extends TaskTideModel<T>>

Parameters:

key -

Returns:

List-TaskTideModel

findByFieldForGroupWithAnno

public List<T> findByFieldForGroupWithAnno(String field,
 Object value,
 String group,
 Object groupVal,
 String annoKey,
 Object annoValue)

Extends collection, state query with annotation filtering

Specified by:

findByFieldForGroupWithAnno in interface TaskTideRepository<T extends TaskTideModel<T>>

Overrides:

findByFieldForGroupWithAnno in class AbstractRepository<T extends TaskTideModel<T>>

Parameters:

field -

value -

group -

groupVal -

annoKey -

annoValue -

Returns:

List-TaskTideModel

findByFieldForGroupWithAnno

public List<T> findByFieldForGroupWithAnno(String field,
 Object value,
 String group,
 Object groupVal,
 CustomAnnotation anno)

Extends collection, state query with annotation filtering

Specified by:

findByFieldForGroupWithAnno in interface TaskTideRepository<T extends TaskTideModel<T>>

Overrides:

findByFieldForGroupWithAnno in class AbstractRepository<T extends TaskTideModel<T>>

Parameters:

field -

value -

group -

groupVal -

anno -

Returns:

List-TaskTideModel

deleteModel

public boolean deleteModel(String id)

Delete record from DB

Parameters:

id -

Returns:

boolean

findByField

public List<T> findByField(String field,
 Object value)

Fetch records where value of target field matches queried

Parameters:

field -

value -

Returns:

List of TaskTideModel

findByFieldForGroup

public List<T> findByFieldForGroup(String field,
 Object value,
 String group,
 Object groupVal)

Find TaskTideModel from backend with field and group having specified value. Step = Name, State = ToDo

Parameters:

field -

value -

group -

groupVal -

Returns:

List-TaskTideModel

findAll

public List<T> findAll()

Retrieve all records

Returns:

List of TaskTideModel

save

public int save()

Commit prototype cache to master

Returns:

true 1, false -1

load

public List<T> load()

Open connection to both master and prototype

Specified by:

load in interface TaskTideRepository<T extends TaskTideModel<T>>

Overrides:

load in class AbstractRepository<T extends TaskTideModel<T>>

Returns:

List of TaskTideModel

extendModel

public boolean extendModel(List<T> toAdd)

Add record list to repo

Parameters:

toAdd -

Returns:

boolean

getCollectionName

public String getCollectionName()

Return collection name

Overrides:

getCollectionName in class AbstractRepository<T extends TaskTideModel<T>>

Returns:

String

clear

public void clear()

Removes prototype

getResultSetSize

public int getResultSetSize()

Get results set size

Specified by:

getResultSetSize in interface TaskTideRepository<T extends TaskTideModel<T>>

Overrides:

getResultSetSize in class AbstractRepository<T extends TaskTideModel<T>>

Returns:

int

setResultSetSize

public void setResultSetSize(int nRecords)

Set results set size

Specified by:

setResultSetSize in interface TaskTideRepository<T extends TaskTideModel<T>>

Overrides:

setResultSetSize in class AbstractRepository<T extends TaskTideModel<T>>

Parameters:

nRecords -