前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >在Oracle RAC中如何指定JOB的运行实例?

在Oracle RAC中如何指定JOB的运行实例?

作者头像
小麦苗DBA宝典
发布2023-08-10 15:32:31
3050
发布2023-08-10 15:32:31
举报

题目部分

RAC中如何指定JOB的运行实例?

答案部分

在RAC中,可以让JOB在某个指定的实例上运行。对于DBMS_JOB和DBMS_SCHEDULER来说,它们的指定方法不同:

(1)在DBMS_JOB下,在执行SYS.DBMS_JOB.SUBMIT包创建JOB的时候,可以指定INSTANCE参数,该参数指定了JOB运行的实例。

在RAC环境中,采用DBMS_JOB包可以指定JOB运行时候的实例。示例代码如下所示,该例子展示了获取RAC数据库的IP地址并记录到临时表T_IPADDRESS_LHR中,例子很经典,希望读者可以理解。

1) 创建临时表用于记录RAC数据库的IP地址

DROP TABLE T_IPADDRESS_LHR;

CREATE TABLE T_IPADDRESS_LHR(INST_ID NUMBER, HOST_NAME VARCHAR2(255), HOST_IP VARCHAR2(255) );

2) 创建视图VH_IPADDRESS_LHR用于从V$DIAG_ALERT_EXT中获取IP地址

代码语言:javascript
复制
CREATE OR REPLACE VIEW VH_IPADDRESS_LHR AS  

SELECT A.HOST_ID || ': ' || A.HOST_ADDRESS HOST_IP1,

       A.HOST_ADDRESS HOST_IP2,

  A.HOST_ID HOST_NAME2

        FROM V$DIAG_ALERT_EXT A

       WHERE A.COMPONENT_ID = 'RDBMS'

         AND UPPER(A.FILENAME) =

             (SELECT UPPER(SUBSTR(D.VALUE, 1, (LENGTH(D.VALUE) - 5)) ||

                           'ALERT' || SUBSTR(D.VALUE, -6, 1) || 'LOG.XML')

                FROM V$PARAMETER D

               WHERE D.NAME = 'BACKGROUND_DUMP_DEST')

         AND A.INDX =

             (SELECT MAX(B.INDX)

                FROM V$DIAG_ALERT_EXT B

               WHERE B.COMPONENT_ID = 'RDBMS'

                 AND UPPER(B.FILENAME) =

                     (SELECT UPPER(SUBSTR(D.VALUE, 1, (LENGTH(D.VALUE) - 5)) ||

                                   'ALERT' || SUBSTR(D.VALUE, -6, 1) ||

                                   'LOG.XML')

                        FROM V$PARAMETER D

                       WHERE D.NAME = 'BACKGROUND_DUMP_DEST'));

/

3) 创建存储过程用于在指定的实例上运行程序,首先从函数UTL_INADDR.GET_HOST_ADDRESS中获取,若是系统没有该包,则从视图VH_IPADDRESS_LHR中获取IP地址

代码语言:javascript
复制
CREATE OR REPLACE PROCEDURE PH_IP_LHR AS



  V_SQL VARCHAR2(4000);

BEGIN



  INSERT INTO T_IPADDRESS_LHR

    (INST_ID, HOST_NAME)

    SELECT V.INSTANCE_NUMBER, V.HOST_NAME FROM V$INSTANCE V;

  COMMIT;



  V_SQL := 'UPDATE T_IPADDRESS_LHR T

     SET T.HOST_IP = UTL_INADDR.GET_HOST_ADDRESS

   WHERE T.INST_ID = USERENV(''INSTANCE'')';



  EXECUTE IMMEDIATE V_SQL;



  COMMIT;



EXCEPTION

  WHEN OTHERS THEN



    V_SQL := 'UPDATE T_IPADDRESS_LHR T

       SET T.HOST_IP =

           (SELECT V.HOST_IP2 FROM VH_IPADDRESS_LHR V)

     WHERE T.INST_ID = USERENV(''INSTANCE'')';

    EXECUTE IMMEDIATE V_SQL;

    COMMIT;



END PH_IP_LHR;

/

4) 创建JOB来获取IP地址

DECLARE

  X NUMBER;

