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
All Methods Instance Methods Concrete Methods 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 repositoryorg.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 Infovoid
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
-
-
-
-
Constructor Detail
-
KettleDatabaseRepositoryDatabaseDelegate
public KettleDatabaseRepositoryDatabaseDelegate(KettleDatabaseRepository repository)
-
-
Method Detail
-
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
-
-