首先打开PL/SQL创建一张表emp_copy
drop table emp_copy;
CREATE TABLE emp_copy(empno NUMBER ,deptno NUMBER, ename VARCHAR2(40));
添加一条记录
INSERT INTO emp_copy VALUES (1, 60, 'qm');
现在我们来看下添加的那条数据
SELECT * FROM emp_copy;
![学习下oracle的存储过程增删改查操作以及java调用存储过程 学习下oracle的存储过程增删改查操作以及java调用存储过程](/default/index/img?u=aHR0cHM6Ly9waWFuc2hlbi5jb20vaW1hZ2VzLzE4Ny83NDk4NGEwNGU1MDM2NjU1ODliMGJiNzQ2ZTNjZjQxYi5wbmc=)
现在我们新建一个SQL Window窗口,写一个添加数据的存储过程
01 |
create or replace procedure sp_test8(emp_name in varchar2,dept_no in number)
|
04 |
declare max_empno number;
|
06 |
if(emp_name is null or length(emp_name)=0) then
|
14 |
select max (empno) into max_empno from emp_copy;
|
16 |
insert into emp_copy(empno,ename,deptno) values (max_empno+1,emp_name,dept_no);
|
1 |
create or replace procedure 是创表语句()里面的是输入参数
|
下面的是判断条件,emp_name 如果为空或者长度为0,则不能插入,dept_no值不为60则不能插入,主键=最大的主键+1,也就是所谓的自增,ok,这个存储过程我们写完了。运行下。
![学习下oracle的存储过程增删改查操作以及java调用存储过程 学习下oracle的存储过程增删改查操作以及java调用存储过程](/default/index/img?u=aHR0cHM6Ly9waWFuc2hlbi5jb20vaW1hZ2VzLzg5MS8xNjU3NDg5NDllMGZmZDQwNDQwODNkMGI5MGMyOTlmMy5wbmc=)
接下来我们用java来调用这个存储过程。
03 |
import java.sql.CallableStatement;
|
04 |
import java.sql.Connection;
|
05 |
import java.sql.DriverManager;
|
06 |
import java.sql.ResultSet;
|
07 |
import java.sql.SQLException;
|
08 |
import java.sql.Statement;
|
14 |
public class Sptest1 {
|
15 |
public static void main(String[] args) {
|
16 |
String driver = "oracle.jdbc.driver.OracleDriver" ;
|
17 |
String strUrl = "jdbc:oracle:thin:@127.0.0.1:1521: ORCL " ;
|
18 |
Statement stmt = null ;
|
20 |
Connection conn = null ;
|
21 |
CallableStatement cstmt = null ;
|
23 |
Class.forName(driver);
|
24 |
conn = DriverManager.getConnection(strUrl, " quanmin " , " quanmin " );
|
25 |
CallableStatement proc = null ; // 创建执行存储过程的对象
|
26 |
proc = conn.prepareCall( "{ call sp_test8(?,?) }" ); // 设置存储过程 call为关键字.
|
27 |
proc.setString( 1 , "quanmin" ); // 设置第一个输入参数
|
28 |
proc.setInt( 2 , 60 ); // 设置第二个输入参数
|
30 |
} catch (SQLException ex2) {
|
31 |
ex2.printStackTrace();
|
32 |
} catch (Exception ex2) {
|
33 |
ex2.printStackTrace();
|
45 |
} catch (SQLException ex1) {
|
然后运行这个main方法。
再次在数据库查询下结果
SELECT * FROM emp_copy;
我们会发现,数据插入成功了。
接下来和上面一样,写一个删除的操作。我就不说那么仔细了直接发存储过程
1 |
CREATE OR REPLACE PROCEDURE sp_test7(e_name IN VARCHAR2) AS
|
3 |
DELETE emp_copy WHERE ename = e_name;
|
同样的发java代码调用
package sptest;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
/**
* 删除
* @author quanmin
*
*/
public class Sptest2 {
public static void main(String[] args) {
String driver = "oracle.jdbc.driver.OracleDriver";
String strUrl = "jdbc:oracle:thin:@127.0.0.1:1521: ORCL ";
Statement stmt = null;
ResultSet rs = null;
Connection conn = null;
CallableStatement cstmt = null;
try {
Class.forName(driver);
conn = DriverManager.getConnection(strUrl, " quanmin ", " quanmin ");
CallableStatement proc = null; // 创建执行存储过程的对象
proc = conn.prepareCall("{ call sp_test7(?) }"); // 设置存储过程 call为关键字.
proc.setString(1, "quanmin"); // 设置第一个输入参数
//proc.setInt(2, 60);// 设置第二个输入参数
proc.execute();// 执行
} catch (SQLException ex2) {
ex2.printStackTrace();
} catch (Exception ex2) {
ex2.printStackTrace();
} finally {
try {
if (rs != null) {
rs.close();
if (stmt != null) {
stmt.close();
}
if (conn != null) {
conn.close();
}
}
} catch (SQLException ex1) {
}
}
}
}
查询下数据库,发现刚刚之前添加的一条数据已经没有了。
接下来发更新的存储过程
1 |
CREATE OR REPLACE PROCEDURE sp_test9(emp_no in number,emp_name IN VARCHAR2) AS
|
3 |
UPDATE emp_copy SET ename = emp_name where empno=emp_no;
|
java调用存储过程
package sptest;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
/**
* 更新
* @author quanmin
*
*/
public class Sptest3 {
public static void main(String[] args) {
String driver = "oracle.jdbc.driver.OracleDriver";
String strUrl = "jdbc:oracle:thin:@127.0.0.1:1521: ORCL ";
Statement stmt = null;
ResultSet rs = null;
Connection conn = null;
CallableStatement cstmt = null;
try {
Class.forName(driver);
conn = DriverManager.getConnection(strUrl, " quanmin ", " quanmin ");
CallableStatement proc = null; // 创建执行存储过程的对象
proc = conn.prepareCall("{ call sp_test9(?,?) }"); // 设置存储过程 call为关键字.
proc.setInt(1, 1); // 设置第一个输入参数
proc.setString(2, "张三");// 设置第二个输入参数
proc.execute();// 执行
} catch (SQLException ex2) {
ex2.printStackTrace();
} catch (Exception ex2) {
ex2.printStackTrace();
} finally {
try {
if (rs != null) {
rs.close();
if (stmt != null) {
stmt.close();
}
if (conn != null) {
conn.close();
}
}
} catch (SQLException ex1) {
}
}
}
}
查看数据库发现刚刚的qm变成了“张三”![学习下oracle的存储过程增删改查操作以及java调用存储过程 学习下oracle的存储过程增删改查操作以及java调用存储过程](/default/index/img?u=aHR0cHM6Ly9waWFuc2hlbi5jb20vaW1hZ2VzLzgwNC9kYjViOGMxNThkNzhjNjlmNWM4NjM0MWM3ODE2ZDRkYy5wbmc=)
补充下还有查找所有的存储过程
create or replace procedure sp_test11
/*
*存储过程实例
*/
is
cursor var_c is SELECT * FROM emp_copy;
Begin
for temp in var_c loop
dbms_output.put_line('ename = '||temp.ename);
end loop;
end;
好了不说这么多了,我要继续去学了