org.pentaho.platform.plugin.services.metadata

Class PentahoMetadataDomainRepository

java.lang.Object

org.pentaho.platform.plugin.services.metadata.PentahoMetadataDomainRepository

All Implemented Interfaces:

org.pentaho.metadata.repository.IMetadataDomainRepository, IAclAwarePentahoMetadataDomainRepositoryImporter, IModelAnnotationsAwareMetadataDomainRepositoryImporter, IPentahoMetadataDomainRepositoryExporter, IPentahoMetadataDomainRepositoryImporter

Direct Known Subclasses:

CachingPentahoMetadataDomainRepository, PentahoMondrianDomainRepository, SecurityAwarePentahoMetadataDomainRepository

public class PentahoMetadataDomainRepository
extends Object
implements org.pentaho.metadata.repository.IMetadataDomainRepository, IModelAnnotationsAwareMetadataDomainRepositoryImporter, IAclAwarePentahoMetadataDomainRepositoryImporter, IPentahoMetadataDomainRepositoryExporter

Handles the storage and retrieval of Pentaho Metada Domain objects in a repository. It does this by using a pre-defined system location (defined by PentahoMetadataDomainRepositoryInfo) as the storage location for the Domain files and associated locale files.

Since Domain IDs are the unique identifier for Pentaho Metadata domains and may contain any character (including repository folder separator character(s) like '/', a UUID will be created to store each file. The metadata for the file will be used to store the information (such as the Domain ID).

Author:

David M. Kincade

Field Summary

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

Modifier	Constructor and Description
	PentahoMetadataDomainRepository(IUnifiedRepository repository) Creates an instance of this class providing the IUnifiedRepository repository backend.
protected	PentahoMetadataDomainRepository(IUnifiedRepository repository, RepositoryUtils repositoryUtils, org.pentaho.metadata.util.XmiParser xmiParser, org.pentaho.metadata.util.LocalizationUtil localizationUtil) Helper constructor used for setting other objects in this class

Method Summary

Modifier and Type	Method and Description
void	addLocalizationFile(String domainId, String locale, InputStream inputStream, boolean overwrite)
void	addLocalizationFile(String domainId, String locale, Properties properties) Adds a set of properties as a locale properties file for the specified Domain ID
void	createOrUpdateAnnotationsXml(RepositoryFile domainFile, RepositoryFile annotationsFile, String annotationsXml)
protected RepositoryFile	createUniqueFile(String domainId, String locale, SimpleRepositoryFileData data) Creates a new repository file (with the supplied data) and applies the proper metadata to this file.
protected String	endsWithXmi(String value)
void	flushDomains() flush the domains from memory
String	generateRowLevelSecurityConstraint(org.pentaho.metadata.model.LogicalModel model)
RepositoryFileAcl	getAclFor(String domainId)
protected IAclNodeHelper	getAclHelper()
RepositoryFile	getAnnotationsXmlFile(RepositoryFile domainFile)
org.pentaho.metadata.model.Domain	getDomain(String domainId) retrieve a domain from the repo.
Map<String,InputStream>	getDomainFilesData(String domainId)
protected String	getDomainIdFromXmi(StringBuilder sb)
Set<String>	getDomainIds() return a list of all the domain ids in the repository.
protected org.pentaho.metadata.util.LocalizationUtil	getLocalizationUtil()
protected org.apache.commons.logging.Log	getLogger()
protected RepositoryFile	getMetadataDir()
protected RepositoryFile	getMetadataRepositoryFile(String domainId) Accesses the metadata mapping (with 1 retry) to find the metadata file for the specified domainId
protected IUnifiedRepository	getRepository()
protected RepositoryUtils	getRepositoryUtils()
protected org.pentaho.metadata.util.XmiParser	getXmiParser()
boolean	hasAccess(int accessType, org.pentaho.metadata.model.concept.IConcept aclHolder) The aclHolder cannot be null unless the access type requested is ACCESS_TYPE_SCHEMA_ADMIN.
boolean	hasAccessFor(String domainId)
protected boolean	isDomainIdXmiEqualsOrNotPresent(String domainId, String domainIdXmi)
String	loadAnnotationsXml(String domainId)
protected void	loadLocaleStrings(String domainId, org.pentaho.metadata.model.Domain domain)
protected Properties	loadProperties(RepositoryFile bundle)
protected String	noXmi(String value)
void	reloadDomains() reload domains from disk
void	removeDomain(String domainId) remove a domain from disk and memory.
void	removeModel(String domainId, String modelId) remove a model from a domain which is stored either on a disk or memory.
protected String	replaceDomainId(StringBuilder sb, String domainId)
protected String	resolveAnnotationsFilePath(RepositoryFile domainFile)
void	setAclFor(String domainId, RepositoryFileAcl acl)
protected void	setLocalizationUtil(org.pentaho.metadata.util.LocalizationUtil localizationUtil)
protected void	setRepository(IUnifiedRepository repository)
protected void	setRepositoryUtils(RepositoryUtils repositoryUtils)
protected void	setXmiParser(org.pentaho.metadata.util.XmiParser xmiParser)
void	storeAnnotationsXml(String domainId, String annotationsXml)
void	storeDomain(org.pentaho.metadata.model.Domain domain, boolean overwrite) Store a domain to the repository.
void	storeDomain(InputStream inputStream, String domainId, boolean overwrite) Stores a domain to the repository directly as an Input Stream
void	storeDomain(InputStream inputStream, String domainId, boolean overwrite, RepositoryFileAcl acl)
protected String	toString(RepositoryFile file)

Methods inherited from class java.lang.Object

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

Constructor Detail

PentahoMetadataDomainRepository

public PentahoMetadataDomainRepository(IUnifiedRepository repository)

Creates an instance of this class providing the IUnifiedRepository repository backend.

Parameters:

repository - the IUnifiedRepository in which data will be stored / retrieved

PentahoMetadataDomainRepository

protected PentahoMetadataDomainRepository(IUnifiedRepository repository,
                                          RepositoryUtils repositoryUtils,
                                          org.pentaho.metadata.util.XmiParser xmiParser,
                                          org.pentaho.metadata.util.LocalizationUtil localizationUtil)

Helper constructor used for setting other objects in this class

Parameters:

repository - the IUnifiedRepository in which data will be stored / retrieved

repositoryUtils - utility class for working inside the repository
(NOTE: null is acceptable and will create a default instance)

xmiParser - the parser class for serializing / de-serializing Domain objects
(NOTE: null is acceptable and will create a default instance)

localizationUtil - the object used to add locale bundles into a Pentaho Metadata Domain object
(NOTE: null is acceptable and will create a default instance)

Method Detail

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

Store a domain to the repository. The domain should persist between JVM restarts.

Specified by:

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

Parameters:

domain - domain object to store

overwrite - if true, overwrite existing domain

Throws:

org.pentaho.metadata.repository.DomainIdNullException - if domain id is null or empty

org.pentaho.metadata.repository.DomainAlreadyExistsException - if a domain with the same Domain ID already exists in the repository and overwrite == false

org.pentaho.metadata.repository.DomainStorageException - if there is a problem storing the domain

endsWithXmi

protected String endsWithXmi(String value)

noXmi

protected String noXmi(String value)

replaceDomainId

protected String replaceDomainId(StringBuilder sb,
                                 String domainId)

getDomainIdFromXmi

protected String getDomainIdFromXmi(StringBuilder sb)

isDomainIdXmiEqualsOrNotPresent

protected boolean isDomainIdXmiEqualsOrNotPresent(String domainId,
                                                  String domainIdXmi)

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

Stores a domain to the repository directly as an Input Stream

Specified by:

storeDomain in interface IPentahoMetadataDomainRepositoryImporter

Parameters:

inputStream -

domainId -

overwrite -

Throws:

org.pentaho.metadata.repository.DomainIdNullException

org.pentaho.metadata.repository.DomainAlreadyExistsException

org.pentaho.metadata.repository.DomainStorageException

storeDomain

public void storeDomain(InputStream inputStream,
                        String domainId,
                        boolean overwrite,
                        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

getAclHelper

protected IAclNodeHelper getAclHelper()

setAclFor

public void setAclFor(String domainId,
                      RepositoryFileAcl acl)

Specified by:

setAclFor in interface IAclAwarePentahoMetadataDomainRepositoryImporter

getAclFor

public RepositoryFileAcl getAclFor(String domainId)

Specified by:

getAclFor in interface IAclAwarePentahoMetadataDomainRepositoryImporter

hasAccessFor

public boolean hasAccessFor(String domainId)

Specified by:

hasAccessFor in interface IAclAwarePentahoMetadataDomainRepositoryImporter

getDomainFilesData

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

Specified by:

getDomainFilesData in interface IPentahoMetadataDomainRepositoryExporter

getDomain

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

retrieve a domain from the repo. This does lazy loading of the repo, so it calls reloadDomains() if not already loaded.

Specified by:

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

Parameters:

domainId - domain to get from the repository

Returns:

domain object

getDomainIds

public Set<String> getDomainIds()

return a list of all the domain ids in the repository. triggers a call to reloadDomains if necessary.

Specified by:

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

Returns:

the domain Ids.

removeDomain

public void removeDomain(String domainId)

remove a domain from disk and memory.

Specified by:

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

Specified by:

removeDomain in interface IPentahoMetadataDomainRepositoryImporter

Parameters:

domainId -

removeModel

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

remove a model from a domain which is stored either on a disk or memory.

Specified by:

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

Parameters:

domainId -

modelId -

Throws:

org.pentaho.metadata.repository.DomainIdNullException

org.pentaho.metadata.repository.DomainStorageException

reloadDomains

public void reloadDomains()

reload domains from disk

Specified by:

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

flushDomains

public void flushDomains()

flush the domains from memory

Specified by:

flushDomains 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)

The aclHolder cannot be null unless the access type requested is ACCESS_TYPE_SCHEMA_ADMIN.

Specified by:

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

addLocalizationFile

public void addLocalizationFile(String domainId,
                                String locale,
                                Properties properties)
                         throws org.pentaho.metadata.repository.DomainStorageException

Adds a set of properties as a locale properties file for the specified Domain ID

Parameters:

domainId - the domain ID for which this properties file will be added

locale - the locale for which this properties file will be added

properties - the properties to be added

Throws:

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

getMetadataDir

protected RepositoryFile getMetadataDir()

loadLocaleStrings

protected void loadLocaleStrings(String domainId,
                                 org.pentaho.metadata.model.Domain domain)

loadProperties

protected Properties loadProperties(RepositoryFile bundle)

createUniqueFile

protected RepositoryFile createUniqueFile(String domainId,
                                          String locale,
                                          SimpleRepositoryFileData data)

Creates a new repository file (with the supplied data) and applies the proper metadata to this file.

Parameters:

domainId - the Domain id associated with this file

locale - the locale associated with this file (or null for a domain file)

data - the data to put in the file

Returns:

the repository file created

getRepository

protected IUnifiedRepository getRepository()

getXmiParser

protected org.pentaho.metadata.util.XmiParser getXmiParser()

getRepositoryUtils

protected RepositoryUtils getRepositoryUtils()

getLocalizationUtil

protected org.pentaho.metadata.util.LocalizationUtil getLocalizationUtil()

setRepository

protected void setRepository(IUnifiedRepository repository)

setXmiParser

protected void setXmiParser(org.pentaho.metadata.util.XmiParser xmiParser)

setRepositoryUtils

protected void setRepositoryUtils(RepositoryUtils repositoryUtils)

setLocalizationUtil

protected void setLocalizationUtil(org.pentaho.metadata.util.LocalizationUtil localizationUtil)

toString

protected String toString(RepositoryFile file)

getMetadataRepositoryFile

protected RepositoryFile getMetadataRepositoryFile(String domainId)

Accesses the metadata mapping (with 1 retry) to find the metadata file for the specified domainId

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

getAnnotationsXmlFile

public RepositoryFile getAnnotationsXmlFile(RepositoryFile domainFile)

createOrUpdateAnnotationsXml

public void createOrUpdateAnnotationsXml(RepositoryFile domainFile,
                                         RepositoryFile annotationsFile,
                                         String annotationsXml)

resolveAnnotationsFilePath

protected String resolveAnnotationsFilePath(RepositoryFile domainFile)

getLogger

protected org.apache.commons.logging.Log getLogger()