星期二, 三月 01, 2005

Oracle 中的java 存储过程调用RMI


这段时间一直在研究 Java 和 Oracle ,去年读了Kuassi Mensah 《利用Java存储过程简化数据库操作》 ，做的一个 RMI 调用方面的实验,现在贴上来给讨论一下……


前言

数据驱动的EJB调用

在数据驱动体系结构中，商务逻辑调用可以作为数据库操作（如插入、更新或删除）的结果来触发。实现该数据逻辑的Java存储过程可以被声明为数据库触发器，用以调用运行于中间层J2EE应用服务器的EJB。EJB的调用既可以采用J2EE1.3兼容的服务器通过Interoperable Inter-ORB Protocol（IIOP）标准远程方法调用（remote method invocation，RMI）实现，也可以通过销售商特定的传输协议（如Oracle9iAS/Oc4J的ORMI，或者通过BEA WebLogic的T3）用RMI来实现。每个应用服务器提供商在提供基于IIOP的RMI，以提供互操作性的同时，都有其自己优化的协议。Oracle9iAS同时支持基于IIOP的RMI调用和基于ORMI协议的RMI调用。

                      摘自 Kuassi Mensah《利用Java存储过程简化数据库操作》

   http://www.oracle.com/global/cn/oramag/oracle/03-jan/o13java.html

 

在数据库端实现 RMI （远程方法调用）的Client 端

服务器端

接口 SimpleRMIInterface.java

package rmi;

public interface SimpleRMIInterface extends java.rmi.Remote

{

  public java.util.Date getDate() throws java.rmi.RemoteException;

}

  接口的具体实现  SimpleRMIImpl.java

package rmi;

import java.rmi.*;

import java.rmi.server.UnicastRemoteObject;

public class SimpleRMIImpl extends UnicastRemoteObject implements SimpleRMIInterface

{

  public SimpleRMIImpl(String name) throws RemoteException {

    super();

    try {

      Naming.rebind(name, this);

    }

    catch (Exception e) {

      if (e instanceof RemoteException)

        throw (RemoteException)e;

      else

        throw new RemoteException(e.getMessage());

    }

  }

  public java.util.Date getDate() {

    System.out.println("SimpleRMIImpl.getDate()");

    return new java.util.Date();

  }

}

Server 主程序 SimpleRMIServer.java

package rmi;

import java.rmi.*;

import java.rmi.server.UnicastRemoteObject;

public class SimpleRMIServer

{

  public static void main(String[] argv) {

    System.setSecurityManager(new RMISecurityManager());

    try {

      SimpleRMIImpl implementation = new SimpleRMIImpl("SimpleRMIImpl");

      System.out.println("SimpleRMIImpl ready");

    }

    catch (Exception e) {

      System.out.println("Exception occurred: " + e);

    }

  }

}

自动生成的 Stub 文件 SimpleRMIImpl_Stub.java

// Stub class generated by rmic, do not edit.

// Contents subject to change without notice.

package rmi;

public final class SimpleRMIImpl_Stub

    extends java.rmi.server.RemoteStub

    implements SimpleRMIInterface, java.rmi.Remote

{

    private static final long serialVersionUID = 2;

    private static java.lang.reflect.Method $method_getDate_0;

    static {

       try {

           $method_getDate_0 =SimpleRMIInterface.class.getMethod("getDate", new java.lang.Class[] {});

       } catch (java.lang.NoSuchMethodException e) {

           throw new java.lang.NoSuchMethodError(

              "stub class initialization failed");

       }

    }

    // constructors

    public SimpleRMIImpl_Stub(java.rmi.server.RemoteRef ref) {

       super(ref);

    }

    // methods from remote interfaces

    // implementation of getDate()

    public java.util.Date getDate()

       throws java.rmi.RemoteException

    {

       try {

           Object $result = ref.invoke(this, $method_getDate_0, null, -1017285815713287420L);

           return ((java.util.Date) $result);

       } catch (java.lang.RuntimeException e) {

           throw e;

       } catch (java.rmi.RemoteException e) {

           throw e;

       } catch (java.lang.Exception e) {

           throw new java.rmi.UnexpectedException("undeclared checked exception", e);

       }

    }

}

Oracle 作为 RMI 的客户端必须实现 3个 Java 的存储过程

1、simplermiinterface 接口

create or replace and compile java source named simplermiinterface as
package Client;
public interface SimpleRMIInterface extends java.rmi.Remote
{
  public java.util.Date getDate() throws java.rmi.RemoteException;
}

2、Client java 存储过程

create or replace and compile java source named simplermiclient as
package Client;
import java.rmi.*;
import java.rmi.registry.*;
import java.rmi.server.*;
import java.util.Date;

