mysql8并行查询_并行查询（Parallel Query）

电玩女神 2022-10-31 12:15 1178阅读 0赞

通过Hint来控制并行查询

使用Hint语法可以对单个语句进行控制，例如系统默认关闭并行查询情况下，但需要对某个高频的慢SQL查询进行加速，此时就可以使用Hint对特定SQL进行加速。

您可以使用如下任意一种方式开启并行查询：SELECT /\*+PARALLEL(x)\*/ ... FROM ...; -- x >0

SELECT /\*+ SET\_VAR(max\_parallel\_degree=n) \*/ \* FROM ... // n > 0

您可以使用如下任意一种方式关闭并行查询：SELECT /\*+NO\_PARALLEL()\*/ ... FROM ...;

SELECT /\*+ SET\_VAR(max\_parallel\_degree=0) \*/ \* FROM ...

Hint高级用法

并行查询提供了PARALLEL和NO\_PARALLEL两种Hint。

通过PARALLEL Hint可以强制查询并行执行，同时可以指定并行度和并行扫描的表。

通过NO\_PARALLEL Hint可以强制查询串行执行，或者指定不选择某些表作为并行扫描的表。

Hint语法如下所示：/\*+ PARALLEL \[( \[query\_block\] \[table\_name\] \[degree\] )\] \*/

/\*+ NO\_PARALLEL \[( \[query\_block\] \[table\_name\]\[, table\_name\] )\] \*/

其中参数说明如下所示。

参数

说明

query\_block

应用Hint的query block名称。

table\_name

应用Hint的表名称。

degree

并行度。

示例：SELECT /\*+PARALLEL()\*/ \* FROM t1, t2;

\-- 当表记录数小于records\_threshold\_for\_parallelism设置的行数 ( 默认10000行)时，会强制并行，

\-- 并行度用系统默认max\_parallel\_degree， 如果max\_parallel\_degree > 0,

\-- 则打开并行，如果max\_parallel\_degree等于0时，依旧时关闭并行。

SELECT /\*+PARALLEL(8)\*/ \* FROM t1, t2;

\-- 强制并行度8并行执行，

\-- 当表记录数小于records\_threshold\_for\_parallelism设置的行数 ( 默认10000行)时，会强制并行，

\-- 并行度设置max\_parallel\_degree为8。

SELECT /\*+ SET\_VAR(max\_parallel\_degree=8) \*/ \* FROM ...

\-- 设置并行度max\_parallel\_degree为8，

\-- 当表记录数小于records\_threshold\_for\_parallelism设置的行数(如20000行)时，会自动关闭并行。

SELECT /\*+PARALLEL(t1)\*/ \* FROM t1, t2;

\-- 选择t1表并行, 对t1表执行/\*+PARALLEL()\*/ 语法

SELECT /\*+PARALLEL(t1 8)\*/ \* FROM t1, t2;

\-- 强制并行度8且选择t1表并行执行， 对t1表执行/\*+PARALLEL(8)\*/语法

SELECT /\*+PARALLEL(@subq1)\*/ SUM(t.a) FROM t WHERE t.a =

(SELECT /\*+QB\_NAME(subq1)\*/ SUM(t1.a) FROM t1);

\--强制subquery并行执行， 并行度用系统默认max\_parallel\_degree，

\-- 如果max\_parallel\_degree > 0, 则打开并行，max\_parallel\_degree等于0时，依旧时关闭并行

SELECT /\*+PARALLEL(@subq1 8)\*/ SUM(t.a) FROM t WHERE t.a =

(SELECT /\*+QB\_NAME(subq1)\*/ SUM(t1.a) FROM t1);

\--强制subquery并行执行， 并行度设置max\_parallel\_degree为8

SELECT SUM(t.a) FROM t WHERE t.a =

(SELECT /\*+PARALLEL()\*/ SUM(t1.a) FROM t1);

\--强制subquery并行执行，

\-- 并行度用系统默认max\_parallel\_degree，

\-- 如果max\_parallel\_degree > 0, 则打开并行，max\_parallel\_degree等于0时，依旧时关闭并行

SELECT SUM(t.a) FROM t WHERE t.a =

(SELECT /\*+PARALLEL(8)\*/ SUM(t1.a) FROM t1);

\--强制subquery并行执行， 设置并行度max\_parallel\_degree为8

SELECT /\*+NO\_PARALLEL()\*/ \* FROM t1, t2;

\-- 禁止并行执行

SELECT /\*+NO\_PARALLEL(t1)\*/ \* FROM t1, t2;

\-- 只对t1表禁止并行， 当系统打开并行时， 有可能对t2进行并行扫描，并行执行

SELECT /\*+NO\_PARALLEL(t1, t2)\*/ \* FROM t1, t2;

\-- 同时对t1和t2表禁止并行

SELECT /\*+NO\_PARALLEL(@subq1)\*/ SUM(t.a) FROM t WHERE t.a =

(SELECT /\*+QB\_NAME(subq1)\*/ SUM(t1.a) FROM t1);

\--禁止subquery 并行执行

SELECT SUM(t.a) FROM t WHERE t.a =

(SELECT /\*+NO\_PARALLEL()\*/ SUM(t1.a) FROM t1);

\--禁止subquery 并行执行

说明 对于不支持并行的查询或者并行扫描的表，PARALLEL Hint不生效。

并行子查询的选择方式(并行子查询详细信息请参见/\*+ PQ\_PUSHDOWN \[( \[query\_block\])\] \*/ 对应的子查询会选择push down的并行子查询执行策略

/\*+ NO\_PQ\_PUSHDOWN \[( \[query\_block\])\] \*/ 对应的子查询会选择shared access的并行子查询执行策略

示例：\#子查询选择push down并行策略

EXPLAIN SELECT /\*+ PQ\_PUSHDOWN(@qb1) \*/ \* FROM t2 WHERE t2.a =

(SELECT /\*+ qb\_name(qb1) \*/ a FROM t1);

\#子查询选择shared access并行策略

EXPLAIN SELECT /\*+ NO\_PQ\_PUSHDOWN(@qb1) \*/ \* FROM t2 WHERE t2.a =

(SELECT /\*+ qb\_name(qb1) \*/ a FROM t1);

\#不加query block进行控制

EXPLAIN SELECT \* FROM t2 WHERE t2.a =

(SELECT /\*+ NO\_PQ\_PUSHDOWN() \*/ a FROM t1);

mysql8并行查询_并行查询（Parallel Query）

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 Parallel.ForEach() 并行循环

相关 Java8中并行化流parallel的使用

相关 mysql多线程并行查询_mysql并行查询问题

相关为什么并行(Parallel)优于串行(Serial)？

相关 mysql8并行查询_并行查询（Parallel Query）

相关 Oracle学习笔记：parallel并行处理

相关 GreatSQL重磅特性，InnoDB并行并行查询优化测试

相关并行计算—parallel，for联合使用

相关并行计算—OpenMP—parallel指令

相关 java多线程并行查询记录