newperformancetest.java

hibernate 开源框架的代码 jar包希望大家能喜欢

package org.hibernate.test.perf;

import java.io.Serializable;
import java.util.List;

import junit.framework.Test;
import junit.textui.TestRunner;

import org.hibernate.classic.Session;
import org.hibernate.junit.functional.FunctionalTestCase;
import org.hibernate.junit.functional.FunctionalTestClassTestSuite;
import org.hibernate.test.legacy.Simple;

public class NewPerformanceTest extends FunctionalTestCase {

	public NewPerformanceTest(String arg0) {
		super(arg0);
	}

	public String[] getMappings() {
		return new String[] { "legacy/Simple.hbm.xml" };
	}

	public static Test suite() {
		return new FunctionalTestClassTestSuite( NewPerformanceTest.class );
	}

	public static void main(String[] args) throws Exception {
		TestRunner.run( suite() );
	}

	public void testPerformance() throws Exception {

		for ( int n=2; n<4000; n*=2 ) {

			Simple[] simples = new Simple[n];
			Serializable[] ids = new Serializable[n];
			for ( int i=0; i<n; i++ ) {
				simples[i] = new Simple();
				simples[i].init();
				simples[i].setCount(i);
				ids[i] = new Long(i);
			}

			Session s = openSession();
			prepare(s, simples, ids, n);
			s.close();

			long find = 0;
			long flush = 0;

			for ( int i=0; i<100; i++ ) {

				s = openSession();
				long time = System.currentTimeMillis();
				List list = s.createQuery("from Simple s where not s.name='osama bin laden' and s.other is null").list();
				find += System.currentTimeMillis() - time;
				assertTrue( list.size()==n );
				time = System.currentTimeMillis();
				s.flush();
				flush += System.currentTimeMillis() - time;
				time = System.currentTimeMillis();
				s.connection().commit();
				find += System.currentTimeMillis() - time;
				s.close();

			}

			System.out.println( "Objects: " + n + " - find(): " + find + "ms / flush(): " + flush + "ms / Ratio: " + ( (float) flush )/find );
			System.out.println( "Objects: " + n + " flush time per object: " + flush / 100.0 / n );
			System.out.println( "Objects: " + n + " load time per object: " + find / 100.0 / n );
			s = openSession();
			delete(s);
			s.close();

		}
	}

	private void prepare(Session s, Simple[] simples, Serializable[] ids, int N) throws Exception {
		for ( int i=0; i<N; i++ ) {
			s.save( simples[i], ids[i] );
		}
		s.flush();
		s.connection().commit();
	}

	private void delete(Session s) throws Exception {
		s.delete("from Simple s");
		s.flush();
		s.connection().commit();
	}

}