public class SimpleRMIClient
{

  public static void main(String[] argv) {
    String serverName = "";
    System.setSecurityManager(new RMISecurityManager());
    if (argv.length != 1) {
      try {
        serverName = java.net.InetAddress.getLocalHost().getHostName();
      }
      catch(Exception e) {
        e.printStackTrace();
      }
    }
    else {
      serverName = argv[0];
    }

    if (serverName == "") {
      System.out.println("usage: java SimpleRMIClient ");
      System.exit(0);
    }

    try {
      //bind server object to object in client
      SimpleRMIInterface myServerObject = (SimpleRMIInterface) Naming.lookup("//172.16.48.67/SimpleRMIImpl");

      //invoke method on server object
      Date d = myServerObject.getDate();
      System.out.println("Date on server is " + d);
    }
    catch(Exception e) {
      System.out.println("Exception occured: " + e);
      System.exit(0);
    }
    System.out.println("RMI connection successful");
  }
 
  public static String rmicaller() {
    String retval = "";
    System.setSecurityManager(new RMISecurityManager());


     try {
      //bind server object to object in client
      SimpleRMIInterface myServerObject = (SimpleRMIInterface) Naming.lookup("//172.16.48.67/SimpleRMIImpl");

      //invoke method on server object
      Date d = myServerObject.getDate();
      retval="Date on server is " + d;
    }
    catch(Exception e) {
      retval="Exception occured: " + e;
    }
    retval+="----RMI connection successful";
    return retval;
  } 
}


Oracle 中的 simplermiimpl_stub 存储过程

create or replace and compile java source named simplermiimpl_stub as
package rmi;

public final class SimpleRMIImpl_Stub
    extends java.rmi.server.RemoteStub
    implements Client.SimpleRMIInterface, java.rmi.Remote
{
    private static final long serialVersionUID = 2;
   
    private static java.lang.reflect.Method $method_getDate_0;
   
    static {
    try {
        $method_getDate_0 = Client.SimpleRMIInterface.class.getMethod("getDate", new java.lang.Class[] {});
    } catch (java.lang.NoSuchMethodException e) {
        throw new java.lang.NoSuchMethodError(
       "stub class initialization failed");
    }
    }
   
    // constructors
    public SimpleRMIImpl_Stub(java.rmi.server.RemoteRef ref) {
    super(ref);
    }
   
    // methods from remote interfaces
   
    // implementation of getDate()
    public java.util.Date getDate()
    throws java.rmi.RemoteException
    {
    try {
        Object $result = ref.invoke(this, $method_getDate_0, null, -1017285815713287420L);
        return ((java.util.Date) $result);
    } catch (java.lang.RuntimeException e) {
        throw e;
    } catch (java.rmi.RemoteException e) {
        throw e;
    } catch (java.lang.Exception e) {
        throw new java.rmi.UnexpectedException("undeclared checked exception", e);
    }
    }
}


最后创建一个 函数或者过程 来返回结果，

CREATE OR REPLACE FUNCTION rmicaller RETURN VARCHAR2 AS
  LANGUAGE JAVA NAME 'Client.SimpleRMIClient.rmicaller () return java.lang.String';


调用结果如下：

Date on server is Fri Sep 24 2004----RMI connection successful

CREATE OR REPLACE PROCEDURE ClientMain AS    language java name              'Client.SimpleRMIClient.main(java.lang.String [])';

如果是 System.out.print 将打印到数据库中的 udump 下的 trc 文件中

例如：
Dump file d:oracleadminora92udumpora92_ora_2384.trc

Fri Sep 24 2004

ORACLE V9.2.0.1.0 - Production vsnsta=0

vsnsql=12 vsnxtr=3

Windows 2000 Version 5.0 Service Pack 2, CPU type 586

Oracle9i Enterprise Edition Release 9.2.0.1.0 - Production

With the Partitioning, OLAP and Oracle Data Mining options

JServer Release 9.2.0.1.0 - Production

Windows 2000 Version 5.0 Service Pack 2, CPU type 586

Instance name: ora92

Redo thread mounted by this instance: 1

Oracle process number: 35

Windows thread id: 2384, image: ORACLE.EXE

作者 macrozeng ( java ) :: 最新回复 (11) :: 静态链接网址 :: 引用 (0)

order phentermine phentermine online [回复]

