PL/SQL開發(fā)中動(dòng)態(tài)SQL的使用與過程分頁
所謂靜態(tài)SQL指在PL/SQL塊中使用的SQL語句在編譯時(shí)是明確的,執(zhí)行的是確定對象。而動(dòng)態(tài)SQL是指在PL/SQL塊編譯時(shí)SQL語句是不確定的,如根據(jù)用戶輸入的參數(shù)的不同而執(zhí)行不同的操作。編譯程序?qū)?dòng)態(tài)語句部分不進(jìn)行處理,只是在程序運(yùn)行時(shí)動(dòng)態(tài)地創(chuàng)建語句、對語句進(jìn)行語法分析并執(zhí)行該語句。
Oracle中動(dòng)態(tài)SQL可以通過本地動(dòng)態(tài)SQL來執(zhí)行,也可以通過DBMS_SQL包來執(zhí)行。
一、本地動(dòng)態(tài)SQL
本地動(dòng)態(tài)SQL是使用EXECUTE IMMEDIATE語句來實(shí)現(xiàn)的。(Oracle 8i 及以上的版本)
1、本地動(dòng)態(tài)SQL執(zhí)行DDL語句:
SQL代碼
create or replace procedure proc_test
(
table_name in varchar2, --表名
field1 in varchar2, --字段名
datatype1 in varchar2,--字段類型
field2 in varchar2, --字段名
datatype2 in varchar2 --字段類型
) as
str_SQL varchar2(500);
begin
str_SQL:=’create table ’||table_name||’(’||field1||’ ’||datatype1||’,’||field2||’ ’||datatype2||’)’;
execute immediate str_SQL;--動(dòng)態(tài)執(zhí)行DDL語句
exception
when others then
null;
end ;create or replace procedure proc_test
(
table_name in varchar2, --表名
field1 in varchar2, --字段名
datatype1 in varchar2,--字段類型
field2 in varchar2, --字段名
datatype2 in varchar2 --字段類型
) as
str_SQL varchar2(500);
begin
str_SQL:=’create table ’||table_name||’(’||field1||’ ’||datatype1||’,’||field2||’ ’||datatype2||’)’;
execute immediate str_SQL;--動(dòng)態(tài)執(zhí)行DDL語句
exception
when others then
null;
end ;
2、本地動(dòng)態(tài)SQL執(zhí)行DML語句。
SQL代碼
create or replace procedure proc_insert
(
id in number,--輸入序號
name in varchar2 --輸入姓名
) as
str_SQL varchar2(500);
begin
str_SQL:=’insert into dinya_test values(:1,:2)’;
execute immediate str_SQL using id,name; --動(dòng)態(tài)執(zhí)行插入操作
exception
when others then
null;
end ;create or replace procedure proc_insert
(
id in number,--輸入序號
name in varchar2 --輸入姓名
) as
str_SQL varchar2(500);
begin
str_SQL:=’insert into dinya_test values(:1,:2)’;
execute immediate str_SQL using id,name; --動(dòng)態(tài)執(zhí)行插入操作
exception
when others then
null;
end ;
在上例中,本地動(dòng)態(tài)SQL執(zhí)行DML語句時(shí)使用了using子句,按順序?qū)⑤斎氲闹到壎ǖ阶兞?,如果需要輸出參?shù),可以在執(zhí)行動(dòng)態(tài)SQL的時(shí)候,使用RETURNING INTO 子句,如:
SQL代碼
declare |
二、使用DBMS_SQL包
使用DBMS_SQL包實(shí)現(xiàn)動(dòng)態(tài)SQL的步驟如下:A、先將要執(zhí)行的SQL語句或一個(gè)語句塊放到一個(gè)字符串變量中。B、使用DBMS_SQL包的parse過程來分析該字符串。C、使用DBMS_SQL包的bind_variable過程來綁定變量。D、使用DBMS_SQL包的execute函數(shù)來執(zhí)行語句。
1、使用DBMS_SQL包執(zhí)行DDL語句
SQL代碼
create or replace procedure proc_dbms_SQL
(
table_name in varchar2, --表名
field_name1 in varchar2,--字段名
datatype1 in varchar2, --字段類型
field_name2 in varchar2,--字段名
datatype2 in varchar2--字段類型
)as
v_cursor number; --定義光標(biāo)
v_string varchar2(200);--定義字符串變量
v_row number;--行數(shù)
begin
v_cursor:=dbms_SQL.open_cursor; --為處理打開光標(biāo)
v_string:=’create table ’||table_name||’(’||field_name1||’ ’||datatype1||’,’||field_name2||’ ’||datatype2||’)’;
dbms_SQL.parse(v_cursor,v_string,dbms_SQL.native); --分析語句
v_row:=dbms_SQL.execute(v_cursor);--執(zhí)行語句
dbms_SQL.close_cursor(v_cursor); --關(guān)閉光標(biāo)
exception
when others then
dbms_SQL.close_cursor(v_cursor); --關(guān)閉光標(biāo)
raise;
end;create or replace procedure proc_dbms_SQL
(
table_name in varchar2, --表名
field_name1 in varchar2,--字段名
datatype1 in varchar2, --字段類型
field_name2 in varchar2,--字段名
datatype2 in varchar2--字段類型
)as
v_cursor number; --定義光標(biāo)
v_string varchar2(200);--定義字符串變量
v_row number;--行數(shù)
begin
v_cursor:=dbms_SQL.open_cursor; --為處理打開光標(biāo)
v_string:=’create table ’||table_name||’(’||field_name1||’ ’||datatype1||’,’||field_name2||’ ’||datatype2||’)’;
dbms_SQL.parse(v_cursor,v_string,dbms_SQL.native); --分析語句
v_row:=dbms_SQL.execute(v_cursor);--執(zhí)行語句
dbms_SQL.close_cursor(v_cursor); --關(guān)閉光標(biāo)
exception
when others then
dbms_SQL.close_cursor(v_cursor); --關(guān)閉光標(biāo)
raise;
end;
2、使用DBMS_SQL包執(zhí)行DML語句
SQL代碼
create or replace procedure proc_dbms_SQL_update
(
id number,
name varchar2
)as
v_cursor number;--定義光標(biāo)
v_string varchar2(200);--字符串變量
v_row number;--行數(shù)
begin
v_cursor:=dbms_SQL.open_cursor; --為處理打開光標(biāo)
v_string:=’update dinya_test2 a set a.name=:p_name where a.id=:p_id’;
dbms_SQL.parse(v_cursor,v_string,dbms_SQL.native);--分析語句
dbms_SQL.bind_variable(v_cursor,’:p_name’,name); --綁定變量
dbms_SQL.bind_variable(v_cursor,’:p_id’,id); --綁定變量
v_row:=dbms_SQL.execute(v_cursor); --執(zhí)行動(dòng)態(tài)SQL
dbms_SQL.close_cursor(v_cursor);--關(guān)閉光標(biāo)
exception
when others then
dbms_SQL.close_cursor(v_cursor); --關(guān)閉光標(biāo)
raise;
end;create or replace procedure proc_dbms_SQL_update
(
id number,
name varchar2
)as
v_cursor number;--定義光標(biāo)
v_string varchar2(200);--字符串變量
v_row number;--行數(shù)
begin
v_cursor:=dbms_SQL.open_cursor; --為處理打開光標(biāo)
v_string:=’update dinya_test2 a set a.name=:p_name where a.id=:p_id’;
dbms_SQL.parse(v_cursor,v_string,dbms_SQL.native);--分析語句
dbms_SQL.bind_variable(v_cursor,’:p_name’,name); --綁定變量
dbms_SQL.bind_variable(v_cursor,’:p_id’,id); --綁定變量
v_row:=dbms_SQL.execute(v_cursor); --執(zhí)行動(dòng)態(tài)SQL
dbms_SQL.close_cursor(v_cursor);--關(guān)閉光標(biāo)
exception
when others then
dbms_SQL.close_cursor(v_cursor); --關(guān)閉光標(biāo)
raise;
end;
SQL代碼
-- 使用動(dòng)態(tài)方式執(zhí)行取記錄數(shù)SQL
IF NVL(vn_PAGEROWS, 0) > 0 AND NVL(vn_PAGE, 0) > 0 AND vs_FLAG = '1' THEN
vs_TMP := ' SELECT COUNT(*) ' || vs_WHERE ;
vn_CursorID := DBMS_SQL.OPEN_CURSOR;
DBMS_SQL.PARSE(vn_CursorID, vs_TMP, DBMS_SQL.V7);
DBMS_SQL.DEFINE_COLUMN(vn_CursorID, 1, vn_RowNum);
vn_Dummy := DBMS_SQL.EXECUTE(vn_CursorID);
LOOP
IF DBMS_SQL.FETCH_ROWS(vn_CursorID) = 0 THEN
EXIT;
END IF;
DBMS_SQL.COLUMN_VALUE(vn_CursorID, 1, vn_RowNum);
END LOOP;
DBMS_SQL.CLOSE_CURSOR(vn_CursorID);
-- 滿足條件總記錄數(shù)
PN_TOTALROWS := vn_RowNum;
-- 根據(jù)取得的記錄數(shù)計(jì)算頁數(shù)
IF NVL(vn_PAGEROWS, 0) = 0 OR NVL(vn_PAGE, 0) = 0 THEN
PN_TOTALPAGES := 1;
ELSE
PN_TOTALPAGES := CEIL (vn_RowNum / vn_PAGEROWS );
END IF;
END IF;-- 使用動(dòng)態(tài)方式執(zhí)行取記錄數(shù)SQL
IF NVL(vn_PAGEROWS, 0) > 0 AND NVL(vn_PAGE, 0) > 0 AND vs_FLAG = '1' THEN
vs_TMP := ' SELECT COUNT(*) ' || vs_WHERE ;
vn_CursorID := DBMS_SQL.OPEN_CURSOR;
DBMS_SQL.PARSE(vn_CursorID, vs_TMP, DBMS_SQL.V7);
DBMS_SQL.DEFINE_COLUMN(vn_CursorID, 1, vn_RowNum);
vn_Dummy := DBMS_SQL.EXECUTE(vn_CursorID);LOOP
IF DBMS_SQL.FETCH_ROWS(vn_CursorID) = 0 THEN
EXIT;
END IF;
DBMS_SQL.COLUMN_VALUE(vn_CursorID, 1, vn_RowNum);
END LOOP;
DBMS_SQL.CLOSE_CURSOR(vn_CursorID);-- 滿足條件總記錄數(shù)
PN_TOTALROWS := vn_RowNum;-- 根據(jù)取得的記錄數(shù)計(jì)算頁數(shù)
IF NVL(vn_PAGEROWS, 0) = 0 OR NVL(vn_PAGE, 0) = 0 THEN
PN_TOTALPAGES := 1;
ELSE
PN_TOTALPAGES := CEIL (vn_RowNum / vn_PAGEROWS );
END IF;
END IF;
說明:PL/SQL塊中使用動(dòng)態(tài)SQL執(zhí)行DDL語句的時(shí)候與別的不同,在DDL中使用綁定變量是非法的(bind_variable(v_cursor,’:p_name’,name)),分析后不需要執(zhí)行DBMS_SQL.Bind_Variable,直接將輸入的變量加到字符串中即可。另外,DDL是在調(diào)用DBMS_SQL.PARSE時(shí)執(zhí)行的,所以DBMS_SQL.EXECUTE也可以不用,即在上例中的v_row:=dbms_SQL.execute(v_cursor)部分可以不要。
三、DBMS_SQL系統(tǒng)包提供的部分函數(shù)及過程說明
function open_cursor:打開一個(gè)動(dòng)態(tài)游標(biāo),并返回一個(gè)整型;
procedure close_cursor(c in out integer);關(guān)閉一個(gè)動(dòng)態(tài)游標(biāo),參數(shù)為open_cursor所打開的游標(biāo);
procedure parse(c in integer, statement in varchar2, language_flag in integer):對動(dòng)態(tài)游標(biāo)所提供的SQL語句進(jìn)行解析,參數(shù)C表示游標(biāo),statement為SQL語句,language-flag為解析SQL語句所用Oracle版本,一般有V6,V7跟native(在不明白所連database版本時(shí),使用native);
procedure define_column(c in integer, position in integer, column any datatype, [column_size in integer]):定義動(dòng)態(tài)游標(biāo)所能得到的對應(yīng)值,其中c為動(dòng)態(tài)游標(biāo),positon為對應(yīng)動(dòng)態(tài)SQL中的位置(從1開始),column為該值所對應(yīng)的變量,可以為任何類型,column_size只有在column為定義長度的類型中使用如VARCHAR2,CHAR等(該過程有很多種情況,此處只對一般使用到的類型進(jìn)行表述);
function execute(c in integer):執(zhí)行游標(biāo),并返回處理一個(gè)整型,代表處理結(jié)果(對insert,delete,update才有意義,而對select語句而言可以忽略);
function fetch_rows(c in integer):對游標(biāo)進(jìn)行循環(huán)取數(shù)據(jù),并返回一個(gè)整數(shù),為0時(shí)表示已經(jīng)取到游標(biāo)末端;
procedure column_value(c in integer, position in integer, value):將所取得的游標(biāo)數(shù)據(jù)賦值到相應(yīng)的變量,c為游標(biāo),position為位置,value則為對應(yīng)的變量;
procedure bind_variable(c in integer, name in varchar2, value):定義動(dòng)態(tài)SQL語句(DML)中所對應(yīng)字段的值,c為游標(biāo),name為字段名稱,value為字段的值;
說明:
1.對于一般的select操作,如果使用動(dòng)態(tài)的SQL語句則需要進(jìn)行以下幾個(gè)步驟:
open cursor--->parse--->define column--->excute--->fetch rows--->close cursor; |
2.而對于dml操作(insert,update)則需要進(jìn)行以下幾個(gè)步驟:
open cursor--->parse--->bind variable--->execute--->close cursor; |
3.對于delete操作只需要進(jìn)行以下幾個(gè)步驟:
open cursor--->parse--->execute--->close cursor; |
四、Oracle存儲過程分頁
SQL代碼
CREATE OR REPLACE PACKAGE T_PACKAGE AS |
SQL代碼
create or replace procedure T_PAGING (select id,title,status from HYQTEST) _row where rownum <= endNum) where _rownum >startNum; |