点击参与 GreatSQL 8.0.32-26 文档捉虫~~~

GreatSQL社区

搜索

[已解决] 关于使用Turbo未生效问题

50 8 6 天前
本帖最后由 mlovewt 于 2025-11-24 11:20 编辑

使用docker  安装的greatsql,开启Turbo引擎后，sql 查询未生效，单表大约100万数据

一、开始Turbo
  1. INSTALL PLUGIN turbo SONAME 'turbo.so';
  2. SET global turbo_enable=ON;
  3. SET global turbo_cost_threshold=0;
复制代码



二、建表语句
  1. CREATE TABLE `generic_survey_response_log` (
  2.   `record_id` bigint unsigned NOT NULL AUTO_INCREMENT,
  3.   `survey_year` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '关联的调研年份标识',
  4.   `attempt_number` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '该年度内的参与序号',
  5.   `log_timestamp` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '记录生成的具体时间戳',
  6.   `entity_code_level0` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '参与者直接归属实体代码',
  7.   `entity_name_level0` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '参与者直接归属实体名称',
  8.   `parent_entity_code` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '参与者上级实体代码',
  9.   `entity_code_level1` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '层级路径上的实体代码1',
  10.   `entity_name_level1` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '层级路径上的实体名称1',
  11.   `entity_code_level2` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '层级路径上的实体代码2',
  12.   `entity_name_level2` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '层级路径上的实体名称2',
  13.   `entity_code_level3` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '层级路径上的实体代码3',
  14.   `entity_name_level3` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '层级路径上的实体名称3',
  15.   `entity_code_level4` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '层级路径上的实体代码4',
  16.   `entity_name_level4` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '层级路径上的实体名称4',
  17.   `entity_code_level5` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '层级路径上的实体代码5',
  18.   `entity_name_level5` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '层级路径上的实体名称5',
  19.   `entity_code_level6` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '层级路径上的实体代码6',
  20.   `entity_name_level6` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '层级路径上的实体名称6',
  21.   `entity_code_level7` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '层级路径上的实体代码7',
  22.   `entity_name_level7` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '层级路径上的实体名称7',
  23.   `participant_id` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '系统内唯一参与者标识符',
  24.   `role_id` bigint DEFAULT NULL COMMENT '参与者角色ID（如有）',
  25.   `category_code` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '问题所属大类编码',
  26.   `category_description` varchar(300) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '问题所属大类说明',
  27.   `question_code` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '具体问题的唯一编码',
  28.   `question_text` varchar(300) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '具体问题的内容描述',
  29.   `response_code` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '选择答案的编码（空值表示未作答）',
  30.   `response_text` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '选择答案的文本描述',
  31.   `points_awarded` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '此题获得的分数',
  32.   `domain_code` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '业务领域或专业条线代码',
  33.   `center_code` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '所属中心或部门代码',
  34.   `is_supervisor_flag` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '标记是否为管理层人员',
  35.   `employment_type` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '用工性质（如正式、外包等）',
  36.   `sub_domain_code` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '业务领域的进一步细分代码',
  37.   PRIMARY KEY (`record_id` DESC) USING BTREE,
  38.   KEY `idx_entity_code_l0` (`entity_code_level0`) USING BTREE,
  39.   KEY `idx_participant` (`participant_id`) USING BTREE,
  40.   KEY `idx_entity_code_l1` (`entity_code_level1`) USING BTREE,
  41.   KEY `idx_entity_code_l2` (`entity_code_level2`) USING BTREE,
  42.   KEY `idx_entity_code_l3` (`entity_code_level3`) USING BTREE,
  43.   KEY `idx_entity_code_l4` (`entity_code_level4`) USING BTREE,
  44.   KEY `idx_entity_code_l5` (`entity_code_level5`) USING BTREE,
  45.   KEY `idx_entity_code_l6` (`entity_code_level6`) USING BTREE,
  46.   KEY `idx_entity_code_l7` (`entity_code_level7`) USING BTREE,
  47.   KEY `idx_domain` (`domain_code`) USING BTREE
  48. ) ENGINE=InnoDB AUTO_INCREMENT=956169 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='通用调研问卷回答明细日志表';
复制代码



