备案控制台
探索云世界
开发者社区 数据库 文章 正文

Oracle并行计算

2017-04-26 1021
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 【前言】现在CPU的发展已不仅朝着单个性能更好的方向了，而且还朝着多核数多核心的方向发展了。Oracle数据库大部分也都是利用单线程的串行方式在运行。通过并行（Parallel）操作特性，充分应用CPU的多核心特点，提高对数据的操作效率，满足在特定场景下对海量数据操作的需求。

【前言】现在CPU的发展已不仅朝着单个性能更好的方向了，而且还朝着多核数多核心的方向发展了。Oracle数据库大部分也都是利用单线程的串行方式在运行。通过并行（Parallel）操作特性，充分应用CPU的多核心特点，提高对数据的操作效率，满足在特定场景下对海量数据操作的需求。

OLTP系统最主要的核心还是数据的录入操作，而这些应用的场景并不适合于并行计算的方式。对于OLAP业务场景更适合并行的操作，并行也成为数据库仓库调优利器；

【使用类型和场景】

Oracle并行处理（Parallel Processing）特性主要是针对SQL语句处理的并行。目前Oracle提供支持并行的操作包括如下类型：

  • 并行查询操作；
  • 并行DDL，对数据对象的DDL操作；
  • 并行DML，进行并行的数据更新修改；

在具体的应用场景上，有如下场景：

  • 数据表、索引范围扫描的查询；
  • 批量增加、修改和删除操作；
  • 数据表、索引对象的创建；
  • "DBMS_STATS"收集统计量；
  • 备份恢复管理器Recovery Manager的使用；


【设置并行和并行度】

  • Alter session force parallel query parallel n;（ALTER SESSION enable parallel query;） 单个SESSION里面
  • Alter table tab1 parallel n; 单个TABLE
  • Select /*+parallel(tab n)*/ from tab; Hint设置单个SQL

优先级：Hint > session > object


【并行度设置】并行度的设置是以多核CPU为核心的，所以并行度不能超过CPU的逻辑数量，Oracle官方文档介绍如下

If the PARALLEL clause is specified but no degree of parallelism is listed, the object gets the default DOP. Default parallelism uses a formula to determine the DOP based on the system configuration, as in the following:

  • For a single instance, DOP = PARALLEL_THREADS_PER_CPU x CPU_COUNT
  • For an Oracle RAC configuration, DOP = PARALLEL_THREADS_PER_CPU x CPU_COUNT x INSTANCE_COUNT



【实验测试】

环境说明：

  • 数据库信息：

点击(此处)折叠或打开

  1. SQL> select * from v$version where rownum<2;
  2. BANNER
  3. -----------------------------------------------------------------------------------------
  4. Oracle Database 11g Enterprise Edition Release 11.2.0.3.0 - 64bit Production


  • CPU信息

点击(此处)折叠或打开

  1. SQL> show parameter cpu
  2. NAME TYPE VALUE
  3. ------------------------------------ ----------- -------------
  4. cpu_count integer 8
  5. parallel_threads_per_cpu integer 1
  6. resource_manager_cpu_allocation integer 8

【实验步骤】

正常情况下的执行计划


点击(此处)折叠或打开

  1. SQL> alter session set STATISTICS_LEVEL=ALL;
  2. Session altered.
  3. SQL> select count(1) from edidc;
  4. COUNT(1)
  5. ----------
  6. 47262191

  8. SQL> select * from table(dbms_xplan.DISPLAY_CURSOR(null, null, 'ALLSTATS'));

  10. PLAN_TABLE_OUTPUT
  11. --------------------------------------------------------------------------------
  12. SQL_ID 8h0snkxwm7x0w, child number 0
  13. -------------------------------------
  14. select count(1) from sapsr3.edidc

  16. Plan hash value: 2138151876

  18. ----------------------------------------------------------------------------------------------------------------------
  19. Id | Operation | Name | Starts | E-Rows | A-Rows | A-Time | Buffers |
  20. -------------------------------------------------------------------------------------------------------------------
  21. | 0 | SELECT STATEMENT | | 1 | | 1 |00:00:15.52| 351K|
  22. | 1 | SORT AGGREGATE | | 1 | 1 | 1 |00:00:15.52| 351K|
  23. | 2 | INDEX FAST FULL SCAN | EDIDC~1 | 1 | 46M | 47M |00:00:09.95| 351K|
  24. --------------------------------------------------------------------------------------------------------------------


修改session的方式


