使用 Bulk Collect 将批量记录插入到远程数据库 (dblink)

我想使用 DBLINK - @FMATLINK 将来自不同表的大量记录插入到目标远程表“Audition_Detail”中。我已经使用了批量收集，但它抛出错误。我也浏览了一些链接：

克服通过数据库链接批量插入的限制 https://stackoverflow.com/questions/10534390/overcoming-the-restriction-on-bulk-inserts-over-a-database-link

PLS-00394: fetch 语句的 INTO 列表中的值数量错误 https://stackoverflow.com/questions/47116220/pls-00394-wrong-number-of-values-in-the-into-list-of-a-fetch-statement

代码如下：

DECLARE
    TYPE FETCH_ARRAY IS TABLE OF AUDITION_DETAIL@FMATLINK%ROWTYPE;   
    A_DATA FETCH_ARRAY;

    CURSOR A_CUR IS
        --------------------------------------------------------Address1--------------------------------------------------------------------------

        SELECT A.PARTY_SITE_NUMBER FMAT_FMATID, B.ZADDRESSFMATID F4F_FMATID,
        C.ADDRESS1 FMAT_VALUE, B.STREET F4F_VALUE , 'ADDRESS1' 
        FROM APPS.HZ_PARTY_SITES@FMATLINK A , f4f_corporateaccount B , APPS.HZ_LOCATIONS@FMATLINK C
        WHERE 1=1
        AND B.ROLECODETEXT = 'Site Account'
        AND A.PARTY_SITE_NUMBER = B.ZADDRESSFMATID
        AND A.STATUS = 'A'

        UNION ALL 
        ------------------------------------------------------Address2-----------------------------------------------------------------------------

        SELECT A.PARTY_SITE_NUMBER FMAT_FMATID, B.ZADDRESSFMATID F4F_FMATID,
        C.ADDRESS2 FMAT_VALUE, B.addressline1 F4F_VALUE , 'ADDRESS2'  
        FROM APPS.HZ_PARTY_SITES@FMATLINK A , f4f_corporateaccount B , APPS.HZ_LOCATIONS@FMATLINK C
        WHERE 1=1
        AND B.ROLECODETEXT = 'Site Account'
        AND A.PARTY_SITE_NUMBER = B.ZADDRESSFMATID
        AND A.STATUS = 'A'


BEGIN   
    OPEN A_CUR;
    LOOP                      
        FETCH A_CUR BULK COLLECT INTO A_DATA LIMIT 20; 
            FORALL IN 1..A_DATA.COUNT     
            INSERT INTO AUDITION_DETAIL@FMATLINK VALUES A_DATA(i);

        EXIT WHEN A_CUR%NOTFOUND;
    END LOOP;
    CLOSE A_CUR;
    COMMIT;
END;

错误报告 -

ORA-06550: 第 39 行，第 3 列：

PLS-00394：FETCH 的 INTO 列表中的值数量错误 陈述

ORA-06550: 第 39 行，第 3 列：

PL/SQL：忽略 SQL 语句

ORA-06550: 第 40 行，第 4 列：

PLS-00739：远程表不支持 FORALL INSERT/UPDATE/DELETE 06550. 00000 - “第 %s 行，第 %s 列：\n%s”

*原因：通常是 PL/SQL 编译错误。 *行动：

错误消息似乎很清楚：

全部插入/更新/删除不支持在远程表上。

事实上，您链接到另一个问题，它解释了这是一个实施限制。 PL/SQL 不允许我们跨数据库链接使用 FORALL 语句，仅此而已。

幸运的是，您不需要在代码中使用批量收集和 FORALL。一个简单的 INSERT INTO .... SELECT 语句应该让您明白：

INSERT INTO AUDITION_DETAIL@FMATLINK 
    SELECT A.PARTY_SITE_NUMBER FMAT_FMATID, B.ZADDRESSFMATID F4F_FMATID,
    C.ADDRESS1 FMAT_VALUE, B.STREET F4F_VALUE , 'ADDRESS1' 
    FROM APPS.HZ_PARTY_SITES@FMATLINK A , f4f_corporateaccount B , APPS.HZ_LOCATIONS@FMATLINK C
    WHERE 1=1
    AND B.ROLECODETEXT = 'Site Account'
    AND A.PARTY_SITE_NUMBER = B.ZADDRESSFMATID
    AND A.STATUS = 'A'

    UNION ALL 
    ------------------------------------------------------Address2-----------------------------------------------------------------------------

    SELECT A.PARTY_SITE_NUMBER FMAT_FMATID, B.ZADDRESSFMATID F4F_FMATID,
    C.ADDRESS2 FMAT_VALUE, B.addressline1 F4F_VALUE , 'ADDRESS2'  
    FROM APPS.HZ_PARTY_SITES@FMATLINK A , f4f_corporateaccount B , APPS.HZ_LOCATIONS@FMATLINK C
    WHERE 1=1
    AND B.ROLECODETEXT = 'Site Account'
    AND A.PARTY_SITE_NUMBER = B.ZADDRESSFMATID
    AND A.STATUS = 'A'

您的代码没有使用显式的 ANSI 92 连接语法，并且您已经整理了代码，因此很难阅读。因此，很容易错过您尚未编写连接条件的事实APPS.HZ_LOCATIONS@FMATLINK C。因此，两个子查询都会为中的所有记录生成笛卡尔积C。你可能不想要这个。

SELECT A.PARTY_SITE_NUMBER as FMAT_FMATID
        , B.ZADDRESSFMATID as F4F_FMATID
        , C.ADDRESS2 as FMAT_VALUE
        , B.addressline1 as F4F_VALUE
        , 'ADDRESS2'  
FROM APPS.HZ_PARTY_SITES@FMATLINK A
      inner join  f4f_corporateaccount B on A.PARTY_SITE_NUMBER = B.ZADDRESSFMATID
      inner join  APPS.HZ_LOCATIONS@FMATLINK C on ** something goes here **
WHERE  B.ROLECODETEXT = 'Site Account'
AND A.STATUS = 'A'

更容易理解，更容易发现缺失的连接。可读性是一个特点。