本文整理了Java中org.pentaho.di.core.database.Database.rollback()方法的一些代码示例，展示了Database.rollback()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Database.rollback()方法的具体详情如下：
包路径：org.pentaho.di.core.database.Database
类名称：Database
方法名：rollback

Database.rollback介绍

暂无

代码示例

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

public void rollback() throws KettleDatabaseException {
 rollback( false );
}

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

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." );
 }
}

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

@Override
 public void dispose( StepMetaInterface smi, StepDataInterface sdi ) {
  meta = (DimensionLookupMeta) smi;
  data = (DimensionLookupData) sdi;
  if ( data.db != null ) {
   try {
    if ( !data.db.isAutoCommit() ) {
     if ( getErrors() == 0 ) {
      data.db.commit();
     } else {
      data.db.rollback();
     }
    }
   } catch ( KettleDatabaseException e ) {
    logError( BaseMessages.getString( PKG, "DimensionLookup.Log.ErrorOccurredInProcessing" ) + e.getMessage() );
   } finally {
    data.db.disconnect();
   }
  }
  super.dispose( smi, sdi );
 }
}

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

public void dispose( StepMetaInterface smi, StepDataInterface sdi ) {
 meta = (CombinationLookupMeta) smi;
 data = (CombinationLookupData) sdi;
 if ( data.db != null ) {
  try {
   if ( !data.db.isAutoCommit() ) {
    if ( getErrors() == 0 ) {
     data.db.commit();
    } else {
     data.db.rollback();
    }
   }
  } catch ( KettleDatabaseException e ) {
   logError( BaseMessages.getString( PKG, "CombinationLookup.Log.UnexpectedError" ) + " : " + e.toString() );
  } finally {
   data.db.disconnect();
  }
 }
 super.dispose( smi, sdi );
}

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

data.db.rollback();
} catch ( KettleDatabaseException e ) {
 logError( "Unexpected error rolling back the database connection.", e );

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

data.db.rollback();
} catch ( KettleDatabaseException e ) {
 logError( "Unexpected error rolling back the database connection.", e );

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

public void dispose( StepMetaInterface smi, StepDataInterface sdi ) {
 meta = (DeleteMeta) smi;
 data = (DeleteData) sdi;
 if ( data.db != null ) {
  try {
   if ( !data.db.isAutoCommit() ) {
    if ( getErrors() == 0 ) {
     data.db.commit();
    } else {
     data.db.rollback();
    }
   }
   data.db.closeUpdate();
  } catch ( KettleDatabaseException e ) {
   logError( BaseMessages.getString( PKG, "Delete.Log.UnableToCommitUpdateConnection" )
    + data.db + "] :" + e.toString() );
   setErrors( 1 );
  } finally {
   data.db.disconnect();
  }
 }
 super.dispose( smi, sdi );
}

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

public void dispose( StepMetaInterface smi, StepDataInterface sdi ) {
 meta = (InsertUpdateMeta) smi;
 data = (InsertUpdateData) sdi;
 if ( data.db != null ) {
  try {
   if ( !data.db.isAutoCommit() ) {
    if ( getErrors() == 0 ) {
     data.db.commit();
    } else {
     data.db.rollback();
    }
   }
   data.db.closeUpdate();
   data.db.closeInsert();
  } catch ( KettleDatabaseException e ) {
   logError( BaseMessages.getString( PKG, "InsertUpdate.Log.UnableToCommitConnection" ) + e.toString() );
   setErrors( 1 );
  } finally {
   data.db.disconnect();
  }
 }
 super.dispose( smi, sdi );
}

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

public void dispose( StepMetaInterface smi, StepDataInterface sdi ) {
 meta = (UpdateMeta) smi;
 data = (UpdateData) sdi;
 if ( data.db != null ) {
  try {
   if ( !data.db.isAutoCommit() ) {
    if ( getErrors() == 0 ) {
     data.db.emptyAndCommit( data.prepStatementUpdate, meta.useBatchUpdate() );
    } else {
     data.db.rollback();
    }
   }
   data.db.closePreparedStatement( data.prepStatementUpdate );
   data.db.closePreparedStatement( data.prepStatementLookup );
  } catch ( KettleDatabaseException e ) {
   logError( BaseMessages.getString( PKG, "Update.Log.UnableToCommitUpdateConnection" )
    + data.db + "] :" + e.toString() );
   setErrors( 1 );
  } finally {
   data.db.disconnect();
  }
 }
 super.dispose( smi, sdi );
}

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

@Override
public void dispose( StepMetaInterface smi, StepDataInterface sdi ) {
 meta = (ExecSQLRowMeta) smi;
 data = (ExecSQLRowData) sdi;
 if ( log.isBasic() ) {
  logBasic( BaseMessages.getString( PKG, "ExecSQLRow.Log.FinishingReadingQuery" ) );
 }
 if ( data.db != null ) {
  try {
   if ( !data.db.isAutoCommit() ) {
    if ( getErrors() == 0 ) {
     data.db.commit();
    } else {
     data.db.rollback();
    }
   }
  } catch ( KettleDatabaseException e ) {
   logError( BaseMessages.getString( PKG, "Update.Log.UnableToCommitUpdateConnection" )
    + data.db + "] :" + e.toString() );
   setErrors( 1 );
  } finally {
   data.db.disconnect();
  }
 }
 super.dispose( smi, sdi );
}

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

} else {
 data.db.clearBatch( insertStatement );
 data.db.rollback();
 StringBuilder msg = new StringBuilder( "Error batch inserting rows into table [" + tableName + "]." );
 msg.append( Const.CR );
  data.db.rollback( data.savepoint );
  if ( data.releaseSavepoint ) {
   data.db.releaseSavepoint( data.savepoint );
 } else {
  setErrors( getErrors() + 1 );
  data.db.rollback();
  throw new KettleException( "Error inserting row into table ["
   + tableName + "] with values: " + rowMeta.getString( r ), dbe );

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

data.db.commit( true );
} else {
 data.db.rollback();
 StringBuilder msg = new StringBuilder( "Error batch inserting rows into table [" + data.realTableName + "]." );
 msg.append( Const.CR );
  if ( data.savepoint != null || !data.lookupFailure ) {
   data.db.rollback( data.savepoint );
   if ( data.releaseSavepoint ) {
    data.db.releaseSavepoint( data.savepoint );
} else {
 setErrors( getErrors() + 1 );
 data.db.rollback();
 throw new KettleException( "Error inserting row into table [" + data.realTableName + "] with values: "
   + data.inputRowMeta.getString( row ), dbe );

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

database.rollback( true );
log.logBasic( BaseMessages.getString( PKG, "Trans.Exception.TransactionsRolledBackOnConnection",
 database.toString() ) );