Module com.aoapps.dao.base

Package com.aoapps.dao.base

Class GlobalCacheTable<K extends Comparable<? super K>,R extends Row<K,?>>

java.lang.Object

com.aoapps.dao.base.AbstractTable<K,R>

com.aoapps.dao.base.GlobalCacheTable<K,R>

All Implemented Interfaces:

Table<K,R>, Iterable<R>, Collection<R>

public abstract class GlobalCacheTable<K extends Comparable<? super K>,R extends Row<K,?>>
extends AbstractTable<K,R>

Caches results by querying the entire table upon first use, the cache is persistent and shared by all users.

1. All rows are loaded and stored unsorted
2. allRowsLoaded is called, given unsorted rows
3. Map is built upon first call to get(K)
4. Rows are sorted upon first call to getRows

TODO: Coordinate invalidation between nodes in cluster TODO: Coordinate invalidation between PHP and Java TODO: Once both done, more aggressively use global caches for better remote database performance TODO: Publish PHP version on PECL

Field Summary

Fields inherited from class com.aoapps.dao.base.AbstractTable

map, sortedMap

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	GlobalCacheTable(Class<K> keyClass, Class<R> rowClass, Model model)

Method Summary

Modifier and Type	Method	Description
protected void	allRowsLoaded(Set<? extends R> rows)	Called when all rows have been loaded at once.
R	get(K key)
SortedSet<? extends R>	getRows()
protected abstract Set<? extends R>	getRowsNoCache()
Set<? extends R>	getUnsortedRows()
void	tableUpdated()	Clears the global caches when the table is updated.

Methods inherited from class com.aoapps.dao.base.AbstractTable

getMap, getModel, getSortedMap

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Collection

equals, hashCode, parallelStream, removeIf, spliterator, stream, toArray

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface com.aoapps.dao.Table

add, addAll, canonicalize, clear, clearCaches, contains, containsAll, getIterator, getName, getOrderedRows, getRows, getSize, isEmpty, iterator, remove, removeAll, retainAll, size, toArray, toArray

Constructor Details

GlobalCacheTable

protected GlobalCacheTable(Class<K> keyClass,
 Class<R> rowClass,
 Model model)

Method Details

tableUpdated

public void tableUpdated()

Clears the global caches when the table is updated.

getUnsortedRows

public Set<? extends R> getUnsortedRows()
                                 throws SQLException

Throws:

SQLException

allRowsLoaded

protected void allRowsLoaded(Set<? extends R> rows)
                      throws SQLException

Called when all rows have been loaded at once. This allows for subclasses to populate any views or caches.

This default implementation does nothing.

Throws:

SQLException

getRows

public SortedSet<? extends R> getRows()
                               throws SQLException

Throws:

SQLException

get

public R get(K key)
      throws NoRowException,
SQLException

Throws:

NoRowException

SQLException

getRowsNoCache

protected abstract Set<? extends R> getRowsNoCache()
                                            throws SQLException

Throws:

SQLException