• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Java DatabaseImpact类代码示例

原作者: [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;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java VirtGraph类代码示例发布时间:2022-05-23
下一篇:
Java JavaCodeFragment类代码示例发布时间:2022-05-23
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap