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

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

本文整理了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

private StringBuilder appendConnectionInfo( StringBuilder report, Database db, DatabaseMeta databaseMeta ) {
 // Check to see if the interface is of a type GenericDatabaseMeta, since it does not have hostname and port fields
 if ( databaseMeta.getDatabaseInterface() instanceof GenericDatabaseMeta ) {
  String customUrl = databaseMeta.getAttributes().getProperty( GenericDatabaseMeta.ATRRIBUTE_CUSTOM_URL );
  String customDriverClass =
   databaseMeta.getAttributes().getProperty( GenericDatabaseMeta.ATRRIBUTE_CUSTOM_DRIVER_CLASS );
  return report.append( BaseMessages.getString( PKG, "GenericDatabaseMeta.report.customUrl" ) ).append(
   db.environmentSubstitute( customUrl ) ).append( Const.CR ).append(
   BaseMessages.getString( PKG, "GenericDatabaseMeta.report.customDriverClass" ) ).append(
   db.environmentSubstitute( customDriverClass ) ).append( Const.CR );
 }
 return appendConnectionInfo( report, db.environmentSubstitute( databaseMeta.getHostname() ), db
  .environmentSubstitute( databaseMeta.getDatabasePortNumberString() ), db
  .environmentSubstitute( databaseMeta.getDatabaseName() ) );
}

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

@Override
public boolean getBooleanValueOfVariable( String variableName, boolean defaultValue ) {
 if ( !Utils.isEmpty( variableName ) ) {
  String value = environmentSubstitute( variableName );
  if ( !Utils.isEmpty( value ) ) {
   return ValueMetaBase.convertStringToBoolean( value );
  }
 }
 return defaultValue;
}

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

String schemaTable =
 databaseMeta.getQuotedSchemaTableCombination(
  environmentSubstitute( logTable.getActualSchemaName() ), environmentSubstitute( logTable
   .getActualTableName() ) );
RowMetaInterface rowMeta = logRecord.getRowMeta();
 insertRow( environmentSubstitute( logTable.getActualSchemaName() ), environmentSubstitute( logTable
  .getActualTableName() ), logRecord.getRowMeta(), logRecord.getData() );
DatabaseLogExceptionFactory.getExceptionStrategy( logTable, e )
 .registerException( log, e, PKG, "Database.Error.WriteLogTable",
  environmentSubstitute( logTable.getActualTableName() ) );

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

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

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

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

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

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

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

appendConnectionInfo( report, db.environmentSubstitute( partitioningInformation[i].getHostname() ), db
  .environmentSubstitute( partitioningInformation[i].getPort() ), db
  .environmentSubstitute( partitioningInformation[i].getDatabaseName() ) );
 report.append( Const.CR );
 appendJndiConnectionInfo( report, db.environmentSubstitute( databaseMeta.getDatabaseName() ) );
} else {
 appendConnectionInfo( report, db, databaseMeta );

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

url = environmentSubstitute( databaseMeta.getURL( partitionId ) );
} else {
 url = environmentSubstitute( databaseMeta.getURL() );
 password = clusterPassword;
} else {
 username = environmentSubstitute( databaseMeta.getUsername() );
 password = Encr.decryptPasswordOptionallyEncrypted( environmentSubstitute( databaseMeta.getPassword() ) );
   String instance = environmentSubstitute( databaseMeta.getSQLServerInstance() );
   if ( !Utils.isEmpty( instance ) ) {
    url += ";instanceName=" + instance;

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

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

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

String tableName = db.environmentSubstitute( logTable.getTableName() );
String schemaTable =
 logTable.getDatabaseMeta().getQuotedSchemaTableCombination(
  db.environmentSubstitute( logTable.getSchemaName() ),
  db.environmentSubstitute( logTable.getTableName() ) );
String createTable = db.getDDL( schemaTable, fields );

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

String tableName = db.environmentSubstitute( logTable.getTableName() );
String schemaTable =
 logTable.getDatabaseMeta().getQuotedSchemaTableCombination(
  db.environmentSubstitute( logTable.getSchemaName() ), tableName );
String createTable = db.getDDL( schemaTable, fields );

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

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

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

RowMetaInterface r =
 db.getTableFieldsMeta(
  db.environmentSubstitute( wSchema.getText() ),
  db.environmentSubstitute( wTable.getText() ) );
if ( r != null && !r.isEmpty() ) {
 String schemaTable =
  ci.getQuotedSchemaTableCombination( db.environmentSubstitute( wSchema.getText() ), db
   .environmentSubstitute( wTable.getText() ) );
 logDebug( BaseMessages.getString( PKG, "DatabaseLookupDialog.Log.FoundTableFields" )
  + schemaTable + " --> " + r.toStringMeta() );

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

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

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

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

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

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

相关文章

微信公众号

最新文章

更多