org.pentaho.di.repository.kdr.delegates

Class KettleDatabaseRepositoryMetaStoreDelegate

java.lang.Object

org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate

org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryMetaStoreDelegate

public class KettleDatabaseRepositoryMetaStoreDelegate
extends KettleDatabaseRepositoryBaseDelegate

Constructor Summary

Constructors

Constructor and Description
KettleDatabaseRepositoryMetaStoreDelegate(KettleDatabaseRepository repository)

Method Summary

Methods

Modifier and Type	Method and Description
void	deleteElement(org.pentaho.di.repository.ObjectId elementId)
void	deleteElementType(org.pentaho.di.repository.ObjectId elementTypeId)
void	deleteNamespace(org.pentaho.di.repository.ObjectId namespaceId)
String	encodeAttributeValue(Object object)
org.pentaho.di.core.RowMetaAndData	getElement(org.pentaho.di.repository.LongObjectId elementId)
org.pentaho.di.core.RowMetaAndData	getElementAttribute(org.pentaho.di.repository.LongObjectId elementAttributeId)
Collection<org.pentaho.di.core.RowMetaAndData>	getElementAttributes(org.pentaho.di.repository.ObjectId elementId, org.pentaho.di.repository.ObjectId parentAttributeId)
org.pentaho.di.repository.LongObjectId	getElementId(org.pentaho.di.repository.LongObjectId elementTypeId, String elementName)
Collection<org.pentaho.di.core.RowMetaAndData>	getElements(org.pentaho.di.repository.LongObjectId elementTypeId)
org.pentaho.di.core.RowMetaAndData	getElementType(org.pentaho.di.repository.LongObjectId elementTypeId)
org.pentaho.di.repository.LongObjectId	getElementTypeId(org.pentaho.di.repository.LongObjectId namespaceId, String elementTypeName)
Collection<org.pentaho.di.core.RowMetaAndData>	getElementTypes(org.pentaho.di.repository.LongObjectId namespaceId)
org.pentaho.di.repository.LongObjectId	getNamespaceId(String namespace) Retrieve the ID for a namespace
Collection<org.pentaho.di.core.RowMetaAndData>	getNamespaces()
org.pentaho.di.repository.ObjectId	insertElement(org.pentaho.metastore.api.IMetaStoreElementType elementType, org.pentaho.metastore.api.IMetaStoreElement element)
org.pentaho.di.repository.ObjectId	insertElementType(KDBRMetaStoreElementType type)
org.pentaho.di.repository.ObjectId	insertNamespace(String namespace)
Object	parseAttributeValue(String value) supported types:
KDBRMetaStoreElement	parseElement(org.pentaho.metastore.api.IMetaStoreElementType elementType, org.pentaho.di.core.RowMetaAndData elementRow)
KDBRMetaStoreElementType	parseElementType(String namespace, org.pentaho.di.repository.ObjectId namespaceId, org.pentaho.di.core.RowMetaAndData elementTypeRow)
org.pentaho.di.repository.ObjectId	updateElementType(org.pentaho.di.repository.ObjectId namespaceId, org.pentaho.di.repository.ObjectId elementTypeId, org.pentaho.metastore.api.IMetaStoreElementType type)
org.pentaho.di.repository.ObjectId	verifyNamespace(String namespace)

Methods inherited from class org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate

quote, quoteTable

Methods inherited from class java.lang.Object

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

Constructor Detail

KettleDatabaseRepositoryMetaStoreDelegate

public KettleDatabaseRepositoryMetaStoreDelegate(KettleDatabaseRepository repository)

Method Detail

getNamespaceId

public org.pentaho.di.repository.LongObjectId getNamespaceId(String namespace)
                                                      throws org.pentaho.di.core.exception.KettleException

Retrieve the ID for a namespace

Parameters:

namespace - The namespace to look up

Returns:

the ID of the namespace

Throws:

org.pentaho.di.core.exception.KettleException

verifyNamespace

public org.pentaho.di.repository.ObjectId verifyNamespace(String namespace)
                                                   throws org.pentaho.metastore.api.exceptions.MetaStoreException

Throws:

org.pentaho.metastore.api.exceptions.MetaStoreException

getElementTypeId

public org.pentaho.di.repository.LongObjectId getElementTypeId(org.pentaho.di.repository.LongObjectId namespaceId,
                                                      String elementTypeName)
                                                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getElementId

public org.pentaho.di.repository.LongObjectId getElementId(org.pentaho.di.repository.LongObjectId elementTypeId,
                                                  String elementName)
                                                    throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getElementType

