/******************************************************************************* | |
* Copyright (c) 1998, 2013 Oracle and/or its affiliates. All rights reserved. | |
* This program and the accompanying materials are made available under the | |
* terms of the Eclipse Public License v1.0 and Eclipse Distribution License v. 1.0 | |
* which accompanies this distribution. | |
* The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html | |
* and the Eclipse Distribution License is available at | |
* http://www.eclipse.org/org/documents/edl-v10.php. | |
* | |
* Contributors: | |
* Oracle - initial API and implementation from Oracle TopLink | |
******************************************************************************/ | |
package org.eclipse.persistence.tools.profiler; | |
import java.io.StringWriter; | |
import java.util.*; | |
import java.util.concurrent.ConcurrentHashMap; | |
import org.eclipse.persistence.queries.*; | |
/** | |
* <p><b>Purpose</b>: | |
* Provide a very simple low overhead means for measuring query executions, and cache hits. | |
* This can be useful for performance analysis in a complex system. | |
* This monitor is enabled through the System property "org.eclipse.persistence.querymonitor=true" or | |
* through the persistence.xml property eclipselink.profiler=QueryMonitor. | |
* It dumps the number of query cache hits, and executions (misses) once every 100s. | |
* | |
* @author James Sutherland | |
* @since TopLink 10.1.3 | |
*/ | |
public class QueryMonitor { | |
public static Map<String, Number> cacheHits = new ConcurrentHashMap<String, Number>(); | |
public static Map<String, Number> cacheMisses = new ConcurrentHashMap<String, Number>(); | |
public static long dumpTime = System.currentTimeMillis(); | |
public static Boolean shouldMonitor; | |
public static boolean shouldMonitor() { | |
if (shouldMonitor == null) { | |
shouldMonitor = Boolean.FALSE; | |
String property = System.getProperty("org.eclipse.persistence.querymonitor"); | |
if ((property != null) && (property.toUpperCase().equals("TRUE"))) { | |
shouldMonitor = Boolean.TRUE; | |
} | |
} | |
return shouldMonitor.booleanValue(); | |
} | |
public static void checkDumpTime() { | |
if ((System.currentTimeMillis() - dumpTime) > 100000) { | |
dumpTime = System.currentTimeMillis(); | |
StringWriter writer = new StringWriter(); | |
writer.write("Query Monitor:"); | |
writer.write(String.valueOf(dumpTime)); | |
writer.write("\n"); | |
writer.write("Query"); | |
writer.write("\t"); | |
writer.write("Cache"); | |
writer.write("\t"); | |
writer.write("Database"); | |
writer.write("\n"); | |
Set<String> queries = new TreeSet<String>(cacheMisses.keySet()); | |
queries.addAll(cacheHits.keySet()); | |
for (String query : queries) { | |
Number hits = cacheHits.get(query); | |
if (hits == null) { | |
hits = Integer.valueOf(0); | |
} | |
Number misses = cacheMisses.get(query); | |
if (misses == null) { | |
misses = Integer.valueOf(0); | |
} | |
writer.write(query); | |
writer.write("\t"); | |
writer.write(hits.toString()); | |
writer.write("\t"); | |
writer.write(misses.toString()); | |
writer.write("\n"); | |
} | |
System.out.println(writer.toString()); | |
} | |
} | |
public static void incrementReadObjectHits(ReadObjectQuery query) { | |
checkDumpTime(); | |
String name = query.getReferenceClass().getName() + "-findByPrimaryKey"; | |
Number hits = cacheHits.get(name); | |
if (hits == null) { | |
hits = Integer.valueOf(0); | |
} | |
hits = Integer.valueOf(hits.intValue() + 1); | |
cacheHits.put(name, hits); | |
} | |
public static void incrementReadObjectMisses(ReadObjectQuery query) { | |
checkDumpTime(); | |
String name = query.getReferenceClass().getName() + "-findByPrimaryKey"; | |
Number misses = cacheMisses.get(name); | |
if (misses == null) { | |
misses = Integer.valueOf(0); | |
} | |
misses = Integer.valueOf(misses.intValue() + 1); | |
cacheMisses.put(name, misses); | |
} | |
public static void incrementReadAllHits(ReadAllQuery query) { | |
checkDumpTime(); | |
String name = query.getReferenceClass().getName(); | |
if (query.getName() == null) { | |
name = name + "-findAll"; | |
} else { | |
name = name + "-" + query.getName(); | |
} | |
Number hits = cacheHits.get(name); | |
if (hits == null) { | |
hits = Integer.valueOf(0); | |
} | |
hits = Integer.valueOf(hits.intValue() + 1); | |
cacheHits.put(name, hits); | |
} | |
public static void incrementReadAllMisses(ReadAllQuery query) { | |
checkDumpTime(); | |
String name = query.getReferenceClass().getName(); | |
if (query.getName() == null) { | |
name = name + "-findAll"; | |
} else { | |
name = name + "-" + query.getName(); | |
} | |
Number misses = cacheMisses.get(name); | |
if (misses == null) { | |
misses = Integer.valueOf(0); | |
} | |
misses = Integer.valueOf(misses.intValue() + 1); | |
cacheMisses.put(name, misses); | |
} | |
public static void incrementInsert(WriteObjectQuery query) { | |
checkDumpTime(); | |
String name = query.getReferenceClass().getName() + "-insert"; | |
Number misses = cacheMisses.get(name); | |
if (misses == null) { | |
misses = Integer.valueOf(0); | |
} | |
misses = Integer.valueOf(misses.intValue() + 1); | |
cacheMisses.put(name, misses); | |
} | |
public static void incrementUpdate(WriteObjectQuery query) { | |
checkDumpTime(); | |
String name = query.getReferenceClass().getName() + "-update"; | |
Number misses = cacheMisses.get(name); | |
if (misses == null) { | |
misses = Integer.valueOf(0); | |
} | |
misses = Integer.valueOf(misses.intValue() + 1); | |
cacheMisses.put(name, misses); | |
} | |
public static void incrementDelete(DeleteObjectQuery query) { | |
checkDumpTime(); | |
String name = query.getReferenceClass().getName() + "-delete"; | |
Number misses = cacheMisses.get(name); | |
if (misses == null) { | |
misses = Integer.valueOf(0); | |
} | |
misses = Integer.valueOf(misses.intValue() + 1); | |
cacheMisses.put(name, misses); | |
} | |
} |