PL/SQL开发中动态SQL的使用与过程分页

所谓静态SQL指在PL/SQL块中使用的SQL语句在编译时是明确的，执行的是确定对象。而动态SQL是指在PL/SQL块编译时SQL语句是不确定的，如根据用户输入的参数的不同而执行不同的操作。编译程序对动态语句部分不进行处理，只是在程序运行时动态地创建语句、对语句进行语法分析并执行该语句。

  Oracle中动态SQL可以通过本地动态SQL来执行，也可以通过DBMS_SQL包来执行。

一、本地动态SQL

本地动态SQL是使用EXECUTE IMMEDIATE语句来实现的。(Oracle 8i 及以上的版本)

1、本地动态SQL执行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;--动态执行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;--动态执行DDL语句  exception   when others then null; end ; 2、本地动态SQL执行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; --动态执行插入操作  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; --动态执行插入操作  exception   when others then null; end ;  

• 1.

• 2.

• 3.

• 4.

• 5.

• 6.

• 7.

• 8.

• 9.

• 10.

• 11.

• 12.

• 13.

• 14.

• 15.

• 16.

• 17.

• 18.

• 19.

• 20.

• 21.

• 22.

• 23.

• 24.

• 25.

• 26.

• 27.

• 28.

• 29.

• 30.

• 31.

• 32.

• 33.

• 34.

• 35.

• 36.

• 37.

• 38.

• 39.

• 40.

• 41.

• 42.

• 43.

• 44.

• 45.

• 46.

• 47.

• 48.

• 49.

• 50.

• 51.

• 52.

• 53.

• 54.

• 55.

• 56.

• 57.

• 58.

• 59.

• 60.

• 61.

• 62.

• 63.

• 64.

• 65.

• 66.

• 67.

• 68.

• 69.

在上例中，本地动态SQL执行DML语句时使用了using子句，按顺序将输入的值绑定到变量，如果需要输出参数，可以在执行动态SQL的时候，使用RETURNING INTO 子句，如：

SQL代码

declare  
 p_id number:=1;
 v_count number;
begin 
 v_string:=’select count(*) from table_name a where a.id=:id’;
 execute immediate v_string into v_count using p_id;  
end ;

二、使用DBMS_SQL包

 使用DBMS_SQL包实现动态SQL的步骤如下：A、先将要执行的SQL语句或一个语句块放到一个字符串变量中。B、使用DBMS_SQL包的parse过程来分析该字符串。C、使用DBMS_SQL包的bind_variable过程来绑定变量。D、使用DBMS_SQL包的execute函数来执行语句。

1、使用DBMS_SQL包执行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;  --定义光标
 v_string varchar2(200);--定义字符串变量
 v_row number;--行数
begin  
 v_cursor:=dbms_SQL.open_cursor;  --为处理打开光标
 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);--执行语句
 dbms_SQL.close_cursor(v_cursor);  --关闭光标
 exception
  when others then  
dbms_SQL.close_cursor(v_cursor);  --关闭光标
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;  --定义光标  v_string varchar2(200);--定义字符串变量  v_row number;--行数 begin  v_cursor:=dbms_SQL.open_cursor;  --为处理打开光标  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);--执行语句  dbms_SQL.close_cursor(v_cursor);  --关闭光标  exception   when others then dbms_SQL.close_cursor(v_cursor);  --关闭光标 raise; end; 2、使用DBMS_SQL包执行DML语句 SQL代码 create or replace procedure proc_dbms_SQL_update (  id number,  name varchar2 )as   v_cursor number;--定义光标  v_string varchar2(200);--字符串变量  v_row number;--行数 begin   v_cursor:=dbms_SQL.open_cursor; --为处理打开光标  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);　　　　　　　　　　　--执行动态ＳＱＬ  dbms_SQL.close_cursor(v_cursor);--关闭光标  exception   when others then  dbms_SQL.close_cursor(v_cursor); --关闭光标 raise; end; 

create or replace procedure proc_dbms_SQL_update (  id number,  name varchar2 )as  v_cursor number;--定义光标  v_string varchar2(200);--字符串变量  v_row number;--行数 begin  v_cursor:=dbms_SQL.open_cursor; --为处理打开光标  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);　　　　　　　　　　　--执行动态ＳＱＬ  dbms_SQL.close_cursor(v_cursor);--关闭光标  exception   when others then dbms_SQL.close_cursor(v_cursor); --关闭光标 raise; end; SQL代码 -- 使用动态方式执行取记录数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);     -- 满足条件总记录数   PN_TOTALROWS := vn_RowNum;     -- 根据取得的记录数计算页数   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; 

  -- 使用动态方式执行取记录数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);

 -- 满足条件总记录数  PN_TOTALROWS := vn_RowNum;

 -- 根据取得的记录数计算页数  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;

• 1.

• 2.

• 3.

• 4.

• 5.

• 6.

• 7.

• 8.

• 9.

• 10.

• 11.

• 12.

• 13.

• 14.