BEGIN



  FOR CUR IN (SELECT B.JOB

                FROM DBA_JOBS B

               WHERE B.WHAT = 'PH_IP_LHR;') LOOP



    SYS.DBMS_IJOB.REMOVE(CUR.JOB);

    COMMIT;

  END LOOP;



  FOR CUR IN (SELECT B.INST_ID FROM GV$INSTANCE B) LOOP



    SYS.DBMS_JOB.SUBMIT(JOB       => X,

                        WHAT      => 'PH_IP_LHR;',

                        NEXT_DATE => SYSDATE+CUR.INST_ID/8640,

                        INTERVAL  => 'NULL',

                        NO_PARSE  => FALSE,

                        INSTANCE  => CUR.INST_ID);

    COMMIT;

  END LOOP;

END;

/

(2)DBMS_SCHEDULER下指定实例运行JOB稍微有点复杂,首先创建SERVICE,再创建JOB_CLASS,最后创建JOB才可以,具体过程可以参考如下案例的代码。

该例子和上面的DBMS_JOB例子一样展示了获取集群数据库的IP地址并记录到临时表T_IPADDRESS_LHR中,例子的前3步和上面的例子一样,不再赘述,接下来就是创建SERVICE和JOB_CLASS,最后是创建JOB的过程。

代码语言:javascript
复制
BEGIN

  FOR CUR IN (SELECT V.INST_ID,

                     V.INSTANCE_NAME,

                     'INST_LHR_' || V.INST_ID SERVICE_NAME,

                     'LHR_RAC' || V.INST_ID || '_JOB_CLASS' JOB_CLASS_NAME,

                     'RAC_LHR_' || V.INST_ID JOB_NAME

                FROM GV$INSTANCE V) LOOP

    BEGIN

      DBMS_SERVICE.STOP_SERVICE(SERVICE_NAME  => CUR.SERVICE_NAME,

                                INSTANCE_NAME => CUR.INSTANCE_NAME);

      DBMS_SERVICE.DELETE_SERVICE(SERVICE_NAME => CUR.SERVICE_NAME);

    EXCEPTION

      WHEN OTHERS THEN

        NULL;

    END;

    BEGIN

      DBMS_SCHEDULER.DROP_JOB_CLASS(JOB_CLASS_NAME => CUR.JOB_CLASS_NAME,

                                    FORCE          => TRUE);

    EXCEPTION

      WHEN OTHERS THEN

        NULL;

    END;

    BEGIN

      DBMS_SCHEDULER.DROP_JOB(JOB_NAME => CUR.JOB_NAME, FORCE => TRUE);

    EXCEPTION

      WHEN OTHERS THEN

        NULL;

    END;

  END LOOP;



  FOR CUR IN (SELECT V.INST_ID,

                     V.INSTANCE_NAME,

                     'INST_LHR_' || V.INST_ID SERVICE_NAME,

                     'LHR_RAC' || V.INST_ID || '_JOB_CLASS' JOB_CLASS_NAME,

                     'RAC_LHR_' || V.INST_ID JOB_NAME

                FROM GV$INSTANCE V) LOOP



    DBMS_SERVICE.CREATE_SERVICE(SERVICE_NAME => CUR.SERVICE_NAME,

                                NETWORK_NAME => CUR.SERVICE_NAME);

    DBMS_SERVICE.START_SERVICE(SERVICE_NAME  => CUR.SERVICE_NAME,

                               INSTANCE_NAME => CUR.INSTANCE_NAME);



    DBMS_SCHEDULER.CREATE_JOB_CLASS(JOB_CLASS_NAME => CUR.JOB_CLASS_NAME,

                                    SERVICE        => CUR.SERVICE_NAME);



    DBMS_SCHEDULER.CREATE_JOB(JOB_NAME    => 'RAC_LHR_' || CUR.INST_ID,

                              JOB_TYPE        => 'STORED_PROCEDURE',

                              JOB_ACTION      => 'PH_IP_LHR',

                              REPEAT_INTERVAL => NULL, --'FREQ=MINUTELY;INTERVAL=1'

                              JOB_CLASS       => CUR.JOB_CLASS_NAME,

                              END_DATE        => NULL,

                              ENABLED         => TRUE);



  END LOOP;

END;

/
本文参与 腾讯云自媒体同步曝光计划,分享自微信公众号。
原始发表:2023-08-01,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 DB宝 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
数据库
云数据库为企业提供了完善的关系型数据库、非关系型数据库、分析型数据库和数据库生态工具。您可以通过产品选择和组合搭建,轻松实现高可靠、高可用性、高性能等数据库需求。云数据库服务也可大幅减少您的运维工作量,更专注于业务发展,让企业一站式享受数据上云及分布式架构的技术红利!
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档