Oracle вставить в таблицу 2, а затем удалить из таблицы 1, исключение в случае сбоя - PullRequest
Новая
       11

Oracle вставить в таблицу 2, а затем удалить из таблицы 1, исключение в случае сбоя

0 голосов
/ 05 ноября 2018

создание процедуры, которая будет вставлять данные из моей таблицы1 в мою таблицу2 и удалять их после вставки, или, если таблица2 достигла своего предела, я создам новую резервную копию таблицы.

У меня есть две таблицы sii_bck_cfg_tab и sii_bck_tab

Вкл. cfg_tab У меня есть список имен таблиц с несколькими столбцами (id,name_tab, prefix_tab, created_on , keep_days, max_rows_bck) prefix_tab - где я получаю префикс, когда мне нужно создать новую резервную копию таблицы keep_days - количество дней, в которые я хочу хранить данные таблиц max_rows - количество строк, которые я добавлю в резервную таблицу, прежде чем я создам новую.

на моем bck_tab у меня есть следующие столбцы (id, tab_name, id_cfg_bck, created_on, close_dt) tab_name-имя созданной резервной таблицы id_cfg_bck- FK из cfg_bck close_dt - дата, когда таблица резервных копий достигает своего предела и «закрывается» 

enter code here
CREATE OR REPLACE PROCEDURE LIMPAR_TAB_proc 
IS

stmt VARCHAR2(1000);
stmt_ins_bck VARCHAR2(1000);

n_tab sii_bck_cfg_tab.nome_tab%type;
prefix sii_bck_cfg_tab.pref_tab_bck%type;
max_reg sii_bck_cfg_tab.max_reg_bck%type;
id_fk sii_bck_cfg_tab.id_bck_cfg_tab%type;
dt_criado sii_bck_cfg_tab.criado_em%TYPE;  

id_fk2 sii_bck_tab.id_bck_cfg_tab%type;
dt_fec sii_bck_tab.dt_fecho%TYPE;
n_tab2 sii_bck_tab.nome_tab%type;
stmt_ins VARCHAR2(500);
id_seq VARCHAR2(500);
num_rows VARCHAR2(500);
stmt_up VARCHAR2(500);
stmt_del VARCHAR2(500);

CURSOR c1 IS
SELECT ID_BCK_CFG_TAB,Nome_tab, pref_tab_bck, max_reg_bck, criado_em FROM sii_bck_cfg_tab WHERE desativado_em IS NULL OR desativado_em<=SYSDATE AND n_dias_reten>0 ORDER BY criado_em; 

CURSOR c2 IS 
SELECT sii_bck_tab.ID_BCK_CFG_TAB , sii_bck_tab.nome_tab from sii_bck_tab,sii_bck_cfg_tab WHERE sii_bck_cfg_tab.id_bck_cfg_tab=sii_bck_tab.id_bck_cfg_tab and dt_fecho is NULL;

BEGIN                                  