点击(此处)折叠或打开

  1. SQL> alter session set STATISTICS_LEVEL=ALL;
  2. SQL> Alter session force parallel query;
  3. SQL> select count(1) from edidc;
  4. COUNT(1)
  5. ----------
  6. 47262191
  7. SQL> select * from table(dbms_xplan.DISPLAY_CURSOR(null, null, 'ALLSTATS'));
  8. -------------------------------------------------------------------------
  9. | Id | Operation | Name | E-Rows |
  10. -------------------------------------------------------------------------
  11. | 0 | SELECT STATEMENT | | |
  12. | 1 | SORT AGGREGATE | | 1 |
  13. | 2 | PX COORDINATOR | | |
  14. | 3 | PX SEND QC (RANDOM) | :TQ10000 | 1 |
  15. | 4 | SORT AGGREGATE | | 1 |
  16. | 5 | PX BLOCK ITERATOR | | 46M |
  17. |* 6 | INDEX FAST FULL SCAN| EDIDC~1 | 46M |
  18. ----------------------------------------------------------------------------
  19. Predicate Information (identified by operation id):
  20. ----------------------------------------------------------------------------
  21. 6 - access(:Z>=:Z AND :Z<=:Z)
  22. ------------------------------------------------------


用hint的方式进行


点击(此处)折叠或打开

  1. SQL> select /*+ PARALLEL(4) */ count(1) from edidc;
  2. COUNT(1)
  3. ----------
  4. 47262191

  6. SQL> select * from table(dbms_xplan.DISPLAY_CURSOR(null, null, 'ALLSTATS'));
  7. PLAN_TABLE_OUTPUT
  8. --------------------------------------------------------------------------------
  9. SQL_ID gr4rp3q9c4qu3, child number 0
  10. -------------------------------------
  11. select /*+ PARALLEL(4) */ count(1) from sapsr3.edidc

  13. Plan hash value: 152749150

  15. -------------------------------------------------------------------------------------------------------------------------------------
  16. | Id | Operation | Name | Starts | E-Rows | A-Rows | A-Time | Buffers | Reads |
  17. -------------------------------------------------------------------------------------------------------------------------------------------
  18. | 0 | SELECT STATEMENT | | 1 | | 1 |00:00:13.86 | 25 | 0 |
  19. | 1 | SORT AGGREGATE | | 1 | 1 | 1 |00:00:13.86 | 25 | 0 |
  20. | 2 | PX COORDINATOR | | 1 | | 4 |00:00:13.86 | 25 | 0 |
  21. | 3 | PX SEND QC (RANDOM) | :TQ10000 | 0 | 1 | 0 |00:00:00.01 | 0 | 0 |
  22. | 4 | SORT AGGREGATE | | 4 | 1 | 4 |00:00:52.76 | 357K | 351K |
  23. | 5 | PX BLOCK ITERATOR | | 4 | 46M | 47M |00:00:41.69 | 357K | 351K |
  24. |* 6 | INDEX FAST FULL SCAN | EDIDC~1 | 136 | 46M | 47M |00:00:20.42 | 357K | 351K |
  25. --------------------------------------------------------------------------------------------------------------------------------------
  26. Predicate Information (identified by operation id):
  27. ---------------------------------------------------
  28. 6 - access(:Z>=:Z AND :Z<=:Z)
  29. PLAN_TABLE_OUTPUT
  30. --------------------------------------------------------------------------------


修改table的方式


点击(此处)折叠或打开

  1. SQL> ALTER TABLE edidc PARALLEL 2; #设置完成后需要更新统计信息

  3. SQL> SELECT TABLE_NAME, degree FROM dba_tables WHERE TABLE_NAME='EDIDC';
  4. TABLE_NAME DEGREE
  5. ------------------------------ ------------------------------
  6. EDIDC 2
  7. SQL> alter session set STATISTICS_LEVEL=ALL;
  8. Session altered.
  9. SQL> select count(1) from edidc;
  10. COUNT(1)
  11. ----------
  12. 47262191

  14. SQL> select * from table(dbms_xplan.DISPLAY_CURSOR(null, null, 'ALLSTATS'));
  15. --------------------------------------------------------------------------------------------------------------------------
  16. | Id | Operation | Name | Starts | E-Rows | A-Rows | A-Time | Buffers | Reads |
  17. -------------------------------------------------------------------------------------------------------------------------
  18. | 0 | SELECT STATEMENT | | 1 | | 1 |00:00:12.93 | 25 | 0 |
  19. | 1 | SORT AGGREGATE | | 1 | 1 | 1 |00:00:12.93 | 25 | 0 |
  20. | 2 | PX COORDINATOR | | 1 | | 8 |00:00:12.93 | 25 | 0 |
  21. | 3 | PX SEND QC (RANDOM) | :TQ10000 | 0 | 1 | 0 |00:00:00.01 | 0 | 0 |
  22. | 4 | SORT AGGREGATE | | 8 | 1 | 8 |00:01:39.17 | 359K| 351K|
  23. | 5 | PX BLOCK ITERATOR | | 8 | 46M | 47M|00:01:23.50 | 359K| 351K|
  24. |* 6 | INDEX FAST FULL SCAN | EDIDC~1 | 164 | 46M| 47M|00:00:54.01 | 359K| 351K|
  25. ------------------------------------------------------------------------------------------------------------------------
  26. Predicate Information (identified by operation id):
  27. ---------------------------------------------------
  28. 6 - access(:Z>=:Z AND :Z<=:Z)
  29. PLAN_TABLE_OUTPUT
  30. ---------------------------------------------------

  32. SQL>ALTER TABLE TABLE_NAME NOPARALLEL; 取消并行


