测试类型

SQL功能

测试版本

7.0.0LTS

问题描述

操作系统和硬件信息

2403 arm

测试环境

企业版主备

被测功能

预置条件

操作步骤

- ============================================================================
-- Case0024  【新增】主表 CU 与 delta 并存时查询正确
-- Case Name : 超阈值直入主表 + 未超进delta，查询为二者之和；未超阈值 DELTAMERGE 不迁入；再合入超阈值后迁入且结果仍正确
-- ============================================================================
-- gs_guc reload -N all -I all -c "autovacuum=off"

DROP TABLE IF EXISTS t_delta_table_0024 CASCADE;
CREATE TABLE t_delta_table_0024(id int, val int)
    WITH (orientation = column, deltarow_threshold = 1000);

SELECT a.oid, 'cstore.' || b.relname AS delta_name
FROM pg_class a JOIN pg_class b ON a.reldeltarelid = b.oid
WHERE a.relname = 't_delta_table_0024';

-- 用 FROM generate_series 保证 id=val，避免 SELECT 列表双 SRF 导致求和偏差
INSERT INTO t_delta_table_0024 SELECT gs, gs FROM generate_series(1, 1005) AS gs;     -- >=阈值，直入主表
INSERT INTO t_delta_table_0024 SELECT gs, gs FROM generate_series(1006, 1105) AS gs;  -- 100 <阈值，进 delta
SELECT count(*) FROM t_delta_table_0024;                          -- 期望 1105
SELECT count(*) FROM cstore.pg_delta_<oid>;                       -- 期望 100
SELECT sum(val) FROM t_delta_table_0024;                          -- 期望 1+...+1105 = 610915
SELECT count(*) FROM t_delta_table_0024 WHERE id > 1000;          -- 期望 105
SELECT val FROM t_delta_table_0024 WHERE id = 1;                  -- 期望 1（主表 CU）
SELECT val FROM t_delta_table_0024 WHERE id = 1105;               -- 期望 1105（delta）

VACUUM DELTAMERGE t_delta_table_0024;
SELECT count(*) FROM cstore.pg_delta_<oid>;                       -- 期望 100（100 < 1000，单次 DELTAMERGE 不迁入）
SELECT count(*) FROM t_delta_table_0024;                          -- 期望 1105
SELECT sum(val) FROM t_delta_table_0024;                          -- 期望 610915（查询结果不变）
SELECT count(*) FROM t_delta_table_0024 WHERE id > 1000;          -- 期望 105

-- 再合入 900 行（单次 < 阈值，进 delta），累计 1000 >= 阈值
INSERT INTO t_delta_table_0024 SELECT gs, gs FROM generate_series(1106, 2005) AS gs;
SELECT count(*) FROM t_delta_table_0024;                          -- 期望 2005
SELECT count(*) FROM cstore.pg_delta_<oid>;                       -- 期望 1000
SELECT sum(val) FROM t_delta_table_0024;                          -- 期望 1+...+2005 = 2011015
VACUUM DELTAMERGE t_delta_table_0024;
SELECT count(*) FROM cstore.pg_delta_<oid>;                       -- 期望 0（累计超阈值，迁入主表）
SELECT count(*) FROM t_delta_table_0024;                          -- 期望 2005
SELECT sum(val) FROM t_delta_table_0024;                          -- 期望 2011015
SELECT val FROM t_delta_table_0024 WHERE id = 1;                  -- 期望 1
SELECT val FROM t_delta_table_0024 WHERE id = 2005;               -- 期望 2005

DROP TABLE IF EXISTS t_delta_table_0024 CASCADE;
-- gs_guc reload -N all -I all -c "autovacuum=on"

预期输出

实际输出

日志信息

提单组织

测试团队

测试代码