Oracle 10g数据库游标的使用学习三（实践）

需求说明
S132877699668612为服务模板ID，每一个服务模板下面有多条服务模板配置数据，如下：
/config/cpf/bm_tp_service_cfg/data/S132877699668612_common_1
/config/cpf/bm_tp_service_cfg/data/S132877699668612_pipeline_1
/config/cpf/bm_tp_service_cfg/data/S132877699668612_M101_1

但是现在数据库中出现了一些服务模板下面的配置数据缺失，主要是缺失_common_1和_pipeline_1，现在需要手动用sql脚本去弥补缺失

-- Created on 2012/12/20 by ZHENGTIAN 
declare
  --服务模板ID
  srv_tp_id varchar2(256);
  --服务模板URI
  srv_tp_uri varchar2(256);
  --服务模板配置ID
  srv_tp_cfg_id varchar2(256);
  --服务模板配置URI
  srv_tp_cfg_uri varchar2(2000);
  --是否存在common标志位
  common_flag integer;
  --是否存在pipeline标志位
  pipeline_flag integer;
  
  --common和pipeline的初始化数据
  common_init_data varchar2(4000) := '<common_config><start_cmd></start_cmd><stop_cmd></stop_cmd><forced_stop_cmd></forced_stop_cmd><check_cmd></check_cmd><restart_cmd></restart_cmd><ts_classpath></ts_classpath><log><file_prefix></file_prefix><level>debug</level><show_io_log>true</show_io_log><log4j-configuration><appender><class>DailyRollingFileAppender</class><name>dailyrollingfile</name><param><name>maxfilesize</name><value></value></param><param><name>datepattern</name><value>yyyy-MM-dd</value></param><param><name>intervalmin</name><value></value></param><param><name>maxbackupindex</name><value></value></param><param><name>flush_immediately</name><value>true</value></param><param><name>file</name><value>$LOGPATH/aierr/</value></param><layout><class>SimpleLayout</class></layout><param><name>max</name><value></value></param></appender><root><priority><value>trace</value></priority><appender-ref><ref>dailyrollingfile</ref></appender-ref></root></log4j-configuration><path>$LOGPATH/</path></log></common_config>';
  pipeline_init_data varchar2(4000) := '<pipe_line><pipe_line_configs><sysinfo /></pipe_line_configs><pipe_line_id>1</pipe_line_id><pipe_line_name>ts</pipe_line_name><pipe_line_type>business</pipe_line_type></pipe_line>';
  
  --服务模板查询条件
  srv_tp_prefix varchar2(256) := '/config/cpf/bm_tp_service/data/';
  --查询数据库中所有的服务模板的URI
  cursor cursor_srv_tp_sel is select t.uri from cfg_runtime_data t where t.uri like srv_tp_prefix || '%';
  
   --服务模板配置查询条件
  srv_tp_cfg_prefix varchar2(256) := '/config/cpf/bm_tp_service_cfg/data/';
  srv_tp_cfg_sql varchar2(512);
  cursor_srv_tp_cfg_sel sys_refcursor;
  
begin
  --循环结果集
  for flow_tp in cursor_srv_tp_sel loop
    srv_tp_uri := flow_tp.uri;
    --dbms_output.put_line('uri:' || srv_tp_uri);
    srv_tp_id := substr(srv_tp_uri,length(srv_tp_prefix)+1,length(srv_tp_uri));
    --dbms_output.put_line(srv_tp_id);
    
    --组装查询服务模板配置的sql
    srv_tp_cfg_sql := 'select t.uri from cfg_runtime_data t where t.uri like ''' || srv_tp_cfg_prefix || srv_tp_id || '%''';
    --dbms_output.put_line(srv_tp_cfg_sql);
    
    --初始化标志位
    common_flag := 0;
    pipeline_flag := 0;
    
    --查询服务模板配置
    open cursor_srv_tp_cfg_sel for srv_tp_cfg_sql;
    loop fetch cursor_srv_tp_cfg_sel into srv_tp_cfg_uri;
       exit when cursor_srv_tp_cfg_sel%notfound;
       srv_tp_cfg_id := substr(srv_tp_cfg_uri,length(srv_tp_cfg_prefix)+length(srv_tp_id)+1,length(srv_tp_cfg_uri));
       --dbms_output.put_line(srv_tp_cfg_id);
       if srv_tp_cfg_id = '_common_1' then common_flag := 1;
       end if;
       if srv_tp_cfg_id = '_pipeline_1' then pipeline_flag := 1;
       end if;
    end loop;
    
    if common_flag = 1 
    then
       insert into cfg_runtime_data(uri, app_code, data, lastup_date, is_compress)
       values(srv_tp_cfg_prefix || srv_tp_id || '_common_1', 'clound', RAWTOHEX(common_init_data), sysdate, 0); 
    end if;
    
    if pipeline_flag = 1 
    then
       insert into cfg_runtime_data(uri, app_code, data, lastup_date, is_compress) 
       values(srv_tp_cfg_prefix || srv_tp_id || '_pipeline_1', 'clound', RAWTOHEX(pipeline_init_data),sysdate, 0);
    end if;

  end loop;
   --提交
  --commit;
  dbms_output.put_line('修改完成！');
  exception
    when others then DBMS_output.PUT_LINE(sqlerrm);
    
end;