fix test

Author: zhyass

src/query/service/tests/it/storages/fuse/operations/analyze.rs

@@ -100,23 +100,37 @@ async fn test_fuse_snapshot_analyze_purge() -> Result<()> {
     let case_name = "analyze_statistic_purge";
     do_insertions(&fixture).await?;
 
-    // optimize statistics three times
-    for i in 0..3 {
-        analyze_table(&fixture).await?;
-        check_data_dir(
-            &fixture,
-            case_name,
-            3 + i,
-            1 + i,
-            2,
-            2,
-            2,
-            2,
-            Some(()),
-            None,
-        )
-        .await?;
-    }
+    analyze_table(&fixture).await?;
+    check_data_dir(
+        &fixture,
+        case_name,
+        3,
+        1,
+        2,
+        2,
+        2,
+        2,
+        Some(()),
+        None,
+    )
+    .await?;
+
+    
+    append_sample_data(1, &fixture).await?;
+    analyze_table(&fixture).await?;
+    check_data_dir(
+        &fixture,
+        case_name,
+        5,
+        2,
+        3,
+        3,
+        3,
+        2,
+        Some(()),
+        None,
+    )
+    .await?;
 
     // Purge will keep at least two snapshots.
     let table = fixture.latest_default_table().await?;
@@ -126,7 +140,7 @@ async fn test_fuse_snapshot_analyze_purge() -> Result<()> {
     fuse_table
         .do_purge(&table_ctx, snapshot_files, None, true, false)
         .await?;
-    check_data_dir(&fixture, case_name, 1, 1, 1, 1, 1, 1, Some(()), Some(())).await?;
+    check_data_dir(&fixture, case_name, 1, 1, 2, 2, 2, 1, Some(()), Some(())).await?;
 
     Ok(())
 }

tests/sqllogictests/suites/base/09_fuse_engine/09_0020_analyze.test

@@ -243,5 +243,49 @@ select count() from fuse_snapshot('db_09_0020','t2');
 statement ok
 DROP TABLE t2;
 
+statement ok
+CREATE TABLE t3(a int, b string) approx_distinct_columns = '';
+
+statement ok
+insert into t3 values(1, 'a'), (2, 'b');
+
+statement ok
+alter table t3 set options(approx_distinct_columns = 'a, b');
+
+statement ok
+insert into t3 values(4, 'c'), (3, 'b');
+
+query B
+select segment_stats_size is null from fuse_segment('db_09_0020','t3') order by file_location;
+----
+1
+0
+
+statement ok
+analyze table t3;
+
+query B
+select segment_stats_size is null from fuse_segment('db_09_0020','t3') order by file_location;
+----
+0
+0
+
+query T
+select * from fuse_statistic('db_09_0020', 't3') order by column_name;
+----
+a 4 (empty)
+b 3 (empty)
+
+statement ok
+analyze table t3;
+
+query I
+select count() from fuse_snapshot('db_09_0020', 't3');
+----
+3
+
+statement ok
+DROP TABLE t3;
+
 statement ok
 DROP DATABASE db_09_0020