protected void applyRowChangeData(RowChangeData data,List<ReplOption> options,String sourceDbmsType) throws ReplicatorException {
  if (options != null) {
    try {
      if (applySessionVariables(null,options)) {
        if (logger.isDebugEnabled()) {
          logger.debug("Applying changed session variables");
        }
        executePendingBatch();
        statement.executeBatch();
        statement.clearBatch();
      }
    }
 catch (    SQLException e) {
      throw new ApplierException("Failed to apply session variables",e);
    }
  }
  List<ReplOption> rowOptions=data.getOptions();
  if (rowOptions != null) {
    try {
      if (applySessionVariables(null,rowOptions)) {
        if (logger.isDebugEnabled()) {
          logger.debug("Applying changed row option variables");
        }
        executePendingBatch();
        statement.executeBatch();
        statement.clearBatch();
      }
    }
 catch (    SQLException e) {
      throw new ApplierException("Failed to apply session variables",e);
    }
  }
  for (  OneRowChange row : data.getRowChanges()) {
    applyOneRowChangePrepared(row,sourceDbmsType);
  }
}

protected void applyRowChangeData ( RowChangeData data , List < ReplOption > options , String sourceDbmsType ) throws ReplicatorException { if ( options != null ) { try { if ( applySessionVariables ( null , options ) ) { if ( logger . isDebugEnabled ( ) ) { logger . debug ( "Applying changed session variables" ) ; } executePendingBatch ( ) ; statement . executeBatch ( ) ; statement . clearBatch ( ) ; } } catch ( SQLException e ) { throw new ApplierException ( "Failed to apply session variables" , e ) ; } } List < ReplOption > rowOptions = data . getOptions ( ) ; if ( rowOptions != null ) { try { if ( applySessionVariables ( null , rowOptions ) ) { if ( logger . isDebugEnabled ( ) ) { logger . debug ( "Applying changed row option variables" ) ; } executePendingBatch ( ) ; statement . executeBatch ( ) ; statement . clearBatch ( ) ; } } catch ( SQLException e ) { throw new ApplierException ( "Failed to apply session variables" , e ) ; } } for ( OneRowChange row : data . getRowChanges ( ) ) { applyOneRowChangePrepared ( row , sourceDbmsType ) ; } }
apply one or more row changes .