以上是针对查询的操作，同样也是适用于DML操作的；

并行的使用并是简单的以上的几个语句的套用，在OLTP系统中使用需谨慎，用好了是一把调优的利器，用不好可能反而会被利器所伤。本文档也是是针对并行的一篇基础文章，后续会针对更深入的应用继续说明。

文章标签：
关系型数据库
SQL
索引
Oracle
并行计算
测试技术
OLTP
OLAP
数据库
关键词：
Oracle数据库一键上云并行
猎人笔记
目录
相关文章
小Lee
|
5月前
|
SQL 存储 Oracle
flink-cdc-oracle 可以并行读取吗
flink-cdc-oracle 可以并行读取吗， 同步1000万数据，我这边半天没同步完， 这个有什么优化策略吗？这个怎么设置先全量并行读，然后增量 是flink sql跑的？
小Lee
56 1
姚远OracleACE
|
11月前
|
Oracle 关系型数据库
oracle恢复时并行进程数增加，process参数需要调大，Media Recovery failed with error 448。
检查process值是150,增大后问题解决！
姚远OracleACE
205 0
小小工匠
|
11月前
|
SQL 监控 Oracle
Oracle优化08-并行执行
Oracle优化08-并行执行
小小工匠
70 0
lemotree
|
索引
oracle-index-在线并行rebuild失效索引
lemotree
392 0
小麦苗
|
SQL Oracle 关系型数据库
Oracle并行和并发收集统计信息
Oracle并行和并发收集统计信息
小麦苗
316 0
德哥,digoal
|
Oracle 关系型数据库 PostgreSQL
PostgreSQL Oracle 兼容性之 - 自定义并行聚合函数 PARALLEL_ENABLE AGGREGATE
德哥,digoal
3778 0
小麦苗
|
Oracle 关系型数据库
Oracle中的并行
小麦苗
3042 0
嗯哼9925
|
SQL Oracle 关系型数据库
如何测试Oracle并行执行的并行度状况
嗯哼9925
1163 0
嗯哼9925
|
Oracle 关系型数据库
Oracle出现与并行相关的ORA-00600时的调查方法
嗯哼9925
1298 0
嗯哼9925
|
SQL Oracle 关系型数据库
如何取得Oracle并行执行的trace
嗯哼9925
1054 0

热门文章

最新文章

  • 1
    Oracle 面试题及答案整理，最新面试题
  • 2
    Seata常见问题之oracle 数据库 报 just support mysql如何解决
  • 3
    PolarDB常见问题之PolarDB(Oracle兼容版) 执行命令报错如何解决
  • 4
    Dataphin实时集成Oracle CDC相关问题排查
  • 5
    【Oracle】玩转Oracle数据库（一）：装上去，飞起来！
  • 6
    【Oracle】玩转Oracle数据库（二）：体系结构、存储结构与各类参数
  • 7
    【Oracle】玩转Oracle数据库（七）：RMAN恢复管理器
  • 8
    struts+hibernate+oracle+easyui实现lazyout组件的简单案例——Emp实体类和对应的配置信息
  • 9
    oracle基本笔记整理及案例分析1
  • 10
    struts+hibernate+oracle+easyui实现lazyout组件的简单案例——EmpDao层代码
  • 1
    服务器Centos7 静默安装Oracle Database 12.2
    71
  • 2
    SpringBoot整合Mybatis连接Oracle数据库
    52
  • 3
    避坑，Oracle中rownum与order by的执行顺序
    25
  • 4
    避坑，Oracle中left join 与 (+) 的区别
    19
  • 5
    Oracle临时表详解
    17
  • 6
    Oracle insert数据时字符串中有‘单引号问题
    25
  • 7
    【Bug记录】Oracle中小数点前面的0不显示的问题
    37
  • 8
    Oracle中merge Into的用法
    17
  • 9
    Flink CDC产品常见问题之使用cdc-Oracle连接器报错如何解决
    48
  • 10
    Oracle系列十八：Oracle RAC
    47

    • 相关电子书

    更多
  • PostgresChina2018_樊文凯_ORACLE数据库和应用异构迁移最佳实践
  • PostgresChina2018_王帅_从Oracle到PostgreSQL的数据迁移
  • Oracle云上最佳实践

    • 推荐镜像

    更多
  • oracle
  • arch4edu
  • debian-archive
    • 下一篇
    阿里云oss简介和使用流程