在資料遷移期間oracle學習筆記

0主鍵（自增） 1使用者程式碼 2區域程式碼 3承保公司程式碼 4理賠編碼 5投保確認碼 6案件狀態 7案件進展 8重開案件進展 9轉換後案件狀態

需求分析：
1、根據上述要求建立需要的表
2、將幾個表中的相應資料對應插入到新建立的表中
3、因為claim_id是固定的，可以根據claim_id進行迴圈插入幾個表中的資料
4、在7、8項中涉及到案件狀態的去重和拼接
5、案件狀態的轉換

--建立表T_CLAIM_NEW
create table T_CLAIM_NEW(
    ID NUMBER
 
,                  --主鍵ID
    ClaimId number(10),
    UserCode varchar2(30),      --使用者名稱稱
    AreaCode varchar2(10),      --地區程式碼
    CompanyCode varchar2(8),    --公司程式碼
    ClaimQueryNo varchar2(50),  --理賠編碼
    PolicyConfirmNo varchar2(50), --投保確認碼
    CLAIM_STATUS varchar2(2),       --案件狀態
    G_CLAIM_STATUS varchar2(30
 
),        --案件進展
    REOPEN_CLAIM_STATUS varchar2(30), --重開後的案件進展
    IA_CLAIM_STATUS varchar2(30),       --轉換後的案件狀態
    CONSTRAINT PK_ID PRIMARY KEY (ID)
);

--自增序列
CREATE SEQUENCE T_CLAIM_NEW_ID1
    INCREMENT BY 1      --每次+1
    START WITH 1            --從1開始
    NOMAXVALUE              --不設定最大值
    NOCYCLE                     
    NOCACHE;
 


--建立觸發器
CREATE OR REPLACE TRIGGER TRI_T_CLAIM_NEW_ID1
    BEFORE INSERT 
    ON T_CLAIM_NEW
    FOR EACH ROW 
    begin
    select T_CLAIM_NEW_ID1.nextval INTO :NEW.ID from dual; 
end;
/

************************************************************************************************************************************************

--去重：                                                                                                                                                 
--建立臨時表                                                                                                                                             
create table ma_20180709 as (select * from T_CLAIM_LIST_RECORD);                                                                                    
--刪除重複資料並保留最大時間（因為最後一次更新時間也是id越大時間越大）                                                                                                                                    
delete from  ma_20180709 where RECORD_ID not in (select max(RECORD_ID) from ma_20180709 group by claim_id,claim_code);
************************************************************************************************************************************************                                                                                                         
--查詢表ma_20180709中相應資料並拼接claim_status欄位                                                                                                              
--insert into tablename                                                                                                                             
select  listagg(claim_status,',') within group(order by CLAIM_STATUS) from ma_20180709 group by claim_id,claim_code;    



************************************************************************************************************************************************
--對軌跡表進行去重等操作
--建立ma_01臨時表
create table ma_01 as (select * from T_CLAIM_LIST_RECORD);
--去重
delete from ma_01 where RECORD_ID not in (select max(RECORD_ID) from ma_01 group by claim_id,claim_code);

--對重開軌跡表進行去重等操作
--建立ma_03臨時表
create table ma_03 as (select * from T_CLAIM_LIST_RECORD_REOPEN);
--去重
delete from ma_03 where RECORD_ID not in (select max(RECORD_ID) from ma_03 group by claim_id,claim_code);


--建立主表T_CLAIM_LIST的臨時表ma_02
create table ma_02 as (select * from T_CLAIM_LIST);
************************************************************************************************************************************************

--函式入口
declare

--宣告投保確認碼
CONFIRM_SEQUENCE varchar(50);
--宣告案件狀態
claim_status_bj varchar2(30);
--宣告案件進展（拼接後案件狀態）
claim_status_pj varchar2(30);
--宣告重開後案件狀態
claim_status_ck varchar2(30);
--宣告遊標
cursor TAGENTMENUd is select * from t_claim_list_record where 1=1;

begin
for claim in TAGENTMENUd LOOP

    --查詢出claim_id相等的案件狀態並賦值給變數claim_status_bj
    select CLAIM_STATUS into claim_status_bj from ma_01 where claim_id = claim.claim_id;
    --查詢出claim_id相等的案件狀態並賦值給變數CONFIRM_SEQUENCE
    select CONFIRM_SEQUENCE_NO into CONFIRM_SEQUENCE from ma_02 where claim_id=claim.claim_id;
    --拼接去重後軌跡表ma_01中的案件狀態並根據claim_id賦值給變數claim_status_pj
    select listagg(claim_status,',') within group(order by CLAIM_STATUS) into claim_status_pj from ma_01 where claim_id=claim.claim_id;
    --拼接去重後重開軌跡表ma_03中的案件狀態，並根據claim_id賦值給變數claim_starus_ck
    select listagg(claim_status,',') within group(order by CLAIM_STATUS) into claim_starus_ck from ma_03 where claim_id=claim.claim_id;
    --將拼接後的案件狀態進行對應轉換

      --插入操作  
        insert into T_CLAIM_NEW(ClaimId,AreaCode,ClaimQueryNo,POLICYCONFIRMNO,CLAIM_STATUS,G_CLAIM_STATUS,REOPEN_CLAIM_STATUS) 
            values(claim.claim_id,'110000',claim.claim_code,CONFIRM_SEQUENCE,claim_status_bj,claim_status_pj,claim_starus_ck);

END LOOP;
end;
/                                                                                                               
************************************************************************************************************************************************    
注意點：
1、在函式建立過程中遇到變數問題，想要給查詢出來的東西賦值，賦值語法為：
    'select 欄位名（公式） into 變數名 from tablename where 條件語句'

2、函式中的迴圈   如上述所示
for '變數' in '範圍/結果集' loop