org.pentaho.di.core.database.Database.environmentSubstitute()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(6.2k)|赞(0)|评价(0)|浏览(184)

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

Database.environmentSubstitute介绍

暂无

代码示例

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

  1. private StringBuilder appendConnectionInfo( StringBuilder report, Database db, DatabaseMeta databaseMeta ) {
  2. // Check to see if the interface is of a type GenericDatabaseMeta, since it does not have hostname and port fields
  3. if ( databaseMeta.getDatabaseInterface() instanceof GenericDatabaseMeta ) {
  4. String customUrl = databaseMeta.getAttributes().getProperty( GenericDatabaseMeta.ATRRIBUTE_CUSTOM_URL );
  5. String customDriverClass =
  6. databaseMeta.getAttributes().getProperty( GenericDatabaseMeta.ATRRIBUTE_CUSTOM_DRIVER_CLASS );
  7. return report.append( BaseMessages.getString( PKG, "GenericDatabaseMeta.report.customUrl" ) ).append(
  8. db.environmentSubstitute( customUrl ) ).append( Const.CR ).append(
  9. BaseMessages.getString( PKG, "GenericDatabaseMeta.report.customDriverClass" ) ).append(
  10. db.environmentSubstitute( customDriverClass ) ).append( Const.CR );
  11. }
  12. return appendConnectionInfo( report, db.environmentSubstitute( databaseMeta.getHostname() ), db
  13. .environmentSubstitute( databaseMeta.getDatabasePortNumberString() ), db
  14. .environmentSubstitute( databaseMeta.getDatabaseName() ) );
  15. }

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

  1. @Override
  2. public boolean getBooleanValueOfVariable( String variableName, boolean defaultValue ) {
  3. if ( !Utils.isEmpty( variableName ) ) {
  4. String value = environmentSubstitute( variableName );
  5. if ( !Utils.isEmpty( value ) ) {
  6. return ValueMetaBase.convertStringToBoolean( value );
  7. }
  8. }
  9. return defaultValue;
  10. }

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

  1. String schemaTable =
  2. databaseMeta.getQuotedSchemaTableCombination(
  3. environmentSubstitute( logTable.getActualSchemaName() ), environmentSubstitute( logTable
  4. .getActualTableName() ) );
  5. RowMetaInterface rowMeta = logRecord.getRowMeta();
  6. insertRow( environmentSubstitute( logTable.getActualSchemaName() ), environmentSubstitute( logTable
  7. .getActualTableName() ), logRecord.getRowMeta(), logRecord.getData() );
  8. DatabaseLogExceptionFactory.getExceptionStrategy( logTable, e )
  9. .registerException( log, e, PKG, "Database.Error.WriteLogTable",
  10. environmentSubstitute( logTable.getActualTableName() ) );

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

  1. if ( schemaname == null ) {
  2. if ( databaseMeta.useSchemaNameForTableList() ) {
  3. schemaname = environmentSubstitute( databaseMeta.getUsername() ).toUpperCase();

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

  1. public void cleanupLogRecords( LogTableCoreInterface logTable ) throws KettleDatabaseException {
  2. double timeout = Const.toDouble( Const.trim( environmentSubstitute( logTable.getTimeoutInDays() ) ), 0.0 );
  3. if ( timeout < 0.000001 ) {
  4. databaseMeta.getQuotedSchemaTableCombination( environmentSubstitute( logTable.getActualSchemaName() ),
  5. environmentSubstitute( logTable.getActualTableName() ) );
  6. DatabaseLogExceptionFactory.getExceptionStrategy( logTable )
  7. .registerException( log, PKG, "Database.Exception.UnableToCleanUpOlderRecordsFromLogTable",
  8. environmentSubstitute( logTable.getActualTableName() ) );

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

  1. if ( schemaname == null ) {
  2. if ( databaseMeta.useSchemaNameForTableList() ) {
  3. schemaname = environmentSubstitute( databaseMeta.getUsername() ).toUpperCase();

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

  1. appendConnectionInfo( report, db.environmentSubstitute( partitioningInformation[i].getHostname() ), db
  2. .environmentSubstitute( partitioningInformation[i].getPort() ), db
  3. .environmentSubstitute( partitioningInformation[i].getDatabaseName() ) );
  4. report.append( Const.CR );
  5. appendJndiConnectionInfo( report, db.environmentSubstitute( databaseMeta.getDatabaseName() ) );
  6. } else {
  7. appendConnectionInfo( report, db, databaseMeta );

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

  1. url = environmentSubstitute( databaseMeta.getURL( partitionId ) );
  2. } else {
  3. url = environmentSubstitute( databaseMeta.getURL() );
  4. password = clusterPassword;
  5. } else {
  6. username = environmentSubstitute( databaseMeta.getUsername() );
  7. password = Encr.decryptPasswordOptionallyEncrypted( environmentSubstitute( databaseMeta.getPassword() ) );
  8. String instance = environmentSubstitute( databaseMeta.getSQLServerInstance() );
  9. if ( !Utils.isEmpty( instance ) ) {
  10. url += ";instanceName=" + instance;

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

  1. if ( schemaname == null ) {
  2. if ( databaseMeta.useSchemaNameForTableList() ) {
  3. schemaname = environmentSubstitute( databaseMeta.getUsername() ).toUpperCase();

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

  1. String tableName = db.environmentSubstitute( logTable.getTableName() );
  2. String schemaTable =
  3. logTable.getDatabaseMeta().getQuotedSchemaTableCombination(
  4. db.environmentSubstitute( logTable.getSchemaName() ),
  5. db.environmentSubstitute( logTable.getTableName() ) );
  6. String createTable = db.getDDL( schemaTable, fields );

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

  1. String tableName = db.environmentSubstitute( logTable.getTableName() );
  2. String schemaTable =
  3. logTable.getDatabaseMeta().getQuotedSchemaTableCombination(
  4. db.environmentSubstitute( logTable.getSchemaName() ), tableName );
  5. String createTable = db.getDDL( schemaTable, fields );

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

  1. db.environmentSubstitute( schemaName ),
  2. db.environmentSubstitute( tablename ) );

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

  1. RowMetaInterface r =
  2. db.getTableFieldsMeta(
  3. db.environmentSubstitute( wSchema.getText() ),
  4. db.environmentSubstitute( wTable.getText() ) );
  5. if ( r != null && !r.isEmpty() ) {
  6. String schemaTable =
  7. ci.getQuotedSchemaTableCombination( db.environmentSubstitute( wSchema.getText() ), db
  8. .environmentSubstitute( wTable.getText() ) );
  9. logDebug( BaseMessages.getString( PKG, "DatabaseLookupDialog.Log.FoundTableFields" )
  10. + schemaTable + " --> " + r.toStringMeta() );

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

  1. String jndiName = environmentSubstitute( databaseMeta.getDatabaseName() );
  2. try {
  3. this.connection = dsp.getNamedDataSource( jndiName, DatasourceType.JNDI ).getConnection();
  4. String sql = environmentSubstitute( databaseMeta.getConnectSQL() );

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

  1. String realSchemaName = db.environmentSubstitute( schemaName );
  2. String realTableName = db.environmentSubstitute( tableName );
  3. String schemaTable =
  4. databaseMeta.getQuotedSchemaTableCombination( realSchemaName, realTableName );

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

  1. sNewSQL = db.environmentSubstitute( sql );
  2. if ( space != null ) {
  3. sNewSQL = space.environmentSubstitute( sNewSQL );

相关文章