Teradata TPumpモニターのマクロ - Parallel Data Pump

Teradata® Parallel Data Pumpリファレンス - 17.20

Product
Parallel Data Pump
Release Number
17.20
Published
2022年10月10日
Language
日本語
Last Update
2022-11-21
dita:mapPath
ja-JP/kpf1641281806652.ditamap
dita:ditavalPath
ja-JP/ovd1619195504008.ditaval
dita:id
B035-3021
Product Category
Teradata Tools and Utilities

Teradata TPumpモニターは、モニター インターフェース テーブルを更新し、個別のTeradata TPumpインポート ジョブのモニターと制御を行なう一連のマクロを提供します。次のTeradata TPumpモニター マクロが提供されています。

Macro TPumpMacro. TPumpUpdateSelect

このマクロは、データベース管理者が個別のTeradata TPumpジョブの操作とモニターを行なうために使用する目的で提供されています。

CREATE MACRO SysAdmin.TPumpUpdateSelect
(
    LogDB          VARCHAR(32),
    LogTable       VARCHAR(32),
    UserName       VARCHAR(32),
    Import         INTEGER,
    RequestChange  CHAR(1),
    StmtsUnLimited CHAR(1),
    StmtsDesired   INTEGER,
    PeriodsDesired INTEGER
)
AS
(
    LOCK ROW WRITE    /* OR LOCKING Sysadmin.TPumpStatus for WRITE */
    SELECT
        RecordsOut     ,
        RecordsSkipped ,
        RecordsRejcted ,
        RecordsRead    ,
        RecordsErrored
    FROM
        SysAdmin.TPumpStatusTbl
    WHERE
        UserName = :UserName  AND
        LogDB    = :LogDB     AND
        Import   = :Import    AND
        LogTable = :LogTable

    ; UPDATE SysAdmin.TPumpStatusTbl
    SET
        RequestChange  = :RequestChange,
        StmtsUnLimited = :StmtsUnLimited,
        StmtsDesired   = :StmtsDesired,
        PeriodsDesired = :PeriodsDesired
    WHERE
        UserName = :UserName  AND
        LogDB    = :LogDB     AND
        LogTable = :LogTable  AND
        Import   = :Import       ;
);mport   = :Import       ;
);

Macro TPumpMacro. UserUpdateSelect

UserUpdateSelectマクロは、Teradata TPumpジョブのモニター/更新を行なうためのものです。

CREATE MACRO TPumpMacro.UserUpdateSelect
(
    LogDB          VARCHAR(32),
    LogTable       VARCHAR(32),
    Import         INTEGER,
    RequestChange  CHAR(1),
    StmtsUnLimited CHAR(1),
    StmtsDesired   INTEGER,
    PeriodsDesired INTEGER
)
AS
(
    LOCK ROW  WRITE /* OR LOCKING Sysadmin.TPumpStatus FOR WRITE */ SELECT
        RecordsOut     ,
        RecordsSkipped ,
        RecordsRejcted ,
        RecordsRead    ,
        RecordsErrored
    FROM
        SysAdmin.TPumpStatusTbl
    WHERE
        UserName = USER       AND
        LogDB    = :LogDB     AND
        Import   = :Import    AND
        LogTable = :LogTable

    ; UPDATE SysAdmin.TPumpStatusTbl
    SET
        RequestChange  = :RequestChange,
        StmtsUnLimited = :StmtsUnLimited,
        StmtsDesired   = :StmtsDesired,
        PeriodsDesired = :PeriodsDesired
    WHERE
        UserName = USER       AND
        LogDB    = :LogDB     AND
        LogTable = :LogTable  AND
        Import   = :Import       ;
);