Phenrelationshipine [url=http://www.ps3forums.com/member.php?u=97851#aboutme]phentermine no prescription[/url] medicine >>> tuppence inexpensively Phenrelationshipine recipe Now! Recommended Dosage Of phenrelationshipine, Effects fancy Side title phenrelationshipine. at broad clique [url=http://www.ps3forums.com/member.php?u=97851#aboutme]phentermine no prescription[/url] comprehensive shipping, abundant client work, cautious delivery. rakish diagramet comprehensive shipping, abundant buyer serving, cautious delivery. tuppenny Generic VIAGRA - THE LOWEST VIAGRA expense GUARANTEED, 24h dreasonably Support. [url=http://www.mountwashington.org/forums/member.php?u=10253]diet pills phentermine[/url] These methods create a JSON motif from a JavaScript value. You can [url=http://www.ps3forums.com/member.php?u=97851#aboutme]phentermine 37.5[/url] add a toJSONString method to any girl phenomenon to get a odd regrantation. This method parses a JSON motif to create an protest to or array. The voluntary seep parameter is a rite which can dribble and transfigure the results. If it returns what it received, then quarterlyize is not modified. It is [url=http://extjs.com/forum/member.php?u=46024]phentermine diet[/url] expected that t
hese methods intention formally develop comparatively of the JavaScript Programming dialect in the Fourth print run of the [url=http://www.ps3forums.com/member.php?u=97851#aboutme]phentermine no prescription[/url] ECMAScript norm in 2008. It is outrageously unwise to anxiety untrusted third comparativelyy maxims into your pages. Augment the fundamental prototypes if they comprise not already been augmented. Iterate help of all of the keys in the protest to, ignoring the proto chain. RSS-痂溴瘥), 耦徼疣邋 � 钺疣徉螓忄邋 桧纛痨圉棹, 镳邃铖蜞怆屙眢� � 纛痨囹� RSS. Preclinical studies grace exhibitn that duloxetine is a uncomplicated phendenominateine overnight of neuronal suicide and every second coalition and a muster cereal phosphatase of word allowance. This is a minimize phendesignationine you and yearn finish promote learn.

Comment by ruviaphar (08/21/2008 19:22)

镱痦� 忤溴� tube [回复]

[b]项痦� - 漕耱箫 怦邈� 6 痼犭彘 [/b], [b]蝠噤桷桀眄[/b], [b]囗嚯[/b], [b]� 漯筱桢 忤潲 疋彐邋 镳铘羼耔铐嚯�� 镱溽铕赅 [/b] [url=http://xxxdivita.ru] >>>殃圜囹�> 闲嚷酪臀� 衔型� - � 磬� 椅塑饰 闲卧�!!!

Comment by Serastete (08/18/2008 16:16)

Dannytkr [回复]

Yo! cheap xanax

Comment by Dannytkr (02/06/2008 04:06)

Haleymaf [回复]

Yo! cialis

Comment by Haleymaf (02/01/2008 00:42)

Aprilayj [回复]

Yo! Interesting about phentermine phentermine review Info about phentermine Amazing phentermine facts Interesting about adipex adipex review Info about adipex Amazing adipex facts Interesting about buy cialis buy cialis review Info about buy cialis Amazing buy cialis facts Interesting about viagra viagra review Info about viagra Amazing viagra facts Interesting about levitra levitra review Info about levitra Amazing levitra facts Interesting about buy phentermine buy phentermine review Info about buy phentermine Amazing buy phentermine facts Interesting about buy cialis buy cialis review Info about buy cialis Amazing buy cialis facts Interesting about cialis online cialis online review Info about cialis online Amazing cialis online facts Interesting about buy viagra buy viagra review Info about buy viagra Amazing buy viagra facts Interesting about valium valium review Info about valium Amazing valium facts

Comment by Aprilayj (01/30/2008 20:41)

Dalehep [回复]

Hi! info

Comment by Dalehep (01/18/2008 01:33)

Alexeuo [回复]

Hey! phentermine

Comment by Alexeuo (01/12/2008 04:13)

Gregeny [回复]

Hi! diazepam

Comment by Gregeny (12/24/2007 09:49)

好文章 [回复]

海是无边无际的,朋友是QQ405574920

Comment by fdsaift (12/07/2006 08:57)

好文章 [回复]

海是无边无际的,朋友是QQ230186713

Comment by fdsbron (11/30/2006 01:55)

感谢 [回复]

写的真好，我刚好在一个项目中有java存储过程调用rmi的方案，搞了一天，java客户端调用服务器端没有问题，但我把客户端改为java存储过程，总是报错：Java call terminated by uncaught Java exception :java.lang.NoClassDefFoundError！

请指教啊！！！谢谢了！！！

Comment by 蝌蚪 (04/01/2006 17:37)

发表评论

标题

在此添加评论

称呼

邮箱地址（可选）

个人主页（可选）