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

Field Summary

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

log, repository

Constructor Summary

Constructors

Constructor and Description
KettleDatabaseRepositoryMetaStoreDelegate(KettleDatabaseRepository repository)

Method Summary

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

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

quote, quoteTable

Methods inherited from class java.lang.Object

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

Constructor Detail

KettleDatabaseRepositoryMetaStoreDelegate

public KettleDatabaseRepositoryMetaStoreDelegate(KettleDatabaseRepository repository)

Method Detail

getNamespaceId

public LongObjectId getNamespaceId(String namespace)
                            throws KettleException

Retrieve the ID for a namespace

Parameters:

namespace - The namespace to look up

Returns:

the ID of the namespace

Throws:

KettleException

verifyNamespace

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

Throws:

org.pentaho.metastore.api.exceptions.MetaStoreException

getElementTypeId

public LongObjectId getElementTypeId(LongObjectId namespaceId,
                                     String elementTypeName)
                              throws KettleException

Throws:

KettleException

getElementId

public LongObjectId getElementId(LongObjectId elementTypeId,
                                 String elementName)
                          throws KettleException

Throws:

KettleException

getElementType

public RowMetaAndData getElementType(LongObjectId elementTypeId)
                              throws KettleException

Throws:

KettleException

getElement

public RowMetaAndData getElement(LongObjectId elementId)
                          throws KettleException

Throws:

KettleException

getElementAttribute

public RowMetaAndData getElementAttribute(LongObjectId elementAttributeId)
                                   throws KettleException

Throws:

KettleException

getNamespaces

public Collection<RowMetaAndData> getNamespaces()
                                         throws KettleDatabaseException,
                                                KettleValueException

Throws:

KettleDatabaseException

KettleValueException

getElementTypes

public Collection<RowMetaAndData> getElementTypes(LongObjectId namespaceId)
                                           throws KettleDatabaseException,
                                                  KettleValueException

Throws:

KettleDatabaseException

KettleValueException

getElements

public Collection<RowMetaAndData> getElements(LongObjectId elementTypeId)
                                       throws KettleDatabaseException,
                                              KettleValueException

Throws:

KettleDatabaseException

KettleValueException

getElementAttributes

public Collection<RowMetaAndData> getElementAttributes(ObjectId elementId,
                                                       ObjectId parentAttributeId)
                                                throws KettleDatabaseException,
                                                       KettleValueException

Throws:

KettleDatabaseException

KettleValueException

insertNamespace

public ObjectId insertNamespace(String namespace)
                         throws KettleException

Throws:

KettleException

insertElementType

public ObjectId insertElementType(KDBRMetaStoreElementType type)
                           throws KettleException

Throws:

KettleException

updateElementType

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

Throws:

KettleException

parseElementType

public KDBRMetaStoreElementType parseElementType(String namespace,
                                                 ObjectId namespaceId,
                                                 RowMetaAndData elementTypeRow)
                                          throws KettleValueException

Throws:

KettleValueException

deleteElementType

public void deleteElementType(ObjectId elementTypeId)
                       throws KettleException

Throws:

KettleException

deleteNamespace

public void deleteNamespace(ObjectId namespaceId)
                     throws KettleException

Throws:

KettleException

parseElement

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

Throws:

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 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(ObjectId elementId)
                   throws KettleException

Throws:

KettleException