OPEN c1;
LOOP
--inserir os registos que cumprem a restrição da data e dos dias de retenção
FETCH c1 INTO id_fk,n_tab,prefix,max_reg, dt_criado;
EXIT WHEN c1%NOTFOUND;
DBMS_OUTPUT.PUT_LINE('Nome Tabela c1 = ' || id_fk ||' '|| n_tab ||' '|| prefix ||' '|| max_reg); 


    OPEN c2;
      LOOP

         FETCH c2 INTO id_fk2, n_tab2;
        --DBMS_OUTPUT.PUT_LINE('chave aqui c2= ' || id_fk2 || n_tab2);

         --registos de tabelas que não estão fechadas           
         IF c2%FOUND AND id_fk=id_fk2 THEN
         BEGIN
         SAVEPOINT start_transaction;
           stmt_ins:= 'INSERT all into ' || n_tab2 || ' SELECT * FROM ' || n_tab || ' where ' || dt_criado || '<' || SYSDATE;
           --falta verificar se foi bem sucedido e apagar da original

        -- EXECUTE IMMEDIATE stmt_ins;
                        dbms_output.put_line('value '||SQL%ROWCOUNT);
           DBMS_OUTPUT.PUT_LINE(stmt_ins);

         siima_logs_bck.INSE_LOG(1,'TESTE INSERIR','INS_LOGS','2', 'testes insert log');
        EXCEPTION 
        WHEN DUP_VAL_ON_INDEX THEN
          ROLLBACK TO start_transaction; 

        END; 
         stmt_del:= 'DELETE FROM ' || n_tab || ' WHERE (SELECT *
         FROM ' || n_tab2 || ' WHERE criado_em' ||'<'|| sysdate ;

         DBMS_OUTPUT.PUT_LINE(stmt_del);
         siima_logs_bck.INSE_LOG(1,'TESTE ELIMINAR','INS_LOGS','2', 'testes delete log');
         ELSE IF c2%NOTFOUND THEN 
           stmt:= 'create table ' || prefix || SII_BCK_TAB_ID_SEQ.nextval || 
           ' AS SELECT * FROM '|| n_tab || ' WHERE 1=0';
         --  DBMS_OUTPUT.PUT_LINE(stmt);
         --EXECUTE IMMEDIATE stmt;
           id_seq:= prefix||SII_BCK_TAB_ID_SEQ.CURRVAL;
         -- DBMS_OUTPUT.PUT_LINE(id_seq); 
           stmt_ins_bck:= 'insert into sii_bck_tab(nome_tab,id_bck_cfg_tab) VALUES ' || '(' || id_seq || ',' || id_fk || ')';
         --  DBMS_OUTPUT.PUT_LINE(stmt_ins_bck);
           --EXECUTE IMMEDIATE stmt_ins_bck; 

           EXIT WHEN c2%NOTFOUND;           
         END IF;    
         END IF;  
                       --vefificar numero de registos e update
         EXECUTE IMMEDIATE 'SELECT Count (*) from ' ||n_tab INTO num_rows;
       --  DBMS_OUTPUT.PUT_LINE(num_rows);

         IF num_rows>max_reg THEN             
         stmt_up:='update ' || n_tab ||  ' set ' || dt_fec || '=' || sysdate;
         DBMS_OUTPUT.PUT_LINE(stmt_up);
         --EXECUTE IMMEDIATE stmt_up;

         END IF;

      END LOOP;
    CLOSE c2;
END LOOP;
CLOSE c1;
end;

На данный момент у меня проблемы с тем, чтобы вставить в динамическую таблицу, а затем удалить, если я успешно вставил в резервную таблицу. 

stmt_ins:= 'INSERT all into ' || n_tab2 || ' SELECT * FROM ' || n_tab || ' where ' || dt_criado || '<' || SYSDATE;

- этот stmt работает без предложения where, но мне нужно, чтобы он работал, чтобы я мог фильтровать данные по дате.

Я хочу убедиться, что я правильно вставил свои данные в свою резервную таблицу, а затем удалил из моей основной таблицы. 

stmt_del:= 'DELETE FROM ' || n_tab || ' WHERE (SELECT *
             FROM ' || n_tab2 || ' WHERE criado_em' ||'<'|| sysdate ;

в моем состоянии удаления данных у меня та же проблема со столбцом criado_em.

Это процедура, которая будет выполняться в задании и ежедневно передавать данные из основной таблицы в резервные таблицы и сохранять определенный объем данных в основной таблице (как, например, за последние 30 дней)

Спасибо за любую помощь

1 Ответ

0 голосов
/ 05 ноября 2018

этот stmt работает без предложения where

Это может быть потому, что когда вы объединяете строки, они неявно преобразуются, и ваше условие where не выполняется во время выполнения. Попробуйте предложение USING с переменными связывания. 

stmt_ins:= 'INSERT  INTO ' || n_tab2 || ' SELECT * FROM ' || n_tab || ' where ' || dt_criado || ' < :dt ' ;

EXECUTE IMMEDIATE stmt_ins USING SYSDATE;
...