bahraindb4o.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.db4o;

import org.polepos.circuits.bahrain.*;
import org.polepos.data.*;
import org.polepos.framework.*;

import com.db4o.*;
import com.db4o.query.*;



/**
 * @author Herkules
 */
public class BahrainDb4o extends Db4oDriver implements BahrainDriver{
		
	
	public void takeSeatIn(Car car, TurnSetup setup) throws CarMotorFailureException{

        Db4o.configure().objectClass( Pilot.class ).objectField( "mName" ).indexed( true );
        Db4o.configure().objectClass( Pilot.class ).objectField( "mLicenseID" ).indexed( true );

        super.takeSeatIn(car, setup);
	}
	
	public void write(){
        int commitctr = 0;
        int count = setup().getObjectCount();
        int commitInterval = setup().getCommitInterval();
        begin();
		for ( int i = 1; i <= count; i++ ){
			store( new Pilot( "Pilot_" + i, "Jonny_" + i, i , i ) );
            if ( commitInterval> 0  &&  ++commitctr >= commitInterval ){
                commitctr = 0;
                commit();
                begin();
            }
            addToCheckSum(i);
		}
		commit();
	}
 
    public void query_indexed_string() {
        int count = setup().getSelectCount();
        for (int i = 1; i <= count; i++) {
            Query q = db().query();
            q.constrain( Pilot.class );
            q.descend( "mName" ).constrain("Pilot_" + i);
            doQuery( q );
        }
        
    }
            
    public void query_string() {
        int count = setup().getSelectCount();
        for (int i = 1; i <= count; i++) {
            Query q = db().query();
            q.constrain( Pilot.class );
            q.descend( "mFirstName" ).constrain("Jonny_" + i);
            doQuery( q );
        }
    }

    public void query_indexed_int() {
        int count = setup().getSelectCount();
        for (int i = 1; i <= count; i++) {
    		Query q = db().query();
    		q.constrain( Pilot.class );
    		q.descend( "mLicenseID" ).constrain(new Integer(i));
    		doQuery( q );
        }
    }

    public void query_int() {
        int count = setup().getSelectCount();
        for (int i = 1; i <= count; i++) {
    		Query q = db().query();
    		q.constrain( Pilot.class );
    		q.descend( "mPoints" ).constrain(new Integer(i));
    		doQuery( q );
        }
    }

    public void update() {
        int updateCount = setup().getUpdateCount();
        Query q = db().query();
    	q.constrain( Pilot.class );
    	ObjectSet set = q.execute();
        for (int i = 1; i <= updateCount; i++) {
            Pilot p = (Pilot)set.next();
            p.setName( p.getName().toUpperCase() );
            db().set(p);
            addToCheckSum(1);
        }
    	db().commit();
	}
	
    public void delete() {
    	Query q = db().query();
    	q.constrain( Pilot.class );
    	ObjectSet deleteset = q.execute();
    	while ( deleteset.hasNext() ){
    		db().delete( deleteset.next() );
            addToCheckSum(1);
    	}
    	db().commit();
	}
	
}