Oracle Java存储过程访问异构数据库的方案


  本文标签:Oracle Java

  以下的文章主要介绍的是如何用Oracle Java的存储过程来访问异构数据库的实际操作,我们都知道在通常的企业实际应用中,Oracle数据库的类型可能会有多种,这些异构数据库之间的互连往往成为某个应用的瓶颈  。

  解决的办法有多种,一是透过应用程序作为桥梁,在异构数据库之间牵线搭桥;二是数据库厂商提供的解决方案,比如SQL Server的Link Server, Oracle的Transparent Gateway技术;三是 通过数据库的应用扩展接口,例如Oracle的PL/SQL允许透过Java扩展访问外部数据库  。

  本文着眼于第三点,以Oracle连接SQL Server为例,探讨如何利用Java编写PL/SQL访问SQL Server,这点对于那些需要在非WINDOWS平台下访问SQL Server的Oracle应用特别有意义  。

  本文中系统配置如下  。

  一、硬件及操作系统

  Dell Intel Xeon Server + Windows2000 Server

  二、数据库环境

  Oracle 8.1.7

  三、安装

  欲使Oracle支持Java,必须在Oracle上安装Jserver组件  。在安装Oracle软件的时候,如果选择典型安装,Jserver是默认安装的,如果选择自定义安装,记得选择Jserver组件  。还有另一种方法可以手工安装Jserver.办法是:

  进入Oracle安装目录下的\javavm\install目录,以sys用户的身份执行initjvm.sql,这个脚本会为数据库配置一个Java运行环境,同时会把基本的java类库装载到数据库中去  。建议在执行此脚本之前,先阅读\javavm\readme.txt文件,里面包括安装前对数据库某些配置的必要修改的说明,以及对脚本执行出错的处理描述  。

  脚本执行时间大约10分钟,如果失败可以重新执行  。

  在脚本执行完毕后,用DBA Studio工具可以看到多了Jserver这个东西  。

  四、权限赋予

  要能在Oracle中执行Java存储过程,需要一个javauserpriv的角色,这个角色在安装Jserver后会自动创建,将此角色赋给各个Oracle的使用账号  。

  五、编写Oracle Java存储过程

  1、 在本地机器上编写一个Java类  。

  

  1. public class TEST  
  2. {  
  3. public static void main (String args[])   
  4. {  
  5. System.out.println("HELLO THIS iS A JAVA PROCEDURE");  
  6. }  
  7. }  
  8. xml:namespace prefix = o ns = "urn:schemas-microsoft-com:office:office" /> 

  2、 用loadjava指令将写好的java类文件上传到数据库中  。

  例如:C:\>loadjava –u test/oracle@mytest -o –v –r d:\TEST.java

  当然,除了上载.java文件,也可以上载.class/.jar/.properties文件,上载后的文件在数据库中会以Object的形式存在.

  文件若有改动,可以重新上载,会将以前的版本覆盖掉  。

  3、 生成声明接口

  上载的java类需要发布成一个可供调用的接口,这些接口可以是Store Procesure/Trrigger/Function 等  。

  1. SQL>create or replace procedure test_java   
  2. as language java   
  3. name TEST.main(java.lang.String[]);  

  4、 测试

  1. SQL> set serveroutput on size 5000  
  2. SQL> call dbms_java.set_output(5000); 

  调用完成  。

  1. SQL> execute test_java;  
  2. HELLO THIS iS A JAVA PROCEDURE 

  PL/SQL 过程已成功完成  。

  1. SQL> call test_java();  
  2. HELLO THIS iS A JAVA PROCEDURE 

  调用完成  。

  5、 以上是一个简单的java 类,其实如果要在Oracle中访问到非Oracle的数据库,只

  要在java 类中实现访问非Oracle数据库就可以了  。

  

  1. public static String getStringFomSql(){  
  2. String strResult ="";  
  3. Connection conn = null;  
  4. Statement stmt = null;  
  5. ResultSet rs = null;  
  6. try {  
  7. Class.forName("com.inet.tds.TdsDriver").newInstance();   
  8. String url="jdbc:inetdae7:10.24.09.192:1433?database=pubs";   

  

  pubs为你的数据库的

  

  1. String user="sa";   
  2. String password="123";   
  3. connDriverManager.getConnection(url,user,password);   
  4. String sql="select top 1 dtype,dname from test";   
  5. stmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);   
  6. rs=stmt.executeQuery(sql);   
  7. if( rs.next()){  
  8. strResult = "The result from sql server is:dtype->" + rs.getString("dtype") + " dname->" + rs.getString("dname");  
  9. }  
  10. } catch (InstantiationException e) {  
  11. TODO Auto-generated catch block  
  12. e.printStackTrace();  
  13. strResult = "operator fail in InstantiationException";  
  14. } catch (IllegalAccessException e) {  
  15. TODO Auto-generated catch block  
  16. e.printStackTrace();  
  17. strResult = "operator fail in IllegalAccessException";  
  18. } catch (ClassNotFoundException e) {  
  19. TODO Auto-generated catch block  
  20. e.printStackTrace();  
  21. strResult = "operator fail in ClassNotFoundException";  
  22. } catch (SQLException e) {  
  23. TODO Auto-generated catch block  
  24. e.printStackTrace();  
  25. strResult = "operator fail in SQLException";  
  26. }  
  27. finally{  
  28. try {  
  29. rs.close();  
  30. conn.close();  
  31. } catch (SQLException e1) {  
  32. e1.printStackTrace();  
  33. }  
  34. }  
  35. return strResult;  
  36. }  

  

  
值得注意的一点是,通过java存储访问SQL Server,如果返回一个结果集,在9i以下的Oracle版本是没有对应的数据类型可以转换的,一个可以变通的办法是要么返回一个字符串,要么将返回的结果集存放到Oracle中的表里  。这样做是为了方便那些非Windows平台下无法直接访问SQL Server的程序  。

  六、外部程序调用Oracle java存储过程

  调用java存储过程的方法跟调用一般的Oracle Java存储过程的方法是一样的.