Rename hash to sqlHash to better reflect what it is (CRC32 checksum of the sql)

This commit is contained in:
rbygrave
2021-08-06 12:06:43 +12:00
parent 7ca72a39b1
commit 202d785710
12 changed files with 31 additions and 31 deletions
@@ -21,8 +21,8 @@ public interface MetaQueryMetric extends MetaTimedMetric {
String getSql();
/**
* Return the hash of the plan.
* Return the hash of the sql.
*/
long getHash();
long getSqlHash();
}
@@ -6,7 +6,7 @@ package io.ebean.meta;
public class MetricData {
private String name;
private long hash;
private long sqlHash;
private String loc;
private String sql;
@@ -30,12 +30,12 @@ public class MetricData {
this.name = name;
}
public long getHash() {
return hash;
public long getSqlHash() {
return sqlHash;
}
public void setHash(long hash) {
this.hash = hash;
public void setSqlHash(long sqlHash) {
this.sqlHash = sqlHash;
}
public String getLoc() {
@@ -18,9 +18,9 @@ public interface SpiQueryPlan {
String getName();
/**
* The hash for the query plan.
* The hash of the sql.
*/
long getHash();
long getSqlHash();
/**
* The SQL for the query plan.
@@ -120,7 +120,7 @@ class DumpMetrics {
appendQueryName(metric, sb);
appendCounters(metric, sb);
if (dumpHash) {
sb.append("\n hash:").append(metric.getHash());
sb.append("\n sqlHash:").append(metric.getSqlHash());
}
appendProfileAndSql(metric, sb);
out(sb.toString());
@@ -67,7 +67,7 @@ class DumpMetricsData {
final MetricData data = create(metric);
appendCounters(data, metric);
appendLocationAndSql(data, metric);
data.setHash(metric.getHash());
data.setSqlHash(metric.getSqlHash());
}
private void appendLocationAndSql(MetricData data, MetaQueryMetric metric) {
@@ -197,7 +197,7 @@ class DumpMetricsJson implements ServerMetricsAsJson {
metricStart(metric);
appendTiming(metric);
if (withHash) {
keyVal("hash", metric.getHash());
keyVal("sqlHash", metric.getSqlHash());
}
if (isIncludeDetail(metric)) {
appendExtra("loc", metric.getLocation());
@@ -1558,7 +1558,7 @@ public class BeanDescriptor<T> implements BeanType<T>, STreeType, SpiBeanType {
void queryPlanInit(QueryPlanInit request, List<MetaQueryPlan> list) {
for (CQueryPlan queryPlan : queryPlanCache.values()) {
if (request.includeHash(queryPlan.getHash())) {
if (request.includeHash(queryPlan.getSqlHash())) {
queryPlan.queryPlanInit(request.getThresholdMicros());
list.add(queryPlan.createMeta(null, null));
}
@@ -10,7 +10,7 @@ class DQueryPlanMeta {
private final ProfileLocation profileLocation;
private final String name;
private final String sql;
private final long hash;
private final long sqlHash;
DQueryPlanMeta(Class<?> type, String label, ProfileLocation profileLocation, String sql) {
this.type = type;
@@ -22,15 +22,15 @@ class DQueryPlanMeta {
name += "_" + label;
}
this.name = name;
this.hash = Checksum.checksum(sql);
this.sqlHash = Checksum.checksum(sql);
}
public Class<?> getType() {
return type;
}
public long getHash() {
return hash;
public long getSqlHash() {
return sqlHash;
}
public String getName() {
@@ -59,8 +59,8 @@ class DQueryPlanMetric implements QueryPlanMetric {
}
@Override
public long getHash() {
return meta.getHash();
public long getSqlHash() {
return meta.getSqlHash();
}
@Override
@@ -68,7 +68,7 @@ public class CQueryPlan implements SpiQueryPlan {
private final boolean rawSql;
private final String sql;
private final long hash;
private final long sqlHash;
private final String logWhereSql;
@@ -118,7 +118,7 @@ public class CQueryPlan implements SpiQueryPlan {
this.stats = new CQueryPlanStats(this);
this.dependentTables = sqlTree.dependentTables();
this.bindCapture = initBindCapture(query);
this.hash = Checksum.checksum(sql);
this.sqlHash = Checksum.checksum(sql);
}
/**
@@ -143,7 +143,7 @@ public class CQueryPlan implements SpiQueryPlan {
this.stats = new CQueryPlanStats(this);
this.dependentTables = sqlTree.dependentTables();
this.bindCapture = initBindCaptureRaw(sql, query);
this.hash = Checksum.checksum(sql);
this.sqlHash = Checksum.checksum(sql);
}
private String deriveName(String label, SpiQuery.Type type, String simpleName) {
@@ -193,8 +193,8 @@ public class CQueryPlan implements SpiQueryPlan {
}
@Override
public long getHash() {
return hash;
public long getSqlHash() {
return sqlHash;
}
@Override
@@ -226,7 +226,7 @@ public class CQueryPlan implements SpiQueryPlan {
@Override
public DQueryPlanOutput createMeta(String bind, String planString) {
return new DQueryPlanOutput(getBeanType(), name, hash, sql, profileLocation, bind, planString);
return new DQueryPlanOutput(getBeanType(), name, sqlHash, sql, profileLocation, bind, planString);
}
public DataReader createDataReader(ResultSet rset) {
@@ -273,7 +273,7 @@ public class CQueryPlan implements SpiQueryPlan {
private String calcAuditQueryKey() {
// rawSql needs to include the MD5 hash of the sql
return rawSql ? planKey.getPartialKey() + "_" + hash : planKey.getPartialKey();
return rawSql ? planKey.getPartialKey() + "_" + sqlHash : planKey.getPartialKey();
}
SqlTree getSqlTree() {
@@ -127,8 +127,8 @@ public final class CQueryPlanStats {
}
@Override
public long getHash() {
return queryPlan.getHash();
public long getSqlHash() {
return queryPlan.getSqlHash();
}
@Override
@@ -216,7 +216,7 @@ public class TestCustomerFinder extends BaseTestCase {
assertThat(plans0).isNotEmpty();
for (MetaQueryPlan plan : plans) {
logger.info("queryplan label:{}, queryTimeMicros:{} loc:{} sql:{} bind:{} plan:{}",
logger.info("queryPlan label:{}, queryTimeMicros:{} loc:{} sql:{} bind:{} plan:{}",
plan.getLabel(), plan.getQueryTimeMicros(), plan.getProfileLocation(),
plan.getSql(), plan.getBind(), plan.getPlan());
System.out.println(plan);
@@ -244,7 +244,7 @@ public class TestCustomerFinder extends BaseTestCase {
assertThat(metricsJson).contains("\"name\":\"orm.Customer.findList\"");
assertThat(metricsJson).contains("\"loc\":\"CustomerFinder.byNameStatus(CustomerFinder.java:44)\"");
if (isH2() || isPostgres()) {
assertThat(metricsJson).contains("\"hash\":3634991469");
assertThat(metricsJson).contains("\"sqlHash\":3634991469");
assertThat(metricsJson).contains("\"sql\":\"select t0.id, t0.status,");
}
}
@@ -267,7 +267,7 @@ public class TestCustomerFinder extends BaseTestCase {
assertThat(metricsJson).contains("\"name\":\"txn.main\"");
assertThat(metricsJson).contains("\"name\":\"orm.Customer.findList\"");
assertThat(metricsJson).doesNotContain("\"loc\":");
assertThat(metricsJson).doesNotContain("\"hash\":");
assertThat(metricsJson).doesNotContain("\"sqlHash\":");
assertThat(metricsJson).doesNotContain("\"sql\":");
}