diff options
| author | chenjinsong <[email protected]> | 2018-09-27 16:21:05 +0800 |
|---|---|---|
| committer | chenjinsong <[email protected]> | 2018-09-27 16:21:05 +0800 |
| commit | dc91c4c9871c13a5237eb3fdaf9dd8ef5b1ab61b (patch) | |
| tree | c5e227244ec676e8d56d3b17b858b98310035089 /sql/sqlupdate(20140616-20140616)--grant-Dbms_lock.sql | |
initial commit
Diffstat (limited to 'sql/sqlupdate(20140616-20140616)--grant-Dbms_lock.sql')
| -rw-r--r-- | sql/sqlupdate(20140616-20140616)--grant-Dbms_lock.sql | 300 |
1 files changed, 300 insertions, 0 deletions
diff --git a/sql/sqlupdate(20140616-20140616)--grant-Dbms_lock.sql b/sql/sqlupdate(20140616-20140616)--grant-Dbms_lock.sql new file mode 100644 index 0000000..f2b6076 --- /dev/null +++ b/sql/sqlupdate(20140616-20140616)--grant-Dbms_lock.sql @@ -0,0 +1,300 @@ +--赋予用户执行dbma_lock的权限:需要sys或者dba才能赋予权限 +grant execute on dbms_lock to nms; + +--PRO_RECORD_LOG_INFO +create or replace procedure PRO_RECORD_LOG_INFO(log_table_name in VARCHAR2,id in number, proname in VARCHAR2, sequence in VARCHAR2,log_cont in VARCHAR2) +is + v_log_table_sql VARCHAR2(2000);----记录日志sql语句 + pragma autonomous_transaction; +begin + v_log_table_sql := 'INSERT INTO '||log_table_name||'(id,proname,sequence,log_cont) VALUES('||id||','''||proname||''','''||sequence||''','''||log_cont||''')'; + EXECUTE IMMEDIATE v_log_table_sql; + COMMIT; +end PRO_RECORD_LOG_INFO; +/ + +--pro_del_part_by_day +create or replace procedure pro_del_part_by_day(v_table_name IN VARCHAR2,v_par_sequence IN VARCHAR2,v_partition_name IN VARCHAR2) +Authid Current_User----使存储过程可以使用role权限 +AS +------------------------------------------------------------------------------------------------------------- + +--此过程的功能 +--每次执行可以自动自动删除分区,删除指定的表空间,(按天) +--当前版本:1. 0 +--作 者:hyx +--日 期:2013.11.01 +--- +------------------------------------------------------------------------------------------------------------- +--变量声明 + ----表空间名= 表空间名前缀 + 表名 + _ + 日期 + c_table_name_prefix CONSTANT VARCHAR2(100) :=''; ----表空间名前缀(注意:一定要大写) + c_log_table_name CONSTANT VARCHAR2(100) :='PRO_EXEC_LOG'; --日志记录在此表内 + c_cur_pro_name CONSTANT VARCHAR2(100) :='pro_del_part_by_day'; --当前存储过程的名称 +------------------------------------------------------------------------------------------------------------- + --v_log_table_sql VARCHAR2(2000);----记录日志sql语句 + v_del_partition_sql VARCHAR2(2000); --删除分区sql语句 + v_log_id NUMBER;--日志记录id + +------------------------------------------------------------------------------------------------------------- +BEGIN + + ---------------------------------------------------------- + + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,v_par_sequence||'3','3.删除'||v_table_name||'表分区 begin'); + + + ----删除指定表分区 + v_del_partition_sql := 'alter table '||v_table_name||' drop partition '||v_partition_name||' update indexes'; + + execute immediate v_del_partition_sql; + + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,v_par_sequence||'4','4.删除'||v_table_name||'表分区 end'); + + -------------------------- -------------------------------- + + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,v_par_sequence||'5','5.删除'||v_table_name||'表 表空间 begin'); + + + ----删除指定表空间 + execute immediate 'drop tablespace '||c_table_name_prefix||v_partition_name||' including contents and datafiles'; + + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,v_par_sequence||'6','6.删除'||v_table_name||'表 表空间 end'); + + + ---------------------------------------------------------- +EXCEPTION + --异常处理机制,记录相关的ora错误号以及相关异常信息 + WHEN OTHERS THEN + BEGIN + ROLLBACK; + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,'-1','error:'||SQLERRM); + + END; +END pro_del_part_by_day; +/ + +--PRO_DELTABSPACE +create or replace procedure PRO_DELTABSPACE(v_par_sequence IN VARCHAR2,v_cur_sql IN VARCHAR2) +Authid Current_User----使存储过程可以使用role权限 +is +-------------------------------------------------------------- +--可配置 + c_log_table_name CONSTANT VARCHAR2(100) :='PRO_EXEC_LOG'; --日志记录在此表内 + c_cur_pro_name CONSTANT VARCHAR2(100) :='PRO_DELTABSPACE'; --当前存储过程的名称 + +--变量 + v_table_name VARCHAR2(2000); --表名 + v_partition_name VARCHAR2(2000); --表分区名 + v_sequence_count NUMBER :=0; --此存储过程的步骤编号 + v_full_sequence VARCHAR2(100);--步骤编号全称 + --v_log_table_sql VARCHAR2(2000);----记录日志sql语句 + v_log_id NUMBER;--日志记录id +--游标 + type cur_type is ref cursor; + cur cur_type; + CT_COLUMNS user_tab_partitions%ROWTYPE;--定义CT_COLUMNS:表名%rowtype 或者游标名%rowtype +-------------------------------------------------------------- +BEGIN + OPEN cur for v_cur_sql; + + LOOP + v_sequence_count := v_sequence_count + 1; + FETCH cur INTO CT_COLUMNS; + EXIT WHEN cur%NOTFOUND; +-------------------------------------------------------------- + v_table_name :=CT_COLUMNS.table_name;--表名 + v_partition_name :=CT_COLUMNS.partition_name;--表分区名 + + v_full_sequence := v_par_sequence||v_sequence_count; + + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,v_full_sequence,v_sequence_count||'.删除'||v_table_name||'表指定的表空间和表分区 begin'); + + + --删除detection_info表指定的表空间和表分区 + pro_del_part_by_day(v_table_name,v_full_sequence||'_',v_partition_name); + + v_sequence_count := v_sequence_count + 1; + v_full_sequence := v_par_sequence||v_sequence_count; + + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,v_full_sequence,v_sequence_count||'.删除'||v_table_name||'表指定的表空间和表分区 end'); + +-------------------------------------------------------------- + END LOOP; + CLOSE cur; + EXCEPTION + --异常处理机制,记录相关的ora错误号以及相关异常信息 + WHEN OTHERS THEN + BEGIN + ROLLBACK; + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,'-1','error:'||SQLERRM); + END; +END PRO_DELTABSPACE; +/ + +--pro_driver_del_Partition +create or replace procedure pro_driver_del_Partition +Authid Current_User----使存储过程可以使用role权限 +is +------------- ---------------------------------------- +--可配置 + c_log_table_name CONSTANT VARCHAR2(100) :='PRO_EXEC_LOG'; --日志记录在此表内 +-- c_user_name CONSTANT VARCHAR2(100) :='NMS'; --用户名 + c_cur_pro_name CONSTANT VARCHAR2(100) :='pro_driver_del_Partition'; --当前存储过程的名称 + c_day CONSTANT NUMBER :=7;----指定删除多少天前那天的分区和表空间 + c_count CONSTANT NUMBER :=3;----尝试停用或恢复外键的最大次数(当插入数据时,停用或启用外键会报异常) + c_sleep_count CONSTANT NUMBER :=5;----两次尝试停用或启用外键的间隔时间,单位:秒 + +--- + v_del_date VARCHAR2(200);----需要删除分区的日期 + --v_log_table_sql VARCHAR2(2000);----记录日志sql语句 + v_cur_sql VARCHAR2(2000);----游标sql + space_sql VARCHAR2(2000);----sql语句变量 + v_table_name VARCHAR2(2000); --表名 + v_count NUMBER :=0; --记录已尝试停用或恢复外键的次数(当插入数据时,停用或启用外键会报异常) + v_log_id NUMBER;--日志记录id +----------------------------------------------------- +begin +------------------------------------------------------ + + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,'1','1.获取需要删除分区的日期 begin'); + + ----获取需要删除分区的日期--暂时未用到 + select to_char(sysdate-c_day,'yyyymmdd') into v_del_date from dual; + + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,'2','2.获取需要删除分区的日期:'||v_del_date||' end'); + +------------------------------------------------------ +--删除指定的表空间 +------------------------------------------------------ + + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,'3','3.删除动态表的表空间和分区 begin'); + + + --一、删除动态表的表空间和分区 + v_cur_sql :='select * from user_tab_partitions utp where utp.table_name <> ''DETECTION_INFO'' and to_date(substr(utp.partition_name,-8),''yyyy-MM-dd'')<=to_date('||v_del_date||',''yyyy-MM-dd'')'; + PRO_DELTABSPACE('3_',v_cur_sql); + + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,'4','4.删除动态表的表空间和分区 end'); + +------------------------------------------------------ + + v_table_name :='DETECTION_INFO'; + + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,'5','5.暂时停用'||v_table_name||'表被用作外键表的外键 begin'); + + + -- 循环尝试停用detection_info表的外键 + <<continueTryDis>> + LOOP + BEGIN + -- 尝试够一定次数,或者 一次执行成功 则退出循环 + EXIT WHEN v_count=c_count; + + --二、暂时停用被用作外键表的外键 + space_sql :='alter table detection_info disable primary key cascade'; + EXECUTE IMMEDIATE space_sql; + + EXCEPTION + --异常处理机制,记录相关的ora错误号以及相关异常信息 + WHEN OTHERS THEN + BEGIN + --ROLLBACK;--停用失败后,不该回滚所有的事务,而是该再次尝试,即使尝试到一定次数都失败,也不可以回滚 + + v_count := v_count + 1; + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,'-1','error:'||SQLERRM||',已尝试停用detection_info表的外键'||v_count||'次'); + + + --停用外键失败,则再次尝试,再次尝试前先睡眠一段时间 + dbms_lock.sleep(c_sleep_count); + GOTO continueTryDis; + END; + END; + EXIT; + END LOOP; + + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,'6','6.暂时停用'||v_table_name||'表被用作外键表的外键 end'); + +------------------------------------------------------ + v_table_name :='DETECTION_INFO'; + + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,'7','7.删除'||v_table_name||'表包含外键表的分区及表空间 begin'); + + + --三、删除包含外键表的分区及表空间 + v_cur_sql :='select * from user_tab_partitions utp where utp.table_name = ''DETECTION_INFO'' and to_date(substr(utp.partition_name,-8),''yyyy-MM-dd'')<=to_date('||v_del_date||',''yyyy-MM-dd'')'; + PRO_DELTABSPACE('7_',v_cur_sql); + + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,'8','8.删除'||v_table_name||'表包含外键表的分区及表空间 end'); + +------------------------------------------------------ + v_table_name :='detection_info'; + + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,'9','9.恢复'||v_table_name||'表被用作外键表的外键 begin'); + + + -- 循环尝试启用detection_info表的外键 + v_count :=0; + <<continueTryEna>> + LOOP + BEGIN + -- 尝试够一定次数,或者 一次执行成功 则退出循环 + EXIT WHEN v_count=c_count; + + --四、恢复被用作外键表的外键 + space_sql :='alter table detection_info enable primary key'; + EXECUTE IMMEDIATE space_sql; + EXCEPTION + --异常处理机制,记录相关的ora错误号以及相关异常信息 + WHEN OTHERS THEN + BEGIN + --ROLLBACK;--停用失败后,不该回滚所有的事务,而是该再次尝试,即使尝试到一定次数都失败,也不可以回滚 + + v_count := v_count + 1; + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,'-1','error:'||SQLERRM||',已尝试启用detection_info表的外键'||v_count||'次'); + + + --启用外键失败,则再次尝试,再次尝试前先睡眠一段时间 + dbms_lock.sleep(c_sleep_count); + GOTO continueTryEna; + END; + END; + EXIT; + END LOOP; + + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,'10','10.恢复'||v_table_name||'表被用作外键表的外键 end'); + + +------------------------------------------------------ + EXCEPTION + --异常处理机制,记录相关的ora错误号以及相关异常信息 + WHEN OTHERS THEN + BEGIN + ROLLBACK; + + select SEQ_PRO_EXEC_LOG.nextval into v_log_id from dual; + PRO_RECORD_LOG_INFO(c_log_table_name,v_log_id,c_cur_pro_name,'-1','error:'||SQLERRM); + + END; +end pro_driver_del_Partition; +/
\ No newline at end of file |
