本文整理了Java中org.pentaho.di.core.database.Database.environmentSubstitute()
方法的一些代码示例,展示了Database.environmentSubstitute()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Database.environmentSubstitute()
方法的具体详情如下:
包路径:org.pentaho.di.core.database.Database
类名称: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 );
内容来源于网络,如有侵权,请联系作者删除!