Хранимая процедура имеет проблему производительности при обновлении таблицы из представления источника

Question

Source_View имеет только около 800 записей, но моя процедура заняла почти 3 минуты для обновления таблицы PHONE. У меня есть комментарии на каждом этапе, чтобы объяснить логику. Любая помощь приветствуется.

Требование: создать процесс для ежедневной проверки телефонных номеров с использованием просмотра и соответственно обновлять его.

1) Получить весь территориальный ключ из таблицы 1 SELCT * FROM Table1, ГДЕ КАТЕГОРИЯ = 'T';

2) получить данные активных торговых представителей из таблицы 2 и получить его идентификатор пользователя SELECT USER_ID FROM Table2 WHERE key_colval = '' AND JOB_TITLE = 'Sales Rep' AND STATUS = 'Active';

3) Используйте этот идентификатор пользователя для запроса source_VIEW SELECT * FROM source_VIEW WHERE USER_ID = '' AND key_colval = '';

4) Если мы не найдем ничего из вышеприведенного шага, то 4.1) SELECT * FROM source_VIEW WHERE key_colval = '';

PROCEDURE main_PHONE_UPD 

IS

   V_USER_ID                      VARCHAR2(10);
BEGIN
    EXECUTE IMMEDIATE 'TRUNCATE TABLE TMP_source_VIEW';

    EXECUTE IMMEDIATE 'INSERT INTO TMP_source_VIEW  SELECT SUBSTR(key_col,6) key_colval,MOBILE,USER_ID FROM  source_VIEW WHERE MOBILE IS NOT NULL'; -- Loading to temp table from source view 
    COMMIT;

   FOR REC IN (SELECT key_colval
                 FROM Table1
                WHERE CATEGORY = 'T' ) LOOP --- Getting only category 'T' from Table 1

      BEGIN
         SELECT USER_ID         -- Get user_id for given keycolval , getting only one value based on hire_date
           INTO V_USER_ID
           FROM(SELECT USER_ID
                  FROM Table2
                WHERE key_colval   = REC.key_colval
                  AND JOB_TITLE          = 'Sales Rep' 
                  AND STATUS = 'Active'
                  ORDER BY HIRE_DATE ASC)
          WHERE ROWNUM <= 1;          
         calling_PHONE_upd(V_USER_ID, REC.key_colval,'Y'); -- if data exists call this with indicator 'Y' to load phone table 
         COMMIT; 
      EXCEPTION
         WHEN NO_DATA_FOUND THEN
            calling_PHONE_upd(NULL, REC.key_colval,'N');  -- -- if data exists call this with indicator 'N' to load phone table 
            COMMIT;
      END;

   END LOOP;
END main_PHONE_UPD;


PROCEDURE calling_PHONE_upd( 

   IN_USER_ID                    VARCHAR2,
   IN_key_colval                 VARCHAR2,
   IN_USER_INDICATOR             VARCHAR2)
IS
    V_COUNT                 NUMBER := 0;
    V_PHONE_REC             PHONE%ROWTYPE;

BEGIN


   IF IN_USER_INDICATOR = 'Y' THEN
   FOR rec IN (SELECT * FROM TMP_user_VIEW WHERE USER_ID=IN_USER_ID AND key_colval=IN_key_colval )
   LOOP  - This logic to update primary/secondary numbers if mutilple values 
      V_COUNT := V_COUNT + 1;
      V_PHONE_REC.key_colval  := rec.key_colval;
      V_PHONE_REC.PHONE_NUMBER_TYPE := CASE WHEN V_COUNT = 1 THEN 'PRI'
                                            WHEN V_COUNT = 2 THEN 'SCD'
                                            ELSE NULL
                                       END;
      V_PHONE_REC.PHONE_AREA_CODE   := SUBSTR(rec.MOBILE,1,3);
      V_PHONE_REC.PHONE_NUMBER      := SUBSTR(rec.MOBILE,5,3)||SUBSTR(rec.MOBILE,9);
      V_PHONE_REC.PHONE_EXTENSION   := NULL;
      BEGIN 
            INSERT INTO PHONE VALUES V_PHONE_REC;
      EXCEPTION
          WHEN DUP_VAL_ON_INDEX THEN
              BEGIN
                  UPDATE PHONE SET ROW = V_PHONE_REC WHERE key_colval = V_PHONE_REC.key_colval AND PHONE_NUMBER_TYPE = V_PHONE_REC.PHONE_NUMBER_TYPE;
      END;
      IF V_COUNT > 2 THEN --Primary Phone Number
          EXIT;
      END IF;
   END LOOP;

   ELSE

   FOR rec IN (SELECT * FROM TMP_user_VIEW WHERE key_colval=IN_key_colval)
   LOOP  -- - This logic to update primary/secondary numbers if mutilple values 
      V_COUNT := V_COUNT + 1;
      V_PHONE_REC.PHONE_NUMBER_TYPE := CASE WHEN V_COUNT = 1 THEN 'PRI'
                                            WHEN V_COUNT = 2 THEN 'SCD'
                                            ELSE NULL
                                       END;
      V_PHONE_REC.PHONE_AREA_CODE   := SUBSTR(rec.MOBILE,1,3);
      V_PHONE_REC.PHONE_NUMBER      := SUBSTR(rec.MOBILE,5,3)||SUBSTR(rec.MOBILE,9);
      V_PHONE_REC.PHONE_EXTENSION   := NULL;
      BEGIN 
            INSERT INTO PHONE VALUES V_PHONE_REC;
      EXCEPTION
          WHEN DUP_VAL_ON_INDEX THEN
              BEGIN
                  UPDATE PHONE SET ROW = V_PHONE_REC WHERE key_colval = V_PHONE_REC.key_colval AND PHONE_NUMBER_TYPE = V_PHONE_REC.PHONE_NUMBER_TYPE;
      END;
      IF V_COUNT > 2 THEN --Primary Phone Number
          EXIT;
      END IF;
   END LOOP;

   END IF;

