0

Есть три таблицы

CREATE TABLE A (
  ID NUMBER,
  B_ID NUMBER NOT NULL,
  ...........
  CONSTRAINT FK_A_B FOREIGN KEY (B_ID)
    REFERENCES B (ID) ENABLE VALIDATE,
  CONSTRAINT PK_A
  PRIMARY KEY (ID) ENABLE VALIDATE
)

CREATE TABLE B (
  ID NUMBER,
  TYPE NUMBER NOT NULL,
  ...........
  CONSTRAINT PK_B
  PRIMARY KEY (ID) ENABLE VALIDATE
)

CREATE TABLE C (
  ID NUMBER,
  A_ID NUMBER NOT NULL,
  DATA NUMBER NOT NULL,
  ...........
  CONSTRAINT FK_C_A FOREIGN KEY (A_ID)
    REFERENCES A (ID) ENABLE VALIDATE,
  CONSTRAINT PK_A
  PRIMARY KEY (ID) ENABLE VALIDATE
)

(пара A_ID, DATA не уникальна и может повторяться до трех раз)

Нужно после (или во время) импорта данных в эти таблицы для всех новых записей вставить записи в такую таблицу

CREATE TABLE D (
  ID NUMBER GENERATED ALWAYS AS IDENTITY,
  A_ID NUMBER NOT NULL,
  DATA NUMBER,
  CONSTRAINT FK_D_A FOREIGN KEY (A_ID)
    REFERENCES A (ID) ON DELETE CASCADE ENABLE VALIDATE,
  CONSTRAINT PK_D
  PRIMARY KEY (ID) ENABLE VALIDATE,
  CONSTRAINT UNQ_D
  UNIQUE (A_ID, "DATA") ENABLE VALIDATE
)

Но вставить по хитрому алгоритму.

  1. Для каждой новой записи в таблицах A и C через таблицу A, получить значение B.TYPE
  2. Для этого значения вызвать функцию my_func, которая вернет 0 или 1
  3. Если функция вернула 0, то выполнить запрос

    INSERT INTO D (A_ID, DATA)
      SELECT ID, NULL FROM A WHERE ID = current_id;
    
  4. Если функция вернула 1, то выполнить такой запрос

    INSERT INTO D (A_ID, DATA)
      SELECT DISTINCT A_ID, DATA FROM C WHERE A_ID = current_a_id;
    

Функция my_func имеет вид

CREATE FUNCTION my_func (in_type IN NUMBER)
RETURN NUMBER
DETERMINISTIC
IS
BEGIN
  IF (in_type IN (5, 13, 17, 20, 65, 79)) THEN
    RETURN 1;
  ELSE
    RETURN 0;
  END IF;
END;

Как бы эту задачу решить поэффективней? Учитывая, что возможна ситуация когда импорт одних и тех же данных может происходить параллельно (если данные уже есть, то ничего делать не нужно. Вернее нужно обновить другие поля, но к этому алгоритму они не относятся). Задача осложняется тем, что возможна ситуация (хотя она и маловероятна) когда к существующим записям в С, которые ссылаются на одну запись из A добавляются еще записи, ссылающиеся на эту же запись и для my_func() = 1 нужно будет добавить записи в D

В одном пакете импорта могут прийти тысячи записей в A (не факт, что все они будут новыми). На каждую запись из A могут ссылаться до 10 записей из C

17
  • А импорт чем выполняется?
    – Viktorov
    15 фев 2018 в 18:17
  • Ерунда какая-то... Если функция вернула X, то выполнить запрос - вставить в таблицу D все записи из А или С? Догадываюсь, что как-то нужно коррелироваться по A_ID на вставляемую запись... тогда Задача осложняется тем, что - есть ещё хуже - вставляем в А, функция вернула 1, лезем в С, а там шиш такого A_ID...
    – Akina
    15 фев 2018 в 19:20
  • В чем собственно вы видите какие либо проблемы ? "если данные уже есть - ничего не делать", так и не делайте, insert и не будет пытаться пройти, значит больше ничего происходить и не будет. А по поводу остального, нет никакого "оптимального" пути, есть только единственный существующий, триггера на таблицах A и C должны отработать эти ситуации и выполнить действия. Если функция my_func детерменированна и при этом долго выполняется, возможно стоит где то хранить готовые значения 0 и 1 для всех B.TYPE. P.S. хотя есть отличная оптимизация, исходя из приведенной структуры таблица D вообще не нужн
    – Mike
    15 фев 2018 в 19:41
  • @Akina не все, а текущую просматриваемую 15 фев 2018 в 21:25
  • @Viktorov Внешней самописной утилитой. Утилита для вставки/обновления вызывает процедуры БД 15 фев 2018 в 21:28

1 ответ 1

0

Итого остановился на AFTER INSERT триггере для C

CREATE TRIGGER TR_C_AI AFTER INSERT ON C
REFERENCING NEW AS NEW OLD AS OLD FOR EACH ROW
DECLARE
  var_action NUMBER;
BEGIN
  SELECT
    my_func(B."TYPE")
  INTO
    var_action
  FROM
    A
    LEFT JOIN B ON (
      A.B_ID = B.ID
    )
  WHERE
    A.ID = :NEW.A_ID;

  IF (var_action = 1) THEN
    MERGE INTO
      D
    USING (
      SELECT
        :NEW.A_ID AS A_ID,
        :NEW.DATA AS DATA
      FROM
        dual
    ) sub
    ON (
      D.A_ID = sub.A_ID AND
      D.DATA = sub.DATA
    ) WHEN NOT MATCHED THEN INSERT (
      A_ID,
      DATA
    ) VALUES (
      :NEW.A_ID,
      :NEW.DATA
    );
  ELSE
    MERGE INTO
      D
    USING (
      SELECT
        :NEW.A_ID AS A_ID
      FROM
        dual
    ) sub
    ON (
      D.A_ID = sub.A_ID
    ) WHEN NOT MATCHED THEN INSERT (
      A_ID,
      DATA
    ) VALUES (
      :NEW.A_ID,
      NULL
    );
  END IF;
END;

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.