缓慢变化思想3

vv_task_pos := 'insert into t_e_fsi_link_mid all ';

insert /*+ append */

into LBI_EDM_VDF.t_e_fsi_link_mid

(customer_id,

link_type_id,

biz_org_id,

fsi_core_product_id,

status,

first_active_time,

has_read_condition,

link_account_id,

modify_time,

version,

last_change_date,

fsi_link_pk ,

customer_status,

STATUS_CHANGE_TIME

)

select /*+ parallel(link_o,4) */

-- distinct

link_o.customer_id,

link_o.link_type_id,

link_o.biz_org_id,

link_o.fsi_core_product_id,

link_o.status,

link_o.first_active_time,

link_o.has_read_condition,

link_o.link_account_id,

link_o.modify_time,

0, --version ,

link_o.load_data_ts,

link_o.customer_id|| link_o.biz_org_id || link_o.fsi_core_product_id || link_o.first_active_time ||to_char(link_o.load_data_ts, 'yyyymmddhh24miss'), --fsi_link_pk ,

cust.status,

CUST.STATUS_CHANGE_TIME

from LBI_ODS_VDF.t_o_fsi_link link_o --1

left join

LBI_ODS_VDF.t_o_Customer cust

on link_o.customer_id=cust.customer_id

where (link_o.load_data_ts >= start_date and

link_o.load_data_ts < end_date);



commit;