如何在Oracle中使用Java存储过程(详解)

简介:
其实,这篇短文,我早就应该写了。因为, Java存储过程今后在各大 数据库厂商中越来越流行,功能也越来越强大。这里以 Oracle为例,介绍一下java存储过程的具体用法。

  一、如何创建java存储过程?

  通常有三种方法来创建java存储过程。

  1、使用oracle的sql语句来创建:

  e.g. 使用create or replace and compile java source named "<name>" as

  后边跟上java源程序。要求类的方法必须是public static的,才能用于存储过程。

  1. SQL> create or replace and compile java source named "javademo1" 
  2.   2  as 
  3.   3  import java.sql.*;  
  4.   4  public class JavaDemo1  
  5.   5  {  
  6.   6  public static void main(String[] argv)  
  7.   7  {  
  8.   8  System.out.println("hello, java demo1");  
  9.   9  }  
  10.  10  }  
  11.  11  /  

  12. Java 已创建。  

  13. SQL> show errors java source "javademo1" 
  14. 没有错误。  

  15. SQL> create or replace procedure javademo1  
  16.   2  as 
  17.   3  language java name 'JavaDemo1.main(java.lang.String[])';  
  18.   4  /  

  19. 过程已创建。  

  20. SQL> set serveroutput on 
  21. SQL> call javademo1();  

  22. 调用完成。  

  23. SQL> call dbms_java.set_output(5000);  

  24. 调用完成。  

  25. SQL> call javademo1();  
  26. hello, java demo1  

  27. 调用完成。  

  28. SQL> call javademo1();  
  29. hello, java demo1  
  30. 调用完成。

  2、使用外部class文件来装载创建

  e.g. 这里既然用到了外部文件,必然要将class文件放到oracle Server的某一目录下边。

  1. public class OracleJavaProc  
  2. {  
  3.     public static void main(String[] argv)  
  4.     {  
  5.         System.out.println("It's a Java Oracle procedure.");  
  6.     }  
  7. }  


  8. SQL> grant create any directory to scott;  

  9. 授权成功。  

  10. SQL> conn scott/tiger@iihero.oracledb  
  11. 已连接。  
  12. SQL> create or   replace   directory   test_dir   as  'd:/oracle';  

  13. 目录已创建。  

  14. SQL> create or replace java class using bfile(test_dir, 'OracleJavaProc.CLASS')  
  15.   2  /  

  16. Java 已创建。  

  17. SQL> create or replace procedure testjavaproc as language java name 'OracleJavaProc.main(java.lang.String[])';  
  18.   2  /  

  19. 过程已创建。  

  20. SQL> call testjavaproc();  

  21. 调用完成。  

  22. SQL> execute testjavaproc;  

  23. PL/SQL 过程已成功完成。  

  24. SQL> set serveroutput on size 5000  
  25. SQL> call dbms_java.set_output(5000);  

  26. 调用完成。  

  27. SQL> execute testjavaproc;  
  28. It's a Java Oracle procedure.

  3、我推荐的一种方法,直接使用loadjava命令远程装载并创建。

  先创建一个类, e.g.

  1. import java.sql.*;  
  2. import oracle.jdbc.*;  
  3.  
  4. public class OracleJavaProc {  
  5.  
  6.    //Add a salgrade to the database.  
  7.    public static void addSalGrade(int grade, int losal, int hisal) {  
  8.  
  9.       System.out.println("Creating new salgrade for EMPLOYEE...");  
  10.  
  11.       try {  
  12.          Connection conn =  
  13.             DriverManager.getConnection("jdbc:default:connection:");  
  14.  
  15.          String sql =  
  16.             "INSERT INTO salgrade " +  
  17.             "(GRADE,LOSAL,HISAL) " +  
  18.             "VALUES(?,?,?)";  
  19.          PreparedStatement pstmt = conn.prepareStatement(sql);  
  20.          pstmt.setInt(1,grade);  
  21.          pstmt.setInt(2,losal);  
  22.          pstmt.setInt(3,hisal);  
  23.          pstmt.executeUpdate();  
  24.          pstmt.close();  
  25.          }  
  26.       catch(SQLException e) {  
  27.          System.err.println("ERROR! Adding Salgrade: "   
  28.            + e.getMessage());  
  29.          }  
  30.    }  
  31. }

  使用loadjava命令将其装载到服务器端并编译:

  1. D:eclipse3.1workspacedbtest>loadjava -u scott/tiger@iihero.oracledb -v -resolve Or  
  2. acleJavaProc.java  
  3. arguments: '-u' 'scott/tiger@iihero.oracledb '-v' '-resolve' 'OracleJavaProc.java'  
  4. creating : source OracleJavaProc  
  5. loading  : source OracleJavaProc  
  6. resolving: source OracleJavaProc

  查询一下状态:

  1. 连接到:  
  2. Oracle9i Enterprise Edition Release 9.2.0.1.0 - Production  
  3. With the Partitioning, OLAP and Oracle Data Mining options  
  4. JServer Release 9.2.0.1.0 - Production  
  5.  
  6. SQL> SELECT object_name, object_type, status FROM user_objects WHERE object_type LIKE 'JAVA%';  
  7.  
  8. OBJECT_NAME  
  9. --------------------------------------------------------------------------------  
  10.  
  11. OBJECT_TYPE                          STATUS  
  12. ------------------------------------ --------------  
  13. OracleJavaProc  
  14. JAVA CLASS                           VALID  
  15.  
  16. OracleJavaProc  
  17. JAVA SOURCE                          VALID

  测试一下存储过程:

  1. SQL> create or replace procedure add_salgrade(id number, losal number, hisal num  
  2. ber) as language java name 'OracleJavaProc.addSalGrade(int, int, int)';  
  3.   2  /  
  4.  
  5. 过程已创建。  
  6.  
  7. SQL> set serveroutput on size 2000  
  8. SQL> call dbms_java.set_output(2000);  
  9.  
  10. 调用完成。  
  11.  
  12. SQL> execute add_salgrade(6, 10000, 15000);  
  13. Creating new salgrade for EMPLOYEE...  
  14.  
  15. PL/SQL 过程已成功完成。  
  16.  
  17. SQL> select * from salgrade where grade=6;  
  18.  
  19.      GRADE      LOSAL      HISAL  
  20. ---------- ---------- ----------  
  21.          6      10000      15000

  二、如何更新你已经编写的java存储过程?

  假如要往类OracleJavaProc里添加一个存储过程方法,如何开发?

  正确的步骤应该是先dropjava, 改程序,再loadjava。

  e.g.修改OracleJavaProc类内容如下:

  1. import java.sql.*;  
  2. import oracle.jdbc.*;  
  3.  
  4. public class OracleJavaProc {  
  5.  
  6.    // Add a salgrade to the database.  
  7.    public static void addSalGrade(int grade, int losal, int hisal) {  
  8.  
  9.       System.out.println("Creating new salgrade for EMPLOYEE...");  
  10.  
  11.       try {  
  12.          Connection conn =  
  13.             DriverManager.getConnection("jdbc:default:connection:");  
  14.  
  15.          String sql =  
  16.             "INSERT INTO salgrade " +  
  17.             "(GRADE,LOSAL,HISAL) " +  
  18.             "VALUES(?,?,?)";  
  19.          PreparedStatement pstmt = conn.prepareStatement(sql);  
  20.          pstmt.setInt(1,grade);  
  21.          pstmt.setInt(2,losal);  
  22.          pstmt.setInt(3,hisal);  
  23.          pstmt.executeUpdate();  
  24.          pstmt.close();  
  25.          }  
  26.       catch(SQLException e) {  
  27.          System.err.println("ERROR! Adding Salgrade: "   
  28.            + e.getMessage());  
  29.          }  
  30.    }  
  31.      
  32.    public static int getHiSal(int grade)  
  33.    {  
  34.     try {  
  35.         Connection conn =  
  36.           DriverManager.getConnection("jdbc:default:connection:");  
  37.         String sql = "SELECT hisal FROM salgrade WHERE grade = ?";  
  38.         PreparedStatement pstmt = conn.prepareStatement(sql);pstmt.setInt(1, grade);  
  39.         ResultSet rset = pstmt.executeQuery();  
  40.         int res = 0;  
  41.         if (rset.next())  
  42.         {  
  43.             res = rset.getInt(1);  
  44.         }  
  45.         rset.close();  
  46.         return res;  
  47.        }  
  48.     catch (SQLException e)   
  49.     {  
  50.         System.err.println("ERROR! Querying Salgrade: "   
  51.            + e.getMessage());  
  52.           return -1;  
  53.     }      
  54.    }  
  55.         
  56. }

  如何更新呢?

  1. D:eclipse3.1workspacedbtest>dropjava -u scott -v OracleJavaProc  
  2.  
  3. D:/tiger@iihero.oracledbeclipse3.1workspacedbtest>loadjava -u scott -v -resolve Or 
  4. acleJavaProc/tiger@iihero.oracledb.java  
  5. arguments: '-u' 'scott/tiger@iihero.oracledb' '-v' '-resolve' 'OracleJavaProc.java' 
  6. creating : source OracleJavaProc  
  7. loading  : source OracleJavaProc  
  8. resolving: source OracleJavaProc

  后边的应用示例:

  1. SQL> create or replace function query_hisal(grade number) return number as langu  
  2. age java name 'OracleJavaProc.getHiSal(int) return int';  
  3.   2  /  
  4.  
  5. 函数已创建。  
  6.  
  7. SQL> set serveroutput on size 2000  
  8. SQL> call dbms_java.set_output(2000);  
  9.  
  10. 调用完成。  
  11. SQL> select query_hisal(5) from dual;  
  12.  
  13. QUERY_HISAL(5)  
  14. --------------  
  15.           9999

  全文完!

  用法个人见解:不要手动drop java source,不要手动drop procedure。


