本随笔文章，由个人博客（鸟不拉屎）转移至博客园
发布时间： 2018 年 12 月 20 日
原地址：https://niaobulashi.com/archives/oracle-procedures-dynamicsql-update.html

花了我一下午时间，外加晚上加班
终于把存储过程的主要功能给写出来了！！！
emmmmm，做个笔记
后面有时间就细细分析下，先把代码贴一下。

create or replace procedure P_SYNC_TA_PRODUCT_TEST(v_res           OUT NUMBER,v_errorCode     OUT NVARCHAR2,v_errorMsg      OUT NVARCHAR2,d_dateStartDate IN NVARCHAR2,d_dateEndDate   IN NVARCHAR2) IS--查询是否存在已经同步的TA产品信息的个数v_count_updatePolling number(8) := 0;--收益率ID自动生成序列v_yieldRateId NVARCHAR2(36);--受益级别表的产品代码v_productCode varchar2(36);--受益级别表的受益级别v_yieldLevelCode NVARCHAR2(10);--受益级别表的预期年化收益率v_yieldRate NVARCHAR2(20);v_yieldRateStr NVARCHAR2(20);--受益级别表的投资区间（开始）v_investmentIntervalS NVARCHAR2(20);v_investmentIntervalSStr NVARCHAR2(20);--受益级别表的投资区间（结束）v_investmentIntervalD NVARCHAR2(20);v_investmentIntervalDStr NVARCHAR2(20);--受益级别表的投资期限v_dueTime NVARCHAR2(20);--受益级别表的投资期限单位v_dueTimeUnit NVARCHAR2(2);--受益级别表的年化计算天数v_annualDays NVARCHAR2(5);--拼接的SQL语句v_confirmSql varchar2(600);v_confirmCommaSql varchar2(600);v_updateYieldRateSql varchar2(700);--用于判断是否新增或更新/*v_total_pro number(8) := 0;--游标tfundInfos的个数v_total number(8) := 0;--入池产品IDv_pollingProductId NVARCHAR2(36);--用于判断产品表是否存在该产品v_count_pollingProduct number(8) := 0;--用于判断是否存在已入池且当日改动的产品v_count_polling number(8) := 0;--用于判断TA是否存在受益级别信息v_count_productRateYiled number(8) := 0;*/--1.定义游标：查询出产品名称、成立日、预计到期日其中和TA不一致的产品信息CURSOR updateProductInfos ISselect t.c_fundcode as fundCode, --产品代码t.c_fundname as fundName, --产品名称（TA）to_char(t.d_setupdate, 'yyyy-MM-dd') as setupDateStr, --成立日（TA）to_char(t.d_contractenddate, 'yyyy-MM-dd') as contractendDateStr --预计到期日期（TA）from tfundinfo@HSTA tinner join t_polling_product tppon tpp.c_product_code = t.c_fundcodeand tpp.delete_flag = '0'where 1 = 1and to_char(t.d_lastmodifydate, 'yyyy-MM-dd') >=to_char(to_date(d_dateStartDate, 'yyyy-MM-dd'), 'yyyy-MM-dd')and to_char(t.d_lastmodifydate, 'yyyy-MM-dd') <=to_char(to_date(d_dateEndDate, 'yyyy-MM-dd'), 'yyyy-MM-dd')and t.c_fundstatus <> '6'and (t.c_fundname <> tpp.c_product_nameor to_char(t.d_setupdate, 'yyyy-MM-dd') <> to_char(tpp.c_found_date, 'yyyy-MM-dd')or to_char(t.d_contractenddate, 'yyyy-MM-dd') <> to_char(tpp.c_end_date, 'yyyy-MM-dd'));--排除已经结束的产品，0-募集期，1-正常，6-已结束--2.定义游标：核对受益级别数据后更新或新增家族信托产品受益级别CURSOR margeProductYieldRates ISselect t.c_fundcode AS fundCode, --产品代码tp.c_profitclass AS profitClass, --收益级别tp.f_profit*100 AS profit, --从TA获取的收益率需要乘以100tp.f_amountmin AS amountMin, --投资下限（含）tp.f_amountmax AS amountMax, --投资上限（不含）tp.c_durationtime AS durationTime, --投资期限case tp.c_durationtimeunitwhen '0' then 'Y'  --年when '1' then 'M'  --月when '2' then 'D'  --日else ''end as durationTimeUnit, --期限单位case tp.c_bonusfrequencywhen '0' then '04'when '1' then '04'when '2' then '04'when '3' then '04'when '4' then '04'when '5' then '04' --特定周期when '6' then '02' --到期一次性清算when '7' then '03' --不定期else ''end as bonusFrequencyType, --分配频率类型case tp.c_bonusfrequencywhen '2' then 'M' --每月when '3' then 'Q' --每季度when '4' then 'H' --每半年when '5' then 'Y' --每年else ''end as bonusFrequency, --分配频率_特定tp.l_incomeyeardays as incomeYearDays, --年化天数NVL(to_char(t.d_setupdate, 'yyyy-MM-dd'),to_char(sysdate, 'yyyy-MM-dd')) AS yieldStartDateStr --有效开始日期from tfundinfo@HSTA tinner join ttrustfundprofit@HSTA tpon tp.c_fundcode = t.c_fundcodewhere 1 = 1and to_char(t.d_lastmodifydate, 'yyyy-MM-dd') >=to_char(to_date(d_dateStartDate, 'yyyy-MM-dd'), 'yyyy-MM-dd')and to_char(t.d_lastmodifydate, 'yyyy-MM-dd') <=to_char(to_date(d_dateEndDate, 'yyyy-MM-dd'), 'yyyy-MM-dd')and t.c_fundstatus <> '6' and t.c_fundcode in ('CA0FX6','CA0FUC'); --排除已经结束的产品，0-募集期，1-正常，6-已结束begin--================================================================================-------------------------------【执行sql文】----------------------------------------================================================================================--开启日志输出缓冲DBMS_OUTPUT.ENABLE(buffer_size => null);DBMS_OUTPUT.put_line('----------------start------------------');--1.查询是否存在已经同步的TA产品信息select count(*)into v_count_updatePollingfrom tfundinfo@HSTA tinner join t_polling_product tppon tpp.c_product_code = t.c_fundcodewhere 1 = 1and to_char(t.d_lastmodifydate, 'yyyy-MM-dd') >=to_char(to_date(d_dateStartDate, 'yyyy-MM-dd'), 'yyyy-MM-dd')and to_char(t.d_lastmodifydate, 'yyyy-MM-dd') <=to_char(to_date(d_dateEndDate, 'yyyy-MM-dd'), 'yyyy-MM-dd')and t.c_fundstatus <> '6';     --排除已经结束的产品，0-募集期，1-正常，6-已结束--如果查询到存在if v_count_updatePolling > 0 then--1.1 调用游标：查询出产品名称、成立日、预计到期日其中和TA不一致的产品信息/*for updateProductInfo in updateProductInfos loop--非空判断，如果查询到的数据存在，表示，存在家族信托和TA不一致的产品信息，进行更新处理if updateProductInfo.Fundcode is not null then--查询存在说明存在和TA不一致的产品基本信息，则更新和TA一致update t_polling_product tset t.c_product_name       = updateProductInfo.Fundname,t.c_end_date           = to_date(updateProductInfo.Contractenddatestr, 'yyyy-MM-dd'),t.update_time          = sysdate,t.c_found_date         = to_date(updateProductInfo.Setupdatestr, 'yyyy-MM-dd')where t.c_product_code = updateProductInfo.Fundcode;end if;end loop;*/--1.2 调用游标：核对受益级别数据后更新或新增家族信托产品受益级别for margeProductYieldRate IN margeProductYieldRates loopif margeProductYieldRate.Fundcode is not null then/** 1.2.1* 查询TA中的受益级别，家族信托是否存在* 若存在，则表示家族和TA都存在该受益级别，进行核对比较关键信息，发现不同则更新* 若不存在，表示家族这边缺少TA的受益级别，需要从TA进行同步该受益级别*/select tpy.c_product_code,tpy.c_yield_level_code,tpy.c_yield_rate,tpy.c_investment_interval_s,tpy.c_investment_interval_d,tpy.c_due_time,tpy.c_due_time_unit,tpy.c_annual_daysinto v_productCode, --产品代码v_yieldLevelCode, --受益级别v_yieldRate, --预期收益率v_investmentIntervalS, --投资下限v_investmentIntervalD, --投资上限v_dueTime, --投资期限v_dueTimeUnit, --投资期限单位v_annualDays --年化天数from t_product_yield_rate tpywhere tpy.c_yield_level_code = margeProductYieldRate.Profitclassand tpy.c_product_code = margeProductYieldRate.Fundcodeand tpy.delete_flag = '0';--若存在，则表示家族和TA都存在该受益级别，进行核对比较关键信息，发现不同则更新IF v_productCode is not null then/** 将匹配的数据进行核对，发现关键字段不匹配的进行更新* 对受益级别的关键字段进行一一对比* 对比不一样的，进行拼接SQL*/dbms_output.put_line('开始拼接SQL，产品代码为：' || margeProductYieldRate.Fundcode||','||'受益级别为：'||margeProductYieldRate.Profitclass);--oracle  数据库 字段值为小于1的小数时，使用varchar2类型处理，会丢失小数点前面的0v_yieldRateStr := to_char(v_yieldRate, 'fm99999999990.00');v_investmentIntervalSStr := to_char(v_investmentIntervalS, 'fm99999999990.00');v_investmentIntervalDStr := to_char(v_investmentIntervalD, 'fm99999999990.00');dbms_output.put_line('1.收益率，family:' ||v_yieldRateStr||';'||'TA:'||to_char(margeProductYieldRate.Profit, 'fm99999999990.00'));-- 比较年化收益率if v_yieldRateStr is not null and margeProductYieldRate.Profit is not null thenif v_yieldRateStr <> to_char(margeProductYieldRate.Profit, 'fm99999999990.00') thenv_confirmSql := v_confirmSql||'t.c_yield_rate='||to_char(margeProductYieldRate.Profit, 'fm99999999990.00')||',';end if;elsif v_yieldRateStr is null and to_char(margeProductYieldRate.Profit, 'fm99999999990.00') is not null thenv_confirmSql := v_confirmSql||'t.c_yield_rate='||to_char(margeProductYieldRate.Profit, 'fm99999999990.00')||',';elsif v_yieldRateStr is not null and to_char(margeProductYieldRate.Profit, 'fm99999999990.00') is null thenv_confirmSql := v_confirmSql||'t.c_yield_rate=null,';end if;--比较投资上限（含）dbms_output.put_line('2.投资上限，family:' || v_investmentIntervalSStr||';'||'TA:'||to_char(margeProductYieldRate.Amountmin, 'fm99999999990.00'));if v_investmentIntervalSStr is not null and to_char(margeProductYieldRate.Amountmin, 'fm99999999990.00') is not null thenif v_investmentIntervalSStr <> to_char(margeProductYieldRate.Amountmin, 'fm99999999990.00') thenv_confirmSql := v_confirmSql||'t.c_investment_interval_s='||to_char(margeProductYieldRate.Amountmin, 'fm99999999990.00')||',';end if;elsif v_investmentIntervalSStr is null and to_char(margeProductYieldRate.Amountmin, 'fm99999999990.00') is not null thenv_confirmSql := v_confirmSql||'t.c_investment_interval_s='||to_char(margeProductYieldRate.Amountmin, 'fm99999999990.00')||',';elsif v_investmentIntervalSStr is not null and to_char(margeProductYieldRate.Amountmin, 'fm99999999990.00') is null thenv_confirmSql := v_confirmSql||'t.c_investment_interval_s=null,';end if;--比较投资下限（不含）          dbms_output.put_line('2.投资下限，family:' || v_investmentIntervalDStr||';'||'TA:'||to_char(margeProductYieldRate.Amountmax, 'fm99999999990.00'));if v_investmentIntervalDStr is not null and to_char(margeProductYieldRate.Amountmax, 'fm99999999990.00') is not null thenif v_investmentIntervalDStr <> to_char(margeProductYieldRate.Amountmax, 'fm99999999990.00') thenv_confirmSql := v_confirmSql||'t.c_investment_interval_d='||to_char(margeProductYieldRate.Amountmax, 'fm99999999990.00')||',';end if;elsif v_investmentIntervalDStr is null and to_char(margeProductYieldRate.Amountmax, 'fm99999999990.00') is not null thenv_confirmSql := v_confirmSql||'t.c_investment_interval_d='||to_char(margeProductYieldRate.Amountmax, 'fm99999999990.00')||',';elsif v_investmentIntervalDStr is not null and to_char(margeProductYieldRate.Amountmax, 'fm99999999990.00') is null thenv_confirmSql := v_confirmSql||'t.c_investment_interval_d=null,';end if;--比较投资期限dbms_output.put_line('3.投资期限，family:' || v_dueTime||';'||'TA:'||margeProductYieldRate.Durationtime);if v_dueTime is not null and margeProductYieldRate.Durationtime is not null thenif v_dueTime <> margeProductYieldRate.Durationtime thenv_confirmSql := v_confirmSql||'t.c_due_time='||margeProductYieldRate.Durationtime||',';end if;elsif v_dueTime is null and margeProductYieldRate.Durationtime is not null thenv_confirmSql := v_confirmSql||'t.c_due_time='||margeProductYieldRate.Durationtime||',';elsif v_dueTime is not null and margeProductYieldRate.Durationtime is null thenv_confirmSql := v_confirmSql||'t.c_due_time=null,';end if;--比较投资期限单位dbms_output.put_line('4.投资期限单位，family:' || v_dueTimeUnit||';'||'TA:'||margeProductYieldRate.Durationtimeunit);if v_dueTimeUnit is not null and margeProductYieldRate.Durationtimeunit is not null thenif v_dueTimeUnit <> margeProductYieldRate.Durationtimeunit thenv_confirmSql := v_confirmSql||'t.c_due_time_unit='||''''||margeProductYieldRate.Durationtimeunit||''''||',';end if;elsif v_dueTimeUnit is null and margeProductYieldRate.Durationtimeunit is not null thenv_confirmSql := v_confirmSql||'t.c_due_time_unit='||''''||margeProductYieldRate.Durationtimeunit||''''||',';elsif v_dueTimeUnit is not null and margeProductYieldRate.Durationtimeunit is null thenv_confirmSql := v_confirmSql||'t.c_due_time_unit=null,';end if;--比较年化计算天数dbms_output.put_line('5.年化计算天数，family:' || v_annualDays||';'||'TA:'||margeProductYieldRate.Incomeyeardays);if v_annualDays is not null and margeProductYieldRate.Incomeyeardays is not null thenif v_annualDays <> margeProductYieldRate.Incomeyeardays thenv_confirmSql := v_confirmSql||'t.c_annual_days'||''''||margeProductYieldRate.Incomeyeardays||''''||',';end if;elsif v_annualDays is null and margeProductYieldRate.Incomeyeardays is not null thenv_confirmSql := v_confirmSql||'t.c_annual_days='||''''||margeProductYieldRate.Incomeyeardays||''''||',';elsif v_annualDays is not null and margeProductYieldRate.Incomeyeardays is null thenv_confirmSql := v_confirmSql||'t.c_annual_days=null,';end if;--判断存在不一致的受益级别字段if v_confirmSql is not null then--将得到的拼接字符串，去掉最后的一个句号','select substr(v_confirmSql,1,length(v_confirmSql)-1) into v_confirmCommaSql from dual;v_updateYieldRateSql := 'update t_product_yield_rate t set '||v_confirmCommaSql||' where t.c_product_code=:1 and t.c_yield_level_code=:2';dbms_output.put_line('拼接的SQL为：' || v_updateYieldRateSql);--执行更新SQLexecute immediate v_updateYieldRateSql USING margeProductYieldRate.Fundcode, margeProductYieldRate.Profitclass;--本条记录处理完成，将v_confirmSql、v_confirmSqlCount清空准备下条处理v_confirmSql := '';v_confirmCommaSql := '';v_updateYieldRateSql := '';end if;--若不存在，表示家族这边缺少TA的受益级别，需要从TA进行同步该受益级别else--生成收益率ID主键的序列号select concat(to_char(sysdate, 'yyyyMMddHHmmss'),trunc(dbms_random.value(100000, 999999)))into v_yieldRateIdfrom dual;dbms_output.put_line('存在新增的受益级别，产品代码为：'||margeProductYieldRate.Fundcode||',受益级别为：'||margeProductYieldRate.Profitclass);--将该受益级别同步到家族信托中insert into T_PRODUCT_YIELD_RATE(T_PRODUCT_YIELD_RATE.C_YIELD_RATE_ID,T_PRODUCT_YIELD_RATE.C_PRODUCT_CODE,T_PRODUCT_YIELD_RATE.C_PRODUCT_MANAGER_CODE,T_PRODUCT_YIELD_RATE.C_INVESTMENT_INTERVAL_S,T_PRODUCT_YIELD_RATE.C_INVESTMENT_INTERVAL_D,T_PRODUCT_YIELD_RATE.C_YIELD_RATE,T_PRODUCT_YIELD_RATE.DELETE_FLAG,T_PRODUCT_YIELD_RATE.CREATE_USER_ID,T_PRODUCT_YIELD_RATE.CREATE_TIME,T_PRODUCT_YIELD_RATE.UPDATE_USER_ID,T_PRODUCT_YIELD_RATE.UPDATE_TIME,T_PRODUCT_YIELD_RATE.C_YIELD_START_DATE,T_PRODUCT_YIELD_RATE.C_YIELD_END_DATE,T_PRODUCT_YIELD_RATE.C_CHANGE_REASON,T_PRODUCT_YIELD_RATE.C_YIELD_LEVEL_CODE,T_PRODUCT_YIELD_RATE.C_ALLOCATION_TYPE,T_PRODUCT_YIELD_RATE.C_ALLOCATION_TYPE_SP,T_PRODUCT_YIELD_RATE.C_ALLOCATION_TYPE_MD,T_PRODUCT_YIELD_RATE.C_ANNUAL_DAYS,T_PRODUCT_YIELD_RATE.C_DUE_TIME,T_PRODUCT_YIELD_RATE.C_DUE_TIME_UNIT)values(v_yieldRateId,margeProductYieldRate.Fundcode,'0',margeProductYieldRate.Amountmin,margeProductYieldRate.Amountmax,margeProductYieldRate.Profit,'0','00000000000000000000',sysdate,'00000000000000000000',sysdate,to_date(margeProductYieldRate.Yieldstartdatestr, 'yyyy-MM-dd'),to_date('9999-12-31', 'yyyy-MM-dd'),'',margeProductYieldRate.Profitclass,margeProductYieldRate.Bonusfrequencytype,margeProductYieldRate.Bonusfrequency,'',margeProductYieldRate.Incomeyeardays,margeProductYieldRate.Durationtime,margeProductYieldRate.Durationtimeunit);end if;end if;end loop;end if;--输出放回状态信息v_res       := 0;v_errorCode := SQLCODE;v_errorMsg  := 'P_SYNC_TA_PRODUCT_TEST' || ':' || TO_CHAR(SQLERRM);DBMS_OUTPUT.put_line('----------------end------------------');--提交COMMIT;--异常处理EXCEPTIONWHEN OTHERS THENDBMS_OUTPUT.put_line('----------------error------------------');--事务回滚ROLLBACK;v_res       := -1;v_errorCode := SQLCODE;v_errorMsg  := 'P_SYNC_TA_PRODUCT_TEST' || ':' || TO_CHAR(SQLERRM);end P_SYNC_TA_PRODUCT_TEST;