public org.pentaho.di.core.RowMetaAndData getElementType(org.pentaho.di.repository.LongObjectId elementTypeId)
                                                  throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getElement

public org.pentaho.di.core.RowMetaAndData getElement(org.pentaho.di.repository.LongObjectId elementId)
                                              throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getElementAttribute

public org.pentaho.di.core.RowMetaAndData getElementAttribute(org.pentaho.di.repository.LongObjectId elementAttributeId)
                                                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getNamespaces

public Collection<org.pentaho.di.core.RowMetaAndData> getNamespaces()
                                                             throws org.pentaho.di.core.exception.KettleDatabaseException,
                                                                    org.pentaho.di.core.exception.KettleValueException

Throws:

org.pentaho.di.core.exception.KettleDatabaseException

org.pentaho.di.core.exception.KettleValueException

getElementTypes

public Collection<org.pentaho.di.core.RowMetaAndData> getElementTypes(org.pentaho.di.repository.LongObjectId namespaceId)
                                                               throws org.pentaho.di.core.exception.KettleDatabaseException,
                                                                      org.pentaho.di.core.exception.KettleValueException

Throws:

org.pentaho.di.core.exception.KettleDatabaseException

org.pentaho.di.core.exception.KettleValueException

getElements

public Collection<org.pentaho.di.core.RowMetaAndData> getElements(org.pentaho.di.repository.LongObjectId elementTypeId)
                                                           throws org.pentaho.di.core.exception.KettleDatabaseException,
                                                                  org.pentaho.di.core.exception.KettleValueException

Throws:

org.pentaho.di.core.exception.KettleDatabaseException

org.pentaho.di.core.exception.KettleValueException

getElementAttributes

public Collection<org.pentaho.di.core.RowMetaAndData> getElementAttributes(org.pentaho.di.repository.ObjectId elementId,
                                                                  org.pentaho.di.repository.ObjectId parentAttributeId)
                                                                    throws org.pentaho.di.core.exception.KettleDatabaseException,
                                                                           org.pentaho.di.core.exception.KettleValueException

Throws:

org.pentaho.di.core.exception.KettleDatabaseException

org.pentaho.di.core.exception.KettleValueException

insertNamespace

public org.pentaho.di.repository.ObjectId insertNamespace(String namespace)
                                                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertElementType

public org.pentaho.di.repository.ObjectId insertElementType(KDBRMetaStoreElementType type)
                                                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

updateElementType

public org.pentaho.di.repository.ObjectId updateElementType(org.pentaho.di.repository.ObjectId namespaceId,
                                                   org.pentaho.di.repository.ObjectId elementTypeId,
                                                   org.pentaho.metastore.api.IMetaStoreElementType type)
                                                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

parseElementType

public KDBRMetaStoreElementType parseElementType(String namespace,
                                        org.pentaho.di.repository.ObjectId namespaceId,
                                        org.pentaho.di.core.RowMetaAndData elementTypeRow)
                                          throws org.pentaho.di.core.exception.KettleValueException

Throws:

org.pentaho.di.core.exception.KettleValueException

deleteElementType

public void deleteElementType(org.pentaho.di.repository.ObjectId elementTypeId)
                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

deleteNamespace

public void deleteNamespace(org.pentaho.di.repository.ObjectId namespaceId)
                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

parseElement

public KDBRMetaStoreElement parseElement(org.pentaho.metastore.api.IMetaStoreElementType elementType,
                                org.pentaho.di.core.RowMetaAndData elementRow)
                                  throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

parseAttributeValue

public Object parseAttributeValue(String value)
                           throws Exception

supported types:

 S : String (java.lang.String)
 D : Date (java.util.Date)
 N : Number (Double)
 I : Integer (Long)
 B : Boolean (Boolean)

 Examples
 S:Pentaho Data Integration
 D:2013/08/23 17:25:00
 N:1039348.9347
 I:12345678
 B:true
 

Parameters:

value -

Returns:

The native value

Throws:

Exception - in case of conversion trouble

encodeAttributeValue

public String encodeAttributeValue(Object object)
                            throws Exception

Throws:

Exception

insertElement

public org.pentaho.di.repository.ObjectId insertElement(org.pentaho.metastore.api.IMetaStoreElementType elementType,
                                               org.pentaho.metastore.api.IMetaStoreElement element)
                                                 throws org.pentaho.metastore.api.exceptions.MetaStoreException

Throws:

org.pentaho.metastore.api.exceptions.MetaStoreException

deleteElement

public void deleteElement(org.pentaho.di.repository.ObjectId elementId)
                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException