Package org.pentaho.di.repository.kdr.delegates

Class KettleDatabaseRepositoryDatabaseDelegate

java.lang.Object

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

org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryDatabaseDelegate

public class KettleDatabaseRepositoryDatabaseDelegate
extends KettleDatabaseRepositoryBaseDelegate

Field Summary

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

log, repository

Constructor Summary

Constructors

Constructor	Description
KettleDatabaseRepositoryDatabaseDelegate(KettleDatabaseRepository repository)

Method Summary

Modifier and Type	Method	Description
void	delDatabase(org.pentaho.di.repository.ObjectId id_database)
void	delDatabaseAttributes(org.pentaho.di.repository.ObjectId id_database)
void	deleteDatabaseMeta(String databaseName)	Remove a database connection from the repository
org.pentaho.di.core.RowMetaAndData	getDatabase(org.pentaho.di.repository.ObjectId id_database)
org.pentaho.di.core.RowMetaAndData	getDatabaseAttribute(org.pentaho.di.repository.ObjectId id_database_attribute)
Collection<org.pentaho.di.core.RowMetaAndData>	getDatabaseAttributes()
String	getDatabaseConTypeCode(org.pentaho.di.repository.ObjectId id_database_contype)
org.pentaho.di.repository.ObjectId	getDatabaseConTypeID(String code)
org.pentaho.di.repository.ObjectId	getDatabaseID(String name)
String	getDatabaseTypeCode(org.pentaho.di.repository.ObjectId id_database_type)
org.pentaho.di.repository.ObjectId	getDatabaseTypeID(String code)
int	getNrDatabaseAttributes(org.pentaho.di.repository.ObjectId id_database)
int	getNrDatabases()
int	getNrDatabases(org.pentaho.di.repository.ObjectId id_transformation)
org.pentaho.di.repository.ObjectId	insertDatabase(String name, String type, String access, String host, String dbname, String port, String user, String pass, String servername, String data_tablespace, String index_tablespace)
org.pentaho.di.core.database.DatabaseMeta	loadDatabaseMeta(org.pentaho.di.repository.ObjectId id_database)	Load the Database Info
void	saveDatabaseMeta(org.pentaho.di.core.database.DatabaseMeta databaseMeta)	Saves the database information into a given repository.
void	updateDatabase(org.pentaho.di.repository.ObjectId id_database, String name, String type, String access, String host, String dbname, String port, String user, String pass, String servername, String data_tablespace, String index_tablespace)

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 Details

KettleDatabaseRepositoryDatabaseDelegate

public KettleDatabaseRepositoryDatabaseDelegate(KettleDatabaseRepository repository)

Method Details

getDatabaseID

public org.pentaho.di.repository.ObjectId getDatabaseID(String name)
                                                 throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getDatabaseTypeCode

public String getDatabaseTypeCode(org.pentaho.di.repository.ObjectId id_database_type)
                           throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getDatabaseConTypeCode

public String getDatabaseConTypeCode(org.pentaho.di.repository.ObjectId id_database_contype)
                              throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getDatabase

public org.pentaho.di.core.RowMetaAndData getDatabase(org.pentaho.di.repository.ObjectId id_database)
                                               throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getDatabaseAttribute

public org.pentaho.di.core.RowMetaAndData getDatabaseAttribute(org.pentaho.di.repository.ObjectId id_database_attribute)
                                                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getDatabaseAttributes

public Collection<org.pentaho.di.core.RowMetaAndData> getDatabaseAttributes()
                                                                     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

loadDatabaseMeta

public org.pentaho.di.core.database.DatabaseMeta loadDatabaseMeta(org.pentaho.di.repository.ObjectId id_database)
                                                           throws org.pentaho.di.core.exception.KettleException

Load the Database Info

Throws:

org.pentaho.di.core.exception.KettleException

saveDatabaseMeta

public void saveDatabaseMeta(org.pentaho.di.core.database.DatabaseMeta databaseMeta)
                      throws org.pentaho.di.core.exception.KettleException

Saves the database information into a given repository.

Parameters:

databaseMeta - The database metadata object to store

Throws:

org.pentaho.di.core.exception.KettleException - if an error occurs.

insertDatabase

public org.pentaho.di.repository.ObjectId insertDatabase(String name,
 String type,
 String access,
 String host,
 String dbname,
 String port,
 String user,
 String pass,
 String servername,
 String data_tablespace,
 String index_tablespace)
                                                  throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

updateDatabase

public void updateDatabase(org.pentaho.di.repository.ObjectId id_database,
 String name,
 String type,
 String access,
 String host,
 String dbname,
 String port,
 String user,
 String pass,
 String servername,
 String data_tablespace,
 String index_tablespace)
                    throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getDatabaseTypeID

public org.pentaho.di.repository.ObjectId getDatabaseTypeID(String code)
                                                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getDatabaseConTypeID

public org.pentaho.di.repository.ObjectId getDatabaseConTypeID(String code)
                                                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

deleteDatabaseMeta

public void deleteDatabaseMeta(String databaseName)
                        throws org.pentaho.di.core.exception.KettleException

Remove a database connection from the repository

Parameters:

databaseName - The name of the connection to remove

Throws:

org.pentaho.di.core.exception.KettleException - In case something went wrong: database error, insufficient permissions, depending objects, etc.

delDatabase

public void delDatabase(org.pentaho.di.repository.ObjectId id_database)
                 throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delDatabaseAttributes

public void delDatabaseAttributes(org.pentaho.di.repository.ObjectId id_database)
                           throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getNrDatabases

public int getNrDatabases()
                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getNrDatabases

public int getNrDatabases(org.pentaho.di.repository.ObjectId id_transformation)
                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getNrDatabaseAttributes

public int getNrDatabaseAttributes(org.pentaho.di.repository.ObjectId id_database)
                            throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException