Class KettleDatabaseRepositoryDatabaseDelegate

    • 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