本文整理了Java中org.pentaho.di.repository.Repository.getJobEntryAttributeString方法的一些代码示例，展示了Repository.getJobEntryAttributeString的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Repository.getJobEntryAttributeString方法的具体详情如下：
包路径：org.pentaho.di.repository.Repository
类名称：Repository
方法名：getJobEntryAttributeString

Repository.getJobEntryAttributeString介绍

暂无

代码示例

代码示例来源：origin: pentaho/pentaho-kettle

@Override
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId idJobentry, List<DatabaseMeta> databases,
  List<SlaveServer> slaveServers ) throws KettleException {
 try {
  server = rep.getJobEntryAttributeString( idJobentry, "server" );
  port = rep.getJobEntryAttributeString( idJobentry, "port" );
  variableName = rep.getJobEntryAttributeString( idJobentry, "variable" );
 } catch ( KettleException dbe ) {
  throw new KettleException( "Unable to load job entry from the repository for id_jobentry=" + idJobentry, dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
 List<SlaveServer> slaveServers ) throws KettleException {
 try {
  hostname = rep.getJobEntryAttributeString( id_jobentry, "hostname" );
  port = rep.getJobEntryAttributeString( id_jobentry, "port" );
  timeout = rep.getJobEntryAttributeString( id_jobentry, "timeout" );
 } catch ( KettleException dbe ) {
  throw new KettleException(
   "Unable to load job entry of type 'Telnet' exists from the repository for id_jobentry=" + id_jobentry,
   dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
 List<SlaveServer> slaveServers ) throws KettleException {
 try {
  bodymessage = rep.getJobEntryAttributeString( id_jobentry, "bodymessage" );
  titremessage = rep.getJobEntryAttributeString( id_jobentry, "titremessage" );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException(
   "Unable to load job entry of type 'Msgbox Info' from the repository with id_jobentry=" + id_jobentry,
   dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
  List<SlaveServer> slaveServers ) throws KettleException {
 try {
  xmlfilename = rep.getJobEntryAttributeString( id_jobentry, "xmlfilename" );
  xsdfilename = rep.getJobEntryAttributeString( id_jobentry, "xsdfilename" );
 } catch ( KettleException dbe ) {
  throw new KettleException( "Unable to load job entry of type 'xsdvalidator' from the repository for id_jobentry="
    + id_jobentry, dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
 List<SlaveServer> slaveServers ) throws KettleException {
 try {
  url = rep.getJobEntryAttributeString( id_jobentry, "url" );
  connectTimeOut = rep.getJobEntryAttributeString( id_jobentry, "connectTimeOut" );
  readTimeOut = rep.getJobEntryAttributeString( id_jobentry, "readTimeOut" );
 } catch ( KettleException dbe ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "JobEntryWebServiceAvailable.ERROR_0002_Cannot_Load_Job_From_Repository", "" + id_jobentry ), dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

protected String loadSourceRep( Repository rep, ObjectId id_jobentry, int a ) throws KettleException {
 String source_filefolder = rep.getJobEntryAttributeString( id_jobentry, a, SOURCE_FILE_FOLDER );
 String ncName = rep.getJobEntryAttributeString( id_jobentry, a, SOURCE_CONFIGURATION_NAME );
 return loadURL( source_filefolder, ncName, getMetaStore(), configurationMappings );
}

代码示例来源：origin: pentaho/pentaho-kettle

public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
 List<SlaveServer> slaveServers ) throws KettleException {
 try {
  filename = rep.getJobEntryAttributeString( id_jobentry, "filename" );
  className = rep.getJobEntryAttributeString( id_jobentry, "class_name" );
 } catch ( KettleException dbe ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "JobEntryTalendJobExec.ERROR_0002_Cannot_Load_Job_From_Repository", id_jobentry ), dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

@Override
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
 List<SlaveServer> slaveServers ) throws KettleException {
 try {
  logmessage = rep.getJobEntryAttributeString( id_jobentry, "logmessage" );
  entryLogLevel = LogLevel.getLogLevelForCode( rep.getJobEntryAttributeString( id_jobentry, "loglevel" ) );
  logsubject = rep.getJobEntryAttributeString( id_jobentry, "logsubject" );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( BaseMessages.getString( PKG, "WriteToLog.Error.UnableToLoadFromRepository.Label" )
   + id_jobentry, dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
 List<SlaveServer> slaveServers ) throws KettleException {
 try {
  gpglocation = rep.getJobEntryAttributeString( id_jobentry, "gpglocation" );
  filename = rep.getJobEntryAttributeString( id_jobentry, "filename" );
  detachedfilename = rep.getJobEntryAttributeString( id_jobentry, "detachedfilename" );
  useDetachedSignature = rep.getJobEntryAttributeBoolean( id_jobentry, "useDetachedSignature" );
 } catch ( KettleException dbe ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "JobEntryPGPVerify.ERROR_0002_Cannot_Load_Job_From_Repository", id_jobentry ), dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

protected String loadDestinationRep( Repository rep, ObjectId id_jobentry, int a ) throws KettleException {
 String destination_filefolder = rep.getJobEntryAttributeString( id_jobentry, a, DESTINATION_FILE_FOLDER );
 String ncName = rep.getJobEntryAttributeString( id_jobentry, a, DESTINATION_CONFIGURATION_NAME );
 return loadURL( destination_filefolder, ncName, getMetaStore(), configurationMappings );
}

代码示例来源：origin: pentaho/pentaho-kettle

public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
 List<SlaveServer> slaveServers ) throws KettleException {
 try {
  foldername = rep.getJobEntryAttributeString( id_jobentry, "foldername" );
  specifywildcard = rep.getJobEntryAttributeBoolean( id_jobentry, "specify_wildcard" );
  wildcard = rep.getJobEntryAttributeString( id_jobentry, "wildcard" );
  wildcardexclude = rep.getJobEntryAttributeString( id_jobentry, "wildcardexclude" );
 } catch ( KettleException dbe ) {
  throw new KettleXMLException( BaseMessages.getString(
   PKG, "JobEntryDeleteResultFilenames.CanNotLoadFromRep", "" + id_jobentry, dbe.getMessage() ) );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
 List<SlaveServer> slaveServers ) throws KettleException {
 try {
  tablename = rep.getJobEntryAttributeString( id_jobentry, "tablename" );
  schemaname = rep.getJobEntryAttributeString( id_jobentry, "schemaname" );
  connection = rep.loadDatabaseMetaFromJobEntryAttribute( id_jobentry, "connection", "id_database", databases );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException(
   BaseMessages.getString( PKG, "TableExists.Meta.UnableLoadRep", "" + id_jobentry ), dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
 List<SlaveServer> slaveServers ) throws KettleException {
 try {
  messageAbort = rep.getJobEntryAttributeString( id_jobentry, "message" );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( BaseMessages.getString( PKG, "JobEntryAbort.UnableToLoadFromRepo.Label", String
   .valueOf( id_jobentry ) ), dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
 List<SlaveServer> slaveServers ) throws KettleException {
 try {
  script = rep.getJobEntryAttributeString( id_jobentry, "script" );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( BaseMessages.getString( PKG, "JobEntryEval.UnableToLoadFromRepo", String
   .valueOf( id_jobentry ) ), dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
 List<SlaveServer> slaveServers ) throws KettleException {
 try {
  filename = rep.getJobEntryAttributeString( id_jobentry, "filename" );
 } catch ( KettleException dbe ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "JobEntryFileExists.ERROR_0002_Cannot_Load_Job_From_Repository", id_jobentry ), dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
 List<SlaveServer> slaveServers ) throws KettleException {
 try {
  foldername = rep.getJobEntryAttributeString( id_jobentry, "foldername" );
  failOfFolderExists = rep.getJobEntryAttributeBoolean( id_jobentry, "fail_of_folder_exists" );
 } catch ( KettleException dbe ) {
  throw new KettleException(
   "Unable to load job entry of type 'create Folder' from the repository for id_jobentry=" + id_jobentry,
   dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
 List<SlaveServer> slaveServers ) throws KettleException {
 try {
  filename = rep.getJobEntryAttributeString( id_jobentry, "filename" );
  failIfFileNotExists = rep.getJobEntryAttributeBoolean( id_jobentry, "fail_if_file_not_exists" );
 } catch ( KettleException dbe ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "JobEntryDeleteFile.ERROR_0002_Unable_To_Load_From_Repository", id_jobentry ), dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

@Override
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
 List<SlaveServer> slaveServers ) throws KettleException {
 try {
  maximumTimeout = rep.getJobEntryAttributeString( id_jobentry, "maximumTimeout" );
  scaleTime = (int) rep.getJobEntryAttributeInteger( id_jobentry, "scaletime" );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( BaseMessages.getString( PKG, "JobEntryDelay.UnableToLoadFromRepo.Label" )
   + id_jobentry, dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
 List<SlaveServer> slaveServers ) throws KettleException {
 try {
  filename = rep.getJobEntryAttributeString( id_jobentry, "filename" );
  failIfFileExists = rep.getJobEntryAttributeBoolean( id_jobentry, "fail_if_file_exists" );
  addfilenameresult = rep.getJobEntryAttributeBoolean( id_jobentry, "add_filename_result" );
 } catch ( KettleException dbe ) {
  throw new KettleException(
   "Unable to load job entry of type 'create file' from the repository for id_jobentry=" + id_jobentry, dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

@Before
public void setUp() throws Exception {
 repo = mock( Repository.class );
 doReturn( XXEUtils.MALICIOUS_XML ).when( repo ).getJobEntryAttributeString( any( ObjectId.class ), anyString() );
 doReturn( XXEUtils.MALICIOUS_XML ).when( repo ).getStepAttributeString( any( ObjectId.class ), anyString() );
}