连续查询ok

pkg/dao/dbinit.go

@@ -15,19 +15,19 @@ const (
 
 	//样本总数：request的总量
 	ApdexCqAll = `CREATE CONTINUOUS QUERY cq_apdex_all ON monitor RESAMPLE FOR 1h BEGIN ` +
-		`SELECT count(traceId) AS ct_all INTO monitor.autogen.apdex FROM trace_info GROUP BY sys_name, time(1m) fill(1) END;`
+		`SELECT count(traceId) AS ct_all INTO monitor.autogen.apdex FROM monitor.autogen.trace_info GROUP BY sys_name, time(1m) fill(1) END;`
 
 	//满意样本：request的响应时间[0, m)秒
 	ApdexCqSat = `CREATE CONTINUOUS QUERY cq_apdex_sat_%s ON monitor RESAMPLE FOR 1h BEGIN ` +
-		`SELECT count(traceId) AS sat INTO monitor.autogen.apdex FROM trace_info ` +
-		`WHERE sys_name = '%s' AND 'duration' < %d ` +
-		`GROUP BY time(1m) fill(0) END;`
+		`SELECT count(traceId) AS sat INTO monitor.autogen.apdex FROM monitor.autogen.trace_info ` +
+		`WHERE sys_name = '%s' AND "duration" < %d ` +
+		`GROUP BY sys_name, time(1m) fill(0) END;`
 
 	//可容忍样本：request的响应时间[m, n)秒
 	ApdexCqTol = `CREATE CONTINUOUS QUERY cq_apdex_tol_%s ON monitor RESAMPLE FOR 1h BEGIN ` +
-		`SELECT count(traceId) AS tol INTO monitor.autogen.apdex FROM trace_info ` +
-		`WHERE sys_name = '%s' AND 'duration' >= %d AND 'duration' < %d ` +
-		`GROUP BY time(1m) fill(0) END;`
+		`SELECT count(traceId) AS tol INTO monitor.autogen.apdex FROM monitor.autogen.trace_info ` +
+		`WHERE sys_name = '%s' AND "duration" >= %d AND "duration" < %d ` +
+		`GROUP BY sys_name, time(1m) fill(0) END;`
 
 	//获取全部服务
 	SysNameSql = "show tag values from trace_info with key = sys_name;"