Hibernate
/
hibernate-orm
mirror of https://github.com/hibernate/hibernate-orm
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

HHH-3998 - Fix spurious failures in ConfigurationPerformanceTest 

git-svn-id: https://svn.jboss.org/repos/hibernate/core/trunk@16969 1b8cb986-b30d-0410-93ca-fae66ebed9b2
This commit is contained in:
Steve Ebersole 2009-06-30 04:14:35 +00:00
parent 7271546f4e
commit 86295c36bc
2 changed files with 108 additions and 82 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
core/src/main/java/org/hibernate/id/factory/DefaultIdentifierGeneratorFactory.java
View File

@ -25,6 +25,7 @@
package org.hibernate.id.factory;
import java.util.Properties;
import java.io.Serializable;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@ -55,10 +56,10 @@ import org.hibernate.MappingException;
*
* @author Steve Ebersole
*/
public class DefaultIdentifierGeneratorFactory implements IdentifierGeneratorFactory {
public class DefaultIdentifierGeneratorFactory implements IdentifierGeneratorFactory, Serializable {
private static final Logger log = LoggerFactory.getLogger( DefaultIdentifierGeneratorFactory.class );
private Dialect dialect;
private transient Dialect dialect;
private FastHashMap generatorStrategyToClassNameMap = new FastHashMap();
/**

159
testsuite/src/test/java/org/hibernate/test/cfg/ConfigurationPerformanceTest.java
View File

@ -54,9 +54,13 @@ public class ConfigurationPerformanceTest extends UnitTestCase {
mappingBaseDir = new File( compilationBaseDir, "org/hibernate/test" );
workPackageDir = new File( compilationBaseDir, workPackageName.replace( '.', '/' ) );
if ( workPackageDir.exists() ) {
//noinspection ResultOfMethodCallIgnored
workPackageDir.delete();
}
workPackageDir.mkdirs();
boolean created = workPackageDir.mkdirs();
if ( !created ) {
System.err.println( "Unable to create workPackageDir during setup" );
}
}
protected void tearDown() throws Exception {
@ -120,37 +124,27 @@ public class ConfigurationPerformanceTest extends UnitTestCase {
}
public void testLoadingAndSerializationOfConfiguration() throws Throwable {
String prefix = mappingBaseDir.getAbsolutePath() + '/';
final File cachedCfgFile = new File( workPackageDir, "hibernate.cfg.bin" );
try {
// first time
System.err.println( "###FIRST SAVELOAD###" );
SessionFactory factory = saveAndLoad( prefix, FILES, "hibernate.cfg.bin" );
factory.close();
// second time to validate
System.err.println( "###SECOND SAVELOAD###" );
factory = saveAndLoad( prefix, FILES, "hibernate.cfg.bin" );
factory.close();
System.err.println( "#### Preparing serialized configuration ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~" );
prepareSerializedConfiguration( mappingBaseDir, FILES, cachedCfgFile );
System.err.println( "#### Preparing serialized configuration complete ~~~~~~~~~~~~~~~~~~~~~~~~" );
// now make sure we can reload the serialized configuration...
System.err.println( "#### Reading serialized configuration ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~" );
readSerializedConfiguration( cachedCfgFile );
System.err.println( "#### Reading serialized configuration complete ~~~~~~~~~~~~~~~~~~~~~~~~~~" );
}
finally {
System.err.println( "###CLEANING UP###" );
File file = null;
try {
// clean up
file = new File( "hibernate.cfg.bin" );
file.delete();
if ( ! cachedCfgFile.delete() ) {
System.err.println( "Unable to cleanup file " + cachedCfgFile.getAbsolutePath() );
}
catch ( Throwable t ) {
System.err.println( "Unable to cleanup [" + file + "] : " + t );
}
//noinspection ForLoopReplaceableByForEach
for ( int i = 0; i < FILES.length; i++ ) {
try {
String fileName = FILES[i];
file = new File( prefix, fileName + ".bin" );
file.delete();
}
catch ( Throwable t ) {
System.err.println( "Unable to cleanup [" + file + "] : " + t );
File file = new File( mappingBaseDir, FILES[i] + ".bin" );
if ( ! file.delete() ) {
System.err.println( "Unable to cleanup file " + file.getAbsolutePath() );
}
}
}
@ -163,66 +157,100 @@ public class ConfigurationPerformanceTest extends UnitTestCase {
return;
}
SessionFactory factory = saveAndLoad(
workPackageDir.getAbsolutePath() + '/',
long start = System.currentTimeMillis();
Configuration configuration = buildConfigurationFromCacheableFiles(
workPackageDir,
workPackageDir.list(
new FilenameFilter() {
public boolean accept(File dir, String name) {
return name.endsWith( ".hbm.xml" );
}
}
),
"hibernateperftest.cfg.bin"
)
);
Session session = factory.openSession();
session.createQuery( "from Test1" ).list();
SessionFactory factory = configuration.buildSessionFactory();
long initial = System.currentTimeMillis() - start;
factory.close();
}
private SessionFactory saveAndLoad(String prefix, String[] files, String cfgName) throws Throwable {
System.err.println( "saveAndLoad from " + prefix + " with cfg = " + cfgName );
File cachedCfgFile = new File( workPackageDir, cfgName );
Configuration cfg;
long start;
if ( !cachedCfgFile.exists() ) {
start = System.currentTimeMillis();
cfg = new Configuration();
cfg.setProperty( Environment.HBM2DDL_AUTO, "create-drop" );
System.err.println( "Created configuration: " + ( System.currentTimeMillis() - start ) / 1000.0 + " sec." );
start = System.currentTimeMillis();
for ( int i = 0; i < files.length; i++ ) {
String file = files[i];
cfg.addCacheableFile( new File( prefix + file ) );
configuration = buildConfigurationFromCacheableFiles(
workPackageDir,
workPackageDir.list(
new FilenameFilter() {
public boolean accept(File dir, String name) {
return name.endsWith( ".hbm.xml" );
}
System.err.println(
"Added " + ( files.length ) + " resources: " +
( System.currentTimeMillis() - start ) / 1000.0 + " sec."
}
)
);
factory = configuration.buildSessionFactory();
long subsequent = System.currentTimeMillis() - start;
// Let's make sure the mappings were read in correctly (in termas of they are operational).
Session session = factory.openSession();
session.beginTransaction();
session.createQuery( "from Test1" ).list();
session.getTransaction().commit();
session.close();
factory.close();
System.err.println( "Initial SessionFactory load time : " + initial );
System.err.println( "Subsequent SessionFactory load time : " + subsequent );
}
private void prepareSerializedConfiguration(
File mappingFileBase,
String[] files,
File cachedCfgFile) throws IOException {
Configuration cfg = buildConfigurationFromCacheableFiles( mappingFileBase, files );
ObjectOutputStream os = new ObjectOutputStream( new FileOutputStream( cachedCfgFile ) );
os.writeObject( cfg ); // need to serialize Configuration *before* building sf since it would require non-mappings and cfg types to be serializable
os.flush();
os.close();
timeBuildingSessionFactory( cfg );
}
else {
private Configuration buildConfigurationFromCacheableFiles(File mappingFileBase, String[] files) {
long start = System.currentTimeMillis();
Configuration cfg = new Configuration();
cfg.setProperty( Environment.HBM2DDL_AUTO, "create-drop" );
System.err.println(
"Created configuration: " + ( System.currentTimeMillis() - start ) / 1000.0 + " sec."
);
start = System.currentTimeMillis();
ObjectInputStream is = new ObjectInputStream( new FileInputStream( cachedCfgFile ) );
cfg = ( Configuration ) is.readObject();
is.close();
System.err
.println( "Loaded serializable configuration:" + ( System.currentTimeMillis() - start ) / 1000.0 + " sec." );
//noinspection ForLoopReplaceableByForEach
for ( int i = 0; i < files.length; i++ ) {
cfg.addCacheableFile( new File( mappingFileBase, files[i] ) );
}
start = System.currentTimeMillis();
System.err.println(
"Added " + ( files.length ) + " resources: " +
( System.currentTimeMillis() - start ) / 1000.0 + " sec."
);
return cfg;
}
private void timeBuildingSessionFactory(Configuration configuration) {
long start = System.currentTimeMillis();
System.err.println( "Start build of session factory" );
SessionFactory factory = cfg.buildSessionFactory();
System.err.println( "Build session factory:" + ( System.currentTimeMillis() - start ) / 1000.0 + " sec." );
return factory;
SessionFactory factory = configuration.buildSessionFactory();
System.err.println( "Built session factory :" + ( System.currentTimeMillis() - start ) / 1000.0 + " sec." );
factory.close();
}
private void readSerializedConfiguration(File cachedCfgFile) throws ClassNotFoundException, IOException {
long start = System.currentTimeMillis();
ObjectInputStream is = new ObjectInputStream( new FileInputStream( cachedCfgFile ) );
Configuration cfg = ( Configuration ) is.readObject();
is.close();
System.err.println(
"Loaded serializable configuration :" +
( System.currentTimeMillis() - start ) / 1000.0 + " sec."
);
timeBuildingSessionFactory( cfg );
}
public void generateTestFiles() throws Throwable {
@ -233,9 +261,6 @@ public class ConfigurationPerformanceTest extends UnitTestCase {
File hbmFile = new File( workPackageDir, name + ".hbm.xml" );
filesToCompile += ( javaFile.getAbsolutePath() + " " );
javaFile.getParentFile().mkdirs();
hbmFile.getParentFile().mkdirs();
System.out.println( "Generating " + javaFile.getAbsolutePath() );
PrintWriter javaWriter = null;
PrintWriter hbmWriter = null;