org.pentaho.platform.plugin.services.metadata

Class SessionCachingMetadataDomainRepository

java.lang.Object

org.pentaho.platform.plugin.services.metadata.SessionCachingMetadataDomainRepository

All Implemented Interfaces:

org.pentaho.metadata.repository.IMetadataDomainRepository, org.pentaho.platform.api.engine.ILogoutListener, IAclAwarePentahoMetadataDomainRepositoryImporter, IModelAnnotationsAwareMetadataDomainRepositoryImporter, IPentahoMetadataDomainRepositoryExporter, IPentahoMetadataDomainRepositoryImporter

public class SessionCachingMetadataDomainRepository
extends Object
implements org.pentaho.metadata.repository.IMetadataDomainRepository, IPentahoMetadataDomainRepositoryExporter, org.pentaho.platform.api.engine.ILogoutListener, IAclAwarePentahoMetadataDomainRepositoryImporter, IModelAnnotationsAwareMetadataDomainRepositoryImporter

This is the platform implementation which provides session-based caching for an existing IMetadataDomainRepository.

Author:

Jordan Ganoff (jganoff@pentaho.com)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static interface	SessionCachingMetadataDomainRepository.CacheIteratorCallback Simple callback interface to facilitate iterating over cache keys
static class	SessionCachingMetadataDomainRepository.CacheKey this as a public class so that if necessary someone can get access to a session key and clear the cache in their own way via javascript rule / etc

Field Summary

Fields

Modifier and Type	Field and Description
static String	CACHE_REGION Public so others know where we're caching our objects
protected SessionCachingMetadataDomainRepository.CacheIteratorCallback	REMOVE_ALL_CALLBACK Removes all keys it encounters from the known cache region

Fields inherited from interface org.pentaho.metadata.repository.IMetadataDomainRepository

ACCESS_TYPE_ADMIN, ACCESS_TYPE_DELETE, ACCESS_TYPE_READ, ACCESS_TYPE_SCHEMA_ADMIN, ACCESS_TYPE_UPDATE, ACCESS_TYPE_WRITE

Fields inherited from interface org.pentaho.platform.plugin.services.metadata.IModelAnnotationsAwareMetadataDomainRepositoryImporter

ANNOTATIONS_FILE_ID_POSTFIX, PROPERTY_NAME_ANNOTATIONS

Constructor Summary

Constructors

Constructor and Description
SessionCachingMetadataDomainRepository(org.pentaho.metadata.repository.IMetadataDomainRepository delegate) Wraps the provided domain repository to provide session-based caching of domains.

Method Summary

Modifier and Type	Method and Description
void	addLocalizationFile(String domainId, String locale, InputStream inputStream, boolean overwrite)
protected void	clearDomainIdsFromCache() Remove domain ID cache for all sessions
protected void	clearDomainIdsFromCache(org.pentaho.platform.api.engine.IPentahoSession session) Remove domain ID cache for a given session
void	flushDomains()
protected void	flushDomains(org.pentaho.platform.api.engine.IPentahoSession session)
protected void	forAllKeys(SessionCachingMetadataDomainRepository.CacheIteratorCallback callback) Calls the callback for every key in the cache region
protected void	forAllKeysInSession(org.pentaho.platform.api.engine.IPentahoSession session, SessionCachingMetadataDomainRepository.CacheIteratorCallback callback) Calls the callback for every key in the cache region whose session id matches the provided session's id.
protected String	generateDomainIdCacheKeyForSession(org.pentaho.platform.api.engine.IPentahoSession session)
String	generateRowLevelSecurityConstraint(org.pentaho.metadata.model.LogicalModel model)
org.pentaho.platform.api.repository2.unified.RepositoryFileAcl	getAclFor(String domainId)
org.pentaho.metadata.model.Domain	getDomain(String id)
Map<String,InputStream>	getDomainFilesData(String domainId)
Set<String>	getDomainIds()
boolean	hasAccess(int accessType, org.pentaho.metadata.model.concept.IConcept aclHolder)
boolean	hasAccessFor(String domainId)
String	loadAnnotationsXml(String domainId)
void	onLogout(org.pentaho.platform.api.engine.IPentahoSession session)
void	reloadDomains()
void	removeDomain(String domainId)
void	removeModel(String domainId, String modelId)
void	setAclFor(String domainId, org.pentaho.platform.api.repository2.unified.RepositoryFileAcl acl)
void	storeAnnotationsXml(String domainId, String annotationsXml)
void	storeDomain(org.pentaho.metadata.model.Domain domain, boolean overwrite)
void	storeDomain(InputStream inputStream, String domainId, boolean overwrite)
void	storeDomain(InputStream inputStream, String domainId, boolean overwrite, org.pentaho.platform.api.repository2.unified.RepositoryFileAcl acl)