• 15.

• 16.

• 17.

• 18.

• 19.

• 20.

• 21.

• 22.

• 23.

• 24.

• 25.

• 26.

• 27.

• 28.

• 29.

• 30.

• 31.

• 32.

• 33.

• 34.

• 35.

• 36.

• 37.

• 38.

• 39.

• 40.

• 41.

• 42.

• 43.

• 44.

• 45.

• 46.

• 47.

• 48.

• 49.

• 50.

• 51.

• 52.

• 53.

• 54.

• 55.

• 56.

• 57.

• 58.

• 59.

• 60.

• 61.

• 62.

• 63.

• 64.

• 65.

• 66.

• 67.

• 68.

• 69.

• 70.

• 71.

• 72.

• 73.

• 74.

• 75.

• 76.

• 77.

• 78.

• 79.

• 80.

• 81.

• 82.

• 83.

• 84.

• 85.

• 86.

• 87.

• 88.

• 89.

• 90.

• 91.

• 92.

• 93.

• 94.

• 95.

• 96.

• 97.

• 98.

• 99.

• 100.

• 101.

• 102.

• 103.

• 104.

• 105.

• 106.

• 107.

• 108.

• 109.

• 110.

• 111.

• 112.

• 113.

• 114.

• 115.

• 116.

• 117.

• 118.

• 119.

• 120.

• 121.

• 122.

• 123.

• 124.

• 125.

• 126.

• 127.

• 128.

• 129.

• 130.

• 131.

• 132.

• 133.

• 134.

• 135.

• 136.

• 137.

• 138.

• 139.

• 140.

• 141.

• 142.

• 143.

• 144.

• 145.

• 146.

• 147.

• 148.

• 149.

• 150.

• 151.

• 152.

• 153.

• 154.

• 155.

• 156.

• 157.

• 158.

• 159.

• 160.

• 161.

• 162.

说明：PL/SQL块中使用动态SQL执行DDL语句的时候与别的不同，在DDL中使用绑定变量是非法的（bind_variable(v_cursor,’:p_name’,name)），分析后不需要执行DBMS_SQL.Bind_Variable，直接将输入的变量加到字符串中即可。另外，DDL是在调用DBMS_SQL.PARSE时执行的，所以DBMS_SQL.EXECUTE也可以不用，即在上例中的v_row:=dbms_SQL.execute(v_cursor)部分可以不要。

三、DBMS_SQL系统包提供的部分函数及过程说明

function open_cursor:打开一个动态游标,并返回一个整型;

procedure close_cursor(c in out integer);关闭一个动态游标,参数为open_cursor所打开的游标;

procedure parse(c in integer, statement in varchar2, language_flag in integer):对动态游标所提供的SQL语句进行解析,参数C表示游标,statement为SQL语句,language-flag为解析SQL语句所用Oracle版本,一般有V6,V7跟native(在不明白所连database版本时,使用native);

procedure define_column(c in integer, position in integer, column any datatype, [column_size in integer]):定义动态游标所能得到的对应值,其中c为动态游标,positon为对应动态SQL中的位置(从1开始),column为该值所对应的变量,可以为任何类型,column_size只有在column为定义长度的类型中使用如VARCHAR2,CHAR等(该过程有很多种情况,此处只对一般使用到的类型进行表述);

function execute(c in integer):执行游标,并返回处理一个整型,代表处理结果(对insert,delete,update才有意义,而对select语句而言可以忽略);

function fetch_rows(c in integer):对游标进行循环取数据,并返回一个整数,为0时表示已经取到游标末端;

procedure column_value(c in integer, position in integer, value):将所取得的游标数据赋值到相应的变量,c为游标,position为位置,value则为对应的变量;

procedure bind_variable(c in integer, name in varchar2, value):定义动态SQL语句(DML)中所对应字段的值,c为游标,name为字段名称,value为字段的值;

说明：

1.对于一般的select操作,如果使用动态的SQL语句则需要进行以下几个步骤:

open cursor--->parse--->define column--->excute--->fetch rows--->close cursor;

2.而对于dml操作(insert,update)则需要进行以下几个步骤:

open cursor--->parse--->bind variable--->execute--->close cursor;

3.对于delete操作只需要进行以下几个步骤:

open cursor--->parse--->execute--->close cursor;

四、Oracle存储过程分页

SQL代码

CREATE OR REPLACE PACKAGE T_PACKAGE AS 
 TYPE P_RESULT IS REF CURSOR; 
end T_PACKAGE;

SQL代码

create or replace procedure T_PAGING
(
  P_RESULT  out T_PACKAGE.P_RESULT ,
  startNum  in  numeric,--开始记录号
  endNum in  numeric --结束记录号
) as 
begin 
OPEN p_CURSOR FOR select * from ( select _row.*, rownum _rownum from

(select id,title,status from HYQTEST) _row where rownum <= endNum) where _rownum >startNum; 
end;

您正在阅读的是《PL/SQL开发中动态SQL的使用与过程分页》