hibernatedriver.java

poleperst-asynch也传上去 希望对大家有所帮助哦 谢谢

/* 
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.hibernate;

import java.util.*;

import org.polepos.framework.*;

import net.sf.hibernate.*;

/**
 * @author Herkules
 */
public abstract class HibernateDriver extends Driver
{

	public void takeSeatIn( Car car, TurnSetup setup ) throws CarMotorFailureException{
        super.takeSeatIn(car, setup);
	}

	public void prepare() throws CarMotorFailureException {
        hibernateCar().openSession();
	}
	
	public void backToPit(){
        hibernateCar().closeSession();
	}
    
    public HibernateCar hibernateCar(){
        return (HibernateCar)car();
    }
		
	public Session db(){
		return hibernateCar().getSession();
	}

	protected void doQuery(String query) {
        
		try{
			Iterator it = db().iterate( query );
			while(it.hasNext()){
				Object o = it.next();
                if(o instanceof CheckSummable){
                    addToCheckSum(((CheckSummable)o).checkSum());
                }
			}
		}
		catch ( HibernateException hex ){
			hex.printStackTrace();
		}		
	}
	
	protected void doSingleResultQuery(String query) {
		try{
			Iterator it = db().iterate( query );
			Object o = (Object) it.next();
            if(o instanceof CheckSummable){
                addToCheckSum(((CheckSummable)o).checkSum());
            }
			if(it.hasNext()) {
				System.err.println("Multiple results, expected only one.");
			}
		}
		catch ( HibernateException hex ){
			hex.printStackTrace();
		}		
	}
}