Java DatabaseImpact类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.pentaho.di.trans.DatabaseImpact类的典型用法代码示例。如果您正苦于以下问题：Java DatabaseImpact类的具体用法？Java DatabaseImpact怎么用？Java DatabaseImpact使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

DatabaseImpact类属于org.pentaho.di.trans包，在下文中一共展示了DatabaseImpact类的11个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: analyseImpact

import org.pentaho.di.trans.DatabaseImpact; //导入依赖的package包/类
public void analyseImpact(List<DatabaseImpact> impact, TransMeta transMeta, StepMeta stepMeta, RowMetaInterface prev, String input[], String output[], RowMetaInterface info) throws KettleStepException
   {
       if (prev != null)
       {
           /* DEBUG CHECK THIS */
           // Insert dateMask fields : read/write
           for (int i = 0; i < fieldTable.length; i++)
           {
               ValueMetaInterface v = prev.searchValueMeta(fieldStream[i]);

               DatabaseImpact ii = new DatabaseImpact(DatabaseImpact.TYPE_IMPACT_READ_WRITE, transMeta.getName(), stepMeta.getName(), databaseMeta
                       .getDatabaseName(), transMeta.environmentSubstitute(tableName), fieldTable[i], fieldStream[i], v!=null?v.getOrigin():"?", "", "Type = " + v.toStringMeta()); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$
               impact.add(ii);
           }
       }
}

开发者ID:icholy，项目名称:geokettle-2.0，代码行数:17，代码来源:LucidDBBulkLoaderMeta.java

示例2: analyseImpact

import org.pentaho.di.trans.DatabaseImpact; //导入依赖的package包/类
public void analyseImpact(List<DatabaseImpact> impact, TransMeta transMeta, StepMeta stepMeta, RowMetaInterface prev, String[] input,
        String[] output, RowMetaInterface info)
        throws KettleStepException
{
    if (prev != null)
    {
        // Lookup: we do a lookup on the natural keys 
        for (int i = 0; i < keyLookup.length; i++)
        {
            ValueMetaInterface v = prev.searchValueMeta(keyStream[i]);

            DatabaseImpact ii = new DatabaseImpact(DatabaseImpact.TYPE_IMPACT_DELETE, transMeta.getName(), stepMeta.getName(), databaseMeta
                    .getDatabaseName(), tableName, keyLookup[i], keyStream[i], v!=null?v.getOrigin():"?", "", "Type = " + v.toStringMeta()); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$
            impact.add(ii);
        }
    }
}

开发者ID:icholy，项目名称:geokettle-2.0，代码行数:18，代码来源:DeleteMeta.java

示例3: analyseImpact

import org.pentaho.di.trans.DatabaseImpact; //导入依赖的package包/类
public void analyseImpact(List<DatabaseImpact> impact, TransMeta transMeta, StepMeta stepMeta, RowMetaInterface prev, String input[], String output[], RowMetaInterface info) throws KettleStepException
   {
       if (prev != null)
       {
           /* DEBUG CHECK THIS */
           // Insert dateMask fields : read/write
           for (int i = 0; i < fieldTable.length; i++)
           {
               ValueMetaInterface v = prev.searchValueMeta(fieldStream[i]);

               DatabaseImpact ii = new DatabaseImpact(DatabaseImpact.TYPE_IMPACT_READ_WRITE, transMeta.getName(), stepMeta.getName(), databaseMeta.getDatabaseName(), 
               		transMeta.environmentSubstitute(tableName), fieldTable[i], fieldStream[i], v!=null?v.getOrigin():"?", "", "Type = " + v.toStringMeta()); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$
               impact.add(ii);
           }
       }
}

开发者ID:icholy，项目名称:geokettle-2.0，代码行数:17，代码来源:GPBulkLoaderMeta.java

示例4: analyseImpact

import org.pentaho.di.trans.DatabaseImpact; //导入依赖的package包/类
public void analyseImpact(List<DatabaseImpact> impact, TransMeta transMeta, StepMeta stepMeta, RowMetaInterface prev,
		String[] input, String[] output, RowMetaInterface info) throws KettleStepException {

	RowMetaInterface out = prev.clone();
	getFields(out, stepMeta.getName(), new RowMetaInterface[] { info, }, null, transMeta );
	if (out!=null)
	{
		for (int i=0;i<out.size();i++)
		{
			ValueMetaInterface outvalue = out.getValueMeta(i);
			DatabaseImpact di = new DatabaseImpact( DatabaseImpact.TYPE_IMPACT_READ, 
					transMeta.getName(),
					stepMeta.getName(),
					databaseMeta.getDatabaseName(),
					"", //$NON-NLS-1$
					outvalue.getName(),
					outvalue.getName(),
					stepMeta.getName(),
					sql,
					Messages.getString("DynamicSQLRowMeta.DatabaseImpact.Title") //$NON-NLS-1$
					);
			impact.add(di);

		}
	}
}

