br.com.sankhya.jape.util

Class InMemoryDataSet

java.lang.Object

br.com.sankhya.jape.util.InMemoryDataSet

public class InMemoryDataSet
extends java.lang.Object

Implementação de um DataSet em memória. O objetivo é manter dados em memória para consulta em alta velocidade. Esses dados são carregados via SQL e são mantidos em uma espécie de cache L2. O esquema de invalidação desta cache é baseado nas modificações que são realizadas nas tabelas do banco de dados que foram usadas na consulta de carregamento dos dados. Sempre que uma tabela é modificada os dataSets em memória que dependem daquela tabela são invalidados. O controle de concorrência foi escrito de tal forma que crie o mínimo de conteção possível.

Author:

gualberto

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	InMemoryDataSet.DatasetPreparer
static interface	InMemoryDataSet.Filter
static interface	InMemoryDataSet.FilterAfter
class	InMemoryDataSet.Query

Method Summary

Modifier and Type	Method and Description
void	addIndex(java.lang.String name, java.lang.String[] columns)
void	addObservingTable(java.lang.String tableName)
java.lang.Object	getColumnValue(int col, java.lang.Object[] row)
java.lang.Object	getColumnValue(java.lang.String name, java.lang.Object[] row)
static InMemoryDataSet	getDataSet(java.lang.String id, JdbcWrapper jdbc, InMemoryDataSet.DatasetPreparer preparer)
static void	invalidateAll()
static void	invalidateAll(boolean notifyCluster)
static void	invalidateById(java.lang.String id)
static void	invalidateById(java.lang.String id, boolean notifyCluster)
InMemoryDataSet.Query	query()
static void	tableWasModified(java.lang.String tableName)
static void	tableWasModified(java.lang.String tableName, boolean notifyCluster)

Methods inherited from class java.lang.Object

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

Method Detail

addObservingTable

public void addObservingTable(java.lang.String tableName)

addIndex

public void addIndex(java.lang.String name,
                     java.lang.String[] columns)

getColumnValue

public java.lang.Object getColumnValue(java.lang.String name,
                                       java.lang.Object[] row)

getColumnValue

public java.lang.Object getColumnValue(int col,
                                       java.lang.Object[] row)

getDataSet

public static InMemoryDataSet getDataSet(java.lang.String id,
                                         JdbcWrapper jdbc,
                                         InMemoryDataSet.DatasetPreparer preparer)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

invalidateById

public static void invalidateById(java.lang.String id,
                                  boolean notifyCluster)

invalidateById

public static void invalidateById(java.lang.String id)

invalidateAll

public static void invalidateAll()

invalidateAll

public static void invalidateAll(boolean notifyCluster)

tableWasModified

public static void tableWasModified(java.lang.String tableName)

tableWasModified

public static void tableWasModified(java.lang.String tableName,
                                    boolean notifyCluster)

query

public InMemoryDataSet.Query query()