三、执行sql

  1. SELECT
  2.     `role_id`,
  3.     `input_entity_code` AS v_org_code,       -- 输入参数：目标实体代码
  4.     `input_entity_name` AS v_org_name,       -- 输入参数：目标实体名称
  5.     `input_parent_entity_code` AS v_parent_org_code, -- 输入参数：目标父级实体代码
  6.     IFNULL(`domain_code`, '1') AS line,      -- 业务领域代码
  7.     '1' AS wt_id,                             -- 固定维度ID（示例）
  8.     IFNULL(`employment_type`, '1') AS job_type, -- 用工性质代码
  9.     ROUND(
  10.         CASE
  11.             WHEN IFNULL(COUNT(`question_code`), 0) = 0 THEN 0
  12.             ELSE SUM(`points_awarded`) / COUNT(`question_code`)
  13.         END, 2
  14.     ) AS total_avg,                           -- 整体平均得分（总体满意度）
  15.    
  16.     ROUND(
  17.         CASE
  18.             WHEN IFNULL(
  19.                     COUNT(
  20.                         CASE
  21.                             WHEN `category_description` = 'Category_A_Specific_Items' THEN `question_code`
  22.                         END
  23.                     ), 0
  24.                  ) = 0
  25.             THEN 0
  26.             ELSE SUM(
  27.                     CASE
  28.                         WHEN `category_description` = 'Category_A_Specific_Items' THEN `points_awarded`
  29.                     END
  30.                  ) /
  31.                  COUNT(
  32.                     CASE
  33.                         WHEN `category_description` = 'Category_A_Specific_Items' THEN `question_code`
  34.                     END
  35.                  )
  36.         END, 2
  37.     ) AS category_a_avg,                      -- 分类A平均得分（示例：对管理层满意度）

  39.     ROUND(
  40.         CASE
  41.             WHEN IFNULL(
  42.                     COUNT(
  43.                         CASE
  44.                             WHEN `category_description` = 'Category_B_Specific_Items' THEN `question_code`
  45.                         END
  46.                     ), 0
  47.                  ) = 0
  48.             THEN 0
  49.             ELSE SUM(
  50.                     CASE
  51.                         WHEN `category_description` = 'Category_B_Specific_Items' THEN `points_awarded`
  52.                     END
  53.                  ) /
  54.                  COUNT(
  55.                     CASE
  56.                         WHEN `category_description` = 'Category_B_Specific_Items' THEN `question_code`
  57.                     END
  58.                  )
  59.         END, 2
  60.     ) AS category_b_avg,                      -- 分类B平均得分（示例：对企业认同度）

  62.     ROUND(
  63.         CASE
  64.             WHEN IFNULL(
  65.                     COUNT(
  66.                         CASE
  67.                             WHEN `category_description` = 'Category_C_Specific_Items' THEN `question_code`
  68.                         END
  69.                     ), 0
  70.                  ) = 0
  71.             THEN 0
  72.             ELSE SUM(
  73.                     CASE
  74.                         WHEN `category_description` = 'Category_C_Specific_Items' THEN `points_awarded`
  75.                     END
  76.                  ) /
  77.                  COUNT(
  78.                     CASE
  79.                         WHEN `category_description` = 'Category_C_Specific_Items' THEN `question_code`
  80.                     END
  81.                  )
  82.         END, 2
  83.     ) AS category_c_avg,                      -- 分类C平均得分（示例：对工作本身满意度）

  85.     ROUND(
  86.         CASE
  87.             WHEN IFNULL(
  88.                     COUNT(
  89.                         CASE
  90.                             WHEN `category_description` = 'Category_D_Specific_Items' THEN `question_code`
  91.                         END
  92.                     ), 0
  93.                  ) = 0
  94.             THEN 0
  95.             ELSE SUM(
  96.                     CASE
  97.                         WHEN `category_description` = 'Category_D_Specific_Items' THEN `points_awarded`
  98.                     END
  99.                  ) /
  100.                  COUNT(
  101.                     CASE
  102.                         WHEN `category_description` = 'Category_D_Specific_Items' THEN `question_code`
  103.                     END
  104.                  )
  105.         END, 2
  106.     ) AS category_d_avg,                      -- 分类D平均得分（示例：对工作回报满意度）

  108.     ROUND(
  109.         CASE
  110.             WHEN IFNULL(
  111.                     COUNT(
  112.                         CASE
  113.                             WHEN `category_description` = 'Category_E_Specific_Items' THEN `question_code`
  114.                         END
  115.                     ), 0
  116.                  ) = 0
  117.             THEN 0
  118.             ELSE SUM(
  119.                     CASE
  120.                         WHEN `category_description` = 'Category_E_Specific_Items' THEN `points_awarded`
  121.                     END
  122.                  ) /
  123.                  COUNT(
  124.                     CASE
  125.                         WHEN `category_description` = 'Category_E_Specific_Items' THEN `question_code`
  126.                     END
  127.                  )
  128.         END, 2
  129.     ) AS category_e_avg,                      -- 分类E平均得分（示例：对员工关怀度）

  131.     COUNT(DISTINCT `participant_id`) AS curr_person,     -- 当前范围总人数
  132.     COUNT(DISTINCT CASE WHEN `question_code` IS NOT NULL THEN `participant_id` END) AS curr_answer, -- 实际参与答题人数
  133.     ROUND(
  134.         CASE
  135.             WHEN IFNULL(COUNT(DISTINCT `participant_id`), 0) = 0 THEN 0
  136.             ELSE (COUNT(DISTINCT CASE WHEN `question_code` IS NOT NULL THEN `participant_id` END) * 100.0)
  137.                  / COUNT(DISTINCT `participant_id`)
  138.         END, 2
  139.     ) AS curr_rate                            -- 答题参与率 (%)

  141. FROM `generic_survey_response_log`
  142. WHERE (
  143.        `entity_code_level0` = `input_entity_code` -- 匹配最直接归属
  144.     OR `entity_code_level1` = `input_entity_code` -- 匹配层级路径上第1级
  145.     OR `entity_code_level2` = `input_entity_code` -- 匹配层级路径上第2级
  146.     OR `entity_code_level3` = `input_entity_code` -- 匹配层级路径上第3级
  147.     OR `entity_code_level4` = `input_entity_code` -- 匹配层级路径上第4级
  148.     OR `entity_code_level5` = `input_entity_code` -- 匹配层级路径上第5级
  149.     OR `entity_code_level6` = `input_entity_code` -- 匹配层级路径上第6级
  150.     OR `entity_code_level7` = `input_entity_code` -- 匹配层级路径上第7级
  151. )
  152. GROUP BY
  153.     `domain_code`,      -- 按业务领域分组
  154.     `employment_type`   -- 按用工性质分组
  155.     WITH ROLLUP;        -- 生成小计和总计行
  156. -- 注意：脱敏后，如果 employment_type 字段没有 '1' 这个特殊值，
  157. -- 则原SQL中 "没有 '1'，job_type" 的注释所指的缓存逻辑可能不再适用或需要调整。
  158. -- 此处保留了 WITH ROLLUP 以维持原始聚合意图。
