–命令行创建存储
DELIMITER //
create procedure test()
begin
select * from student4;
end
//
–命令行调用存储
call test();
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
/**
*获取数据库连接的类
*/
class ConnectDb {
public static Connection getConnection(){
Connection conn = null;
PreparedStatement preparedstatement = null;
try {
Class.forName(“org.gjt.mm.mysql.Driver”).newInstance();
String dbname = “test”;
String url =”jdbc:mysql://localhost/”+dbname+”?user=root&password=root&useUnicode=true&characterEncoding=8859_1″ ;
conn= DriverManager.getConnection(url);
} catch (Exception e) {
e.printStackTrace();
}
return conn;
}
}
import java.sql.*;
/**
* 调用带有输入参数的存储过程，三种情况例子
*/
public class ProcedureTest {
public static void main(String[] args) {
//callIn(111);
//callOut();
callResult();
}
/**
* 1.调用带有输入参数的存储过程
* @param in stored procedure input parameter value
*/
public static void callIn(int in){
//获取连接
Connection conn = ConnectDb.getConnection();
CallableStatement cs = null;
try {
//可以直接传入参数
//cs = conn.prepareCall(“{call sp1(1)}”);
//也可以用问号代替
cs = conn.prepareCall(“{call sp1(?)}”);
//设置第一个输入参数的值为110
cs.setInt(1, in);
cs.execute();
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if(cs != null){
cs.close();
}
if(conn != null){
conn.close();
}
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
/**
* 2.调用带有输出参数的存储过程
*
*/
public static void callOut() {
Connection conn = ConnectDb.getConnection();
CallableStatement cs = null;
try {
cs = conn.prepareCall(“{call sp2(?)}”);
//第一个参数的类型为Int
cs.registerOutParameter(1, Types.INTEGER);
cs.execute();
//得到第一个值
int i = cs.getInt(1);
System.out.println(i);
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if(cs != null){
cs.close();
}
if(conn != null){
conn.close();
}
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
/**
* 3.调用输出结果集的存储过程
*/
public static void callResult(){
Connection conn = ConnectDb.getConnection();
CallableStatement cs = null;
ResultSet rs = null;
try {
cs = conn.prepareCall(“{call sp6()}”);
rs = cs.executeQuery();
//循环输出结果
while(rs.next()){
System.out.println(rs.getString(1));
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if(rs != null){
rs.close();
}
if(cs != null){
cs.close();
}
if(conn != null){
conn.close();
}
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
}
写好存储过程后,在JAVA里可以call了.
java.sql.CallableStatement sp=con.prepareCall(“{call ss.get_hotline(?)}”);
//用CallableStatement对象调用存储过程
sp.registerOutParameter(1,oracle.jdbc.OracleTypes.CURSOR);
//注册存储过程的输出参数,oracle.jdbc.OracleTypes.CURSOR也可以写成-10
sp.execute(); //执行存储过程
java.sql.ResultSet rs=(java.sql.ResultSet)sp.getObject(1); //获取返回的对象,再将对象转为记录集
while(rs.next()){
Syste
在oracle中,在package下的存储过程带上包名可直接执行.
在JAVA中也一样,call的时候加个包名即可获得句柄.
但在返回游标中的procedure时切记不能直接返回ResultSet,虚拟机会将返回的参数做为一个对象集合来处理,它不会将游标做为记录集来处理.只有将对象转化成记录集时才可以直接取数据.m.out.println(rs.getString(1));
}
存储过程结合游标：
1、查看某个订单的合计
DELIMITER //
drop procedure if exists ordertotal;
CREATE PROCEDURE ordertotal
(in onumber int,
in taxable boolean,
out ototal decimal(8,2)
)
begin
declare total decimal(8,2);
declare taxrate int default 6;
select sum(item_price*quantity) from orderitems where order_num=onumber
into total;
if taxable then
select total+(total/100*taxrate) into total;
end if;
select total into ototal;
end;//
2、其中创建一个表，调用1中的存储过程，把结果写入到表中。
drop procedure if exists processorders;
create procedure processorders()
begin
declare done boolean default 0;
declare o int;
declare t decimal(8,2);
declare ordernumbers cursor
for
select order_num from orders;
declare continue handler for sqlstate ‘02000’ set done=1;
create table if not exists ordertotals(order_num int, total decimal(8,2));
open ordernumbers ;
repeat
fetch ordernumbers into o;
call ordertotal (o,1,t);
insert into ordertotals(order_num,total)
values(o,t);
until done end repeat;
close ordernumbers;
end;//
mysql> call processorders//
mysql> select * from ordertotals;//
+———–+———+
| order_num | total |
+———–+———+
| 20005 | 158.86 |
| 20009 | 40.78 |
| 20006 | 58.30 |
| 20007 | 1060.00 |
| 20008 | 132.50 |
| 20008 | 132.50 |
+———–+———+
6 rows in set (0.00 sec)
mysql> DELIMITER ;
存储过程综合实例二：（包含事务,参数,嵌套调用,游标,循环等）
drop procedure if exists pro_rep_shadow_rs;
delimiter |
———————————-
— rep_shadow_rs
— 用来处理信息的增加，更新和删除
— 每次只更新上次以来没有做过的数据
— 根据不同的标志位
— 需要一个输出的参数，
— 如果返回为0，则调用失败，事务回滚
— 如果返回为1，调用成功，事务提交
—
— 测试方法
— call pro_rep_shadow_rs(@rtn);
— select @rtn;
———————————-
create procedure pro_rep_shadow_rs(out rtn int)
begin
— 声明变量，所有的声明必须在非声明的语句前面
declare iLast_rep_sync_id int default -1;
declare iMax_rep_sync_id int default -1;
— 如果出现异常，或自动处理并rollback,但不再通知调用方了
— 如果希望应用获得异常，需要将下面这一句，以及启动事务和提交事务的语句全部去掉
declare exit handler for sqlexception rollback;
— 查找上一次的
select eid into iLast_rep_sync_id from rep_de_proc_log where tbl=’rep_shadow_rs’;
— 如果不存在，则增加一行
if iLast_rep_sync_id=-1 then
insert into rep_de_proc_log(rid,eid,tbl) values(0,0,’rep_shadow_rs’);
set iLast_rep_sync_id = 0;
end if;
— 下一个数字
set iLast_rep_sync_id=iLast_rep_sync_id+1;
— 设置默认的返回值为0：失败
set rtn=0;
— 启动事务
start transaction;
— 查找最大编号
select max(rep_sync_id) into iMax_rep_sync_id from rep_shadow_rs;
— 有新数据
if iMax_rep_sync_id>=iLast_rep_sync_id then
— 调用
call pro_rep_shadow_rs_do(iLast_rep_sync_id,iMax_rep_sync_id);
— 更新日志
update rep_de_proc_log set rid=iLast_rep_sync_id,eid=iMax_rep_sync_id where tbl=’rep_shadow_rs’;
end if;
— 运行没有异常，提交事务
commit;
— 设置返回值为1
set rtn=1;
end;
|
delimiter ;
drop procedure if exists pro_rep_shadow_rs_do;
delimiter |
———————————
— 处理指定编号范围内的数据
— 需要输入2个参数
— last_rep_sync_id 是编号的最小值
— max_rep_sync_id 是编号的最大值
— 无返回值
———————————
create procedure pro_rep_shadow_rs_do(last_rep_sync_id int, max_rep_sync_id int)
begin
declare iRep_operationtype varchar(1);
declare iRep_status varchar(1);
declare iRep_Sync_id int;
declare iId int;
— 这个用于处理游标到达最后一行的情况
declare stop int default 0;
— 声明游标
declare cur cursor for select id,Rep_operationtype,iRep_status,rep_sync_id from rep_shadow_rs where rep_sync_id between last_rep_sync_id and max_rep_sync_id;
— 声明游标的异常处理，设置一个终止标记
declare CONTINUE HANDLER FOR SQLSTATE ‘02000’ SET stop=1;
— 打开游标
open cur;
— 读取一行数据到变量
fetch cur into iId,iRep_operationtype,iRep_status,iRep_Sync_id;
— 这个就是判断是否游标已经到达了最后
while stop <> 1 do
— 各种判断
if iRep_operationtype=’I’ then
insert into rs0811 (id,fnbm) select id,fnbm from rep_shadow_rs where rep_sync_id=iRep_sync_id;
elseif iRep_operationtype=’U’ then
begin
if iRep_status=’A’ then
insert into rs0811 (id,fnbm) select id,fnbm from rep_shadow_rs where rep_sync_id=iRep_sync_id;
elseif iRep_status=’B’ then
delete from rs0811 where id=iId;
end if;
end;
elseif iRep_operationtype=’D’ then
delete from rs0811 where id=iId;
end if;
— 读取下一行的数据
fetch cur into iId,iRep_operationtype,iRep_status,iRep_Sync_id;
end while; — 循环结束
close cur; — 关闭游标
end;
欢迎大家阅读《java调用mysql储存_mysql》,跪求各位点评，by 搞代码
转载请注明原文链接：java调用mysql储存_mysql
