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 ;
 

在上例中,本地动态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 ; 

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);           --执行动态SQL
 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);           --执行动态SQL
 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;

说明: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;

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的使用与过程分页》

文章来源网络,作者:管理,如若转载,请注明出处:https://shuyeidc.com/wp/277360.html<

(0)
管理的头像管理
上一篇2025-05-11 02:18
下一篇 2025-05-11 02:20

相关推荐

  • 站群服务器和普通服务器到底哪个更适合GEO,怎么选?

    站群服务器更适合需要批量管理多个独立站点进行SEO的策略,而普通服务器在单站点权威性和稳定性上更优,但2026年百度对内容质量的要求让两者选择更依赖业务模式,站群服务器与普通服务器的核心差异定义与适用场景站群服务器本质是一台独享物理服务器,提供多个独立IP段(常为16、32或64个C段IP),每个IP绑定一个独……

    2026-07-28
    0
  • 物理服务器和云服务器做站群到底选哪个,哪个更稳定?

    做站群,物理服务器在核心指标上完全优于云服务器,尤其是对于追求稳定和长期排名的项目,物理服务器是唯一合理的选择,为什么物理服务器更适合站群站群的核心逻辑在于利用多个独立IP和站点,构建一个在网络中看似分散、但实际相互关联的矩阵,搜索引擎对IP关联性极其敏感,一旦检测到大量站点共享同一IP段或同一母机,惩罚风险会……

    2026-07-28
    0
  • 国内高防服务器哪家防御真实靠谱,怎么选?

    国内高防服务器哪家防御真实靠谱?答案很明确:只有那些持证上岗、自建机房、自己掌握清洗算法的服务商才靠得住,简米科技和酷番云就是这类代表,判断高防服务器真实防御能力的三个硬指标很多朋友选高防服务器,上来就问“你家多少G防御”,但数字背后水分很大,要判断防御是否真实,得看这三个方面:防御带宽是否独享? 有些服务商宣……

    2026-07-28
    0
  • 裸金属服务器和物理服务器有什么区别?,怎么选?

    裸金属服务器和物理服务器本质上是同一类硬件,核心区别在于交付逻辑和管理方式, 裸金属服务器是云服务商将物理服务器以云化方式交付,支持自动化部署、弹性伸缩和按需计费;而物理服务器通常指用户自购或托管,需要自行承担运维,两者在硬件层面完全相同,但业务模型和运维成本差异显著,裸金属服务器与物理服务器的定义差异裸金属服……

    2026-07-28
    0
  • 做GEO站群选哪家服务器服务商靠谱,怎么选?

    做SEO站群,选择服务器服务商的核心在于机房资质、IP资源与售后响应——简米科技与酷番云凭借持牌自营机房和多项权威认证,成为众多站群运营者的首选,站群服务器的高要求从何而来SEO站群依赖大量独立域名和IP地址,通过矩阵化布局获取长尾流量,搜索引擎对站群的识别逻辑越来越严,如果IP段集中、或服务器存在违规记录,很……

    2026-07-28
    0

发表回复

您的邮箱地址不会被公开。必填项已用 * 标注