@Test public void testInsertClusterSlave() throws KettleException { ArgumentCaptor<String> argumentTableName = ArgumentCaptor.forClass( String.class ); ArgumentCaptor<RowMetaAndData> argumentTableData = ArgumentCaptor.forClass( RowMetaAndData.class ); doNothing().when( repo.connectionDelegate ).insertTableRow( argumentTableName.capture(), argumentTableData.capture() ); doReturn( new LongObjectId( 357 ) ).when( repo.connectionDelegate ).getNextClusterSlaveID(); SlaveServer testSlave = new SlaveServer( "slave1", "fakelocal", "9081", "fakeuser", "fakepass" ); testSlave.setObjectId( new LongObjectId( 864 ) ); ClusterSchema testSchema = new ClusterSchema( "schema1", Arrays.asList( testSlave ) ); testSchema.setObjectId( new LongObjectId( 159 ) ); ObjectId result = repo.insertClusterSlave( testSchema, testSlave ); RowMetaAndData insertRecord = argumentTableData.getValue(); assertEquals( KettleDatabaseRepository.TABLE_R_CLUSTER_SLAVE, argumentTableName.getValue() ); assertEquals( 3, insertRecord.size() ); assertEquals( ValueMetaInterface.TYPE_INTEGER, insertRecord.getValueMeta( 0 ).getType() ); assertEquals( KettleDatabaseRepository.FIELD_CLUSTER_SLAVE_ID_CLUSTER_SLAVE, insertRecord.getValueMeta( 0 ).getName() ); assertEquals( Long.valueOf( 357 ), insertRecord.getInteger( 0 ) ); assertEquals( ValueMetaInterface.TYPE_INTEGER, insertRecord.getValueMeta( 1 ).getType() ); assertEquals( KettleDatabaseRepository.FIELD_CLUSTER_SLAVE_ID_CLUSTER, insertRecord.getValueMeta( 1 ).getName() ); assertEquals( Long.valueOf( 159 ), insertRecord.getInteger( 1 ) ); assertEquals( ValueMetaInterface.TYPE_INTEGER, insertRecord.getValueMeta( 2 ).getType() ); assertEquals( KettleDatabaseRepository.FIELD_CLUSTER_SLAVE_ID_SLAVE, insertRecord.getValueMeta( 2 ).getName() ); assertEquals( Long.valueOf( 864 ), insertRecord.getInteger( 2 ) ); assertEquals( new LongObjectId( 357 ), result ); }
public synchronized ObjectId insertClusterSlave( ClusterSchema clusterSchema, SlaveServer slaveServer ) throws KettleException { ObjectId id = connectionDelegate.getNextClusterSlaveID(); RowMetaAndData table = new RowMetaAndData(); table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_CLUSTER_SLAVE_ID_CLUSTER_SLAVE ), id ); table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_CLUSTER_SLAVE_ID_CLUSTER ), clusterSchema .getObjectId() ); table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_CLUSTER_SLAVE_ID_SLAVE ), slaveServer .getObjectId() ); connectionDelegate.insertTableRow( KettleDatabaseRepository.TABLE_R_CLUSTER_SLAVE, table ); return id; }
KettleDatabaseRepository extends KettleDatabaseRepositoryBase { public synchronized ObjectId insertClusterSlave( ClusterSchema clusterSchema, SlaveServer slaveServer ) throws KettleException { ObjectId id = connectionDelegate.getNextClusterSlaveID(); RowMetaAndData table = new RowMetaAndData(); table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_CLUSTER_SLAVE_ID_CLUSTER_SLAVE ), id ); table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_CLUSTER_SLAVE_ID_CLUSTER ), clusterSchema .getObjectId() ); table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_CLUSTER_SLAVE_ID_SLAVE ), slaveServer .getObjectId() ); connectionDelegate.insertTableRow( KettleDatabaseRepository.TABLE_R_CLUSTER_SLAVE, table ); return id; } }
KettleDatabaseRepository extends KettleDatabaseRepositoryBase { public synchronized ObjectId insertClusterSlave( ClusterSchema clusterSchema, SlaveServer slaveServer ) throws KettleException { ObjectId id = connectionDelegate.getNextClusterSlaveID(); RowMetaAndData table = new RowMetaAndData(); table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_CLUSTER_SLAVE_ID_CLUSTER_SLAVE ), id ); table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_CLUSTER_SLAVE_ID_CLUSTER ), clusterSchema .getObjectId() ); table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_CLUSTER_SLAVE_ID_SLAVE ), slaveServer .getObjectId() ); connectionDelegate.insertTableRow( KettleDatabaseRepository.TABLE_R_CLUSTER_SLAVE, table ); return id; } KettleDatabaseRepository(); }
KettleDatabaseRepository extends KettleDatabaseRepositoryBase { public synchronized ObjectId insertClusterSlave( ClusterSchema clusterSchema, SlaveServer slaveServer ) throws KettleException { ObjectId id = connectionDelegate.getNextClusterSlaveID(); RowMetaAndData table = new RowMetaAndData(); table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_CLUSTER_SLAVE_ID_CLUSTER_SLAVE ), id ); table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_CLUSTER_SLAVE_ID_CLUSTER ), clusterSchema .getObjectId() ); table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_CLUSTER_SLAVE_ID_SLAVE ), slaveServer .getObjectId() ); connectionDelegate.insertTableRow( KettleDatabaseRepository.TABLE_R_CLUSTER_SLAVE, table ); return id; } KettleDatabaseRepository(); void init( RepositoryMeta repositoryMeta ); RepositoryMeta createRepositoryMeta(); void connect( String username, String password ); void connect( String username, String password, boolean upgrade ); @Override boolean test(); @Override void create(); synchronized void commit(); synchronized void rollback(); IUser getUserInfo(); int getMajorVersion(); int getMinorVersion(); String getVersion(); TransMeta loadTransformation( String transname, RepositoryDirectoryInterface repdir,
    ProgressMonitorListener monitor, boolean setInternalVariables, String versionName ); SharedObjects readTransSharedObjects( TransMeta transMeta ); ObjectId renameTransformation( ObjectId id_transformation, RepositoryDirectoryInterface newDir,
      String newName ); synchronized ObjectId renameTransformation( ObjectId id_transformation, String versionComment,
      RepositoryDirectoryInterface newDir, String newName ); JobMeta loadJob( String jobname, RepositoryDirectoryInterface repdir, ProgressMonitorListener monitor,
    String versionName ); SharedObjects readJobMetaSharedObjects( JobMeta jobMeta ); ObjectId renameJob( ObjectId id_job, RepositoryDirectoryInterface dir, String newname ); synchronized ObjectId renameJob( ObjectId id_job, String versionComment, RepositoryDirectoryInterface dir,
    String newname ); boolean exists( String name, RepositoryDirectoryInterface repositoryDirectory,
    RepositoryObjectType objectType ); void save( RepositoryElementInterface repositoryElement, String versionComment ); void save( RepositoryElementInterface repositoryElement, String versionComment,
    ProgressMonitorListener monitor, boolean overwrite ); void save( RepositoryElementInterface repositoryElement, String versionComment,
    ProgressMonitorListener monitor, ObjectId parentId, boolean used, boolean overwrite ); @Override void save( RepositoryElementInterface repositoryElement, String versionComment, Calendar versionDate,
    ProgressMonitorListener monitor, boolean overwrite ); Condition loadCondition( ObjectId id_condition ); ObjectId saveCondition( Condition condition ); ObjectId saveCondition( Condition condition, ObjectId id_condition_parent ); DatabaseMeta loadDatabaseMeta( ObjectId id_database, String versionName ); void deleteDatabaseMeta( String databaseName ); ClusterSchema loadClusterSchema( ObjectId idClusterSchema, List<SlaveServer> slaveServers,
    String versionLabel ); SlaveServer loadSlaveServer( ObjectId id_slave_server, String versionName ); PartitionSchema loadPartitionSchema( ObjectId id_partition_schema, String versionName ); ValueMetaAndData loadValueMetaAndData( ObjectId id_value ); NotePadMeta loadNotePadMeta( ObjectId id_note ); void saveNotePadMeta( NotePadMeta note, ObjectId id_transformation ); RepositoryDirectoryInterface loadRepositoryDirectoryTree(); RepositoryDirectoryInterface loadRepositoryDirectoryTree( RepositoryDirectoryInterface root ); RepositoryDirectoryInterface findDirectory( String directory ); RepositoryDirectoryInterface findDirectory( ObjectId directory ); void saveRepositoryDirectory( RepositoryDirectoryInterface dir ); void deleteRepositoryDirectory( RepositoryDirectoryInterface dir ); ObjectId renameRepositoryDirectory( ObjectId id, RepositoryDirectoryInterface newParentDir, String newName ); RepositoryDirectoryInterface createRepositoryDirectory( RepositoryDirectoryInterface parentDirectory,
    String directoryPath ); synchronized ObjectId getRootDirectoryID(); synchronized int getNrSubDirectories( ObjectId id_directory ); synchronized ObjectId[] getSubDirectoryIDs( ObjectId id_directory ); synchronized ObjectId insertLogEntry( String description ); synchronized void insertTransNote( ObjectId id_transformation, ObjectId id_note ); synchronized void insertJobNote( ObjectId id_job, ObjectId id_note ); synchronized void insertStepDatabase( ObjectId id_transformation, ObjectId id_step, ObjectId id_database ); synchronized void insertJobEntryDatabase( ObjectId id_job, ObjectId id_jobentry, ObjectId id_database ); synchronized ObjectId insertTransformationPartitionSchema( ObjectId id_transformation,
    ObjectId id_partition_schema ); synchronized ObjectId insertClusterSlave( ClusterSchema clusterSchema, SlaveServer slaveServer ); synchronized ObjectId insertTransformationCluster( ObjectId id_transformation, ObjectId id_cluster ); synchronized ObjectId insertTransformationSlave( ObjectId id_transformation, ObjectId id_slave ); synchronized void insertTransStepCondition( ObjectId id_transformation, ObjectId id_step,
    ObjectId id_condition ); synchronized String[] getTransformationNames( ObjectId id_directory, boolean includeDeleted ); List<RepositoryElementMetaInterface> getJobObjects( ObjectId id_directory, boolean includeDeleted ); List<RepositoryElementMetaInterface> getTransformationObjects( ObjectId id_directory,
    boolean includeDeleted ); synchronized String[] getJobNames( ObjectId id_directory, boolean includeDeleted ); synchronized String[] getDirectoryNames( ObjectId id_directory ); synchronized String[] getJobNames(); ObjectId[] getSubConditionIDs( ObjectId id_condition ); ObjectId[] getTransNoteIDs( ObjectId id_transformation ); ObjectId[] getTransformationConditionIDs( ObjectId id_transformation ); ObjectId[] getTransformationDatabaseIDs( ObjectId id_transformation ); ObjectId[] getJobNoteIDs( ObjectId id_job ); ObjectId[] getDatabaseIDs( boolean includeDeleted ); ObjectId[] getDatabaseAttributeIDs( ObjectId id_database ); ObjectId[] getPartitionSchemaIDs( boolean includeDeleted ); ObjectId[] getPartitionIDs( ObjectId id_partition_schema ); ObjectId[] getTransformationPartitionSchemaIDs( ObjectId id_transformation ); ObjectId[] getTransformationClusterSchemaIDs( ObjectId id_transformation ); ObjectId[] getClusterIDs( boolean includeDeleted ); ObjectId[] getSlaveIDs( boolean includeDeleted ); ObjectId[] getClusterSlaveIDs( ObjectId id_cluster_schema ); synchronized String[] getDatabaseNames( boolean includeDeleted ); synchronized String[] getPartitionSchemaNames( boolean includeDeleted ); synchronized String[] getSlaveNames( boolean includeDeleted ); synchronized String[] getClusterNames( boolean includeDeleted ); ObjectId[] getStepIDs( ObjectId id_transformation ); synchronized String[] getTransformationsUsingDatabase( ObjectId id_database ); synchronized String[] getJobsUsingDatabase( ObjectId id_database ); synchronized String[] getClustersUsingSlave( ObjectId id_slave ); synchronized String[] getTransformationsUsingSlave( ObjectId id_slave ); synchronized String[] getTransformationsUsingPartitionSchema( ObjectId id_partition_schema ); synchronized String[] getTransformationsUsingCluster( ObjectId id_cluster ); ObjectId[] getJobHopIDs( ObjectId id_job ); ObjectId[] getTransDependencyIDs( ObjectId id_transformation ); ObjectId[] getJobEntryIDs( ObjectId id_job ); ObjectId[] getJobEntryCopyIDs( ObjectId id_job ); ObjectId[] getJobEntryCopyIDs( ObjectId id_job, ObjectId id_jobentry ); static final String byteArrayToString( byte[] val ); synchronized void delSteps( ObjectId id_transformation ); synchronized void deleteCondition( ObjectId id_condition ); synchronized void delStepConditions( ObjectId id_transformation ); synchronized void delStepDatabases( ObjectId id_transformation ); synchronized void delJobEntryDatabases( ObjectId id_job ); synchronized void delJobEntries( ObjectId id_job ); synchronized void delJobEntryCopies( ObjectId id_job ); synchronized void delDependencies( ObjectId id_transformation ); synchronized void delStepAttributes( ObjectId id_transformation ); synchronized void delTransAttributes( ObjectId id_transformation ); synchronized void delJobAttributes( ObjectId id_job ); synchronized void delPartitionSchemas( ObjectId id_transformation ); synchronized void delPartitions( ObjectId id_partition_schema ); synchronized void delClusterSlaves( ObjectId id_cluster ); synchronized void delTransformationClusters( ObjectId id_transformation ); synchronized void delTransformationSlaves( ObjectId id_transformation ); synchronized void delJobEntryAttributes( ObjectId id_job ); synchronized void delTransHops( ObjectId id_transformation ); synchronized void delJobHops( ObjectId id_job ); synchronized void delTransNotes( ObjectId id_transformation ); synchronized void delJobNotes( ObjectId id_job ); synchronized void delTrans( ObjectId id_transformation ); synchronized void delJob( ObjectId id_job ); synchronized void delTransStepCondition( ObjectId id_transformation ); synchronized void delValue( ObjectId id_value ); synchronized void deleteSlave( ObjectId id_slave ); synchronized void deletePartitionSchema( ObjectId id_partition_schema ); synchronized void deleteClusterSchema( ObjectId id_cluster ); synchronized void deleteTransformation( ObjectId id_transformation ); synchronized void deleteJob( ObjectId id_job ); boolean dropRepositorySchema(); void updateStepTypes(); void updateDatabaseTypes(); void updateJobEntryTypes(); synchronized String toString(); void clearSharedObjectCache(); Database getDatabase(); void setDatabase( Database database ); synchronized void lockRepository(); synchronized void unlockRepository(); List<DatabaseMeta> getDatabases(); List<SlaveServer> getSlaveServers(); DatabaseMeta getDatabaseMeta(); List<DatabaseMeta> readDatabases(); boolean isUseBatchProcessing(); void setImportBaseDirectory( RepositoryDirectory importBaseDirectory ); RepositoryDirectory getImportBaseDirectory(); void createRepositorySchema( ProgressMonitorListener monitor, boolean upgrade, List<String> statements,
    boolean dryRun ); synchronized int countNrStepAttributes( ObjectId id_step, String code ); synchronized int countNrJobEntryAttributes( ObjectId id_jobentry, String code ); synchronized void disconnect(); long getJobEntryAttributeInteger( ObjectId id_jobentry, int nr, String code ); String getJobEntryAttributeString( ObjectId id_jobentry, int nr, String code ); @Override boolean getJobEntryAttributeBoolean( ObjectId id_jobentry, int nr, String code, boolean def ); void saveJobEntryAttribute( ObjectId id_job, ObjectId id_jobentry, int nr, String code, String value ); void saveJobEntryAttribute( ObjectId id_job, ObjectId id_jobentry, int nr, String code, boolean value ); void saveJobEntryAttribute( ObjectId id_job, ObjectId id_jobentry, int nr, String code, long value ); boolean getStepAttributeBoolean( ObjectId id_step, int nr, String code, boolean def ); long getStepAttributeInteger( ObjectId id_step, int nr, String code ); String getStepAttributeString( ObjectId id_step, int nr, String code ); void saveStepAttribute( ObjectId id_transformation, ObjectId id_step, int nr, String code, String value ); void saveStepAttribute( ObjectId id_transformation, ObjectId id_step, int nr, String code, boolean value ); void saveStepAttribute( ObjectId id_transformation, ObjectId id_step, int nr, String code, long value ); void saveStepAttribute( ObjectId id_transformation, ObjectId id_step, int nr, String code, double value ); ObjectId findStepAttributeID( ObjectId id_step, int nr, String code ); void execStatement( String sql ); void loadJobEntry( JobEntryBase jobEntryBase, ObjectId id_jobentry, List<DatabaseMeta> databases,
    List<SlaveServer> slaveServers ); ObjectId getClusterID( String name ); ObjectId getDatabaseID( String name ); ObjectId getJobId( String name, RepositoryDirectoryInterface repositoryDirectory ); ObjectId getPartitionSchemaID( String name ); ObjectId getSlaveID( String name ); ObjectId getTransformationID( String name, RepositoryDirectoryInterface repositoryDirectory ); ObjectId insertJobEntry( ObjectId id_job, JobEntryBase jobEntryBase ); DatabaseMeta loadDatabaseMetaFromStepAttribute( ObjectId idStep, String code, List<DatabaseMeta> databases ); void saveDatabaseMetaStepAttribute( ObjectId id_transformation, ObjectId id_step, String code,
    DatabaseMeta database ); DatabaseMeta loadDatabaseMetaFromJobEntryAttribute( ObjectId id_jobentry, String nameCode, int nr,
    String idCode, List<DatabaseMeta> databases ); void saveDatabaseMetaJobEntryAttribute( ObjectId id_job, ObjectId id_jobentry, int nr, String nameCode,
    String idCode, DatabaseMeta database ); Condition loadConditionFromStepAttribute( ObjectId id_step, String code ); void saveConditionStepAttribute( ObjectId id_transformation, ObjectId id_step, String code,
    Condition condition ); KettleDatabaseRepositorySecurityProvider getSecurityProvider(); KettleDatabaseRepositorySecurityProvider getSecurityManager(); void undeleteObject( RepositoryElementMetaInterface element ); List<RepositoryElementMetaInterface> getJobAndTransformationObjects( ObjectId id_directory,
    boolean includeDeleted ); IRepositoryService getService( Class<? extends IRepositoryService> clazz ); List<Class<? extends IRepositoryService>> getServiceInterfaces(); boolean hasService( Class<? extends IRepositoryService> clazz ); RepositoryDirectory getDefaultSaveDirectory( RepositoryElementInterface repositoryElement ); RepositoryDirectory getUserHomeDirectory(); RepositoryObject getObjectInformation( ObjectId objectId, RepositoryObjectType objectType ); JobMeta loadJob( ObjectId idJob, String versionLabel ); TransMeta loadTransformation( ObjectId idTransformation, String versionLabel ); String getConnectMessage(); IRepositoryExporter getExporter(); IRepositoryImporter getImporter(); KettleDatabaseRepositoryMetaStore getMetaStore(); }
