stats: do not wait for data unchanged when auto analyze

statistics/update.go

@@ -533,28 +533,37 @@ const (
 // AutoAnalyzeMinCnt means if the count of table is less than this value, we needn't do auto analyze.
 var AutoAnalyzeMinCnt int64 = 1000
 
+func tableAnalyzed(tbl *Table) bool {
+	for _, col := range tbl.Columns {
+		if col.Count > 0 {
+			return true
+		}
+	}
+	for _, idx := range tbl.Indices {
+		if idx.Len() > 0 {
+			return true
+		}
+	}
+	return false
+}
+
 func needAnalyzeTable(tbl *Table, limit time.Duration, autoAnalyzeRatio float64) bool {
 	if tbl.ModifyCount == 0 || tbl.Count < AutoAnalyzeMinCnt {
 		return false
 	}
+	analyzed := tableAnalyzed(tbl)
 	t := time.Unix(0, oracle.ExtractPhysical(tbl.Version)*int64(time.Millisecond))
-	if time.Since(t) < limit {
-		return false
-	}
-	if autoAnalyzeRatio > 0 && float64(tbl.ModifyCount)/float64(tbl.Count) > autoAnalyzeRatio {
+	if !analyzed && time.Since(t) >= limit {
 		return true
 	}
-	for _, col := range tbl.Columns {
-		if col.Count > 0 {
-			return false
-		}
+	// Auto analyze is closed.
+	if autoAnalyzeRatio == 0 {
+		return false
 	}
-	for _, idx := range tbl.Indices {
-		if idx.Len() > 0 {
-			return false
-		}
+	if analyzed && float64(tbl.ModifyCount)/float64(tbl.Count) > autoAnalyzeRatio {
+		return true
 	}
-	return true
+	return false
 }
 
 const minAutoAnalyzeRatio = 0.3

statistics/update_test.go

@@ -338,6 +338,9 @@ func (s *testStatsUpdateSuite) TestAutoUpdate(c *C) {
 		break
 	}
 
+	// Test that even if the table is recently modified, we can still analyze the table.
+	h.Lease = time.Second
+	defer func() { h.Lease = 0 }()
 	_, err = testKit.Exec("insert into t values ('fff')")
 	c.Assert(err, IsNil)
 	c.Assert(h.DumpStatsDeltaToKV(statistics.DumpAll), IsNil)
@@ -363,11 +366,7 @@ func (s *testStatsUpdateSuite) TestAutoUpdate(c *C) {
 	_, err = testKit.Exec("insert into t values ('eee')")
 	c.Assert(err, IsNil)
 	h.DumpStatsDeltaToKV(statistics.DumpAll)
-	h.Clear()
-	// We set `Lease` here so that `Update` will use load by need strategy.
-	h.Lease = time.Second
 	h.Update(is)
-	h.Lease = 0
 	err = h.HandleAutoAnalyze(is)
 	c.Assert(err, IsNil)
 	h.Update(is)