开发者ID:icholy，项目名称:geokettle-2.0，代码行数:27，代码来源:DynamicSQLRowMeta.java

示例5: analyseImpact

import org.pentaho.di.trans.DatabaseImpact; //导入依赖的package包/类
public void analyseImpact(List<DatabaseImpact> impact, TransMeta transMeta, StepMeta stepMeta, RowMetaInterface prev,
		String[] input, String[] output, RowMetaInterface info) throws KettleStepException {

	RowMetaInterface out = prev.clone();
	getFields(out, stepMeta.getName(), new RowMetaInterface[] { info, }, null, transMeta );
	if (out!=null)
	{
		for (int i=0;i<out.size();i++)
		{
			ValueMetaInterface outvalue = out.getValueMeta(i);
			DatabaseImpact di = new DatabaseImpact( DatabaseImpact.TYPE_IMPACT_READ, 
					transMeta.getName(),
					stepMeta.getName(),
					databaseMeta.getDatabaseName(),
					"", //$NON-NLS-1$
					outvalue.getName(),
					outvalue.getName(),
					stepMeta.getName(),
					sql,
					BaseMessages.getString(PKG, "DynamicSQLRowMeta.DatabaseImpact.Title") //$NON-NLS-1$
					);
			impact.add(di);

		}
	}
}

开发者ID:yintaoxue，项目名称:read-open-source-code，代码行数:27，代码来源:DynamicSQLRowMeta.java

示例6: analyseImpact

import org.pentaho.di.trans.DatabaseImpact; //导入依赖的package包/类
public void analyseImpact(List<DatabaseImpact> impact, TransMeta transMeta, StepMeta stepMeta, RowMetaInterface prev, String input[], String output[], RowMetaInterface info) throws KettleStepException
{
  if (prev != null)
  {
    /* DEBUG CHECK THIS */
    // Insert dateMask fields : read/write
    for (int i = 0; i < fieldTable.length; i++)
    {
      ValueMetaInterface v = prev.searchValueMeta(fieldStream[i]);

      DatabaseImpact ii = new DatabaseImpact(DatabaseImpact.TYPE_IMPACT_READ_WRITE, transMeta.getName(), stepMeta.getName(), databaseMeta
          .getDatabaseName(), transMeta.environmentSubstitute(tableName), fieldTable[i], fieldStream[i], v!=null?v.getOrigin():"?", "", "Type = " + v.toStringMeta()); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$
      impact.add(ii);
    }
  }
}

开发者ID:jjeb，项目名称:kettle-trunk，代码行数:17，代码来源:MonetDBBulkLoaderMeta.java

示例7: analyseImpact

