Class SqliteStore

java.lang.Object

org.tasktide.itemstore.AbstractItemStore

org.tasktide.itemstore.SqliteStore

All Implemented Interfaces:

ItemStore

public class SqliteStore
extends AbstractItemStore

Class to add support for SQLite

Field Summary

Fields inherited from class AbstractItemStore

dbDirectory, lockStrategy, masterDB, protoDB, storeName

Constructor Summary

Constructors

Constructor	Description
SqliteStore(String storeName, String dbDirectory)	Constructs SQLite ItemStore
SqliteStore(String storeName, String dbDirectory, boolean isLinked)	Constructs SQLite ItemStore
SqliteStore(String storeName, String dbDirectory, String masterDB, String protoDB)	Constructs SQLite ItemStore
SqliteStore(String storeName, String dbDirectory, String masterDB, String protoDB, boolean isLinked)	Construct store with lazy master/proto connection

Method Summary

Modifier and Type	Method	Description
boolean	closeMaster()	Closes connection against master DB
boolean	closePrototoype()	Closes connection against prototype DB
boolean	delete(DbTarget target, Item item)	Deletes provided Item using its Id
<T> T	execute(DbTarget target, Map<String, ItemStore> recipients, LinkedOperationMap<T> operations)	Donates active ItemStore mutex acquisition to provided recipients for provided operation set
<T> T	execute(DbTarget target, ItemStore recipientStore, LinkedOperation<T> linkedOperations)	Performs a set of LinkedOperation over active, and recipient ItemStore.
<T> T	execute(DbTarget target, BulkOperation<T> operationSet)	Performs a set of operations over an ItemStoreSession
List<Item>	getAll(DbTarget target)	Fetch all records from target database
Item	getById(DbTarget target, String id)	Query on Item Id
protected <T> T	getConnection(DbTarget target, Class<T> type)	Get Connection get connection
List<Item>	getItemsByState(DbTarget target, String state)	Query on item state
String	getPayloadById(DbTarget target, String id)	Fetch payload for Item by Id
boolean	isClosed(DbTarget target)	Checks if Master/Prototype are open
boolean	isOpen(DbTarget target)	Checks if Master/Prototype are open
boolean	openMaster()	Open connection master connection
boolean	openPrototoype()	Open connection prototype connection
void	saveItem(DbTarget target, Item item)	Save record to target database
void	saveItemElm(DbTarget target, Item item)	Save element under one commit
void	saveItems(DbTarget target, List<Item> items)	Save all records to target database
boolean	update(DbTarget target, Item item)	Update Item by dropping, then inserting

Methods inherited from class AbstractItemStore

cacheMaster, clearPrototype, closeConn, getDbDirectory, getFilePath, getMasterFilePath, getStoreName, openConn, syncToMaster, syncToMaster, syncToMaster, withLockedConnection, withLockedConnectionUnchecked

Methods inherited from class Object

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

Constructor Details

SqliteStore

public SqliteStore(String storeName,
 String dbDirectory,
 String masterDB,
 String protoDB)

Constructs SQLite ItemStore

Parameters:

storeName -

dbDirectory -

masterDB -

protoDB -

SqliteStore

public SqliteStore(String storeName,
 String dbDirectory)

Constructs SQLite ItemStore

Parameters:

storeName -

dbDirectory -

SqliteStore

public SqliteStore(String storeName,
 String dbDirectory,
 String masterDB,
 String protoDB,
 boolean isLinked)

Construct store with lazy master/proto connection

Parameters:

storeName -

dbDirectory -

masterDB -

protoDB -

isLinked -

SqliteStore

public SqliteStore(String storeName,
 String dbDirectory,
 boolean isLinked)

Constructs SQLite ItemStore

Parameters:

storeName -

dbDirectory -

isLinked -

Method Details

getConnection

protected <T> T getConnection(DbTarget target,
 Class<T> type)

Get Connection get connection

Specified by:

getConnection in class AbstractItemStore

Type Parameters:

T -

Parameters:

target -

type - SqliteStore | RocksDbStore

Returns:

Connection

saveItemElm

public void saveItemElm(DbTarget target,
 Item item)
                 throws ItemStoreCheckedException

Save element under one commit

Parameters:

target -

item -

Throws:

ItemStoreCheckedException

saveItem

public void saveItem(DbTarget target,
 Item item)
              throws ItemStoreCheckedException

Save record to target database

Parameters:

target -

item -

Throws:

ItemStoreCheckedException

saveItems

public void saveItems(DbTarget target,
 List<Item> items)
               throws ItemStoreCheckedException

Save all records to target database

Parameters:

target -

items -

Throws:

ItemStoreCheckedException

getAll

public List<Item> getAll(DbTarget target)
                  throws ItemStoreCheckedException

Fetch all records from target database

Parameters:

target -

Returns:

List-Item

Throws:

ItemStoreCheckedException

getById

public Item getById(DbTarget target,
 String id)
             throws ItemStoreCheckedException

Query on Item Id

Parameters:

target -

id -

Returns:

Item

Throws:

ItemStoreCheckedException

getItemsByState

public List<Item> getItemsByState(DbTarget target,
 String state)
                           throws ItemStoreCheckedException

Query on item state

Parameters:

target -

state -

Returns:

List-Item

Throws:

ItemStoreCheckedException

getPayloadById

public String getPayloadById(DbTarget target,
 String id)

Fetch payload for Item by Id

Parameters:

target -

id -

Returns:

String

delete

public boolean delete(DbTarget target,
 Item item)
               throws ItemStoreCheckedException

Deletes provided Item using its Id

Parameters:

target -

item -

Returns:

boolean

Throws:

ItemStoreCheckedException

update

public boolean update(DbTarget target,
 Item item)
               throws ItemStoreCheckedException

Update Item by dropping, then inserting

Parameters:

target -

item -

Returns:

boolean

Throws:

ItemStoreCheckedException

isOpen

public boolean isOpen(DbTarget target)

Checks if Master/Prototype are open

Parameters:

target -

Returns:

boolean

isClosed

public boolean isClosed(DbTarget target)

Checks if Master/Prototype are open

Parameters:

target -

Returns:

boolean

openMaster

public boolean openMaster()

Open connection master connection

Returns:

boolean

closeMaster

public boolean closeMaster()

Closes connection against master DB

Returns:

boolean

openPrototoype

public boolean openPrototoype()

Open connection prototype connection

Returns:

boolean

closePrototoype

public boolean closePrototoype()

Closes connection against prototype DB

Returns:

boolean

execute

public <T> T execute(DbTarget target,
 BulkOperation<T> operationSet)
              throws ItemStoreCheckedException

Performs a set of operations over an ItemStoreSession

Type Parameters:

T -

Parameters:

target -

operationSet -

Returns:

T

Throws:

ItemStoreCheckedException

execute

public <T> T execute(DbTarget target,
 ItemStore recipientStore,
 LinkedOperation<T> linkedOperations)
              throws ItemStoreCheckedException

Performs a set of LinkedOperation over active, and recipient ItemStore. Under the mutex of the calling ItemStore, hence provided ItemStore referred to as a recipient of the stores mutex

Type Parameters:

T -

Parameters:

target -

recipientStore -

linkedOperations -

Returns:

of T

Throws:

ItemStoreCheckedException

execute

public <T> T execute(DbTarget target,
 Map<String, ItemStore> recipients,
 LinkedOperationMap<T> operations)
              throws ItemStoreCheckedException

Donates active ItemStore mutex acquisition to provided recipients for provided operation set

Type Parameters:

T -

Parameters:

target -

recipients -

operations -

Returns:

of T

Throws:

ItemStoreCheckedException