qileilove

blog已经转移至github,大家请访问 http://qaseven.github.io/

如何在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。

posted on 2012-04-19 10:00 顺其自然EVO 阅读(182) 评论(0)  编辑  收藏 所属分类: 数据库


只有注册用户登录后才能发表评论。


网站导航:
 
<2012年4月>
25262728293031
1234567
891011121314
15161718192021
22232425262728
293012345

导航

统计

常用链接

留言簿(55)

随笔分类

随笔档案

文章分类

文章档案

搜索

最新评论

阅读排行榜

评论排行榜