melbourneperst.java

个人感觉非常不错的poleperst-acid

/* 
This file is part of the PolePosition database benchmark
http://www.polepos.org

This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public
License along with this program; if not, write to the Free
Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
MA  02111-1307, USA. */

package org.polepos.teams.perst;

import org.polepos.circuits.melbourne.*;

import org.garret.perst.*;


/**
 * @author Knizhnik
 */
public class MelbournePerst extends PerstDriver implements MelbourneDriver{
    private IPersistentSet<PerstPilot> extent;

    protected void initialize() { 
        extent = (IPersistentSet<PerstPilot>)db.getRoot();
        if (extent == null) { 
            extent = db.<PerstPilot>createSet();
            db.setRoot(extent);
        }
    }
	
    public void write(){
        
        int numobjects = setup().getObjectCount();
        int commitinterval  = setup().getCommitInterval();
        int commitctr = 0;
        
        for ( int i = 1; i <= numobjects; i++ ) {            
            PerstPilot p = new PerstPilot( "Pilot_" + i, "Herkules", i, i ) ;
            extent.add(p);
            
            if ( commitinterval > 0  &&  ++commitctr >= commitinterval ){
                commitctr = 0;
                commit();
            }
            
            addToCheckSum(i);
        }       
        commit();
    }

    public void read(){
        iterate(extent.iterator());
    }
    
    public void read_hot() {
        read();
    }
	
    public void delete() {
        for (PerstPilot p : extent) { 
            p.deallocate();
        }
        extent.clear();
    	commit();
    }	
}