Methods inherited from class java.lang.Object

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

Field Detail

CACHE_REGION

public static String CACHE_REGION

Public so others know where we're caching our objects

REMOVE_ALL_CALLBACK

protected final SessionCachingMetadataDomainRepository.CacheIteratorCallback REMOVE_ALL_CALLBACK

Removes all keys it encounters from the known cache region

Constructor Detail

SessionCachingMetadataDomainRepository

public SessionCachingMetadataDomainRepository(org.pentaho.metadata.repository.IMetadataDomainRepository delegate)

Wraps the provided domain repository to provide session-based caching of domains.

Method Detail

forAllKeys

protected void forAllKeys(SessionCachingMetadataDomainRepository.CacheIteratorCallback callback)

Calls the callback for every key in the cache region

Parameters:

callback - CacheCallback

forAllKeysInSession

protected void forAllKeysInSession(org.pentaho.platform.api.engine.IPentahoSession session,
                                   SessionCachingMetadataDomainRepository.CacheIteratorCallback callback)

Calls the callback for every key in the cache region whose session id matches the provided session's id.

Parameters:

session - Session to use for matching keys

callback - CacheCallback

getDomain

public org.pentaho.metadata.model.Domain getDomain(String id)

Specified by:

getDomain in interface org.pentaho.metadata.repository.IMetadataDomainRepository

reloadDomains

public void reloadDomains()

Specified by:

reloadDomains in interface org.pentaho.metadata.repository.IMetadataDomainRepository

flushDomains

public void flushDomains()

Specified by:

flushDomains in interface org.pentaho.metadata.repository.IMetadataDomainRepository

flushDomains

protected void flushDomains(org.pentaho.platform.api.engine.IPentahoSession session)

clearDomainIdsFromCache

protected void clearDomainIdsFromCache()

Remove domain ID cache for all sessions

clearDomainIdsFromCache

protected void clearDomainIdsFromCache(org.pentaho.platform.api.engine.IPentahoSession session)

Remove domain ID cache for a given session

Parameters:

session -

generateDomainIdCacheKeyForSession

protected String generateDomainIdCacheKeyForSession(org.pentaho.platform.api.engine.IPentahoSession session)

removeDomain

public void removeDomain(String domainId)

Specified by:

removeDomain in interface org.pentaho.metadata.repository.IMetadataDomainRepository

Specified by:

removeDomain in interface IPentahoMetadataDomainRepositoryImporter

storeDomain

public void storeDomain(org.pentaho.metadata.model.Domain domain,
                        boolean overwrite)
                 throws org.pentaho.metadata.repository.DomainIdNullException,
                        org.pentaho.metadata.repository.DomainAlreadyExistsException,
                        org.pentaho.metadata.repository.DomainStorageException

Specified by:

storeDomain in interface org.pentaho.metadata.repository.IMetadataDomainRepository

Throws:

org.pentaho.metadata.repository.DomainIdNullException

org.pentaho.metadata.repository.DomainAlreadyExistsException

org.pentaho.metadata.repository.DomainStorageException

removeModel

public void removeModel(String domainId,
                        String modelId)
                 throws org.pentaho.metadata.repository.DomainIdNullException,
                        org.pentaho.metadata.repository.DomainStorageException