本文出自seven的测试人生公众号最新内容请见作者的GitHub页:http://qaseven.github.io/

目录
相关文章
|
1月前
|
存储 SQL Oracle
Oracle系列十五:存储过程
Oracle系列十五:存储过程
|
3月前
|
存储 Oracle Java
Java调用存储过程小结
Java调用存储过程小结
|
2月前
|
存储 算法 Java
[Java]散列表的数据结构以及对象在JVM堆中的存储过程
[Java]散列表的数据结构以及对象在JVM堆中的存储过程
52 1
[Java]散列表的数据结构以及对象在JVM堆中的存储过程
|
4月前
|
SQL Oracle 关系型数据库
java往oracle存clob类型的值时,字符长度过长怎么办?
java往oracle存clob类型的值时,字符长度过长怎么办?
70 1
|
3月前
|
存储 Java 数据库
JAVAEE框架数据库技术之13_oracle 之PLSQL技术及存储过程和函数(二)
JAVAEE框架数据库技术之13_oracle 之PLSQL技术及存储过程和函数
38 0
|
3月前
|
存储 SQL Java
JAVAEE框架数据库技术之13_oracle 之PLSQL技术及存储过程和函数(一)
JAVAEE框架数据库技术之13_oracle 之PLSQL技术及存储过程和函数
35 0
|
4月前
|
存储 SQL Oracle
|
5月前
|
SQL 存储 Oracle
Oracle如何使用PL/SQL调试存储过程
Oracle如何使用PL/SQL调试存储过程
112 0
|
23天前
|
存储 SQL 关系型数据库
轻松入门MySQL:加速进销存!利用MySQL存储过程轻松优化每日销售统计(15)
轻松入门MySQL:加速进销存!利用MySQL存储过程轻松优化每日销售统计(15)
|
1月前
|
存储 关系型数据库 MySQL
Mysql基础第二十六天,使用存储过程
Mysql基础第二十六天,使用存储过程
28 0
Mysql基础第二十六天,使用存储过程

推荐镜像

更多