import org.pentaho.di.trans.DatabaseImpact; //导入依赖的package包/类
@Override
public void analyseImpact( List<DatabaseImpact> impact, TransMeta transMeta, StepMeta stepMeta,
  RowMetaInterface prev, String[] input, String[] output, RowMetaInterface info, Repository repository,
  IMetaStore metaStore ) throws KettleStepException {

  // Find the lookupfields...
  //
  RowMetaInterface out = prev.clone();
  getFields( out, stepMeta.getName(), new RowMetaInterface[] { info, }, null, transMeta, repository, metaStore );

  if ( out != null ) {
    for ( int i = 0; i < out.size(); i++ ) {
      ValueMetaInterface outvalue = out.getValueMeta( i );
      DatabaseImpact di =
        new DatabaseImpact(
          DatabaseImpact.TYPE_IMPACT_READ, transMeta.getName(), stepMeta.getName(),
          databaseMeta.getDatabaseName(), "", outvalue.getName(), outvalue.getName(), stepMeta.getName(),
          transMeta.environmentSubstitute( sql ),
          BaseMessages.getString( PKG, "DatabaseJoinMeta.DatabaseImpact.Title" ) );
      impact.add( di );

    }
  }
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:25，代码来源:DatabaseJoinMeta.java

示例8: analyseImpact

import org.pentaho.di.trans.DatabaseImpact; //导入依赖的package包/类
public void analyseImpact( List<DatabaseImpact> impact, TransMeta transMeta, StepMeta stepMeta,
  RowMetaInterface prev, String[] input, String[] output, RowMetaInterface info, Repository repository,
  IMetaStore metaStore ) throws KettleStepException {
  if ( prev != null ) {
    /* DEBUG CHECK THIS */
    // Insert dateMask fields : read/write
    for ( int i = 0; i < fieldTable.length; i++ ) {
      ValueMetaInterface v = prev.searchValueMeta( fieldStream[i] );

      DatabaseImpact ii =
        new DatabaseImpact(
          DatabaseImpact.TYPE_IMPACT_READ_WRITE, transMeta.getName(), stepMeta.getName(), databaseMeta
            .getDatabaseName(), transMeta.environmentSubstitute( tableName ), fieldTable[i],
          fieldStream[i], v != null ? v.getOrigin() : "?", "", "Type = " + v.toStringMeta() );
      impact.add( ii );
    }
  }
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:19，代码来源:PGBulkLoaderMeta.java

示例9: analyseImpact

import org.pentaho.di.trans.DatabaseImpact; //导入依赖的package包/类
public void analyseImpact( List<DatabaseImpact> impact, TransMeta transMeta, StepMeta stepMeta,
  RowMetaInterface prev, String[] input, String[] output, RowMetaInterface info, Repository repository,
  IMetaStore metaStore ) throws KettleStepException {
  if ( prev != null ) {
    // Lookup: we do a lookup on the natural keys
    for ( int i = 0; i < keyLookup.length; i++ ) {
      ValueMetaInterface v = prev.searchValueMeta( keyStream[i] );

      DatabaseImpact ii =
        new DatabaseImpact(
          DatabaseImpact.TYPE_IMPACT_DELETE, transMeta.getName(), stepMeta.getName(), databaseMeta
            .getDatabaseName(), tableName, keyLookup[i], keyStream[i],
          v != null ? v.getOrigin() : "?", "", "Type = " + v.toStringMeta() );
      impact.add( ii );
    }
  }
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:18，代码来源:DeleteMeta.java

示例10: analyseImpact

import org.pentaho.di.trans.DatabaseImpact; //导入依赖的package包/类
public void analyseImpact( List<DatabaseImpact> impact, TransMeta transMeta, StepMeta stepMeta,
    RowMetaInterface prev, String[] input, String[] output, RowMetaInterface info, Repository repository,
    IMetaStore metaStore ) throws KettleStepException {
  if ( prev != null ) {
    /* DEBUG CHECK THIS */
    // Insert dateMask fields : read/write
    for ( int i = 0; i < fieldTable.length; i++ ) {
      ValueMetaInterface v = prev.searchValueMeta( fieldStream[i] );

      DatabaseImpact ii =
          new DatabaseImpact(
              DatabaseImpact.TYPE_IMPACT_READ_WRITE, transMeta.getName(), stepMeta.getName(), databaseMeta
              .getDatabaseName(), transMeta.environmentSubstitute( tableName ), fieldTable[i],
              fieldStream[i], v != null ? v.getOrigin() : "?", "", "Type = " + v.toStringMeta() );
      impact.add( ii );
    }
  }
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:19，代码来源:MonetDBBulkLoaderMeta.java

示例11: analyseImpact

import org.pentaho.di.trans.DatabaseImpact; //导入依赖的package包/类
public void analyseImpact( List<DatabaseImpact> impact, TransMeta transMeta, StepMeta stepMeta,
  RowMetaInterface prev, String[] input, String[] output, RowMetaInterface info, Repository repository,
  IMetaStore metaStore ) throws KettleStepException {

  RowMetaInterface out = prev.clone();
  getFields( out, stepMeta.getName(), new RowMetaInterface[] { info, }, null, transMeta, repository, metaStore );
  if ( out != null ) {
    for ( int i = 0; i < out.size(); i++ ) {
      ValueMetaInterface outvalue = out.getValueMeta( i );
      DatabaseImpact di =
        new DatabaseImpact(
          DatabaseImpact.TYPE_IMPACT_READ, transMeta.getName(), stepMeta.getName(), databaseMeta
            .getDatabaseName(), "", outvalue.getName(), outvalue.getName(), stepMeta.getName(), sql,
          BaseMessages.getString( PKG, "DynamicSQLRowMeta.DatabaseImpact.Title" ) );
      impact.add( di );

    }
  }
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:20，代码来源:DynamicSQLRowMeta.java

注：本文中的org.pentaho.di.trans.DatabaseImpact类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。