org.pentaho.di.repository.Repository.saveJobEntryAttribute()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(10.5k)|赞(0)|评价(0)|浏览(119)

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

Repository.saveJobEntryAttribute介绍

暂无

代码示例

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

protected void saveSourceRep( Repository rep, ObjectId id_job, ObjectId id_jobentry, int i, String value )
 throws KettleException {
 String namedCluster = configurationMappings.get( value );
 rep.saveJobEntryAttribute( id_job, getObjectId(), i, SOURCE_FILE_FOLDER, value );
 rep.saveJobEntryAttribute( id_job, id_jobentry, i, SOURCE_CONFIGURATION_NAME, namedCluster );
}

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

protected void saveDestinationRep( Repository rep, ObjectId id_job, ObjectId id_jobentry, int i, String value )
 throws KettleException {
 String namedCluster = configurationMappings.get( value );
 rep.saveJobEntryAttribute( id_job, getObjectId(), i, DESTINATION_FILE_FOLDER, value );
 rep.saveJobEntryAttribute( id_job, id_jobentry, i, DESTINATION_CONFIGURATION_NAME, namedCluster );
}

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

public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
 try {
  rep.saveJobEntryAttribute( id_job, getObjectId(), "server", server );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "port", port );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "message_variable", messageVariableName );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "type_variable", messageTypeVariableName );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "version_variable", versionVariableName );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( "Unable to save job entry of type 'ftp' to the repository for id_job=" + id_job, dbe );
 }
}

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

public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
 try {
  rep.saveJobEntryAttribute( id_job, getObjectId(), "filename", filename );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "createParentFolder", createParentFolder );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "appendFile", appendFile );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "content", content );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "encoding", encoding );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( "Unable to save job entry of type 'create file' to the repository for id_job="
   + id_job, dbe );
 }
}

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

public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
 try {
  rep.saveJobEntryAttribute( id_job, getObjectId(), "xmlfilename", xmlfilename );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "dtdfilename", dtdfilename );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "dtdintern", dtdintern );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( "Unable to save job entry of type 'DTDvalidator' to the repository for id_job="
    + id_job, dbe );
 }
}

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

public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
 try {
  rep.saveJobEntryAttribute( id_job, getObjectId(), "filename", filename );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "fail_if_file_exists", failIfFileExists );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "add_filename_result", addfilenameresult );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( "Unable to save job entry of type 'create file' to the repository for id_job="
   + id_job, dbe );
 }
}

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

public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
 try {
  rep.saveJobEntryAttribute( id_job, getObjectId(), "hostname", hostname );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "port", port );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "timeout", timeout );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( "Unable to save job entry of type 'Telnet' to the repository for id_job="
   + id_job, dbe );
 }
}

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

public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
 try {
  rep.saveJobEntryAttribute( id_job, getObjectId(), "server", server );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "port", port );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "variable", variableName );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( "Unable to save job entry of type 'ftp' to the repository for id_job=" + id_job, dbe );
 }
}

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

public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
 try {
  rep.saveJobEntryAttribute( id_job, getObjectId(), "smtpCheck", smtpCheck );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "timeout", timeout );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "defaultSMTP", defaultSMTP );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "emailSender", emailSender );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "emailAddress", emailAddress );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( BaseMessages.getString( PKG, "JobEntryMailValidator.Meta.UnableToSaveToRep" )
   + id_job, dbe );
 }
}

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

public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
 try {
  rep.saveJobEntryAttribute( id_job, getObjectId(), "bodymessage", bodymessage );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "titremessage", titremessage );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( "Unable to save job entry of type 'Msgbox Info' to the repository for id_job="
   + id_job, dbe );
 }
}

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

public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
 try {
  rep.saveJobEntryAttribute( id_job, getObjectId(), "xmlfilename", xmlfilename );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "xsdfilename", xsdfilename );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( "Unable to save job entry of type 'xsdvalidator' to the repository for id_job="
    + id_job, dbe );
 }
}

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

public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
 try {
  rep.saveJobEntryAttribute( id_job, getObjectId(), "foldername", foldername );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "fail_of_folder_exists", failOfFolderExists );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( "Unable to save job entry of type 'create Folder' to the repository for id_job="
   + id_job, dbe );
 }
}

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

public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
 try {
  rep.saveJobEntryAttribute( id_job, getObjectId(), "url", url );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "connectTimeOut", connectTimeOut );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "readTimeOut", readTimeOut );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "JobEntryWebServiceAvailable.ERROR_0003_Cannot_Save_Job_Entry", "" + id_job ), dbe );
 }
}

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

@Override
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
 try {
  rep.saveJobEntryAttribute( id_job, getObjectId(), "logmessage", logmessage );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "loglevel", ( entryLogLevel != null ? entryLogLevel
   .getCode() : "" ) );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "logsubject", logsubject );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( BaseMessages.getString( PKG, "WriteToLog.Error.UnableToSaveToRepository.Label" )
   + id_job, dbe );
 }
}

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

public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
 try {
  rep.saveJobEntryAttribute( id_job, getObjectId(), "filename", filename );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "fail_if_file_not_exists", failIfFileNotExists );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "JobEntryDeleteFile.ERROR_0003_Unable_To_Save_Job_To_Repository", id_job ), dbe );
 }
}

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

@Override
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
 try {
  rep.saveJobEntryAttribute( id_job, getObjectId(), "maximumTimeout", maximumTimeout );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "scaletime", scaleTime );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException(
   BaseMessages.getString( PKG, "JobEntryDelay.UnableToSaveToRepo.Label" ) + id_job, dbe );
 }
}

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

public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
 try {
  rep.saveJobEntryAttribute( id_job, getObjectId(), "script", script );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( BaseMessages.getString( PKG, "JobEntryEval.UnableToSaveToRepo", String
   .valueOf( id_job ) ), dbe );
 }
}

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

public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
 try {
  rep.saveDatabaseMetaJobEntryAttribute( id_job, getObjectId(), "connection", "id_database", databaseMeta );
  rep.saveJobEntryAttribute( id_job, getObjectId(), "cubeName", this.getCubeName() );
  for ( int i = 0; i < this.dimensionNames.size(); i++ ) {
   rep.saveJobEntryAttribute( id_job, getObjectId(), i, "dimensionname", this.dimensionNames.get( i ) );
  }
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException(
    "unable to save jobentry of type 'file exists' to the repository for id_job=" + id_job, dbe );
 }
}

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

public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
 try {
  rep.saveJobEntryAttribute( id_job, getObjectId(), "message", messageAbort );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( BaseMessages.getString( PKG, "JobEntryAbort.UnableToSaveToRepo.Label", String
   .valueOf( id_job ) ), dbe );
 }
}

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

public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
 try {
  rep.saveJobEntryAttribute( id_job, getObjectId(), "filename", filename );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "JobEntryFileExists.ERROR_0003_Cannot_Save_Job_Entry", id_job ), dbe );
 }
}

相关文章

Repository类方法