END calling_PHONE_upd;

Answer 1

На вашем месте я бы хотел превратить это в одно выражение MERGE, что-то вроде:

MERGE INTO phone tgt
USING (SELECT t1.key_colval,
              t2.user_id,
              CASE WHEN t2.user_id IS NULL THEN 'N' ELSE 'Y' END INDICATOR
              CASE WHEN row_number() OVER (PARTITION BY t1.colval ORDER BY t1.colval) = 1 THEN 'PRI'
                   ELSE 'SCD'
              END phone_number_type,
              SUBSTR(tuv.MOBILE,1,3) PHONE_AREA_CODE,
              SUBSTR(tuv.MOBILE,5,3)||SUBSTR(tuv.MOBILE,9) PHONE_NUMBER,
              NULL PHONE_EXTENSION
       FROM   Table1 t1
              LEFT OUTER JOIN (SELECT key_colval,
                                      user_id
                               FROM   (SELECT user_id,
                                              key_colval,
                                              row_number() OVER (PARTITION BY key_colval ORDER BY hire_date DESC) rn
                                       FROM   table2
                                       WHERE  job_title = 'Sales Rep'
                                       AND    status = 'Active') t
                               WHERE  rn = 1) t2 ON t1.key_colval = t2.key_colval
              INNER JOIN tmp_user_view tuv ON tuv.key_colval = t1.key_colval AND ((t2.user_id IS NOT NULL AND tuv.user_id = t2.user_id) OR t2.user_id IS NULL)
       WHERE  t1.CATEGORY = 'T'
       AND    ROWNUM <= 2 -- there's no ordering mentioned in your calling_PHONE_upd cursors, so if there should be, you'd need another method of working out the correct 2 rows to return and in which order
       ) src
       ON (tgt.key_colval = src.key_colval -- plus additional columns that make the join between the tgt table and src subquery produce a 1-2-1 mapping
           )
WHEN MATCHED THEN
  UPDATE SET tgt.phone_number_type = src.phone_number_type -- add in the other columns (not the ones in the ON clause above!)
WHEN NOT MATCHED THEN
  INSERT (tgt.key_colval, ...) -- list the other columns being inserted into
  VALUES (src.key_colval, ...); -- list the other source columns being inserted

Я пришел к этому утверждению после прохождения вашей логики и преобразования ручных объединенных вложенных циклов (циклов курсора в циклах курсора) в один оператор выбора, а затем с помощью этого слияния вместо вставки или обновления заявления.

Это должно значительно улучшить ситуацию, поскольку теперь вы можете позволить оптимизатору определить наилучший способ объединения таблиц и исключить все переключения контекста между SQL и PL / SQL.

Я бы тоже не стал заниматься столами для постановки; просто используйте запрос, который заполнил промежуточные таблицы непосредственно в исходном подзапросе оператора Merge. Это экономит ваше время на усечение и вставку данных.

N.B. Мое утверждение явно не проверено, поскольку вы не предоставили полный тестовый пример с образцами данных и ожидаемым результатом. Если это не сработает так, как вы ожидаете, я бы порекомендовал вам исправить это для вашего случая, вместо того чтобы переходить к высокопроцедурному коду, который у вас есть в настоящее время.