io.stallion.dataAccess.db

Class DbPersister<T extends Model>

java.lang.Object

io.stallion.dataAccess.BasePersister<T>

io.stallion.dataAccess.db.DbPersister<T>

All Implemented Interfaces:

Persister<T>

Direct Known Subclasses:

AsyncTaskDbPersister

public class DbPersister<T extends Model>
extends BasePersister<T>

Constructor Summary

Constructors

Constructor and Description
DbPersister()

Method Summary

Modifier and Type	Method and Description
void	attachWatcher() Attach any file system watchers for changed objects
protected boolean	checkNeedsSync()
List<T>	fetchAll() Fetch all the items from the underlying data store.
T	fetchOne(Long id) Fetch one object with the given ID
T	fetchOne(T obj) Re-fetch the passed in object from the underlying data stores
FilterChain<T>	filterChain()
protected String	getBucketSyncedKey()
protected String	getTableName()
void	hardDelete(T obj) Permanently delete the object from the datastore
void	init(DataAccessRegistration registration, ModelController<T> controller, Stash<T> stash) Initialize the persister, called during DalRegistery.register
boolean	isDbBacked()
void	onPreRead() Called before any read operation.
void	persist(T obj) Persist the object to the underlying data store
protected boolean	syncFromDatabase()
void	update(T obj, Map<String,Object> values) Update the specified values.
void	watchEventCallback(String relativePath) Callback for file-based datastores when an object is changed in the file system

Methods inherited from class io.stallion.dataAccess.BasePersister

getBucket, getItemController, getModelClass, getStash, handleFetchOne, onFetchOne, reloadIfNewer, setBucket, setItemController, setModelClass, setStash

Methods inherited from class java.lang.Object

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

Constructor Detail

DbPersister

public DbPersister()

Method Detail

init

public void init(DataAccessRegistration registration,
                 ModelController<T> controller,
                 Stash<T> stash)

Description copied from interface: Persister

Initialize the persister, called during DalRegistery.register

Specified by:

init in interface Persister<T extends Model>

Overrides:

init in class BasePersister<T extends Model>

fetchAll

public List<T> fetchAll()

Description copied from interface: Persister

Fetch all the items from the underlying data store.

Returns:

fetchOne

public T fetchOne(Long id)

Description copied from interface: Persister

Fetch one object with the given ID

Returns:

fetchOne

public T fetchOne(T obj)

Description copied from interface: Persister

Re-fetch the passed in object from the underlying data stores

Returns:

watchEventCallback

public void watchEventCallback(String relativePath)

Description copied from interface: Persister

Callback for file-based datastores when an object is changed in the file system

persist

public void persist(T obj)

Description copied from interface: Persister

Persist the object to the underlying data store

update

public void update(T obj,
                   Map<String,Object> values)

Description copied from interface: Persister

Update the specified values. For datastores that support it, it should only save the updated values to the datastore -- not the entire object.

hardDelete

public void hardDelete(T obj)

Description copied from interface: Persister

Permanently delete the object from the datastore

attachWatcher

public void attachWatcher()

Description copied from interface: Persister

Attach any file system watchers for changed objects

isDbBacked

public boolean isDbBacked()

Specified by:

isDbBacked in interface Persister<T extends Model>

Overrides:

isDbBacked in class BasePersister<T extends Model>

onPreRead

public void onPreRead()

Description copied from interface: Persister

Called before any read operation.

Specified by:

onPreRead in interface Persister<T extends Model>

Overrides:

onPreRead in class BasePersister<T extends Model>

filterChain

public FilterChain<T> filterChain()

syncFromDatabase

protected boolean syncFromDatabase()

getBucketSyncedKey

protected String getBucketSyncedKey()

checkNeedsSync

protected boolean checkNeedsSync()

getTableName

protected String getTableName()