oracle存儲過程創(chuàng)建表分區(qū)實例
更新時間：2013年11月11日 10:44:11 投稿：zxhpj
二種oracle存儲過程創(chuàng)建表分區(qū)實例
用存儲過程創(chuàng)建數據表:
創(chuàng)建時注意必須添加authid current_user，如果創(chuàng)建的表已存在，存儲過程繼續(xù)執(zhí)行，但如不不加此關鍵語句，存儲過程將出現(xiàn)異常，
這個語句相當于賦權限。
例1
創(chuàng)建語句如下：
復制代碼 代碼如下:
create or replace
procedure sp_create_mnl(i_id varchar2) authid current_user as
/*********************************
名稱：sp_create_mnl
功能描述：創(chuàng)建模擬量歷史數據存儲表
修訂記錄：
版本號 編輯時間 編輯人 修改描述
1.0.0 2012-9-20 wylaok 1.創(chuàng)建此存儲過程
1.0.1 2012-9-21 wylaok 2.修改表名稱及變量名稱，增加必要注釋
入參出參描述：
i_id 測點編號
**********************************/
v_tablename varchar2(30);--表名
v_flag number(10,0);
v_sqlfalg varchar(200);
begin
v_flag:=0;
v_tablename:=CONCAT('MNL', UPPER(i_id));
v_sqlfalg:='select count(*) from user_TABLES where table_name='''||v_tablename||'''';
dbms_output.put_line(v_sqlfalg);
execute immediate v_sqlfalg into v_flag;
if v_flag=0 then --如果沒有這個表 則去創(chuàng)建
begin
execute immediate 'create table '||v_tablename ||'
( DATETIME DATE,
MIN00 FLOAT,
AGV00 FLOAT,
MAX00 FLOAT,
MIN05 FLOAT,
AVG05 FLOAT,
MAX05 FLOAT,
MIN10 FLOAT,
AGV10 FLOAT,
MAX10 FLOAT,
MIN15 FLOAT,
AGV15 FLOAT,
MAX15 FLOAT,
MIN20 FLOAT,
AGV20 FLOAT,
MAX20 FLOAT,
MIN25 FLOAT,
AGV25 FLOAT,
MAX25 FLOAT,
MIN30 FLOAT,
AGV30 FLOAT,
MAX30 FLOAT,
MIN35 FLOAT,
AGV35 FLOAT,
MAX35 FLOAT,
MIN40 FLOAT,
AGV40 FLOAT,
MAX40 FLOAT,
MIN45 FLOAT,
AGV45 FLOAT,
MAX45 FLOAT,
MIN50 FLOAT,
AGV50 FLOAT,
MAX50 FLOAT,
MIN55 FLOAT,
AGV55 FLOAT,
MAX55 FLOAT,
MINV FLOAT,
MAXV FLOAT,
AVGV FLOAT,
MAXTIME DATE,
MINTIME DATE
)
tablespace WYG
pctfree 10
initrans 1
maxtrans 255
storage
(
initial 512K
next 512K
minextents 1
maxextents unlimited
pctincrease 0
)';
-- execute immediate sqlstr;
end;
end if;
end;
調用此存儲過程：
復制代碼 代碼如下:
begin
createmnl('mnl_14');
end;
例2
復制代碼 代碼如下:
CREATE OR REPLACE PROCEDURE BIP_MMS_PARTITION_PROC AS
v_Mms_Task_Tab VARCHAR2(50); --表名
v_Mms_Content_Tab VARCHAR2(50);
v_Mms_User_Tab VARCHAR2(50);
v_TableSpace VARCHAR2(20); --表空間
v_PartPreFlag VARCHAR2(50); --分區(qū)名標識
v_SqlCursor NUMBER; --游標
v_SqlExec VARCHAR2(2000); --執(zhí)行語句
v_PartPreDate VARCHAR2(20); --分區(qū)日期
v_RangeValue NUMBER;
v_RangeDate NUMBER;
v_Rows NUMBER(30) := 0;
v_Num NUMBER(30) := 0;
vErrInfo VARCHAR2(200);
p_DateFrom NUMBER;
p_PartNum NUMBER;
p_Range NUMBER;
BEGIN
v_Mms_Task_Tab := 'BIP_MMS_MT_TASK_LOG_TAB_TEST';
v_Mms_Content_Tab := 'BIP_MMS_MT_CONTENT_TAB_TEST';
v_Mms_User_Tab := 'BIP_MMS_MT_USER_LOG_TAB_TEST';
-- 讀取配置參數
BEGIN
SELECT TO_NUMBER(VALUE)
INTO p_DateFrom
FROM BIP_OTHERS_PROPERTIES_TAB
WHERE NAME = 'p_DateFrom';
SELECT TO_NUMBER(VALUE)
INTO p_PartNum
FROM BIP_OTHERS_PROPERTIES_TAB
WHERE NAME = 'p_PartNum';
SELECT TO_NUMBER(VALUE)
INTO p_Range
FROM BIP_OTHERS_PROPERTIES_TAB
WHERE NAME = 'p_Range';
EXCEPTION
WHEN OTHERS THEN
BEGIN
p_DateFrom := 0;
p_PartNum := 1;
p_Range := 180;
END;
END;
--記錄存儲過程添加分區(qū)
INSERT INTO BIP_LOG_STAT_EXEC_TAB
VALUES
(TO_CHAR(SYSDATE, 'yyyymmddhh24miss'),
'BIP_MMS_PARTITION_PROC_ADD',
'BEGIN');
COMMIT;
--ADD PARTITION
FOR i IN 1 .. p_PartNum LOOP
--BIP_MMS_MT_CONTENT_TAB 添加分區(qū)
v_PartPreDate := TO_CHAR(SYSDATE + p_DateFrom + i, 'YYYYMMDD');
dbms_output.put_line(v_PartPreDate);
v_Num := 0;
v_TableSpace := 'BIP_MMS_TS_TEST';
v_PartPreFlag := 'MMS_MT_CONTENT';
SELECT COUNT(*)
INTO v_Num
FROM user_tab_partitions
WHERE table_name = v_Mms_Content_Tab
AND SUBSTR(partition_name, 16, 8) = v_PartPreDate;
IF v_Num < 1 THEN
v_RangeDate := TO_CHAR(SYSDATE + p_DateFrom + i, 'YYYYMMDD');
v_RangeValue := v_RangeDate || '240000';
dbms_output.put_line(v_RangeValue);
v_SqlExec := 'ALTER TABLE ' || v_Mms_Content_Tab || ' ADD PARTITION ' ||
v_PartPreFlag || '_' || v_PartPreDate ||
' VALUES LESS THAN(''' || v_RangeValue ||
''') TABLESPACE ' || v_TableSpace;
dbms_output.put_line(v_SqlExec);
v_SqlCursor := DBMS_SQL.OPEN_CURSOR;
DBMS_SQL.PARSE(v_SqlCursor, v_SqlExec, DBMS_SQL.NATIVE);
v_Rows := DBMS_SQL.EXECUTE(v_SqlCursor);
DBMS_SQL.CLOSE_CURSOR(v_SqlCursor);
END IF;
--BIP_MMS_MT_TASK_LOG_TAB_TEST 添加分區(qū)
v_PartPreDate := TO_CHAR(SYSDATE + p_DateFrom + i, 'YYYYMMDD');
v_Num := 0;
v_TableSpace := 'BIP_MMS_TS_TEST';
v_PartPreFlag := 'MMS_MT_TASK_LOG';
SELECT COUNT(*)
INTO v_Num
FROM user_tab_partitions
WHERE table_name = v_Mms_Task_Tab
AND SUBSTR(partition_name, 17, 8) = v_PartPreDate;
IF v_Num < 1 THEN
v_RangeDate := TO_CHAR(SYSDATE + p_DateFrom + i, 'YYYYMMDD');
v_RangeValue := v_RangeDate || '240000';
v_SqlExec := 'ALTER TABLE ' || v_Mms_Task_Tab || ' ADD PARTITION ' ||
v_PartPreFlag || '_' || v_PartPreDate ||
' VALUES LESS THAN(''' || v_RangeValue ||
''') TABLESPACE ' || v_TableSpace;
dbms_output.put_line(v_SqlExec);
v_SqlCursor := DBMS_SQL.OPEN_CURSOR;
DBMS_SQL.PARSE(v_SqlCursor, v_SqlExec, DBMS_SQL.NATIVE);
v_Rows := DBMS_SQL.EXECUTE(v_SqlCursor);
DBMS_SQL.CLOSE_CURSOR(v_SqlCursor);
END IF;
--BIP_MMS_MT_USER_LOG_TAB_TEST 添加分區(qū)
v_PartPreDate := TO_CHAR(SYSDATE + p_DateFrom + i, 'YYYYMMDD');
v_Num := 0;
v_TableSpace := 'BIP_MMS_TS_TEST';
v_PartPreFlag := 'MMS_MT_USER_LOG';
SELECT COUNT(*)
INTO v_Num
FROM user_tab_partitions
WHERE table_name = v_Mms_User_Tab
AND SUBSTR(partition_name, 17, 8) = v_PartPreDate;
IF v_Num < 1 THEN
v_RangeDate := TO_CHAR(SYSDATE + p_DateFrom + i, 'YYYYMMDD');
v_RangeValue := v_RangeDate || '240000';
v_SqlExec := 'ALTER TABLE ' || v_Mms_User_Tab || ' ADD PARTITION ' ||
v_PartPreFlag || '_' || v_PartPreDate ||
' VALUES LESS THAN(''' || v_RangeValue ||
''') TABLESPACE ' || v_TableSpace;
dbms_output.put_line(v_SqlExec);
v_SqlCursor := DBMS_SQL.OPEN_CURSOR;
DBMS_SQL.PARSE(v_SqlCursor, v_SqlExec, DBMS_SQL.NATIVE);
v_Rows := DBMS_SQL.EXECUTE(v_SqlCursor);
DBMS_SQL.CLOSE_CURSOR(v_SqlCursor);
END IF;
END LOOP;
COMMIT;
INSERT INTO BIP_LOG_STAT_EXEC_TAB
VALUES
(TO_CHAR(SYSDATE, 'yyyymmddhh24miss'), 'BIP_MMS_PARTITION_PROC_ADD', 'END');
COMMIT;
--DELETE PARTITION
INSERT INTO BIP_LOG_STAT_EXEC_TAB
VALUES
(TO_CHAR(SYSDATE, 'yyyymmddhh24miss'),
'BIP_MMS_PARTITION_PROC_DEL',
'BEGIN');
COMMIT;
BEGIN
v_PartPreFlag := 'MMS_MT_CONTENT' || '_' ||
TO_CHAR(SYSDATE - p_Range, 'yyyymmdd');
dbms_output.put_line(v_PartPreFlag);
v_SqlExec := 'ALTER TABLE ' || v_Mms_Content_Tab ||
' TRUNCATE PARTITION ' || v_PartPreFlag;
dbms_output.put_line(v_SqlExec);
v_SqlCursor := DBMS_SQL.OPEN_CURSOR;
DBMS_SQL.PARSE(v_SqlCursor, v_SqlExec, DBMS_SQL.NATIVE);
v_Rows := DBMS_SQL.EXECUTE(v_SqlCursor);
DBMS_SQL.CLOSE_CURSOR(v_SqlCursor);
dbms_output.put_line(v_PartPreFlag || ' truncated');
v_SqlExec := 'ALTER TABLE ' || v_Mms_Content_Tab || ' DROP PARTITION ' ||
v_PartPreFlag;
dbms_output.put_line(v_SqlExec);
v_SqlCursor := DBMS_SQL.OPEN_CURSOR;
DBMS_SQL.PARSE(v_SqlCursor, v_SqlExec, DBMS_SQL.NATIVE);
v_Rows := DBMS_SQL.EXECUTE(v_SqlCursor);
DBMS_SQL.CLOSE_CURSOR(v_SqlCursor);
dbms_output.put_line(v_PartPreFlag || ' dropped');
END;
BEGIN
v_PartPreFlag := 'MMS_MT_TASK_LOG' || '_' ||
TO_CHAR(SYSDATE - p_Range, 'yyyymmdd');
dbms_output.put_line(v_PartPreFlag);
v_SqlExec := 'ALTER TABLE ' || v_Mms_Task_Tab || ' TRUNCATE PARTITION ' ||
v_PartPreFlag;
dbms_output.put_line(v_SqlExec);
v_SqlCursor := DBMS_SQL.OPEN_CURSOR;
DBMS_SQL.PARSE(v_SqlCursor, v_SqlExec, DBMS_SQL.NATIVE);
v_Rows := DBMS_SQL.EXECUTE(v_SqlCursor);
DBMS_SQL.CLOSE_CURSOR(v_SqlCursor);
dbms_output.put_line(v_PartPreFlag || ' truncated');
v_SqlExec := 'ALTER TABLE ' || v_Mms_Task_Tab || ' DROP PARTITION ' ||
v_PartPreFlag;
v_SqlCursor := DBMS_SQL.OPEN_CURSOR;
DBMS_SQL.PARSE(v_SqlCursor, v_SqlExec, DBMS_SQL.NATIVE);
v_Rows := DBMS_SQL.EXECUTE(v_SqlCursor);
DBMS_SQL.CLOSE_CURSOR(v_SqlCursor);
dbms_output.put_line(v_PartPreFlag || ' dropped');
END;
BEGIN
v_PartPreFlag := 'MMS_MT_USER_LOG' || '_' ||
TO_CHAR(SYSDATE - p_Range, 'yyyymmdd');
dbms_output.put_line(v_PartPreFlag);
v_SqlExec := 'ALTER TABLE ' || v_Mms_User_Tab || ' TRUNCATE PARTITION ' ||
v_PartPreFlag;
dbms_output.put_line(v_SqlExec);
v_SqlCursor := DBMS_SQL.OPEN_CURSOR;
DBMS_SQL.PARSE(v_SqlCursor, v_SqlExec, DBMS_SQL.NATIVE);
v_Rows := DBMS_SQL.EXECUTE(v_SqlCursor);
DBMS_SQL.CLOSE_CURSOR(v_SqlCursor);
dbms_output.put_line(v_PartPreFlag || ' truncated');
v_SqlExec := 'ALTER TABLE ' || v_Mms_User_Tab || ' DROP PARTITION ' ||
v_PartPreFlag;
v_SqlCursor := DBMS_SQL.OPEN_CURSOR;
DBMS_SQL.PARSE(v_SqlCursor, v_SqlExec, DBMS_SQL.NATIVE);
v_Rows := DBMS_SQL.EXECUTE(v_SqlCursor);
DBMS_SQL.CLOSE_CURSOR(v_SqlCursor);
dbms_output.put_line(v_PartPreFlag || ' dropped');
END;
COMMIT;
INSERT INTO BIP_LOG_STAT_EXEC_TAB
VALUES
(TO_CHAR(SYSDATE, 'yyyymmddhh24miss'),
'BIP_MMS_PARTITION_PROC_DEL',
'END');
COMMIT;
EXCEPTION
WHEN OTHERS THEN
BEGIN
ROLLBACK;
dbms_output.put_line(TO_CHAR(SQLCODE));
vErrInfo := SUBSTR(SQLERRM, 1, 200);
dbms_output.put_line(TO_CHAR(vErrInfo));
INSERT INTO BIP_LOG_STAT_EXEC_TAB
VALUES
(TO_CHAR(SYSDATE, 'yyyymmddhh24miss'),
'BIP_MMS_PARTITION_PROC_ERROR',
vErrInfo);
COMMIT;
END;
end bip_mms_partition_proc;
相關文章
這篇文章主要介紹了Oracle中手動刪除數據庫教程,本文給出了詳細步驟以及清除ASM數據庫的步驟,需要的朋友可以參考下2014-10-10
在開發(fā)過程中可能會用到oracle table demo 操作語句，本文將以此進行介紹，需要的朋友可以參考下2012-11-11
distinct這個關鍵字來過濾掉多余的重復記錄只保留一條，但往往只用它來返回不重復記錄的條數，而不是用它來返回不重記錄的所有值。其原因是distinct只有用二重循環(huán)查詢來解決，而這樣對于一個數據量非常大的站來說，無疑是會直接影響到效率的。2015-09-09
很多人對JSON不陌生,JSON(JavaScript Object Notation)是一種輕量級的數據交換格式,下面這篇文章主要給大家介紹了關于oracle中對JSON數據處理的詳細指南,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下2023-05-05
oracle 層次化查詢（行政區(qū)劃三級級聯(lián)）
現(xiàn)在將上面的行政區(qū)劃按代碼分為三個級別：?。ê笏奈粸?）/市（后兩位為0）/縣，同時分別標出他們的級別，這樣的話，便于后期根據不同的級別查詢。2009-07-07
這篇文章主要介紹了ORACLE SQL語句優(yōu)化技術的相關內容，小編覺得挺不錯的，在這里分享給大家，需要的朋友可以參考下。2017-10-10
臨時表空間用來管理數據庫排序操作以及用于存儲臨時表、中間排序結果等臨時對象，本文主要介紹了Oracle 臨時表空間SQL語句的實現(xiàn)，感興趣的可以了解一下2021-09-09
Oracle從多條符合條件的記錄中選擇一條這個需求相信大家應該都遇到過,這篇文章主要給大家介紹了關于Oracle數據庫如何獲取多條結果集中的第一條或某一條的相關資料,需要的朋友可以參考下2023-03-03
這篇文章主要介紹了ORACLE中%TYPE和%ROWTYPE的使用,本文給大家講解的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-11-11
這篇文章主要介紹了Linux虛擬機下安裝Oracle 11G教程圖文詳解，本文文字圖解相結合的形式給大家介紹的非常詳細，具有一定的參考借鑒價值,需要的朋友可以參考下2019-04-04