复制代码



四、db状态

  1. turbo_compat_options        COMPAT_FUNC,TIMESTAMP_TO_DOUBLE,TIME_ZONE,TIMESTAMP_REWRITE
  2. turbo_condition_pushdown        OFF
  3. turbo_cost_threshold        0.000000
  4. turbo_enable        ON
  5. turbo_enable_ps_and_sp        ON
  6. turbo_enable_rollback        OFF
  7. turbo_enable_warning        OFF
  8. turbo_exec        
  9. turbo_index_range        OFF
  10. turbo_max_temp_directory_size        1073741824
  11. turbo_memory_limit        5368709120
  12. turbo_parallel_read_buffer_size        2097152
  13. turbo_release_retries        600
  14. turbo_retry_pause        1000
  15. turbo_skip_charset_check        OFF
  16. turbo_temp_directory        duckdb_dp.data.tmp
  17. turbo_worker_threads        4
复制代码


五、执行计划

全部回复(8)
只看楼主
yejr 6 天前
想要使用Turbo引擎，要在执行SELECT时每次都加上相应的HINT才行，执行 set global修改还不够。例如：

EXPLAIN FORMAT=TREE SELECT /*+ SET_VAR(turbo_enable=ON) SET_VAR(turbo_cost_threshold=0) */ * FROM t1;

详情参考手册：https://greatsql.cn/docs/8.4.4-4 ... f-turbo-engine.html
回复 已采纳

举报

mlovewt 5 天前
yejr 发表于 2025-11-20 20:50
想要使用Turbo引擎，要在执行SELECT时每次都加上相应的HINT才行，执行 set global修改还不够。例如：

EXPL ...

好的我今天再试试
回复 采纳

举报

wangcw 5 天前
Turbo引擎是GreatSQL特有的么
回复 采纳

举报

yejr 5 天前
wangcw 发表于 2025-11-21 13:50
Turbo引擎是GreatSQL特有的么

是
回复 采纳

举报

mlovewt 5 天前
yejr 发表于 2025-11-21 15:51
是

8.4.4-4 的并行查询 /*+ PQ(8) */ 这个取消了？
回复 采纳

举报

reddey 4 天前
mlovewt 发表于 2025-11-21 17:56
8.4.4-4 的并行查询 /*+ PQ(8) */ 这个取消了？

之前好像在社区文档中看到这样一句话，要取消并行查询的功能。
回复 采纳

举报

wangcw 3 天前
reddey 发表于 2025-11-22 17:19
之前好像在社区文档中看到这样一句话，要取消并行查询的功能。

并行查询会有引起很多事务一致性问题，需要强一致性的最好不用。
回复 采纳

举报

yejr 3 天前
mlovewt 发表于 2025-11-21 17:56
8.4.4-4 的并行查询 /*+ PQ(8) */ 这个取消了？

是的，这个功能现在取消了，可以改用Rapid或Turbo引擎
回复 采纳

举报

mlovewt

6

主题

0

博客

31

贡献

注册会员

Rank: 2

积分
51

助人为乐（铜）

发消息
互动与交流
社区活动
论坛问答
加入社区
贡献者指南
学习与应用
文章博客
文档资料
视频资料
常见问题
发现社区
社区准则
建议反馈
社区之星

合作电话：010-64087828

社区邮箱：greatsql@greatdb.com

社区公众号
社区小助手
QQ群
友情链接
万里数据库开源中国墨天轮开放原子开源基金会OpenEuler
©2022 GreatSQL All Rights Reserved. ( 京ICP备06057874号 )
GMT+8, 2025-11-26 01:21 , Processed in 0.020965 second(s), 17 queries , Redis On.
快速回复 返回顶部 返回列表