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

Java Counters类代码示例

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

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



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

示例1: commit

import org.pentaho.di.core.Counters; //导入依赖的package包/类
public synchronized void commit() throws KettleException
{
	try
	{
	  closeJobAttributeInsertPreparedStatement();
	  closeStepAttributeInsertPreparedStatement();
	  closeTransAttributeInsertPreparedStatement();
	  
		if (!database.isAutoCommit()) {
		  database.commit();
		}
		
		// Also, clear the counters, reducing the risk of collisions!
		//
		Counters.getInstance().clear();
	}
	catch (KettleException dbe)
	{
		throw new KettleException("Unable to commit repository connection", dbe);
	}
}
开发者ID:yintaoxue，项目名称:read-open-source-code，代码行数:22，代码来源:KettleDatabaseRepositoryConnectionDelegate.java


示例2: getNextID

import org.pentaho.di.core.Counters; //导入依赖的package包/类
public synchronized LongObjectId getNextID(String tableName, String fieldName) throws KettleException
{
    String counterName = tableName+"."+fieldName;
    Counter counter = Counters.getInstance().getCounter(counterName);
    if (counter==null)
    {
    	LongObjectId id = getNextTableID(tableName, fieldName);
        counter = new Counter(id.longValue());
        Counters.getInstance().setCounter(counterName, counter);
        return new LongObjectId(counter.next());
    }
    else
    {
        return new LongObjectId(counter.next());
    }
}
开发者ID:bsspirit，项目名称:kettle-4.4.0-stable，代码行数:17，代码来源:KettleDatabaseRepositoryConnectionDelegate.java


示例3: commit

import org.pentaho.di.core.Counters; //导入依赖的package包/类
public synchronized void commit() throws KettleException {
  try {
    closeJobAttributeInsertPreparedStatement();
    closeStepAttributeInsertPreparedStatement();
    closeTransAttributeInsertPreparedStatement();

    if (!database.isAutoCommit()) {
      database.commit();
    }

    // Also, clear the counters, reducing the risk of collisions!
    //
    Counters.getInstance().clear();
  } catch (KettleException dbe) {
    throw new KettleException("Unable to commit repository connection", dbe);
  }
}
开发者ID:jjeb，项目名称:kettle-trunk，代码行数:18，代码来源:KettleDatabaseRepositoryConnectionDelegate.java


示例4: commit

import org.pentaho.di.core.Counters; //导入依赖的package包/类
public synchronized void commit() throws KettleException {
  try {
    closeJobAttributeInsertPreparedStatement();
    closeStepAttributeInsertPreparedStatement();
    closeTransAttributeInsertPreparedStatement();

    if ( !database.isAutoCommit() ) {
      database.commit();
    }

    // Also, clear the counters, reducing the risk of collisions!
    //
    Counters.getInstance().clear();
  } catch ( KettleException dbe ) {
    throw new KettleException( "Unable to commit repository connection", dbe );
  }
}
开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:18，代码来源:KettleDatabaseRepositoryConnectionDelegate.java


示例5: commit

import org.pentaho.di.core.Counters; //导入依赖的package包/类
public synchronized void commit() throws KettleException
{
	try
	{
		if (!database.isAutoCommit()) database.commit();
		
		// Also, clear the counters, reducing the risk of collisions!
		//
		Counters.getInstance().clear();
	}
	catch (KettleException dbe)
	{
		throw new KettleException("Unable to commit repository connection", dbe);
	}
}
开发者ID:icholy，项目名称:geokettle-2.0，代码行数:16，代码来源:Repository.java


示例6: rollback

import org.pentaho.di.core.Counters; //导入依赖的package包/类
public synchronized void rollback()
{
	try
	{
		database.rollback();
		
		// Also, clear the counters, reducing the risk of collisions!
		//
		Counters.getInstance().clear();
	}
	catch (KettleException dbe)
	{
		log.logError(toString(), "Error rolling back repository.");
	}
}
开发者ID:icholy，项目名称:geokettle-2.0，代码行数:16，代码来源:Repository.java


示例7: rollback

import org.pentaho.di.core.Counters; //导入依赖的package包/类
public synchronized void rollback()
{
	try
	{
		database.rollback();
		
		// Also, clear the counters, reducing the risk of collisions!
		//
		Counters.getInstance().clear();
	}
	catch (KettleException dbe)
	{
		log.logError("Error rolling back repository.");
	}
}
开发者ID:yintaoxue，项目名称:read-open-source-code，代码行数:16，代码来源:KettleDatabaseRepositoryConnectionDelegate.java


示例8: rollback

import org.pentaho.di.core.Counters; //导入依赖的package包/类
public synchronized void rollback() {
  try {
    database.rollback();

    // Also, clear the counters, reducing the risk of collisions!
    //
    Counters.getInstance().clear();
  } catch (KettleException dbe) {
    log.logError("Error rolling back repository.");
  }
}
开发者ID:jjeb，项目名称:kettle-trunk，代码行数:12，代码来源:KettleDatabaseRepositoryConnectionDelegate.java


示例9: getNextID

import org.pentaho.di.core.Counters; //导入依赖的package包/类
public synchronized LongObjectId getNextID(String tableName, String fieldName) throws KettleException {
  String counterName = tableName + "." + fieldName;
  Counter counter = Counters.getInstance().getCounter(counterName);
  if (counter == null) {
    LongObjectId id = getNextTableID(tableName, fieldName);
    counter = new Counter(id.longValue());
    Counters.getInstance().setCounter(counterName, counter);
    return new LongObjectId(counter.next());
  } else {
    return new LongObjectId(counter.next());
  }
}
开发者ID:jjeb，项目名称:kettle-trunk，代码行数:13，代码来源:KettleDatabaseRepositoryConnectionDelegate.java


示例10: rollback

import org.pentaho.di.core.Counters; //导入依赖的package包/类
public synchronized void rollback() {
  try {
    database.rollback();

    // Also, clear the counters, reducing the risk of collisions!
    //
    Counters.getInstance().clear();
  } catch ( KettleException dbe ) {
    log.logError( "Error rolling back repository." );
  }
}
开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:12，代码来源:KettleDatabaseRepositoryConnectionDelegate.java


示例11: getNextID

import org.pentaho.di.core.Counters; //导入依赖的package包/类
public synchronized LongObjectId getNextID( String tableName, String fieldName ) throws KettleException {
  String counterName = tableName + "." + fieldName;
  Counter counter = Counters.getInstance().getCounter( counterName );
  if ( counter == null ) {
    LongObjectId id = getNextTableID( tableName, fieldName );
    counter = new Counter( id.longValue() );
    Counters.getInstance().setCounter( counterName, counter );
    return new LongObjectId( counter.next() );
  } else {
    return new LongObjectId( counter.next() );
  }
}
开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:13，代码来源:KettleDatabaseRepositoryConnectionDelegate.java


示例12: clearNextIDCounters

import org.pentaho.di.core.Counters; //导入依赖的package包/类
public synchronized void clearNextIDCounters()
{
    Counters.getInstance().clear();
}
开发者ID:icholy，项目名称:geokettle-2.0，代码行数:5，代码来源:Repository.java


示例13: clearNextIDCounters

import org.pentaho.di.core.Counters; //导入依赖的package包/类
public synchronized void clearNextIDCounters() {
  Counters.getInstance().clear();
}
开发者ID:jjeb，项目名称:kettle-trunk，代码行数:4，代码来源:KettleDatabaseRepositoryConnectionDelegate.java



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

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
Java Root类代码示例发布时间：2022-05-22
下一篇：
Java NullableComputable类代码示例发布时间：2022-05-22
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

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

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