bahrainprevaylerdriver.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.prevayler.bahrain;

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

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


public class BahrainPrevaylerDriver extends PrevaylerDriver implements BahrainDriver{
	
	private final BahrainSystem _bahrainSystem = (BahrainSystem)_prevayler.prevalentSystem();

    public void write(){
        int objectsToWrite= setup().getObjectCount(); 
        int commitInterval= setup().getCommitInterval();
        
        while (objectsToWrite > 0) {
            int objectsToWriteNow = objectsToWrite < commitInterval
                ? objectsToWrite
                : commitInterval;
            _prevayler.execute(new ObjectCreationTransaction(objectsToWriteNow));
            objectsToWrite -= commitInterval;
        }
	}
 
    public void query_indexed_string() {
        int count = setup().getSelectCount();
        for (int i = 1; i <= count; i++) {
            Pilot p = _bahrainSystem.pilotByName("Pilot_" + i);
            addToCheckSum(p.checkSum());
        }
    }
            
    public void query_string() {
        int count = setup().getSelectCount();
        for (int i = 1; i <= count; i++) {
            Pilot p = _bahrainSystem.pilotByFirstName("Jonny_" + i);
            addToCheckSum(p.checkSum());
        }
    }

    public void query_indexed_int() {
        int count = setup().getSelectCount();
        for (int i = 1; i <= count; i++) {
            Pilot p = _bahrainSystem.pilotByLicenseID(i);
            addToCheckSum(p.checkSum());
        }
    }

    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();
	}

    protected Object prevalentSystem() {
        //return new BahrainSystem();
return null;
    }
	
}