public class KettleDatabaseRepositoryDatabaseDelegate extends KettleDatabaseRepositoryBaseDelegate
Constructor and Description |
---|
KettleDatabaseRepositoryDatabaseDelegate(KettleDatabaseRepository repository) |
Modifier and Type | Method and 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) |
quote, quoteTable
public KettleDatabaseRepositoryDatabaseDelegate(KettleDatabaseRepository repository)
public org.pentaho.di.repository.ObjectId getDatabaseID(String name) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String getDatabaseTypeCode(org.pentaho.di.repository.ObjectId id_database_type) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String getDatabaseConTypeCode(org.pentaho.di.repository.ObjectId id_database_contype) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getDatabase(org.pentaho.di.repository.ObjectId id_database) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getDatabaseAttribute(org.pentaho.di.repository.ObjectId id_database_attribute) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public Collection<org.pentaho.di.core.RowMetaAndData> getDatabaseAttributes() throws org.pentaho.di.core.exception.KettleDatabaseException, org.pentaho.di.core.exception.KettleValueException
org.pentaho.di.core.exception.KettleDatabaseException
org.pentaho.di.core.exception.KettleValueException
public org.pentaho.di.core.database.DatabaseMeta loadDatabaseMeta(org.pentaho.di.repository.ObjectId id_database) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void saveDatabaseMeta(org.pentaho.di.core.database.DatabaseMeta databaseMeta) throws org.pentaho.di.core.exception.KettleException
databaseMeta
- The database metadata object to storeorg.pentaho.di.core.exception.KettleException
- if an error occurs.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
org.pentaho.di.core.exception.KettleException
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
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.repository.ObjectId getDatabaseTypeID(String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.repository.ObjectId getDatabaseConTypeID(String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void deleteDatabaseMeta(String databaseName) throws org.pentaho.di.core.exception.KettleException
databaseName
- The name of the connection to removeorg.pentaho.di.core.exception.KettleException
- In case something went wrong: database error, insufficient permissions, depending objects, etc.public void delDatabase(org.pentaho.di.repository.ObjectId id_database) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delDatabaseAttributes(org.pentaho.di.repository.ObjectId id_database) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrDatabases() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrDatabases(org.pentaho.di.repository.ObjectId id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrDatabaseAttributes(org.pentaho.di.repository.ObjectId id_database) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException