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

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

创新互联2013年至今，是专业互联网技术服务公司，拥有项目做网站、网站建设网站策划，项目实施与项目整合能力。我们以让每一个梦想脱颖而出为使命，1280元芒市做网站,已为上家服务,为芒市各地企业和个人服务,联系电话:13518219792

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

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

1. 使用oracle的sql语句来创建：

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

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

 
 
 
    
  
  
  
  1. SQL> create or replace and compile java source named "javademo1"
    2. 
  
  
  
  2.   2  as
    3. 
  
  
  
  3.   3  import java.sql.*; 
    4. 
  
  
  
  4.   4  public class JavaDemo1 
    5. 
  
  
  
  5.   5  { 
    6. 
  
  
  
  6.   6  public static void main(String[] argv) 
    7. 
  
  
  
  7.   7  { 
    8. 
  
  
  
  8.   8  System.out.println("hello, java demo1"); 
    9. 
  
  
  
  9.   9  } 
    10. 
  
  
  
  10.  10  } 
    11. 
  
  
  
  11.  11  / 
    12. 
  
  
  
  12. 
  
  
  
  13. Java 已创建。 
    14. 
  
  
  
  14. 
  
  
  
  15. SQL> show errors java source "javademo1"
    16. 
  
  
  
  16. 没有错误。 
    17. 
  
  
  
  17. 
  
  
  
  18. SQL> create or replace procedure javademo1 
    19. 
  
  
  
  19.   2  as
    20. 
  
  
  
  20.   3  language java name 'JavaDemo1.main(java.lang.String[])'; 
    21. 
  
  
  
  21.   4  / 
    22. 
  
  
  
  22. 
  
  
  
  23. 过程已创建。 
    24. 
  
  
  
  24. 
  
  
  
  25. SQL> set serveroutput on
    26. 
  
  
  
  26. SQL> call javademo1(); 
    27. 
  
  
  
  27. 
  
  
  
  28. 调用完成。 
    29. 
  
  
  
  29. 
  
  
  
  30. SQL> call dbms_java.set_output(5000); 
    31. 
  
  
  
  31. 
  
  
  
  32. 调用完成。 
    33. 
  
  
  
  33. 
  
  
  
  34. SQL> call javademo1(); 
    35. 
  
  
  
  35. hello, java demo1 
    36. 
  
  
  
  36. 
  
  
  
  37. 调用完成。 
    38. 
  
  
  
  38. 
  
  
  
  39. SQL> call javademo1(); 
    40. 
  
  
  
  40. hello, java demo1 
    41. 
  
  
  
  41. 调用完成。
    42.

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

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

 
 
 
    
  
  
  
  1. public class OracleJavaProc 
    2. 
  
  
  
  2. { 
    3. 
  
  
  
  3.     public static void main(String[] argv) 
    4. 
  
  
  
  4.     { 
    5. 
  
  
  
  5.         System.out.println("It's a Java Oracle procedure."); 
    6. 
  
  
  
  6.     } 
    7. 
  
  
  
  7. } 
    8. 
  
  
  
  8. 
  
  
  
  9. 
  
  
  
  10. SQL> grant create any directory to scott; 
    11. 
  
  
  
  11. 
  
  
  
  12. 授权成功。 
    13. 
  
  
  
  13. 
  
  
  
  14. SQL> conn scott/tiger@iihero.oracledb 
    15. 
  
  
  
  15. 已连接。 
    16. 
  
  
  
  16. SQL> create or   replace   directory   test_dir   as  'd:/oracle'; 
    17. 
  
  
  
  17. 
  
  
  
  18. 目录已创建。 
    19. 
  
  
  
  19. 
  
  
  
  20. SQL> create or replace java class using bfile(test_dir, 'OracleJavaProc.CLASS') 
    21. 
  
  
  
  21.   2  / 
    22. 
  
  
  
  22. 
  
  
  
  23. Java 已创建。 
    24. 
  
  
  
  24. 
  
  
  
  25. SQL> create or replace procedure testjavaproc as language java name 'OracleJavaProc.main(java.lang.String[])'; 
    26. 
  
  
  
  26.   2  / 
    27. 
  
  
  
  27. 
  
  
  
  28. 过程已创建。 
    29. 
  
  
  
  29. 
  
  
  
  30. SQL> call testjavaproc(); 
    31. 
  
  
  
  31. 
  
  
  
  32. 调用完成。 
    33. 
  
  
  
  33. 
  
  
  
  34. SQL> execute testjavaproc; 
    35. 
  
  
  
  35. 
  
  
  
  36. PL/SQL 过程已成功完成。 
    37. 
  
  
  
  37. 
  
  
  
  38. SQL> set serveroutput on size 5000 
    39. 
  
  
  
  39. SQL> call dbms_java.set_output(5000); 
    40. 
  
  
  
  40. 
  
  
  
  41. 调用完成。 
    42. 
  
  
  
  42. 
  
  
  
  43. SQL> execute testjavaproc; 
    44. 
  
  
  
  44. It's a Java Oracle procedure.
    45.

3. 我推荐的一种方法，直接使用loadjava命令远程装载并创建。
先创建一个类, e.g.

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

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

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

查询一下状态：

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

测试一下存储过程：

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

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

假如要往类OracleJavaProc里添加一个存储过程方法，如何开发？
正确的步骤应该是先dropjava, 改程序，再loadjava。

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

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

如何更新呢？

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

后边的应用示例：

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

全文完！

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

分享标题：如何在Oracle中使用Java存储过程(详解)
当前地址：http://www.shufengxianlan.com/qtweb/news29/83579.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

网站营销知识

行业网站建设

成都印刷厂　　 　小程序开发　　 　轻质隔墙板　　 　ssl证书申请　　 　网站推广优化　　 　软文推广　　 　LED网站设计方案　　 　手机软件开发　　 　网站托管运营　　 　成都免费做网站公司　　 　品牌网站建设　　 　凯亚自动化控制　　 　成都VI设计　　 　成都网络推广公司　　 　手机网站制作　　 　成都企业网站建设公司　　 　Android开发　　 　手机网站　　 　自适应网页设计　　 　成都服务器托管