feat: NULL変換関数のスキーマを共通に変更

This commit is contained in:
shimoda.m@nds-tyo.co.jp 2023-09-16 14:56:53 +09:00
parent 5c7489ebe5
commit c0604a9c8d
2 changed files with 158 additions and 157 deletions

View File

@ -125,49 +125,49 @@ class VjskReceiveFileMapper:
,dwh_upd_dt ,dwh_upd_dt
) )
SELECT SELECT
src05.convert_empty_to_null(t.rec_data) medaca_common.convert_empty_to_null(t.rec_data)
,src05.convert_empty_to_null(t.rec_whs_cd) ,medaca_common.convert_empty_to_null(t.rec_whs_cd)
,src05.convert_empty_to_null(t.rec_whs_sub_cd) ,medaca_common.convert_empty_to_null(t.rec_whs_sub_cd)
,src05.convert_empty_to_null(t.rec_whs_org_cd) ,medaca_common.convert_empty_to_null(t.rec_whs_org_cd)
,src05.convert_empty_to_null(t.rec_cust_cd) ,medaca_common.convert_empty_to_null(t.rec_cust_cd)
,src05.convert_empty_to_null(t.rec_comm_cd) ,medaca_common.convert_empty_to_null(t.rec_comm_cd)
,src05.convert_empty_to_null(t.rec_tran_kbn) ,medaca_common.convert_empty_to_null(t.rec_tran_kbn)
,src05.convert_empty_to_null(t.rev_hsdnymd_wrk) ,medaca_common.convert_empty_to_null(t.rev_hsdnymd_wrk)
,src05.convert_empty_to_null(t.rev_hsdnymd_srk) ,medaca_common.convert_empty_to_null(t.rev_hsdnymd_srk)
,src05.convert_empty_to_null(t.rec_urag_num) ,medaca_common.convert_empty_to_null(t.rec_urag_num)
,src05.convert_empty_to_null(t.rec_qty) ,medaca_common.convert_empty_to_null(t.rec_qty)
,src05.convert_empty_to_null(t.rec_nonyu_price) ,medaca_common.convert_empty_to_null(t.rec_nonyu_price)
,src05.convert_empty_to_null(t.rec_nonyu_amt) ,medaca_common.convert_empty_to_null(t.rec_nonyu_amt)
,src05.convert_empty_to_null(t.rec_comm_name) ,medaca_common.convert_empty_to_null(t.rec_comm_name)
,src05.convert_empty_to_null(t.rec_nonyu_fcl_name) ,medaca_common.convert_empty_to_null(t.rec_nonyu_fcl_name)
,src05.convert_empty_to_null(t.free_item) ,medaca_common.convert_empty_to_null(t.free_item)
,src05.convert_empty_to_null(t.rec_nonyu_fcl_addr) ,medaca_common.convert_empty_to_null(t.rec_nonyu_fcl_addr)
,src05.convert_empty_to_null(t.rec_nonyu_fcl_post) ,medaca_common.convert_empty_to_null(t.rec_nonyu_fcl_post)
,src05.convert_empty_to_null(t.rec_nonyu_fcl_tel) ,medaca_common.convert_empty_to_null(t.rec_nonyu_fcl_tel)
,src05.convert_empty_to_null(t.rec_bef_hsdn_ymd) ,medaca_common.convert_empty_to_null(t.rec_bef_hsdn_ymd)
,src05.convert_empty_to_null(t.rec_bef_slip_num) ,medaca_common.convert_empty_to_null(t.rec_bef_slip_num)
,src05.convert_empty_to_null(t.rec_ymd) ,medaca_common.convert_empty_to_null(t.rec_ymd)
,src05.convert_empty_to_null(t.sale_data_cat) ,medaca_common.convert_empty_to_null(t.sale_data_cat)
,src05.convert_empty_to_null(t.slip_file_name) ,medaca_common.convert_empty_to_null(t.slip_file_name)
,t.slip_mgt_num ,t.slip_mgt_num
,t.row_num ,t.row_num
,src05.convert_empty_to_null(t.hsdn_ymd) ,medaca_common.convert_empty_to_null(t.hsdn_ymd)
,src05.convert_empty_to_null(t.exec_dt) ,medaca_common.convert_empty_to_null(t.exec_dt)
,t.v_tran_cd ,t.v_tran_cd
,src05.convert_empty_to_null(t.tran_kbn_name) ,medaca_common.convert_empty_to_null(t.tran_kbn_name)
,src05.convert_empty_to_null(t.whs_org_cd) ,medaca_common.convert_empty_to_null(t.whs_org_cd)
,t.v_whsorg_cd ,t.v_whsorg_cd
,src05.convert_empty_to_null(t.whs_org_name) ,medaca_common.convert_empty_to_null(t.whs_org_name)
,src05.convert_empty_to_null(t.whs_org_kn) ,medaca_common.convert_empty_to_null(t.whs_org_kn)
,t.v_whs_cd ,t.v_whs_cd
,src05.convert_empty_to_null(t.whs_name) ,medaca_common.convert_empty_to_null(t.whs_name)
,src05.convert_empty_to_null(t.nonyu_fcl_cd) ,medaca_common.convert_empty_to_null(t.nonyu_fcl_cd)
,src05.convert_empty_to_null(t.v_inst_cd) ,medaca_common.convert_empty_to_null(t.v_inst_cd)
,src05.convert_empty_to_null(t.v_inst_kn) ,medaca_common.convert_empty_to_null(t.v_inst_kn)
,src05.convert_empty_to_null(t.v_inst_name) ,medaca_common.convert_empty_to_null(t.v_inst_name)
,src05.convert_empty_to_null(t.v_inst_addr) ,medaca_common.convert_empty_to_null(t.v_inst_addr)
,src05.convert_empty_to_null(t.comm_cd) ,medaca_common.convert_empty_to_null(t.comm_cd)
,src05.convert_empty_to_null(t.comm_name) ,medaca_common.convert_empty_to_null(t.comm_name)
,t.nonyu_qty ,t.nonyu_qty
,t.nonyu_price ,t.nonyu_price
,t.nonyu_amt ,t.nonyu_amt
@ -175,39 +175,39 @@ class VjskReceiveFileMapper:
,t.shikiri_amt ,t.shikiri_amt
,t.nhi_price ,t.nhi_price
,t.nhi_amt ,t.nhi_amt
,src05.convert_empty_to_null(t.whspos_err_kbn) ,medaca_common.convert_empty_to_null(t.whspos_err_kbn)
,src05.convert_empty_to_null(t.htdnymd_err_kbn) ,medaca_common.convert_empty_to_null(t.htdnymd_err_kbn)
,src05.convert_empty_to_null(t.prd_exis_kbn) ,medaca_common.convert_empty_to_null(t.prd_exis_kbn)
,src05.convert_empty_to_null(t.fcl_exis_kbn) ,medaca_common.convert_empty_to_null(t.fcl_exis_kbn)
,src05.convert_empty_to_null(t.bef_hsdn_ymd) ,medaca_common.convert_empty_to_null(t.bef_hsdn_ymd)
,src05.convert_empty_to_null(t.bef_slip_num) ,medaca_common.convert_empty_to_null(t.bef_slip_num)
,t.slip_org_kbn ,t.slip_org_kbn
,src05.convert_empty_to_null(t.err_flg1) ,medaca_common.convert_empty_to_null(t.err_flg1)
,src05.convert_empty_to_null(t.err_flg2) ,medaca_common.convert_empty_to_null(t.err_flg2)
,src05.convert_empty_to_null(t.err_flg3) ,medaca_common.convert_empty_to_null(t.err_flg3)
,src05.convert_empty_to_null(t.err_flg4) ,medaca_common.convert_empty_to_null(t.err_flg4)
,src05.convert_empty_to_null(t.err_flg5) ,medaca_common.convert_empty_to_null(t.err_flg5)
,src05.convert_empty_to_null(t.err_flg6) ,medaca_common.convert_empty_to_null(t.err_flg6)
,src05.convert_empty_to_null(t.err_flg7) ,medaca_common.convert_empty_to_null(t.err_flg7)
,src05.convert_empty_to_null(t.err_flg8) ,medaca_common.convert_empty_to_null(t.err_flg8)
,src05.convert_empty_to_null(t.err_flg9) ,medaca_common.convert_empty_to_null(t.err_flg9)
,src05.convert_empty_to_null(t.err_flg10) ,medaca_common.convert_empty_to_null(t.err_flg10)
,src05.convert_empty_to_null(t.err_flg11) ,medaca_common.convert_empty_to_null(t.err_flg11)
,src05.convert_empty_to_null(t.err_flg12) ,medaca_common.convert_empty_to_null(t.err_flg12)
,src05.convert_empty_to_null(t.err_flg13) ,medaca_common.convert_empty_to_null(t.err_flg13)
,src05.convert_empty_to_null(t.err_flg14) ,medaca_common.convert_empty_to_null(t.err_flg14)
,src05.convert_empty_to_null(t.err_flg15) ,medaca_common.convert_empty_to_null(t.err_flg15)
,src05.convert_empty_to_null(t.err_flg16) ,medaca_common.convert_empty_to_null(t.err_flg16)
,src05.convert_empty_to_null(t.err_flg17) ,medaca_common.convert_empty_to_null(t.err_flg17)
,src05.convert_empty_to_null(t.err_flg18) ,medaca_common.convert_empty_to_null(t.err_flg18)
,src05.convert_empty_to_null(t.err_flg19) ,medaca_common.convert_empty_to_null(t.err_flg19)
,src05.convert_empty_to_null(t.err_flg20) ,medaca_common.convert_empty_to_null(t.err_flg20)
,src05.convert_empty_to_null(t.kjyo_ym) ,medaca_common.convert_empty_to_null(t.kjyo_ym)
,src05.convert_empty_to_null(t.tksnbk_kbn) ,medaca_common.convert_empty_to_null(t.tksnbk_kbn)
,src05.convert_empty_to_null(t.fcl_exec_kbn) ,medaca_common.convert_empty_to_null(t.fcl_exec_kbn)
,src05.convert_empty_to_null(t.rec_sts_kbn) ,medaca_common.convert_empty_to_null(t.rec_sts_kbn)
,nullif(t.ins_dt, 0) -- 受領データがブランクだった場合にゼロ日付で取得されるので明示的にNULL値に変換する ,nullif(t.ins_dt, 0) -- 受領データがブランクだった場合にゼロ日付で取得されるので明示的にNULL値に変換する
,src05.convert_empty_to_null(t.ins_usr) ,medaca_common.convert_empty_to_null(t.ins_usr)
,SYSDATE() ,SYSDATE()
FROM org05.sales AS t FROM org05.sales AS t
ON DUPLICATE KEY UPDATE ON DUPLICATE KEY UPDATE
@ -1124,35 +1124,35 @@ class VjskReceiveFileMapper:
,dwh_upd_dt ,dwh_upd_dt
) )
SELECT SELECT
src05.convert_empty_to_null(t.rec_data) medaca_common.convert_empty_to_null(t.rec_data)
,src05.convert_empty_to_null(t.rec_whs_cd) ,medaca_common.convert_empty_to_null(t.rec_whs_cd)
,src05.convert_empty_to_null(t.rec_whs_sub_cd) ,medaca_common.convert_empty_to_null(t.rec_whs_sub_cd)
,src05.convert_empty_to_null(t.rec_sto_place) ,medaca_common.convert_empty_to_null(t.rec_sto_place)
,src05.convert_empty_to_null(t.rec_stock_ymd) ,medaca_common.convert_empty_to_null(t.rec_stock_ymd)
,src05.convert_empty_to_null(t.rec_comm_cd) ,medaca_common.convert_empty_to_null(t.rec_comm_cd)
,src05.convert_empty_to_null(t.rec_qty) ,medaca_common.convert_empty_to_null(t.rec_qty)
,src05.convert_empty_to_null(t.rec_stock_no_sign) ,medaca_common.convert_empty_to_null(t.rec_stock_no_sign)
,src05.convert_empty_to_null(t.rec_jan_cd) ,medaca_common.convert_empty_to_null(t.rec_jan_cd)
,src05.convert_empty_to_null(t.free_item) ,medaca_common.convert_empty_to_null(t.free_item)
,src05.convert_empty_to_null(t.rec_ymd) ,medaca_common.convert_empty_to_null(t.rec_ymd)
,src05.convert_empty_to_null(t.sale_data_cat) ,medaca_common.convert_empty_to_null(t.sale_data_cat)
,src05.convert_empty_to_null(t.slip_file_name) ,medaca_common.convert_empty_to_null(t.slip_file_name)
,t.slip_mgt_num ,t.slip_mgt_num
,t.row_num ,t.row_num
,src05.convert_empty_to_null(t.exec_dt) ,medaca_common.convert_empty_to_null(t.exec_dt)
,src05.convert_empty_to_null(t.err_flg1) ,medaca_common.convert_empty_to_null(t.err_flg1)
,src05.convert_empty_to_null(t.err_flg2) ,medaca_common.convert_empty_to_null(t.err_flg2)
,src05.convert_empty_to_null(t.err_flg3) ,medaca_common.convert_empty_to_null(t.err_flg3)
,src05.convert_empty_to_null(t.err_flg4) ,medaca_common.convert_empty_to_null(t.err_flg4)
,src05.convert_empty_to_null(t.err_flg5) ,medaca_common.convert_empty_to_null(t.err_flg5)
,src05.convert_empty_to_null(t.err_flg6) ,medaca_common.convert_empty_to_null(t.err_flg6)
,src05.convert_empty_to_null(t.err_flg7) ,medaca_common.convert_empty_to_null(t.err_flg7)
,src05.convert_empty_to_null(t.err_flg8) ,medaca_common.convert_empty_to_null(t.err_flg8)
,src05.convert_empty_to_null(t.err_flg9) ,medaca_common.convert_empty_to_null(t.err_flg9)
,src05.convert_empty_to_null(t.err_flg10) ,medaca_common.convert_empty_to_null(t.err_flg10)
,src05.convert_empty_to_null(t.rec_sts_kbn) ,medaca_common.convert_empty_to_null(t.rec_sts_kbn)
,nullif(t.ins_dt, 0) -- 受領データがブランクだった場合にゼロ日付で取得されるので明示的にNULL値に変換する ,nullif(t.ins_dt, 0) -- 受領データがブランクだった場合にゼロ日付で取得されるので明示的にNULL値に変換する
,src05.convert_empty_to_null(t.ins_usr) ,medaca_common.convert_empty_to_null(t.ins_usr)
,SYSDATE() ,SYSDATE()
FROM org05.whole_stock AS t FROM org05.whole_stock AS t
ON DUPLICATE KEY UPDATE ON DUPLICATE KEY UPDATE
@ -1281,41 +1281,41 @@ class VjskReceiveFileMapper:
,dwh_upd_dt ,dwh_upd_dt
) )
SELECT SELECT
src05.convert_empty_to_null(t.rec_data) medaca_common.convert_empty_to_null(t.rec_data)
,src05.convert_empty_to_null(t.rec_whs_cd) ,medaca_common.convert_empty_to_null(t.rec_whs_cd)
,src05.convert_empty_to_null(t.rec_whs_sub_cd) ,medaca_common.convert_empty_to_null(t.rec_whs_sub_cd)
,src05.convert_empty_to_null(t.rec_whs_org_cd) ,medaca_common.convert_empty_to_null(t.rec_whs_org_cd)
,src05.convert_empty_to_null(t.rec_cust_cd) ,medaca_common.convert_empty_to_null(t.rec_cust_cd)
,src05.convert_empty_to_null(t.rec_comm_cd) ,medaca_common.convert_empty_to_null(t.rec_comm_cd)
,src05.convert_empty_to_null(t.rec_tran_kbn) ,medaca_common.convert_empty_to_null(t.rec_tran_kbn)
,src05.convert_empty_to_null(t.rev_hsdnymd_wrk) ,medaca_common.convert_empty_to_null(t.rev_hsdnymd_wrk)
,src05.convert_empty_to_null(t.rev_hsdnymd_srk) ,medaca_common.convert_empty_to_null(t.rev_hsdnymd_srk)
,src05.convert_empty_to_null(t.rec_urag_num) ,medaca_common.convert_empty_to_null(t.rec_urag_num)
,src05.convert_empty_to_null(t.rec_comm_name) ,medaca_common.convert_empty_to_null(t.rec_comm_name)
,src05.convert_empty_to_null(t.rec_nonyu_fcl_name) ,medaca_common.convert_empty_to_null(t.rec_nonyu_fcl_name)
,src05.convert_empty_to_null(t.rec_nonyu_fcl_addr) ,medaca_common.convert_empty_to_null(t.rec_nonyu_fcl_addr)
,src05.convert_empty_to_null(t.rec_lot_num1) ,medaca_common.convert_empty_to_null(t.rec_lot_num1)
,src05.convert_empty_to_null(t.rec_qty1) ,medaca_common.convert_empty_to_null(t.rec_qty1)
,src05.convert_empty_to_null(t.rec_lot_num2) ,medaca_common.convert_empty_to_null(t.rec_lot_num2)
,src05.convert_empty_to_null(t.rec_qty2) ,medaca_common.convert_empty_to_null(t.rec_qty2)
,src05.convert_empty_to_null(t.rec_lot_num3) ,medaca_common.convert_empty_to_null(t.rec_lot_num3)
,src05.convert_empty_to_null(t.rec_qty3) ,medaca_common.convert_empty_to_null(t.rec_qty3)
,src05.convert_empty_to_null(t.rec_ymd) ,medaca_common.convert_empty_to_null(t.rec_ymd)
,src05.convert_empty_to_null(t.sale_data_cat) ,medaca_common.convert_empty_to_null(t.sale_data_cat)
,src05.convert_empty_to_null(t.slip_file_name) ,medaca_common.convert_empty_to_null(t.slip_file_name)
,t.slip_mgt_num ,t.slip_mgt_num
,t.row_num ,t.row_num
,src05.convert_empty_to_null(t.hsdn_ymd) ,medaca_common.convert_empty_to_null(t.hsdn_ymd)
,src05.convert_empty_to_null(t.exec_dt) ,medaca_common.convert_empty_to_null(t.exec_dt)
,t.v_tran_cd ,t.v_tran_cd
,src05.convert_empty_to_null(t.tran_kbn_name) ,medaca_common.convert_empty_to_null(t.tran_kbn_name)
,src05.convert_empty_to_null(t.whs_org_cd) ,medaca_common.convert_empty_to_null(t.whs_org_cd)
,t.v_whsorg_cd ,t.v_whsorg_cd
,src05.convert_empty_to_null(t.whs_org_name) ,medaca_common.convert_empty_to_null(t.whs_org_name)
,src05.convert_empty_to_null(t.whs_org_kn) ,medaca_common.convert_empty_to_null(t.whs_org_kn)
,t.v_whs_cd ,t.v_whs_cd
,src05.convert_empty_to_null(t.whs_name) ,medaca_common.convert_empty_to_null(t.whs_name)
,src05.convert_empty_to_null(t.nonyu_fcl_cd) ,medaca_common.convert_empty_to_null(t.nonyu_fcl_cd)
,nullif(t.v_inst_cd,'') ,nullif(t.v_inst_cd,'')
,nullif(t.v_inst_name,'') ,nullif(t.v_inst_name,'')
,nullif(t.v_inst_kn,'') ,nullif(t.v_inst_kn,'')
@ -1329,36 +1329,36 @@ class VjskReceiveFileMapper:
,t.qty2 ,t.qty2
,t.qty3 ,t.qty3
,t.slip_org_kbn ,t.slip_org_kbn
,src05.convert_empty_to_null(t.bef_slip_mgt_num) ,medaca_common.convert_empty_to_null(t.bef_slip_mgt_num)
,src05.convert_empty_to_null(t.whs_rep_comm_name) ,medaca_common.convert_empty_to_null(t.whs_rep_comm_name)
,src05.convert_empty_to_null(t.whs_rep_nonyu_fcl_name) ,medaca_common.convert_empty_to_null(t.whs_rep_nonyu_fcl_name)
,src05.convert_empty_to_null(t.whs_rep_nonyu_fcl_addr) ,medaca_common.convert_empty_to_null(t.whs_rep_nonyu_fcl_addr)
,src05.convert_empty_to_null(t.err_flg1) ,medaca_common.convert_empty_to_null(t.err_flg1)
,src05.convert_empty_to_null(t.err_flg2) ,medaca_common.convert_empty_to_null(t.err_flg2)
,src05.convert_empty_to_null(t.err_flg3) ,medaca_common.convert_empty_to_null(t.err_flg3)
,src05.convert_empty_to_null(t.err_flg4) ,medaca_common.convert_empty_to_null(t.err_flg4)
,src05.convert_empty_to_null(t.err_flg5) ,medaca_common.convert_empty_to_null(t.err_flg5)
,src05.convert_empty_to_null(t.err_flg6) ,medaca_common.convert_empty_to_null(t.err_flg6)
,src05.convert_empty_to_null(t.err_flg7) ,medaca_common.convert_empty_to_null(t.err_flg7)
,src05.convert_empty_to_null(t.err_flg8) ,medaca_common.convert_empty_to_null(t.err_flg8)
,src05.convert_empty_to_null(t.err_flg9) ,medaca_common.convert_empty_to_null(t.err_flg9)
,src05.convert_empty_to_null(t.err_flg10) ,medaca_common.convert_empty_to_null(t.err_flg10)
,src05.convert_empty_to_null(t.err_flg11) ,medaca_common.convert_empty_to_null(t.err_flg11)
,src05.convert_empty_to_null(t.err_flg12) ,medaca_common.convert_empty_to_null(t.err_flg12)
,src05.convert_empty_to_null(t.err_flg13) ,medaca_common.convert_empty_to_null(t.err_flg13)
,src05.convert_empty_to_null(t.err_flg14) ,medaca_common.convert_empty_to_null(t.err_flg14)
,src05.convert_empty_to_null(t.err_flg15) ,medaca_common.convert_empty_to_null(t.err_flg15)
,src05.convert_empty_to_null(t.err_flg16) ,medaca_common.convert_empty_to_null(t.err_flg16)
,src05.convert_empty_to_null(t.err_flg17) ,medaca_common.convert_empty_to_null(t.err_flg17)
,src05.convert_empty_to_null(t.err_flg18) ,medaca_common.convert_empty_to_null(t.err_flg18)
,src05.convert_empty_to_null(t.err_flg19) ,medaca_common.convert_empty_to_null(t.err_flg19)
,src05.convert_empty_to_null(t.err_flg20) ,medaca_common.convert_empty_to_null(t.err_flg20)
,src05.convert_empty_to_null(t.kjyo_ym) ,medaca_common.convert_empty_to_null(t.kjyo_ym)
,src05.convert_empty_to_null(t.tksnbk_kbn) ,medaca_common.convert_empty_to_null(t.tksnbk_kbn)
,src05.convert_empty_to_null(t.fcl_exec_kbn) ,medaca_common.convert_empty_to_null(t.fcl_exec_kbn)
,src05.convert_empty_to_null(t.rec_sts_kbn) ,medaca_common.convert_empty_to_null(t.rec_sts_kbn)
,nullif(t.ins_dt, 0) -- 受領データがブランクだった場合にゼロ日付で取得されるので明示的にNULL値に変換する ,nullif(t.ins_dt, 0) -- 受領データがブランクだった場合にゼロ日付で取得されるので明示的にNULL値に変換する
,src05.convert_empty_to_null(t.ins_usr) ,medaca_common.convert_empty_to_null(t.ins_usr)
,SYSDATE() ,SYSDATE()
FROM org05.bio_sales AS t FROM org05.bio_sales AS t
ON DUPLICATE KEY UPDATE ON DUPLICATE KEY UPDATE

View File

@ -1,7 +1,8 @@
-- A5M2で実行時に[SQL] - [スラッシュ(/)のみの行でSQLを区切る]に変えてから実行する -- A5M2で実行時に[SQL] - [スラッシュ(/)のみの行でSQLを区切る]に変えてから実行する
-- 空文字→NULL変換 -- 空文字をNULLに変換する
CREATE FUNCTION src05.convert_empty_to_null(column_value VARCHAR(500)) -- 半角スペースを含む値はそのまま返却される
RETURNS VARCHAR(500) DETERMINISTIC CREATE FUNCTION medaca_common.convert_empty_to_null(column_value TEXT)
RETURNS TEXT DETERMINISTIC
BEGIN BEGIN
RETURN ( RETURN (
CASE CASE