KettleDatabaseRepository extends KettleDatabaseRepositoryBase { public synchronized ObjectId insertClusterSlave( ClusterSchema clusterSchema, SlaveServer slaveServer ) throws KettleException { ObjectId id = connectionDelegate.getNextClusterSlaveID(); RowMetaAndData table = new RowMetaAndData(); table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_CLUSTER_SLAVE_ID_CLUSTER_SLAVE ), id ); table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_CLUSTER_SLAVE_ID_CLUSTER ), clusterSchema .getObjectId() ); table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_CLUSTER_SLAVE_ID_SLAVE ), slaveServer .getObjectId() ); connectionDelegate.insertTableRow( KettleDatabaseRepository.TABLE_R_CLUSTER_SLAVE, table ); return id; } KettleDatabaseRepository(); void init( RepositoryMeta repositoryMeta ); RepositoryMeta createRepositoryMeta(); void connect( String username, String password ); void connect( String username, String password, boolean upgrade ); @Override boolean test(); @Override void create(); synchronized void commit(); synchronized void rollback(); IUser getUserInfo(); int getMajorVersion(); int getMinorVersion(); String getVersion(); TransMeta loadTransformation( String transname, RepositoryDirectoryInterface repdir,
    ProgressMonitorListener monitor, boolean setInternalVariables, String versionName ); SharedObjects readTransSharedObjects( TransMeta transMeta ); ObjectId renameTransformation( ObjectId id_transformation, RepositoryDirectoryInterface newDir,
      String newName ); synchronized ObjectId renameTransformation( ObjectId id_transformation, String versionComment,
      RepositoryDirectoryInterface newDir, String newName ); JobMeta loadJob( String jobname, RepositoryDirectoryInterface repdir, ProgressMonitorListener monitor,
    String versionName ); SharedObjects readJobMetaSharedObjects( JobMeta jobMeta ); ObjectId renameJob( ObjectId id_job, RepositoryDirectoryInterface dir, String newname ); synchronized ObjectId renameJob( ObjectId id_job, String versionComment, RepositoryDirectoryInterface dir,
    String newname ); boolean exists( String name, RepositoryDirectoryInterface repositoryDirectory,
    RepositoryObjectType objectType ); void save( RepositoryElementInterface repositoryElement, String versionComment ); void save( RepositoryElementInterface repositoryElement, String versionComment,
    ProgressMonitorListener monitor, boolean overwrite ); void save( RepositoryElementInterface repositoryElement, String versionComment,
    ProgressMonitorListener monitor, ObjectId parentId, boolean used, boolean overwrite ); @Override void save( RepositoryElementInterface repositoryElement, String versionComment, Calendar versionDate,
    ProgressMonitorListener monitor, boolean overwrite ); Condition loadCondition( ObjectId id_condition ); ObjectId saveCondition( Condition condition ); ObjectId saveCondition( Condition condition, ObjectId id_condition_parent ); DatabaseMeta loadDatabaseMeta( ObjectId id_database, String versionName ); void deleteDatabaseMeta( String databaseName ); ClusterSchema loadClusterSchema( ObjectId idClusterSchema, List<SlaveServer> slaveServers,
    String versionLabel ); SlaveServer loadSlaveServer( ObjectId id_slave_server, String versionName ); PartitionSchema loadPartitionSchema( ObjectId id_partition_schema, String versionName ); ValueMetaAndData loadValueMetaAndData( ObjectId id_value ); NotePadMeta loadNotePadMeta( ObjectId id_note ); void saveNotePadMeta( NotePadMeta note, ObjectId id_transformation ); RepositoryDirectoryInterface loadRepositoryDirectoryTree(); RepositoryDirectoryInterface loadRepositoryDirectoryTree( RepositoryDirectoryInterface root ); RepositoryDirectoryInterface findDirectory( String directory ); RepositoryDirectoryInterface findDirectory( ObjectId directory ); void saveRepositoryDirectory( RepositoryDirectoryInterface dir ); void deleteRepositoryDirectory( RepositoryDirectoryInterface dir ); ObjectId renameRepositoryDirectory( ObjectId id, RepositoryDirectoryInterface newParentDir, String newName ); RepositoryDirectoryInterface createRepositoryDirectory( RepositoryDirectoryInterface parentDirectory,
    String directoryPath ); synchronized ObjectId getRootDirectoryID(); synchronized int getNrSubDirectories( ObjectId id_directory ); synchronized ObjectId[] getSubDirectoryIDs( ObjectId id_directory ); synchronized ObjectId insertLogEntry( String description ); synchronized void insertTransNote( ObjectId id_transformation, ObjectId id_note ); synchronized void insertJobNote( ObjectId id_job, ObjectId id_note ); synchronized void insertStepDatabase( ObjectId id_transformation, ObjectId id_step, ObjectId id_database ); synchronized void insertJobEntryDatabase( ObjectId id_job, ObjectId id_jobentry, ObjectId id_database ); synchronized ObjectId insertTransformationPartitionSchema( ObjectId id_transformation,
    ObjectId id_partition_schema ); synchronized ObjectId insertClusterSlave( ClusterSchema clusterSchema, SlaveServer slaveServer ); synchronized ObjectId insertTransformationCluster( ObjectId id_transformation, ObjectId id_cluster ); synchronized ObjectId insertTransformationSlave( ObjectId id_transformation, ObjectId id_slave ); synchronized void insertTransStepCondition( ObjectId id_transformation, ObjectId id_step,
    ObjectId id_condition ); synchronized String[] getTransformationNames( ObjectId id_directory, boolean includeDeleted ); List<RepositoryElementMetaInterface> getJobObjects( ObjectId id_directory, boolean includeDeleted ); List<RepositoryElementMetaInterface> getTransformationObjects( ObjectId id_directory,
    boolean includeDeleted ); synchronized String[] getJobNames( ObjectId id_directory, boolean includeDeleted ); synchronized String[] getDirectoryNames( ObjectId id_directory ); synchronized String[] getJobNames(); ObjectId[] getSubConditionIDs( ObjectId id_condition ); ObjectId[] getTransNoteIDs( ObjectId id_transformation ); ObjectId[] getTransformationConditionIDs( ObjectId id_transformation ); ObjectId[] getTransformationDatabaseIDs( ObjectId id_transformation ); ObjectId[] getJobNoteIDs( ObjectId id_job ); ObjectId[] getDatabaseIDs( boolean includeDeleted ); ObjectId[] getDatabaseAttributeIDs( ObjectId id_database ); ObjectId[] getPartitionSchemaIDs( boolean includeDeleted ); ObjectId[] getPartitionIDs( ObjectId id_partition_schema ); ObjectId[] getTransformationPartitionSchemaIDs( ObjectId id_transformation ); ObjectId[] getTransformationClusterSchemaIDs( ObjectId id_transformation ); ObjectId[] getClusterIDs( boolean includeDeleted ); ObjectId[] getSlaveIDs( boolean includeDeleted ); ObjectId[] getClusterSlaveIDs( ObjectId id_cluster_schema ); synchronized String[] getDatabaseNames( boolean includeDeleted ); synchronized String[] getPartitionSchemaNames( boolean includeDeleted ); synchronized String[] getSlaveNames( boolean includeDeleted ); synchronized String[] getClusterNames( boolean includeDeleted ); ObjectId[] getStepIDs( ObjectId id_transformation ); synchronized String[] getTransformationsUsingDatabase( ObjectId id_database ); synchronized String[] getJobsUsingDatabase( ObjectId id_database ); synchronized String[] getClustersUsingSlave( ObjectId id_slave ); synchronized String[] getTransformationsUsingSlave( ObjectId id_slave ); synchronized String[] getTransformationsUsingPartitionSchema( ObjectId id_partition_schema ); synchronized String[] getTransformationsUsingCluster( ObjectId id_cluster ); ObjectId[] getJobHopIDs( ObjectId id_job ); ObjectId[] getTransDependencyIDs( ObjectId id_transformation ); ObjectId[] getJobEntryIDs( ObjectId id_job ); ObjectId[] getJobEntryCopyIDs( ObjectId id_job ); ObjectId[] getJobEntryCopyIDs( ObjectId id_job, ObjectId id_jobentry ); static final String byteArrayToString( byte[] val ); synchronized void delSteps( ObjectId id_transformation ); synchronized void deleteCondition( ObjectId id_condition ); synchronized void delStepConditions( ObjectId id_transformation ); synchronized void delStepDatabases( ObjectId id_transformation ); synchronized void delJobEntryDatabases( ObjectId id_job ); synchronized void delJobEntries( ObjectId id_job ); synchronized void delJobEntryCopies( ObjectId id_job ); synchronized void delDependencies( ObjectId id_transformation ); synchronized void delStepAttributes( ObjectId id_transformation ); synchronized void delTransAttributes( ObjectId id_transformation ); synchronized void delJobAttributes( ObjectId id_job ); synchronized void delPartitionSchemas( ObjectId id_transformation ); synchronized void delPartitions( ObjectId id_partition_schema ); synchronized void delClusterSlaves( ObjectId id_cluster ); synchronized void delTransformationClusters( ObjectId id_transformation ); synchronized void delTransformationSlaves( ObjectId id_transformation ); synchronized void delJobEntryAttributes( ObjectId id_job ); synchronized void delTransHops( ObjectId id_transformation ); synchronized void delJobHops( ObjectId id_job ); synchronized void delTransNotes( ObjectId id_transformation ); synchronized void delJobNotes( ObjectId id_job ); synchronized void delTrans( ObjectId id_transformation ); synchronized void delJob( ObjectId id_job ); synchronized void delTransStepCondition( ObjectId id_transformation ); synchronized void delValue( ObjectId id_value ); synchronized void deleteSlave( ObjectId id_slave ); synchronized void deletePartitionSchema( ObjectId id_partition_schema ); synchronized void deleteClusterSchema( ObjectId id_cluster ); synchronized void deleteTransformation( ObjectId id_transformation ); synchronized void deleteJob( ObjectId id_job ); boolean dropRepositorySchema(); void updateStepTypes(); void updateDatabaseTypes(); void updateJobEntryTypes(); synchronized String toString(); void clearSharedObjectCache(); Database getDatabase(); void setDatabase( Database database ); synchronized void lockRepository(); synchronized void unlockRepository(); List<DatabaseMeta> getDatabases(); List<SlaveServer> getSlaveServers(); DatabaseMeta getDatabaseMeta(); List<DatabaseMeta> readDatabases(); boolean isUseBatchProcessing(); void setImportBaseDirectory( RepositoryDirectory importBaseDirectory ); RepositoryDirectory getImportBaseDirectory(); void createRepositorySchema( ProgressMonitorListener monitor, boolean upgrade, List<String> statements,
    boolean dryRun ); synchronized int countNrStepAttributes( ObjectId id_step, String code ); synchronized int countNrJobEntryAttributes( ObjectId id_jobentry, String code ); synchronized void disconnect(); long getJobEntryAttributeInteger( ObjectId id_jobentry, int nr, String code ); String getJobEntryAttributeString( ObjectId id_jobentry, int nr, String code ); @Override boolean getJobEntryAttributeBoolean( ObjectId id_jobentry, int nr, String code, boolean def ); void saveJobEntryAttribute( ObjectId id_job, ObjectId id_jobentry, int nr, String code, String value ); void saveJobEntryAttribute( ObjectId id_job, ObjectId id_jobentry, int nr, String code, boolean value ); void saveJobEntryAttribute( ObjectId id_job, ObjectId id_jobentry, int nr, String code, long value ); boolean getStepAttributeBoolean( ObjectId id_step, int nr, String code, boolean def ); long getStepAttributeInteger( ObjectId id_step, int nr, String code ); String getStepAttributeString( ObjectId id_step, int nr, String code ); void saveStepAttribute( ObjectId id_transformation, ObjectId id_step, int nr, String code, String value ); void saveStepAttribute( ObjectId id_transformation, ObjectId id_step, int nr, String code, boolean value ); void saveStepAttribute( ObjectId id_transformation, ObjectId id_step, int nr, String code, long value ); void saveStepAttribute( ObjectId id_transformation, ObjectId id_step, int nr, String code, double value ); ObjectId findStepAttributeID( ObjectId id_step, int nr, String code ); void execStatement( String sql ); void loadJobEntry( JobEntryBase jobEntryBase, ObjectId id_jobentry, List<DatabaseMeta> databases,
    List<SlaveServer> slaveServers ); ObjectId getClusterID( String name ); ObjectId getDatabaseID( String name ); ObjectId getJobId( String name, RepositoryDirectoryInterface repositoryDirectory ); ObjectId getPartitionSchemaID( String name ); ObjectId getSlaveID( String name ); ObjectId getTransformationID( String name, RepositoryDirectoryInterface repositoryDirectory ); ObjectId insertJobEntry( ObjectId id_job, JobEntryBase jobEntryBase ); DatabaseMeta loadDatabaseMetaFromStepAttribute( ObjectId idStep, String code, List<DatabaseMeta> databases ); void saveDatabaseMetaStepAttribute( ObjectId id_transformation, ObjectId id_step, String code,
    DatabaseMeta database ); DatabaseMeta loadDatabaseMetaFromJobEntryAttribute( ObjectId id_jobentry, String nameCode, int nr,
    String idCode, List<DatabaseMeta> databases ); void saveDatabaseMetaJobEntryAttribute( ObjectId id_job, ObjectId id_jobentry, int nr, String nameCode,
    String idCode, DatabaseMeta database ); Condition loadConditionFromStepAttribute( ObjectId id_step, String code ); void saveConditionStepAttribute( ObjectId id_transformation, ObjectId id_step, String code,
    Condition condition ); KettleDatabaseRepositorySecurityProvider getSecurityProvider(); KettleDatabaseRepositorySecurityProvider getSecurityManager(); void undeleteObject( RepositoryElementMetaInterface element ); List<RepositoryElementMetaInterface> getJobAndTransformationObjects( ObjectId id_directory,
    boolean includeDeleted ); IRepositoryService getService( Class<? extends IRepositoryService> clazz ); List<Class<? extends IRepositoryService>> getServiceInterfaces(); boolean hasService( Class<? extends IRepositoryService> clazz ); RepositoryDirectory getDefaultSaveDirectory( RepositoryElementInterface repositoryElement ); RepositoryDirectory getUserHomeDirectory(); RepositoryObject getObjectInformation( ObjectId objectId, RepositoryObjectType objectType ); JobMeta loadJob( ObjectId idJob, String versionLabel ); TransMeta loadTransformation( ObjectId idTransformation, String versionLabel ); String getConnectMessage(); IRepositoryExporter getExporter(); IRepositoryImporter getImporter(); KettleDatabaseRepositoryMetaStore getMetaStore(); public KettleDatabaseRepositoryTransDelegate transDelegate; public KettleDatabaseRepositoryJobDelegate jobDelegate; public KettleDatabaseRepositoryDatabaseDelegate databaseDelegate; public KettleDatabaseRepositorySlaveServerDelegate slaveServerDelegate; public KettleDatabaseRepositoryClusterSchemaDelegate clusterSchemaDelegate; public KettleDatabaseRepositoryPartitionSchemaDelegate partitionSchemaDelegate; public KettleDatabaseRepositoryDirectoryDelegate directoryDelegate; public KettleDatabaseRepositoryConnectionDelegate connectionDelegate; public KettleDatabaseRepositoryUserDelegate userDelegate; public KettleDatabaseRepositoryConditionDelegate conditionDelegate; public KettleDatabaseRepositoryValueDelegate valueDelegate; public KettleDatabaseRepositoryNotePadDelegate notePadDelegate; public KettleDatabaseRepositoryStepDelegate stepDelegate; public KettleDatabaseRepositoryJobEntryDelegate jobEntryDelegate; public KettleDatabaseRepositoryMetaStoreDelegate metaStoreDelegate; public KettleDatabaseRepositoryMetaStore metaStore; }