Specified by:

removeModel in interface org.pentaho.metadata.repository.IMetadataDomainRepository

Throws:

org.pentaho.metadata.repository.DomainIdNullException

org.pentaho.metadata.repository.DomainStorageException

getDomainIds

public Set<String> getDomainIds()

Specified by:

getDomainIds in interface org.pentaho.metadata.repository.IMetadataDomainRepository

generateRowLevelSecurityConstraint

public String generateRowLevelSecurityConstraint(org.pentaho.metadata.model.LogicalModel model)

Specified by:

generateRowLevelSecurityConstraint in interface org.pentaho.metadata.repository.IMetadataDomainRepository

hasAccess

public boolean hasAccess(int accessType,
                         org.pentaho.metadata.model.concept.IConcept aclHolder)

Specified by:

hasAccess in interface org.pentaho.metadata.repository.IMetadataDomainRepository

onLogout

public void onLogout(org.pentaho.platform.api.engine.IPentahoSession session)

Specified by:

onLogout in interface org.pentaho.platform.api.engine.ILogoutListener

getDomainFilesData

public Map<String,InputStream> getDomainFilesData(String domainId)

Specified by:

getDomainFilesData in interface IPentahoMetadataDomainRepositoryExporter

storeDomain

public void storeDomain(InputStream inputStream,
                        String domainId,
                        boolean overwrite,
                        org.pentaho.platform.api.repository2.unified.RepositoryFileAcl acl)
                 throws org.pentaho.metadata.repository.DomainIdNullException,
                        org.pentaho.metadata.repository.DomainAlreadyExistsException,
                        org.pentaho.metadata.repository.DomainStorageException

Specified by:

storeDomain in interface IAclAwarePentahoMetadataDomainRepositoryImporter

Throws:

org.pentaho.metadata.repository.DomainIdNullException

org.pentaho.metadata.repository.DomainAlreadyExistsException

org.pentaho.metadata.repository.DomainStorageException

setAclFor

public void setAclFor(String domainId,
                      org.pentaho.platform.api.repository2.unified.RepositoryFileAcl acl)

Specified by:

setAclFor in interface IAclAwarePentahoMetadataDomainRepositoryImporter

getAclFor

public org.pentaho.platform.api.repository2.unified.RepositoryFileAcl getAclFor(String domainId)

Specified by:

getAclFor in interface IAclAwarePentahoMetadataDomainRepositoryImporter

hasAccessFor

public boolean hasAccessFor(String domainId)

Specified by:

hasAccessFor in interface IAclAwarePentahoMetadataDomainRepositoryImporter

storeDomain

public void storeDomain(InputStream inputStream,
                        String domainId,
                        boolean overwrite)
                 throws org.pentaho.metadata.repository.DomainIdNullException,
                        org.pentaho.metadata.repository.DomainAlreadyExistsException,
                        org.pentaho.metadata.repository.DomainStorageException

Specified by:

storeDomain in interface IPentahoMetadataDomainRepositoryImporter

Throws:

org.pentaho.metadata.repository.DomainIdNullException

org.pentaho.metadata.repository.DomainAlreadyExistsException

org.pentaho.metadata.repository.DomainStorageException

addLocalizationFile

public void addLocalizationFile(String domainId,
                                String locale,
                                InputStream inputStream,
                                boolean overwrite)
                         throws org.pentaho.metadata.repository.DomainStorageException

Specified by:

addLocalizationFile in interface IPentahoMetadataDomainRepositoryImporter

Throws:

org.pentaho.metadata.repository.DomainStorageException

loadAnnotationsXml

public String loadAnnotationsXml(String domainId)

Specified by:

loadAnnotationsXml in interface IModelAnnotationsAwareMetadataDomainRepositoryImporter

storeAnnotationsXml

public void storeAnnotationsXml(String domainId,
                                String annotationsXml)

Specified by:

storeAnnotationsXml in interface IModelAnnotationsAwareMetadataDomainRepositoryImporter