[catalogue] Created the liquibase migration script for the new recycle-bin functionality

7c091d1b · Cedric Caffy · eaa62f92 · 7c091d1b
Commit 7c091d1b authored 4 years ago by Cedric Caffy
--- a/catalogue/migrations/liquibase/oracle/3.1to3.2.sql
+++ b/catalogue/migrations/liquibase/oracle/3.1to3.2.sql
+--liquibase formatted sql
+
+--changeset ccaffy:1 failOnError:true dbms:oracle
+--preconditions onFail:HALT onError:HALT
+--precondition-sql-check expectedResult:"3.1" SELECT CONCAT(CONCAT(CAST(SCHEMA_VERSION_MAJOR as VARCHAR(10)),'.'), CAST(SCHEMA_VERSION_MINOR AS VARCHAR(10))) AS CATALOGUE_VERSION FROM CTA_CATALOGUE;
+UPDATE CTA_CATALOGUE SET STATUS='UPGRADING';
+UPDATE CTA_CATALOGUE SET NEXT_SCHEMA_VERSION_MAJOR=3;
+UPDATE CTA_CATALOGUE SET NEXT_SCHEMA_VERSION_MINOR=2;
+--rollback UPDATE CTA_CATALOGUE SET NEXT_SCHEMA_VERSION_MAJOR=NULL;
+--rollback UPDATE CTA_CATALOGUE SET NEXT_SCHEMA_VERSION_MINOR=NULL;
+--rollback UPDATE CTA_CATALOGUE SET STATUS='PRODUCTION';
+
+--changeset ccaffy:2 failOnError:true dbms:oracle
+--preconditions onFail:HALT onError:HALT
+--precondition-sql-check expectedResult:"3.1" SELECT CONCAT(CONCAT(CAST(SCHEMA_VERSION_MAJOR as VARCHAR(10)),'.'), CAST(SCHEMA_VERSION_MINOR AS VARCHAR(10))) AS CATALOGUE_VERSION FROM CTA_CATALOGUE;
+CREATE SEQUENCE FILE_RECYCLE_LOG_ID_SEQ
+  INCREMENT BY 1
+  START WITH 1
+  NOMAXVALUE
+  MINVALUE 1
+  NOCYCLE
+  CACHE 20
+  NOORDER;
+--rollback DROP SEQUENCE FILE_RECYCLE_LOG_ID_SEQ;
+
+--changeset ccaffy:3 failOnError:true dbms:oracle
+--preconditions onFail:HALT onError:HALT
+--precondition-sql-check expectedResult:"3.1" SELECT CONCAT(CONCAT(CAST(SCHEMA_VERSION_MAJOR as VARCHAR(10)),'.'), CAST(SCHEMA_VERSION_MINOR AS VARCHAR(10))) AS CATALOGUE_VERSION FROM CTA_CATALOGUE;
+CREATE TABLE FILE_RECYCLE_LOG(
+  FILE_RECYCLE_LOG_ID        NUMERIC(20, 0)          CONSTRAINT FILE_RECYCLE_LOG_ID_NN NOT NULL,
+  VID                        VARCHAR2(100)        CONSTRAINT FILE_RECYCLE_LOG_VID_NN NOT NULL,
+  FSEQ                       NUMERIC(20, 0)          CONSTRAINT FILE_RECYCLE_LOG_FSEQ_NN NOT NULL,
+  BLOCK_ID                   NUMERIC(20, 0)          CONSTRAINT FILE_RECYCLE_LOG_BID_NN NOT NULL,
+  LOGICAL_SIZE_IN_BYTES      NUMERIC(20, 0)          CONSTRAINT FILE_RECYCLE_LOG_LSIB_NN NOT NULL,
+  COPY_NB                    NUMERIC(3, 0)           CONSTRAINT FILE_RECYCLE_LOG_COPY_NB_NN NOT NULL,
+  TAPE_FILE_CREATION_TIME    NUMERIC(20, 0)          CONSTRAINT FILE_RECYCLE_LOG_TFCT_NN NOT NULL,
+  ARCHIVE_FILE_ID            NUMERIC(20, 0)          CONSTRAINT FILE_RECYCLE_LOG_AFI_NN NOT NULL,
+  DISK_INSTANCE_NAME         VARCHAR2(100)        CONSTRAINT FILE_RECYCLE_LOG_DIN_NN NOT NULL,
+  DISK_FILE_ID               VARCHAR2(100)        CONSTRAINT FILE_RECYCLE_LOG_DFI_NN NOT NULL,
+  DISK_FILE_ID_WHEN_DELETED  VARCHAR2(100)        CONSTRAINT FILE_RECYCLE_LOG_DFIWD_NN NOT NULL,
+  DISK_FILE_UID              NUMERIC(20, 0)          CONSTRAINT FILE_RECYCLE_LOG_DFU_NN NOT NULL,
+  DISK_FILE_GID              NUMERIC(20, 0)          CONSTRAINT FILE_RECYCLE_LOG_DFG_NN NOT NULL,
+  SIZE_IN_BYTES              NUMERIC(20, 0)          CONSTRAINT FILE_RECYCLE_LOG_SIB_NN NOT NULL,
+  CHECKSUM_BLOB              RAW(200),
+  CHECKSUM_ADLER32           NUMERIC(10, 0)          CONSTRAINT FILE_RECYCLE_LOG_CA_NN NOT NULL,
+  STORAGE_CLASS_ID           NUMERIC(20, 0)          CONSTRAINT FILE_RECYCLE_LOG_SCI_NN NOT NULL,
+  ARCHIVE_FILE_CREATION_TIME NUMERIC(20, 0)          CONSTRAINT FILE_RECYLE_LOG_CT_NN NOT NULL,
+  RECONCILIATION_TIME        NUMERIC(20, 0)          CONSTRAINT FILE_RECYCLE_LOG_RT_NN NOT NULL,
+  COLLOCATION_HINT           VARCHAR2(100),
+  DISK_FILE_PATH             VARCHAR2(2000),
+  REASON_LOG                 VARCHAR2(1000)       CONSTRAINT FILE_RECYCLE_LOG_RL_NN NOT NULL, 
+  RECYCLE_LOG_TIME           NUMERIC(20, 0)          CONSTRAINT FILE_RECYCLE_LOG_RLT_NN NOT NULL,
+  CONSTRAINT FILE_RECYCLE_LOG_PK PRIMARY KEY(FILE_RECYCLE_LOG_ID),
+  CONSTRAINT FILE_RECYCLE_LOG_VID_FK FOREIGN KEY(VID) REFERENCES TAPE(VID),
+  CONSTRAINT FILE_RECYCLE_LOG_SC_FK FOREIGN KEY(STORAGE_CLASS_ID) REFERENCES STORAGE_CLASS(STORAGE_CLASS_ID)
+);
+--rollback DROP TABLE FILE_RECYCLE_LOG;
+
+--changeset ccaffy:4 failOnError:true dbms:oracle
+--preconditions onFail:HALT onError:HALT
+--precondition-sql-check expectedResult:"3.1" SELECT CONCAT(CONCAT(CAST(SCHEMA_VERSION_MAJOR as VARCHAR(10)),'.'), CAST(SCHEMA_VERSION_MINOR AS VARCHAR(10))) AS CATALOGUE_VERSION FROM CTA_CATALOGUE;
+CREATE INDEX FILE_RECYCLE_LOG_DFI_IDX ON FILE_RECYCLE_LOG(DISK_FILE_ID);
+--rollback DROP INDEX FILE_RECYCLE_LOG_DFI_IDX;
+
+--changeset ccaffy:5 failOnError:true dbms:oracle
+--preconditions onFail:HALT onError:HALT
+--precondition-sql-check expectedResult:"3.1" SELECT CONCAT(CONCAT(CAST(SCHEMA_VERSION_MAJOR as VARCHAR(10)),'.'), CAST(SCHEMA_VERSION_MINOR AS VARCHAR(10))) AS CATALOGUE_VERSION FROM CTA_CATALOGUE;
+INSERT INTO FILE_RECYCLE_LOG (
+  FILE_RECYCLE_LOG_ID,
+  VID,
+  FSEQ,
+  BLOCK_ID,
+  LOGICAL_SIZE_IN_BYTES,
+  COPY_NB,
+  TAPE_FILE_CREATION_TIME,
+  ARCHIVE_FILE_ID,
+  DISK_INSTANCE_NAME,
+  DISK_FILE_ID,
+  DISK_FILE_ID_WHEN_DELETED,
+  DISK_FILE_UID,
+  DISK_FILE_GID,
+  SIZE_IN_BYTES,
+  CHECKSUM_BLOB,
+  CHECKSUM_ADLER32,
+  STORAGE_CLASS_ID,
+  ARCHIVE_FILE_CREATION_TIME,
+  RECONCILIATION_TIME,
+  COLLOCATION_HINT,
+  REASON_LOG, 
+  RECYCLE_LOG_TIME
+) SELECT
+    FILE_RECYCLE_LOG_ID_SEQ.NEXTVAL,
+    TAPE_FILE.VID,
+    TAPE_FILE.FSEQ,
+    TAPE_FILE.BLOCK_ID,
+    TAPE_FILE.LOGICAL_SIZE_IN_BYTES,
+    TAPE_FILE.COPY_NB,
+    TAPE_FILE.CREATION_TIME,
+    TAPE_FILE.ARCHIVE_FILE_ID,
+    ARCHIVE_FILE.DISK_INSTANCE_NAME,
+    ARCHIVE_FILE.DISK_FILE_ID,
+    ARCHIVE_FILE.DISK_FILE_ID,
+    ARCHIVE_FILE.DISK_FILE_UID,
+    ARCHIVE_FILE.DISK_FILE_GID,
+    ARCHIVE_FILE.SIZE_IN_BYTES,
+    ARCHIVE_FILE.CHECKSUM_BLOB,
+    ARCHIVE_FILE.CHECKSUM_ADLER32,
+    ARCHIVE_FILE.STORAGE_CLASS_ID,
+    ARCHIVE_FILE.CREATION_TIME,
+    ARCHIVE_FILE.RECONCILIATION_TIME,
+    ARCHIVE_FILE.COLLOCATION_HINT,
+    'REPACK',
+    (cast (systimestamp at time zone 'UTC' as date) - date '1970-01-01') * 86400
+  FROM
+    TAPE_FILE JOIN
+    ARCHIVE_FILE ON TAPE_FILE.ARCHIVE_FILE_ID = ARCHIVE_FILE.ARCHIVE_FILE_ID
+  WHERE TAPE_FILE.SUPERSEDED_BY_VID IS NOT NULL;
+
+--changeset ccaffy:6 failOnError:true dbms:oracle
+--preconditions onFail:HALT onError:HALT
+--precondition-sql-check expectedResult:"3.1" SELECT CONCAT(CONCAT(CAST(SCHEMA_VERSION_MAJOR as VARCHAR(10)),'.'), CAST(SCHEMA_VERSION_MINOR AS VARCHAR(10))) AS CATALOGUE_VERSION FROM CTA_CATALOGUE;
+DELETE FROM TAPE_FILE WHERE SUPERSEDED_BY_VID IS NOT NULL;
+
+--changeset ccaffy:7 failOnError:true dbms:oracle
+--preconditions onFail:HALT onError:HALT
+--precondition-sql-check expectedResult:"3.1" SELECT CONCAT(CONCAT(CAST(SCHEMA_VERSION_MAJOR as VARCHAR(10)),'.'), CAST(SCHEMA_VERSION_MINOR AS VARCHAR(10))) AS CATALOGUE_VERSION FROM CTA_CATALOGUE;
+INSERT INTO FILE_RECYCLE_LOG (
+  FILE_RECYCLE_LOG_ID,
+  VID,
+  FSEQ,
+  BLOCK_ID,
+  LOGICAL_SIZE_IN_BYTES,
+  COPY_NB,
+  TAPE_FILE_CREATION_TIME,
+  ARCHIVE_FILE_ID,
+  DISK_INSTANCE_NAME,
+  DISK_FILE_ID,
+  DISK_FILE_ID_WHEN_DELETED,
+  DISK_FILE_UID,
+  DISK_FILE_GID,
+  SIZE_IN_BYTES,
+  CHECKSUM_BLOB,
+  CHECKSUM_ADLER32,
+  STORAGE_CLASS_ID,
+  ARCHIVE_FILE_CREATION_TIME,
+  RECONCILIATION_TIME,
+  COLLOCATION_HINT,
+  DISK_FILE_PATH,
+  REASON_LOG, 
+  RECYCLE_LOG_TIME
+) SELECT
+    FILE_RECYCLE_LOG_ID_SEQ.NEXTVAL,
+    TAPE_FILE_RECYCLE_BIN.VID,
+    TAPE_FILE_RECYCLE_BIN.FSEQ,
+    TAPE_FILE_RECYCLE_BIN.BLOCK_ID,
+    TAPE_FILE_RECYCLE_BIN.LOGICAL_SIZE_IN_BYTES,
+    TAPE_FILE_RECYCLE_BIN.COPY_NB,
+    TAPE_FILE_RECYCLE_BIN.CREATION_TIME,
+    TAPE_FILE_RECYCLE_BIN.ARCHIVE_FILE_ID,
+    ARCHIVE_FILE_RECYCLE_BIN.DISK_INSTANCE_NAME,
+    ARCHIVE_FILE_RECYCLE_BIN.DISK_FILE_ID,
+    ARCHIVE_FILE_RECYCLE_BIN.DISK_FILE_ID_WHEN_DELETED,
+    ARCHIVE_FILE_RECYCLE_BIN.DISK_FILE_UID,
+    ARCHIVE_FILE_RECYCLE_BIN.DISK_FILE_GID,
+    ARCHIVE_FILE_RECYCLE_BIN.SIZE_IN_BYTES,
+    ARCHIVE_FILE_RECYCLE_BIN.CHECKSUM_BLOB,
+    ARCHIVE_FILE_RECYCLE_BIN.CHECKSUM_ADLER32,
+    ARCHIVE_FILE_RECYCLE_BIN.STORAGE_CLASS_ID,
+    ARCHIVE_FILE_RECYCLE_BIN.CREATION_TIME,
+    ARCHIVE_FILE_RECYCLE_BIN.RECONCILIATION_TIME,
+    ARCHIVE_FILE_RECYCLE_BIN.COLLOCATION_HINT,
+    ARCHIVE_FILE_RECYCLE_BIN.DISK_FILE_PATH,
+    'Deleted file imported from the old recycle-bin',
+    ARCHIVE_FILE_RECYCLE_BIN.DELETION_TIME
+  FROM
+    TAPE_FILE_RECYCLE_BIN JOIN
+    ARCHIVE_FILE_RECYCLE_BIN ON TAPE_FILE_RECYCLE_BIN.ARCHIVE_FILE_ID = ARCHIVE_FILE_RECYCLE_BIN.ARCHIVE_FILE_ID;
+
+--changeset ccaffy:8 failOnError:true dbms:oracle
+--preconditions onFail:HALT onError:HALT
+--precondition-sql-check expectedResult:"3.1" SELECT CONCAT(CONCAT(CAST(SCHEMA_VERSION_MAJOR as VARCHAR(10)),'.'), CAST(SCHEMA_VERSION_MINOR AS VARCHAR(10))) AS CATALOGUE_VERSION FROM CTA_CATALOGUE;
+DELETE FROM TAPE_FILE_RECYCLE_BIN;
+
+--changeset ccaffy:9 failOnError:true dbms:oracle
+--preconditions onFail:HALT onError:HALT
+--precondition-sql-check expectedResult:"3.1" SELECT CONCAT(CONCAT(CAST(SCHEMA_VERSION_MAJOR as VARCHAR(10)),'.'), CAST(SCHEMA_VERSION_MINOR AS VARCHAR(10))) AS CATALOGUE_VERSION FROM CTA_CATALOGUE;
+DELETE FROM ARCHIVE_FILE_RECYCLE_BIN;
+
+--changeset ccaffy:10 failOnError:true dbms:oracle
+--preconditions onFail:HALT onError:HALT
+--precondition-sql-check expectedResult:"3.1" SELECT CONCAT(CONCAT(CAST(SCHEMA_VERSION_MAJOR as VARCHAR(10)),'.'), CAST(SCHEMA_VERSION_MINOR AS VARCHAR(10))) AS CATALOGUE_VERSION FROM CTA_CATALOGUE;
+UPDATE CTA_CATALOGUE SET STATUS='PRODUCTION';
+UPDATE CTA_CATALOGUE SET SCHEMA_VERSION_MAJOR=3;
+UPDATE CTA_CATALOGUE SET SCHEMA_VERSION_MINOR=2;
+UPDATE CTA_CATALOGUE SET NEXT_SCHEMA_VERSION_MAJOR=NULL;
+UPDATE CTA_CATALOGUE SET NEXT_SCHEMA_VERSION_MINOR=NULL;
+--rollback UPDATE CTA_CATALOGUE SET STATUS='UPGRADING';
+--rollback UPDATE CTA_CATALOGUE SET SCHEMA_VERSION_MAJOR=3;
+--rollback UPDATE CTA_CATALOGUE SET SCHEMA_VERSION_MINOR=1;
+--rollback UPDATE CTA_CATALOGUE SET NEXT_SCHEMA_VERSION_MAJOR=3;
+--rollback UPDATE CTA_CATALOGUE SET NEXT_SCHEMA_VERSION_MINOR=2;