- 存储过程包含三部分:声明,执行部分,异常。
- 可以有无参数程序和带参数存储过程。
- 无参程序语法
-
1createorreplaceprocedureNoParPro
-
2as;
-
3begin
-
4;
-
5exception
-
6;
-
7end;
-
8
- 带参存储过程实例
-
1createorreplaceprocedurequeryempname(sfindnoemp.empno%type)as
-
2sNameemp.ename%type;
-
3sjobemp.job%type;
-
4begin
-
5....
-
7exception
- ....
-
14end;
-
15
- 带参数存储过程含赋值方式
-
1createorreplaceprocedurerunbyparmeters(isalinemp.sal%type,
- snameoutvarchar,sjobinoutvarchar)
-
2asicountnumber;
-
3begin
-
4selectcount(*)intoicountfromempwheresal>isalandjob=sjob;
-
5ificount=1then
-
6....
-
9else
-
10....
-
12endif;
-
13exception
-
14whentoo_many_rowsthen
-
15DBMS_OUTPUT.PUT_LINE('返回值多于1行');
-
16whenothersthen
-
17DBMS_OUTPUT.PUT_LINE('在RUNBYPARMETERS过程中出错!');
-
18end;
-
19
- 过程调用
- 方式一
-
1declare
-
2realsalemp.sal%type;
-
3realnamevarchar(40);
-
4realjobvarchar(40);
-
5begin
-
6realsal:=1100;
-
7realname:='';
-
8realjob:='CLERK';
-
9runbyparmeters(realsal,realname,realjob);--必须按顺序
-
10DBMS_OUTPUT.PUT_LINE(REALNAME||''||REALJOB);
-
11END;
-
12
- 方式二
-
1declare
-
2realsalemp.sal%type;
-
3realnamevarchar(40);
-
4realjobvarchar(40);
-
5begin
-
6realsal:=1100;
-
7realname:='';
-
8realjob:='CLERK';
-
9runbyparmeters(sname=>realname,isal=>realsal,sjob=>realjob);--指定值对应变量顺序可变
-
10DBMS_OUTPUT.PUT_LINE(REALNAME||''||REALJOB);
-
11END;
-
12
- 存储过程包含三部分:声明,执行部分,异常。
- 可以有无参数程序和带参数存储过程。
- 无参程序语法
- 1createorreplaceprocedureNoParPro
- 2as;
- 3begin
- 4;
- 5exception
- 6;
- 7end;
- 8
- 带参存储过程实例
- 1createorreplaceprocedurequeryempname(sfindnoemp.empno%type)as
- 2sNameemp.ename%type;
- 3sjobemp.job%type;
- 4begin
- 5....
- 7exception
- ....
- 14end;
- 15
- 带参数存储过程含赋值方式
- 1createorreplaceprocedurerunbyparmeters(isalinemp.sal%type,
- snameoutvarchar,sjobinoutvarchar)
- 2asicountnumber;
- 3begin
- 4selectcount(*)intoicountfromempwheresal>isalandjob=sjob;
- 5ificount=1then
- 6....
- 9else
- 10....
- 12endif;
- 13exception
- 14whentoo_many_rowsthen
- 15DBMS_OUTPUT.PUT_LINE('返回值多于1行');
- 16whenothersthen
- 17DBMS_OUTPUT.PUT_LINE('在RUNBYPARMETERS过程中出错!');
- 18end;
- 19
- 过程调用
- 方式一
- 1declare
- 2realsalemp.sal%type;
- 3realnamevarchar(40);
- 4realjobvarchar(40);
- 5begin
- 6realsal:=1100;
- 7realname:='';
- 8realjob:='CLERK';
- 9runbyparmeters(realsal,realname,realjob);--必须按顺序
- 10DBMS_OUTPUT.PUT_LINE(REALNAME||''||REALJOB);
- 11END;
- 12
- 方式二
- 1declare
- 2realsalemp.sal%type;
- 3realnamevarchar(40);
- 4realjobvarchar(40);
- 5begin
- 6realsal:=1100;
- 7realname:='';
- 8realjob:='CLERK';
- 9runbyparmeters(sname=>realname,isal=>realsal,sjob=>realjob);--指定值对应变量顺序可变
- 10DBMS_OUTPUT.PUT_LINE(REALNAME||''||REALJOB);
- 11END;
- 12
要记录存储过程语法与Java程序的调用方式
一 存储过程
首先,我们建立一个简单的表进行存储过程的测试
create table
xuesheng(id integer, xing_ming varchar2(25), yu_wen number, shu_xue number);
insert into xuesheng values(1,'zhangsan',80,90)
insert into xuesheng values(2,'lisi',85,87)
1)无返回值的存储过程
create or replace procedure xs_proc_no is
begin
insert into xuesheng values (3, 'wangwu', 90, 90);
commit;
end xs_proc_no;
2)有单个数据值返回的存储过程
create or replace procedure xs_proc(temp_name in varchar2,
temp_num out number) is
num_1 number;
num_2 number;
begin
select yu_wen, shu_xue
into num_1, num_2
from xuesheng
where xing_ming = temp_name;
--dbms_output.put_line(num_1 + num_2);
temp_num := num_1 + num_2;
end;
其中,以上两种与sql server基本类似,而对于返回数据集时,上述方法则不能满足我们的要求。在Oracle中,一般使用ref cursor来返回数据集。示例代码如下:
3)有返回值的存储过程(列表返回)
首先,建立我们自己的包。并定义包中的一个自定义ref cursor
create or replace package mypackage as
type my_cursor is ref cursor;
end mypackage;
在定义了ref cursor后,可以书写我们的程序代码
create or replace procedure xs_proc_list(shuxue in number,
p_cursor out mypackage.my_cursor) is
begin
open p_cursor for
select * from xuesheng where shu_xue > shuxue;
end xs_proc_list;
二、程序调用
在本节中,我们使用java语言调用存储过程。其中,关键是使用CallableStatement这个对象,代码如下:
String oracleDriverName =
"oracle.jdbc.driver.OracleDriver" ;
String oracleUrlToConnect =
"jdbc:oracle:thin:@127.0.0.1:1521:orcl" ;
Connection myConnection =
null ;
try
{
Class.forName(oracleDriverName);
}
catch (ClassNotFoundException ex) {
ex.printStackTrace();
}
try
{
myConnection = DriverManager.getConnection(oracleUrlToConnect,
"xxxx" ,
"xxxx" );
}
catch (Exception ex) {
ex.printStackTrace();
}
try
{
CallableStatement proc= null ;
proc=myConnection.prepareCall( "{call xs_proc(?,?)}" );
proc.setString( 1 ,
"zhangsan" );
proc.registerOutParameter( 2 , Types.NUMERIC);
proc.execute();
String teststring=proc.getString( 2 );
System.out.println(teststring);
}
catch (Exception ex) {
ex.printStackTrace();
}
|
对于列表返回值的存储过程,在上述代码中做简单修改。如下
CallableStatement proc=null;
proc=myConnection.prepareCall("{call getdcsj(?,?,?,?,?)}");
proc.setString(1, strDate);
proc.setString(2, jzbh);
proc.registerOutParameter(3, Types.NUMERIC);
proc.registerOutParameter(4, OracleTypes.CURSOR);
proc.registerOutParameter(5, OracleTypes.CURSOR);
proc.execute();
ResultSet rs=null;
int total_number=proc.getInt(3);
rs=(ResultSet)proc.getObject(4);
上述存储过程修改完毕。另外,一个复杂的工程项目中的例子:查询一段数据中间隔不超过十分钟且连续超过100条的数据。即上述代码所调用的getdcsj存储过程
create
or
replace
procedure
getDcsj(var_flag
in
varchar2,
var_jzbh
in
varchar2,
number_total
out
number,
var_cursor_a
out
mypackage.my_cursor,
var_cursor_b
out
mypackage.my_cursor)
is
total number;
cursor
cur
is
select
sj, flag
from
d_dcsj
where
jzbh = var_jzbh
order
by
sj
desc
for
update
;
last_time
date
;
begin
for
cur1
in
cur loop
if last_time
is
null
or
cur1.sj >= last_time - 10 / 60 / 24
then
update
d_dcsj
set
flag = var_flag
where
current
of
cur;
last_time := cur1.sj;
else
select
count
(*)
into
total
from
d_dcsj
where
flag = var_flag;
dbms_output.put_line(total);
if total < 100
then
update
d_dcsj
set
flag =
null
where
flag = var_flag;
last_time :=
null
;
update
d_dcsj
set
flag = var_flag
where
current
of
cur;
else
open
var_cursor_a
for
select
*
from
d_dcsj
where
flag = var_flag
and
jzbh = var_jzbh
and
zh =
'A'
order
by
sj
desc
;
number_total := total;
open
var_cursor_b
for
select
*
from
d_dcsj
where
flag = var_flag
and
jzbh = var_jzbh
and
zh =
'B'
order
by
sj
desc
;
number_total := total;
exit;
end
if;
end
if;
end
loop;
select
count
(*)
into
total
from
d_dcsj
where
flag = var_flag;
dbms_output.put_line(total);
if total < 100
then
open
var_cursor_a
for
select
*
from
d_dcsj
where
zh =
'C'
;
open
var_cursor_b
for
select
*
from
d_dcsj
where
zh =
'C'
;
else
open
var_cursor_a
for
select
*
from
d_dcsj
where
flag = var_flag
and
jzbh = var_jzbh
and
zh =
'A'
order
by
sj
desc
;
number_total := total;
open
var_cursor_b
for
select
*
from
d_dcsj
where
flag = var_flag
and
jzbh = var_jzbh
and
zh =
'B'
order
by
sj
desc
;
number_total := total;
end
if;
commit
;
end
;
/
分享到:
相关推荐
本文实例讲述了Python使用cx_Oracle调用Oracle存储过程的方法。分享给大家供大家参考,具体如下: 这里主要测试在Python中通过cx_Oracle调用PL/SQL。 首先,在数据库端创建简单的存储过程。 create or replace ...
oracle 存储过程实例 oracle存储过程实例
oracle 存储过程导出excel oracle 存储过程导出excel oracle 存储过程导出excel oracle 存储过程导出excel oracle 存储过程导出excel
oracle 存储过程 unwrap 图形解密 工具
可以将SQL Server存储过程转为oracle存储过程的工具
ibatis调用oracle存储过程分页
帆软报表调用Oracle存储过程如果存储过程定义中没有参数,但是设计器中缺弹出一个storeParameter1参数的解决插件
4、开发指南:《Oracle存储过程入门指南&100+种真实业务场景存储过程实例.pdf》,可以帮助初学者系统学习。 5、资源包括“通用存储过程整理” 和 “真实业务存储过程整理” 两部分,通用适合各种系统,可以无缝隙...
oracle存储过程加密破解 0
使用java实现oracle存储过程。 共有3个小例子。实现的功能 1、无返回值的存储过程 如 insert 2、有返回值的存储过程(非列表)select id from tab 3、返回列表 如:select * from tab 顺便鄙视下csdn,作为一个it...
Oracle存储过程中使用临时表 会话级临时表 事务级临时表
oracle存储过程学习经典入门 非常好的 初学者必看
oracle 存储过程 函数 dblink 绝对对工作和平时学习有价值的资料。针对个人具体情况做修改即可使用
oracle 存储过程批量提交
oracle存储过程笔记oracle存储过程笔记oracle存储过程笔记oracle存储过程笔记oracle存储过程笔记oracle存储过程笔记oracle存储过程笔记oracle存储过程笔记oracle存储过程笔记oracle存储过程笔记
行业内Oracle存储过程最基本的开法规范,适合oracle入门小白学习
oracle 存储过程实例 oracle 存储过程实例 oracle 存储过程实例 oracle 存储过程实例
linux系统中使用shell脚本对oracle存储过程进行编译
oracle存储过程+日期+定时任务Job oracle存储过程+日期+定时任务Job oracle存储过程+日期+定时任务Job