public class BatchingBatcherAntica extends AbstractBatcher {

   private int batchSize;
   private Expectation[] expectations;
   
   public BatchingBatcherAntica(ConnectionManager connectionManager, Interceptor interceptor) {
      super( connectionManager, interceptor );
      expectations = new Expectation[ getFactory().getSettings().getJdbcBatchSize() ];
   }

   public void addToBatch(Expectation expectation) throws SQLException, HibernateException {
      if ( !expectation.canBeBatched() ) {
         throw new HibernateException( "attempting to batch an operation which cannot be batched" );
      }
      PreparedStatement batchUpdate = getStatement();
      batchUpdate.addBatch();
      expectations[ batchSize++ ] = expectation;
      if ( batchSize == getFactory().getSettings().getJdbcBatchSize() ) {
         doExecuteBatch( batchUpdate );
      }
   }

   protected void doExecuteBatch(PreparedStatement ps) throws SQLException, HibernateException {
      if ( batchSize == 0 ) {
         //log.debug( "no batched statements to execute" );
      }
      else {

         try {
            //checkRowCounts( ps.executeBatch(), ps );
            ps.executeBatch();
         }
         catch (RuntimeException re) {
            //log.error( "Exception executing batch: ", re );
            throw re;
         }
         finally {
            batchSize = 0;
         }

      }

   }

}