[hibernate-commits] Hibernate SVN: r20160 - core/branches/Branch_3_5/core/src/main/java/org/hibernate/stat.
hibernate-commits at lists.jboss.org
hibernate-commits at lists.jboss.org
Wed Aug 18 13:03:46 EDT 2010
Author: steve.ebersole at jboss.com
Date: 2010-08-18 13:03:45 -0400 (Wed, 18 Aug 2010)
New Revision: 20160
Modified:
core/branches/Branch_3_5/core/src/main/java/org/hibernate/stat/ConcurrentStatisticsImpl.java
Log:
HHH-5469 - HHH-3659 is only half done, due to HHH-4989 (i.e. no HQL performance log when running Java 5)
Modified: core/branches/Branch_3_5/core/src/main/java/org/hibernate/stat/ConcurrentStatisticsImpl.java
===================================================================
--- core/branches/Branch_3_5/core/src/main/java/org/hibernate/stat/ConcurrentStatisticsImpl.java 2010-08-18 10:33:35 UTC (rev 20159)
+++ core/branches/Branch_3_5/core/src/main/java/org/hibernate/stat/ConcurrentStatisticsImpl.java 2010-08-18 17:03:45 UTC (rev 20160)
@@ -1,3 +1,26 @@
+/*
+ * Hibernate, Relational Persistence for Idiomatic Java
+ *
+ * Copyright (c) 2010, Red Hat Inc. or third-party contributors as
+ * indicated by the @author tags or express copyright attribution
+ * statements applied by the authors. All third-party contributions are
+ * distributed under license by Red Hat Inc.
+ *
+ * This copyrighted material is made available to anyone wishing to use, modify,
+ * copy, or redistribute it subject to the terms and conditions of the GNU
+ * Lesser General Public License, as published by the Free Software Foundation.
+ *
+ * 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 Lesser General Public License
+ * for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with this distribution; if not, write to:
+ * Free Software Foundation, Inc.
+ * 51 Franklin Street, Fifth Floor
+ * Boston, MA 02110-1301 USA
+ */
package org.hibernate.stat;
import java.util.concurrent.ConcurrentHashMap;
@@ -6,59 +29,60 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+
import org.hibernate.cache.Region;
import org.hibernate.engine.SessionFactoryImplementor;
import org.hibernate.util.ArrayHelper;
/**
+ * Implementation of {@link Statistics}, as well as {@link StatisticsImplementor}, based on the
+ * {@link java.util.concurrent} package introduced in Java 5.
+ *
* @author Alex Snaps
- * @see org.hibernate.stat.Statistics
*/
public class ConcurrentStatisticsImpl implements Statistics, StatisticsImplementor {
+ private static final Logger log = LoggerFactory.getLogger( ConcurrentStatisticsImpl.class );
+ private static final Logger PERF_LOG = LoggerFactory.getLogger( Statistics.class );
- //TODO: we should provide some way to get keys of collection of statistics to make it easier to retrieve from a GUI perspective
+ private SessionFactoryImplementor sessionFactory;
- private static final Logger log = LoggerFactory.getLogger(ConcurrentStatisticsImpl.class);
+ private volatile boolean isStatisticsEnabled;
+ private volatile long startTime;
+ private AtomicLong sessionOpenCount = new AtomicLong();
+ private AtomicLong sessionCloseCount = new AtomicLong();
+ private AtomicLong flushCount = new AtomicLong();
+ private AtomicLong connectCount = new AtomicLong();
- private SessionFactoryImplementor sessionFactory;
+ private AtomicLong prepareStatementCount = new AtomicLong();
+ private AtomicLong closeStatementCount = new AtomicLong();
- private volatile boolean isStatisticsEnabled;
- private volatile long startTime;
- private AtomicLong sessionOpenCount = new AtomicLong();
- private AtomicLong sessionCloseCount = new AtomicLong();
- private AtomicLong flushCount = new AtomicLong();
- private AtomicLong connectCount = new AtomicLong();
+ private AtomicLong entityLoadCount = new AtomicLong();
+ private AtomicLong entityUpdateCount = new AtomicLong();
+ private AtomicLong entityInsertCount = new AtomicLong();
+ private AtomicLong entityDeleteCount = new AtomicLong();
+ private AtomicLong entityFetchCount = new AtomicLong();
+ private AtomicLong collectionLoadCount = new AtomicLong();
+ private AtomicLong collectionUpdateCount = new AtomicLong();
+ private AtomicLong collectionRemoveCount = new AtomicLong();
+ private AtomicLong collectionRecreateCount = new AtomicLong();
+ private AtomicLong collectionFetchCount = new AtomicLong();
- private AtomicLong prepareStatementCount = new AtomicLong();
- private AtomicLong closeStatementCount = new AtomicLong();
+ private AtomicLong secondLevelCacheHitCount = new AtomicLong();
+ private AtomicLong secondLevelCacheMissCount = new AtomicLong();
+ private AtomicLong secondLevelCachePutCount = new AtomicLong();
- private AtomicLong entityLoadCount = new AtomicLong();
- private AtomicLong entityUpdateCount = new AtomicLong();
- private AtomicLong entityInsertCount = new AtomicLong();
- private AtomicLong entityDeleteCount = new AtomicLong();
- private AtomicLong entityFetchCount = new AtomicLong();
- private AtomicLong collectionLoadCount = new AtomicLong();
- private AtomicLong collectionUpdateCount = new AtomicLong();
- private AtomicLong collectionRemoveCount = new AtomicLong();
- private AtomicLong collectionRecreateCount = new AtomicLong();
- private AtomicLong collectionFetchCount = new AtomicLong();
+ private AtomicLong queryExecutionCount = new AtomicLong();
+ private AtomicLong queryExecutionMaxTime = new AtomicLong();
+ private volatile String queryExecutionMaxTimeQueryString;
+ private AtomicLong queryCacheHitCount = new AtomicLong();
+ private AtomicLong queryCacheMissCount = new AtomicLong();
+ private AtomicLong queryCachePutCount = new AtomicLong();
- private AtomicLong secondLevelCacheHitCount = new AtomicLong();
- private AtomicLong secondLevelCacheMissCount = new AtomicLong();
- private AtomicLong secondLevelCachePutCount = new AtomicLong();
+ private AtomicLong committedTransactionCount = new AtomicLong();
+ private AtomicLong transactionCount = new AtomicLong();
- private AtomicLong queryExecutionCount = new AtomicLong();
- private AtomicLong queryExecutionMaxTime = new AtomicLong();
- private volatile String queryExecutionMaxTimeQueryString;
- private AtomicLong queryCacheHitCount = new AtomicLong();
- private AtomicLong queryCacheMissCount = new AtomicLong();
- private AtomicLong queryCachePutCount = new AtomicLong();
+ private AtomicLong optimisticFailureCount = new AtomicLong();
- private AtomicLong commitedTransactionCount = new AtomicLong();
- private AtomicLong transactionCount = new AtomicLong();
-
- private AtomicLong optimisticFailureCount = new AtomicLong();
-
/**
* second level cache statistics per region
*/
@@ -89,41 +113,41 @@
* reset all statistics
*/
public void clear() {
- secondLevelCacheHitCount.set(0);
- secondLevelCacheMissCount.set(0);
- secondLevelCachePutCount.set(0);
+ secondLevelCacheHitCount.set( 0 );
+ secondLevelCacheMissCount.set( 0 );
+ secondLevelCachePutCount.set( 0 );
- sessionCloseCount.set(0);
- sessionOpenCount.set(0);
- flushCount.set(0);
- connectCount.set(0);
+ sessionCloseCount.set( 0 );
+ sessionOpenCount.set( 0 );
+ flushCount.set( 0 );
+ connectCount.set( 0 );
- prepareStatementCount.set(0);
- closeStatementCount.set(0);
+ prepareStatementCount.set( 0 );
+ closeStatementCount.set( 0 );
- entityDeleteCount.set(0);
- entityInsertCount.set(0);
- entityUpdateCount.set(0);
- entityLoadCount.set(0);
- entityFetchCount.set(0);
+ entityDeleteCount.set( 0 );
+ entityInsertCount.set( 0 );
+ entityUpdateCount.set( 0 );
+ entityLoadCount.set( 0 );
+ entityFetchCount.set( 0 );
- collectionRemoveCount.set(0);
- collectionUpdateCount.set(0);
- collectionRecreateCount.set(0);
- collectionLoadCount.set(0);
- collectionFetchCount.set(0);
+ collectionRemoveCount.set( 0 );
+ collectionUpdateCount.set( 0 );
+ collectionRecreateCount.set( 0 );
+ collectionLoadCount.set( 0 );
+ collectionFetchCount.set( 0 );
- queryExecutionCount.set(0);
- queryCacheHitCount.set(0);
- queryExecutionMaxTime.set(0);
+ queryExecutionCount.set( 0 );
+ queryCacheHitCount.set( 0 );
+ queryExecutionMaxTime.set( 0 );
queryExecutionMaxTimeQueryString = null;
- queryCacheMissCount.set(0);
- queryCachePutCount.set(0);
+ queryCacheMissCount.set( 0 );
+ queryCachePutCount.set( 0 );
- transactionCount.set(0);
- commitedTransactionCount.set(0);
+ transactionCount.set( 0 );
+ committedTransactionCount.set( 0 );
- optimisticFailureCount.set(0);
+ optimisticFailureCount.set( 0 );
secondLevelCacheStatistics.clear();
entityStatistics.clear();
@@ -151,26 +175,29 @@
public void loadEntity(String entityName) {
entityLoadCount.getAndIncrement();
- ((ConcurrentEntityStatisticsImpl) getEntityStatistics(entityName)).incrementLoadCount();
+ ( (ConcurrentEntityStatisticsImpl) getEntityStatistics( entityName ) ).incrementLoadCount();
}
public void fetchEntity(String entityName) {
entityFetchCount.getAndIncrement();
- ((ConcurrentEntityStatisticsImpl) getEntityStatistics(entityName)).incrementFetchCount();
+ ( (ConcurrentEntityStatisticsImpl) getEntityStatistics( entityName ) ).incrementFetchCount();
}
/**
* find entity statistics per name
*
* @param entityName entity name
+ *
* @return EntityStatistics object
*/
public EntityStatistics getEntityStatistics(String entityName) {
- ConcurrentEntityStatisticsImpl es = (ConcurrentEntityStatisticsImpl) entityStatistics.get(entityName);
- if (es == null) {
- es = new ConcurrentEntityStatisticsImpl(entityName);
+ ConcurrentEntityStatisticsImpl es = (ConcurrentEntityStatisticsImpl) entityStatistics.get( entityName );
+ if ( es == null ) {
+ es = new ConcurrentEntityStatisticsImpl( entityName );
ConcurrentEntityStatisticsImpl previous;
- if ((previous = (ConcurrentEntityStatisticsImpl) entityStatistics.putIfAbsent(entityName, es)) != null) {
+ if ( ( previous = (ConcurrentEntityStatisticsImpl) entityStatistics.putIfAbsent(
+ entityName, es
+ ) ) != null ) {
es = previous;
}
}
@@ -179,19 +206,19 @@
public void updateEntity(String entityName) {
entityUpdateCount.getAndIncrement();
- ConcurrentEntityStatisticsImpl es = (ConcurrentEntityStatisticsImpl) getEntityStatistics(entityName);
+ ConcurrentEntityStatisticsImpl es = (ConcurrentEntityStatisticsImpl) getEntityStatistics( entityName );
es.incrementUpdateCount();
}
public void insertEntity(String entityName) {
entityInsertCount.getAndIncrement();
- ConcurrentEntityStatisticsImpl es = (ConcurrentEntityStatisticsImpl) getEntityStatistics(entityName);
+ ConcurrentEntityStatisticsImpl es = (ConcurrentEntityStatisticsImpl) getEntityStatistics( entityName );
es.incrementInsertCount();
}
public void deleteEntity(String entityName) {
entityDeleteCount.getAndIncrement();
- ConcurrentEntityStatisticsImpl es = (ConcurrentEntityStatisticsImpl) getEntityStatistics(entityName);
+ ConcurrentEntityStatisticsImpl es = (ConcurrentEntityStatisticsImpl) getEntityStatistics( entityName );
es.incrementDeleteCount();
}
@@ -199,14 +226,17 @@
* Get collection statistics per role
*
* @param role collection role
+ *
* @return CollectionStatistics
*/
public CollectionStatistics getCollectionStatistics(String role) {
- ConcurrentCollectionStatisticsImpl cs = (ConcurrentCollectionStatisticsImpl) collectionStatistics.get(role);
- if (cs == null) {
- cs = new ConcurrentCollectionStatisticsImpl(role);
+ ConcurrentCollectionStatisticsImpl cs = (ConcurrentCollectionStatisticsImpl) collectionStatistics.get( role );
+ if ( cs == null ) {
+ cs = new ConcurrentCollectionStatisticsImpl( role );
ConcurrentCollectionStatisticsImpl previous;
- if ((previous = (ConcurrentCollectionStatisticsImpl) collectionStatistics.putIfAbsent(role, cs)) != null) {
+ if ( ( previous = (ConcurrentCollectionStatisticsImpl) collectionStatistics.putIfAbsent(
+ role, cs
+ ) ) != null ) {
cs = previous;
}
}
@@ -215,49 +245,52 @@
public void loadCollection(String role) {
collectionLoadCount.getAndIncrement();
- ((ConcurrentCollectionStatisticsImpl) getCollectionStatistics(role)).incrementLoadCount();
+ ( (ConcurrentCollectionStatisticsImpl) getCollectionStatistics( role ) ).incrementLoadCount();
}
public void fetchCollection(String role) {
collectionFetchCount.getAndIncrement();
- ((ConcurrentCollectionStatisticsImpl) getCollectionStatistics(role)).incrementFetchCount();
+ ( (ConcurrentCollectionStatisticsImpl) getCollectionStatistics( role ) ).incrementFetchCount();
}
public void updateCollection(String role) {
collectionUpdateCount.getAndIncrement();
- ((ConcurrentCollectionStatisticsImpl) getCollectionStatistics(role)).incrementUpdateCount();
+ ( (ConcurrentCollectionStatisticsImpl) getCollectionStatistics( role ) ).incrementUpdateCount();
}
public void recreateCollection(String role) {
collectionRecreateCount.getAndIncrement();
- ((ConcurrentCollectionStatisticsImpl) getCollectionStatistics(role)).incrementRecreateCount();
+ ( (ConcurrentCollectionStatisticsImpl) getCollectionStatistics( role ) ).incrementRecreateCount();
}
public void removeCollection(String role) {
collectionRemoveCount.getAndIncrement();
- ((ConcurrentCollectionStatisticsImpl) getCollectionStatistics(role)).incrementRemoveCount();
+ ( (ConcurrentCollectionStatisticsImpl) getCollectionStatistics( role ) ).incrementRemoveCount();
}
/**
* Second level cache statistics per region
*
* @param regionName region name
+ *
* @return SecondLevelCacheStatistics
*/
public SecondLevelCacheStatistics getSecondLevelCacheStatistics(String regionName) {
ConcurrentSecondLevelCacheStatisticsImpl slcs
- = (ConcurrentSecondLevelCacheStatisticsImpl) secondLevelCacheStatistics.get(regionName);
- if (slcs == null) {
- if (sessionFactory == null) {
+ = (ConcurrentSecondLevelCacheStatisticsImpl) secondLevelCacheStatistics.get( regionName );
+ if ( slcs == null ) {
+ if ( sessionFactory == null ) {
return null;
}
- Region region = sessionFactory.getSecondLevelCacheRegion(regionName);
- if (region == null) {
+ Region region = sessionFactory.getSecondLevelCacheRegion( regionName );
+ if ( region == null ) {
return null;
}
- slcs = new ConcurrentSecondLevelCacheStatisticsImpl(region);
+ slcs = new ConcurrentSecondLevelCacheStatisticsImpl( region );
ConcurrentSecondLevelCacheStatisticsImpl previous;
- if ((previous = (ConcurrentSecondLevelCacheStatisticsImpl) secondLevelCacheStatistics.putIfAbsent(regionName, slcs)) != null) {
+ if ( ( previous = (ConcurrentSecondLevelCacheStatisticsImpl) secondLevelCacheStatistics.putIfAbsent(
+ regionName, slcs
+ ) ) != null ) {
slcs = previous;
}
}
@@ -266,60 +299,70 @@
public void secondLevelCachePut(String regionName) {
secondLevelCachePutCount.getAndIncrement();
- ((ConcurrentSecondLevelCacheStatisticsImpl) getSecondLevelCacheStatistics(regionName)).incrementPutCount();
+ ( (ConcurrentSecondLevelCacheStatisticsImpl) getSecondLevelCacheStatistics( regionName ) ).incrementPutCount();
}
public void secondLevelCacheHit(String regionName) {
secondLevelCacheHitCount.getAndIncrement();
- ((ConcurrentSecondLevelCacheStatisticsImpl) getSecondLevelCacheStatistics(regionName)).incrementHitCount();
+ ( (ConcurrentSecondLevelCacheStatisticsImpl) getSecondLevelCacheStatistics( regionName ) ).incrementHitCount();
}
public void secondLevelCacheMiss(String regionName) {
secondLevelCacheMissCount.getAndIncrement();
- ((ConcurrentSecondLevelCacheStatisticsImpl) getSecondLevelCacheStatistics(regionName)).incrementMissCount();
+ ( (ConcurrentSecondLevelCacheStatisticsImpl) getSecondLevelCacheStatistics( regionName ) ).incrementMissCount();
}
public void queryExecuted(String hql, int rows, long time) {
+ PERF_LOG.info( "HQL: {}, time: {}ms, rows: {}", new Object[] {hql, Long.valueOf( time ), Long.valueOf(rows)} );
queryExecutionCount.getAndIncrement();
boolean isLongestQuery = false;
- for (long old = queryExecutionMaxTime.get(); (time > old) && (isLongestQuery = !queryExecutionMaxTime.compareAndSet(old, time)); old = queryExecutionMaxTime.get())
- ;
- if (isLongestQuery) {
+ for ( long old = queryExecutionMaxTime.get();
+ ( time > old ) && ( isLongestQuery = !queryExecutionMaxTime.compareAndSet( old, time ) );
+ old = queryExecutionMaxTime.get() ) {
+ // nothing to do here given the odd loop structure...
+ }
+ if ( isLongestQuery ) {
queryExecutionMaxTimeQueryString = hql;
}
- if (hql != null) {
- ConcurrentQueryStatisticsImpl qs = (ConcurrentQueryStatisticsImpl) getQueryStatistics(hql);
- qs.executed(rows, time);
+ if ( hql != null ) {
+ ConcurrentQueryStatisticsImpl qs = (ConcurrentQueryStatisticsImpl) getQueryStatistics( hql );
+ qs.executed( rows, time );
}
}
public void queryCacheHit(String hql, String regionName) {
queryCacheHitCount.getAndIncrement();
- if (hql != null) {
- ConcurrentQueryStatisticsImpl qs = (ConcurrentQueryStatisticsImpl) getQueryStatistics(hql);
+ if ( hql != null ) {
+ ConcurrentQueryStatisticsImpl qs = (ConcurrentQueryStatisticsImpl) getQueryStatistics( hql );
qs.incrementCacheHitCount();
}
- ConcurrentSecondLevelCacheStatisticsImpl slcs = (ConcurrentSecondLevelCacheStatisticsImpl) getSecondLevelCacheStatistics(regionName);
+ ConcurrentSecondLevelCacheStatisticsImpl slcs = (ConcurrentSecondLevelCacheStatisticsImpl) getSecondLevelCacheStatistics(
+ regionName
+ );
slcs.incrementHitCount();
}
public void queryCacheMiss(String hql, String regionName) {
queryCacheMissCount.getAndIncrement();
- if (hql != null) {
- ConcurrentQueryStatisticsImpl qs = (ConcurrentQueryStatisticsImpl) getQueryStatistics(hql);
+ if ( hql != null ) {
+ ConcurrentQueryStatisticsImpl qs = (ConcurrentQueryStatisticsImpl) getQueryStatistics( hql );
qs.incrementCacheMissCount();
}
- ConcurrentSecondLevelCacheStatisticsImpl slcs = (ConcurrentSecondLevelCacheStatisticsImpl) getSecondLevelCacheStatistics(regionName);
+ ConcurrentSecondLevelCacheStatisticsImpl slcs = (ConcurrentSecondLevelCacheStatisticsImpl) getSecondLevelCacheStatistics(
+ regionName
+ );
slcs.incrementMissCount();
}
public void queryCachePut(String hql, String regionName) {
queryCachePutCount.getAndIncrement();
- if (hql != null) {
- ConcurrentQueryStatisticsImpl qs = (ConcurrentQueryStatisticsImpl) getQueryStatistics(hql);
+ if ( hql != null ) {
+ ConcurrentQueryStatisticsImpl qs = (ConcurrentQueryStatisticsImpl) getQueryStatistics( hql );
qs.incrementCachePutCount();
}
- ConcurrentSecondLevelCacheStatisticsImpl slcs = (ConcurrentSecondLevelCacheStatisticsImpl) getSecondLevelCacheStatistics(regionName);
+ ConcurrentSecondLevelCacheStatisticsImpl slcs = (ConcurrentSecondLevelCacheStatisticsImpl) getSecondLevelCacheStatistics(
+ regionName
+ );
slcs.incrementPutCount();
}
@@ -327,14 +370,17 @@
* Query statistics from query string (HQL or SQL)
*
* @param queryString query string
+ *
* @return QueryStatistics
*/
public QueryStatistics getQueryStatistics(String queryString) {
- ConcurrentQueryStatisticsImpl qs = (ConcurrentQueryStatisticsImpl) queryStatistics.get(queryString);
- if (qs == null) {
- qs = new ConcurrentQueryStatisticsImpl(queryString);
+ ConcurrentQueryStatisticsImpl qs = (ConcurrentQueryStatisticsImpl) queryStatistics.get( queryString );
+ if ( qs == null ) {
+ qs = new ConcurrentQueryStatisticsImpl( queryString );
ConcurrentQueryStatisticsImpl previous;
- if ((previous = (ConcurrentQueryStatisticsImpl) queryStatistics.putIfAbsent(queryString, qs)) != null) {
+ if ( ( previous = (ConcurrentQueryStatisticsImpl) queryStatistics.putIfAbsent(
+ queryString, qs
+ ) ) != null ) {
qs = previous;
}
}
@@ -488,35 +534,35 @@
* log in info level the main statistics
*/
public void logSummary() {
- log.info("Logging statistics....");
- log.info("start time: " + startTime);
- log.info("sessions opened: " + sessionOpenCount);
- log.info("sessions closed: " + sessionCloseCount);
- log.info("transactions: " + transactionCount);
- log.info("successful transactions: " + commitedTransactionCount);
- log.info("optimistic lock failures: " + optimisticFailureCount);
- log.info("flushes: " + flushCount);
- log.info("connections obtained: " + connectCount);
- log.info("statements prepared: " + prepareStatementCount);
- log.info("statements closed: " + closeStatementCount);
- log.info("second level cache puts: " + secondLevelCachePutCount);
- log.info("second level cache hits: " + secondLevelCacheHitCount);
- log.info("second level cache misses: " + secondLevelCacheMissCount);
- log.info("entities loaded: " + entityLoadCount);
- log.info("entities updated: " + entityUpdateCount);
- log.info("entities inserted: " + entityInsertCount);
- log.info("entities deleted: " + entityDeleteCount);
- log.info("entities fetched (minimize this): " + entityFetchCount);
- log.info("collections loaded: " + collectionLoadCount);
- log.info("collections updated: " + collectionUpdateCount);
- log.info("collections removed: " + collectionRemoveCount);
- log.info("collections recreated: " + collectionRecreateCount);
- log.info("collections fetched (minimize this): " + collectionFetchCount);
- log.info("queries executed to database: " + queryExecutionCount);
- log.info("query cache puts: " + queryCachePutCount);
- log.info("query cache hits: " + queryCacheHitCount);
- log.info("query cache misses: " + queryCacheMissCount);
- log.info("max query time: " + queryExecutionMaxTime + "ms");
+ log.info( "Logging statistics...." );
+ log.info( "start time: " + startTime );
+ log.info( "sessions opened: " + sessionOpenCount );
+ log.info( "sessions closed: " + sessionCloseCount );
+ log.info( "transactions: " + transactionCount );
+ log.info( "successful transactions: " + committedTransactionCount );
+ log.info( "optimistic lock failures: " + optimisticFailureCount );
+ log.info( "flushes: " + flushCount );
+ log.info( "connections obtained: " + connectCount );
+ log.info( "statements prepared: " + prepareStatementCount );
+ log.info( "statements closed: " + closeStatementCount );
+ log.info( "second level cache puts: " + secondLevelCachePutCount );
+ log.info( "second level cache hits: " + secondLevelCacheHitCount );
+ log.info( "second level cache misses: " + secondLevelCacheMissCount );
+ log.info( "entities loaded: " + entityLoadCount );
+ log.info( "entities updated: " + entityUpdateCount );
+ log.info( "entities inserted: " + entityInsertCount );
+ log.info( "entities deleted: " + entityDeleteCount );
+ log.info( "entities fetched (minimize this): " + entityFetchCount );
+ log.info( "collections loaded: " + collectionLoadCount );
+ log.info( "collections updated: " + collectionUpdateCount );
+ log.info( "collections removed: " + collectionRemoveCount );
+ log.info( "collections recreated: " + collectionRecreateCount );
+ log.info( "collections fetched (minimize this): " + collectionFetchCount );
+ log.info( "queries executed to database: " + queryExecutionCount );
+ log.info( "query cache puts: " + queryCachePutCount );
+ log.info( "query cache hits: " + queryCacheHitCount );
+ log.info( "query cache misses: " + queryCacheMissCount );
+ log.info( "max query time: " + queryExecutionMaxTime + "ms" );
}
/**
@@ -545,49 +591,54 @@
* Get all executed query strings
*/
public String[] getQueries() {
- return ArrayHelper.toStringArray(queryStatistics.keySet());
+ return ArrayHelper.toStringArray( queryStatistics.keySet() );
}
/**
* Get the names of all entities
*/
public String[] getEntityNames() {
- if (sessionFactory == null) {
- return ArrayHelper.toStringArray(entityStatistics.keySet());
- } else {
- return ArrayHelper.toStringArray(sessionFactory.getAllClassMetadata().keySet());
+ if ( sessionFactory == null ) {
+ return ArrayHelper.toStringArray( entityStatistics.keySet() );
}
+ else {
+ return ArrayHelper.toStringArray( sessionFactory.getAllClassMetadata().keySet() );
+ }
}
/**
* Get the names of all collection roles
*/
public String[] getCollectionRoleNames() {
- if (sessionFactory == null) {
- return ArrayHelper.toStringArray(collectionStatistics.keySet());
- } else {
- return ArrayHelper.toStringArray(sessionFactory.getAllCollectionMetadata().keySet());
+ if ( sessionFactory == null ) {
+ return ArrayHelper.toStringArray( collectionStatistics.keySet() );
}
+ else {
+ return ArrayHelper.toStringArray( sessionFactory.getAllCollectionMetadata().keySet() );
+ }
}
/**
* Get all second-level cache region names
*/
public String[] getSecondLevelCacheRegionNames() {
- if (sessionFactory == null) {
- return ArrayHelper.toStringArray(secondLevelCacheStatistics.keySet());
- } else {
- return ArrayHelper.toStringArray(sessionFactory.getAllSecondLevelCacheRegions().keySet());
+ if ( sessionFactory == null ) {
+ return ArrayHelper.toStringArray( secondLevelCacheStatistics.keySet() );
}
+ else {
+ return ArrayHelper.toStringArray( sessionFactory.getAllSecondLevelCacheRegions().keySet() );
+ }
}
public void endTransaction(boolean success) {
transactionCount.getAndIncrement();
- if (success) commitedTransactionCount.getAndIncrement();
+ if ( success ) {
+ committedTransactionCount.getAndIncrement();
+ }
}
public long getSuccessfulTransactionCount() {
- return commitedTransactionCount.get();
+ return committedTransactionCount.get();
}
public long getTransactionCount() {
@@ -612,7 +663,7 @@
public void optimisticFailure(String entityName) {
optimisticFailureCount.getAndIncrement();
- ((ConcurrentEntityStatisticsImpl) getEntityStatistics(entityName)).incrementOptimisticFailureCount();
+ ( (ConcurrentEntityStatisticsImpl) getEntityStatistics( entityName ) ).incrementOptimisticFailureCount();
}
public long getOptimisticFailureCount() {
@@ -621,36 +672,36 @@
public String toString() {
return new StringBuilder()
- .append("Statistics[")
- .append("start time=").append(startTime)
- .append(",sessions opened=").append(sessionOpenCount)
- .append(",sessions closed=").append(sessionCloseCount)
- .append(",transactions=").append(transactionCount)
- .append(",successful transactions=").append(commitedTransactionCount)
- .append(",optimistic lock failures=").append(optimisticFailureCount)
- .append(",flushes=").append(flushCount)
- .append(",connections obtained=").append(connectCount)
- .append(",statements prepared=").append(prepareStatementCount)
- .append(",statements closed=").append(closeStatementCount)
- .append(",second level cache puts=").append(secondLevelCachePutCount)
- .append(",second level cache hits=").append(secondLevelCacheHitCount)
- .append(",second level cache misses=").append(secondLevelCacheMissCount)
- .append(",entities loaded=").append(entityLoadCount)
- .append(",entities updated=").append(entityUpdateCount)
- .append(",entities inserted=").append(entityInsertCount)
- .append(",entities deleted=").append(entityDeleteCount)
- .append(",entities fetched=").append(entityFetchCount)
- .append(",collections loaded=").append(collectionLoadCount)
- .append(",collections updated=").append(collectionUpdateCount)
- .append(",collections removed=").append(collectionRemoveCount)
- .append(",collections recreated=").append(collectionRecreateCount)
- .append(",collections fetched=").append(collectionFetchCount)
- .append(",queries executed to database=").append(queryExecutionCount)
- .append(",query cache puts=").append(queryCachePutCount)
- .append(",query cache hits=").append(queryCacheHitCount)
- .append(",query cache misses=").append(queryCacheMissCount)
- .append(",max query time=").append(queryExecutionMaxTime)
- .append(']')
+ .append( "Statistics[" )
+ .append( "start time=" ).append( startTime )
+ .append( ",sessions opened=" ).append( sessionOpenCount )
+ .append( ",sessions closed=" ).append( sessionCloseCount )
+ .append( ",transactions=" ).append( transactionCount )
+ .append( ",successful transactions=" ).append( committedTransactionCount )
+ .append( ",optimistic lock failures=" ).append( optimisticFailureCount )
+ .append( ",flushes=" ).append( flushCount )
+ .append( ",connections obtained=" ).append( connectCount )
+ .append( ",statements prepared=" ).append( prepareStatementCount )
+ .append( ",statements closed=" ).append( closeStatementCount )
+ .append( ",second level cache puts=" ).append( secondLevelCachePutCount )
+ .append( ",second level cache hits=" ).append( secondLevelCacheHitCount )
+ .append( ",second level cache misses=" ).append( secondLevelCacheMissCount )
+ .append( ",entities loaded=" ).append( entityLoadCount )
+ .append( ",entities updated=" ).append( entityUpdateCount )
+ .append( ",entities inserted=" ).append( entityInsertCount )
+ .append( ",entities deleted=" ).append( entityDeleteCount )
+ .append( ",entities fetched=" ).append( entityFetchCount )
+ .append( ",collections loaded=" ).append( collectionLoadCount )
+ .append( ",collections updated=" ).append( collectionUpdateCount )
+ .append( ",collections removed=" ).append( collectionRemoveCount )
+ .append( ",collections recreated=" ).append( collectionRecreateCount )
+ .append( ",collections fetched=" ).append( collectionFetchCount )
+ .append( ",queries executed to database=" ).append( queryExecutionCount )
+ .append( ",query cache puts=" ).append( queryCachePutCount )
+ .append( ",query cache hits=" ).append( queryCacheHitCount )
+ .append( ",query cache misses=" ).append( queryCacheMissCount )
+ .append( ",max query time=" ).append( queryExecutionMaxTime )
+ .append( ']' )
.toString();
}
More information about the hibernate-commits
mailing list