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
Method Summary |
void |
delDatabase(ObjectId id_database)
|
void |
delDatabaseAttributes(ObjectId id_database)
|
void |
deleteDatabaseMeta(String databaseName)
Remove a database connection from the repository |
RowMetaAndData |
getDatabase(ObjectId id_database)
|
RowMetaAndData |
getDatabaseAttribute(ObjectId id_database_attribute)
|
Collection<RowMetaAndData> |
getDatabaseAttributes()
|
String |
getDatabaseConTypeCode(ObjectId id_database_contype)
|
ObjectId |
getDatabaseConTypeID(String code)
|
ObjectId |
getDatabaseID(String name)
|
String |
getDatabaseTypeCode(ObjectId id_database_type)
|
ObjectId |
getDatabaseTypeID(String code)
|
int |
getNrDatabaseAttributes(ObjectId id_database)
|
int |
getNrDatabases()
|
int |
getNrDatabases(ObjectId id_transformation)
|
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)
|
DatabaseMeta |
loadDatabaseMeta(ObjectId id_database)
Load the Database Info |
void |
saveDatabaseMeta(DatabaseMeta databaseMeta)
Saves the database information into a given repository. |
void |
updateDatabase(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)
|
KettleDatabaseRepositoryDatabaseDelegate
public KettleDatabaseRepositoryDatabaseDelegate(KettleDatabaseRepository repository)
getDatabaseID
public ObjectId getDatabaseID(String name)
throws KettleException
- Throws:
KettleException
getDatabaseTypeCode
public String getDatabaseTypeCode(ObjectId id_database_type)
throws KettleException
- Throws:
KettleException
getDatabaseConTypeCode
public String getDatabaseConTypeCode(ObjectId id_database_contype)
throws KettleException
- Throws:
KettleException
getDatabase
public RowMetaAndData getDatabase(ObjectId id_database)
throws KettleException
- Throws:
KettleException
getDatabaseAttribute
public RowMetaAndData getDatabaseAttribute(ObjectId id_database_attribute)
throws KettleException
- Throws:
KettleException
getDatabaseAttributes
public Collection<RowMetaAndData> getDatabaseAttributes()
throws KettleDatabaseException,
KettleValueException
- Throws:
KettleDatabaseException
KettleValueException
loadDatabaseMeta
public DatabaseMeta loadDatabaseMeta(ObjectId id_database)
throws KettleException
- Load the Database Info
- Throws:
KettleException
saveDatabaseMeta
public void saveDatabaseMeta(DatabaseMeta databaseMeta)
throws KettleException
- Saves the database information into a given repository.
- Parameters:
databaseMeta
- The database metadata object to store
- Throws:
KettleException
- if an error occurs.
insertDatabase
public 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 KettleException
- Throws:
KettleException
updateDatabase
public void updateDatabase(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 KettleException
- Throws:
KettleException
getDatabaseTypeID
public ObjectId getDatabaseTypeID(String code)
throws KettleException
- Throws:
KettleException
getDatabaseConTypeID
public ObjectId getDatabaseConTypeID(String code)
throws KettleException
- Throws:
KettleException
deleteDatabaseMeta
public void deleteDatabaseMeta(String databaseName)
throws KettleException
- Remove a database connection from the repository
- Parameters:
databaseName
- The name of the connection to remove
- Throws:
KettleException
- In case something went wrong: database error, insufficient permissions, depending objects, etc.
delDatabase
public void delDatabase(ObjectId id_database)
throws KettleException
- Throws:
KettleException
delDatabaseAttributes
public void delDatabaseAttributes(ObjectId id_database)
throws KettleException
- Throws:
KettleException
getNrDatabases
public int getNrDatabases()
throws KettleException
- Throws:
KettleException
getNrDatabases
public int getNrDatabases(ObjectId id_transformation)
throws KettleException
- Throws:
KettleException
getNrDatabaseAttributes
public int getNrDatabaseAttributes(ObjectId id_database)
throws KettleException
- Throws:
KettleException