Oracle触发器调用webservice说明

该文档主要介绍oracle触发器加载java代码，在java代码中调用一个webservice服务接口的测试例子。

1. 测试环境(本测试用例使用的环境)

· Oracle版本：Release 10.2.0.1.0

· Tomcat版本：apache-tomcat-7.0.63

2. Webservice服务器

使用axis2创建一个测试用的webservice服务器。

服务器配置：

1) 把附件中的[axis2.war]拷贝到tomcat路径下的webapps。我的是在C:apache-tomcat-7.0.63webapps。启动tomcat，axis2.war会自动解压。

2) 把附件中的[test.aar]文件拷贝到解压后的文件路径axis2WEB-INFservices下面。我的是在C:apache-tomcat-7.0.63webappsaxis2WEB-INFservices。

3) 这样webservice服务器就配置好了。

说明：test.aar文件就是webservice测试服务器代码编译成的。使用的是axis2 Service Archiver插件编译而成。插件如下：

服务器代码如下:

3. Java代码

Java端代码说明：由于java代码需要加载到oracle中，而oracle10g使用的jdk版本为1.4。因此java端代码只能使用1.4版本的jdk支持的api。此处测试代码用的是axis调用webservice。

说明：下列代码中ulr=？的地址需要自行修改，根据自己tomcat端口调整。

3.1代码如下

文件名为Main.java

import java.rmi.RemoteException;

import javax.activation.DataHandler;

import javax.xml.namespace.QName;

import javax.xml.rpc.ServiceException;

import org.apache.axis.client.Call;

import org.apache.axis.client.Service;

import org.apache.axis.encoding.ser.JAFDataHandlerDeserializerFactory;

import org.apache.axis.encoding.ser.JAFDataHandlerSerializerFactory;

public class Main {

public static void service(String name) {

String url = "http://localhost:8800/axis2/services/test/simpleMethod";

Service service = new Service();

Call call;

String vstr ;

try {

call = (Call) service.createCall();

QName qn = new QName("ns1:DataHandler", "DataHandler");

call.setTargetEndpointAddress(url);

call.setOperationName(new QName("http://test", "simpleMethod"));

call.registerTypeMapping(DataHandler.class, qn,

JAFDataHandlerSerializerFactory.class,

JAFDataHandlerDeserializerFactory.class);

vstr = (String)call.invoke(new Object[] {name});

System.out.println(vstr);

} catch (ServiceException e) {

e.printStackTrace();

} catch (RemoteException e) {

e.printStackTrace();

}

}

}

3.2所需jar包

为了能正常运行上述java代码，需要在oracle中加载两个axis的jar包，分别为：axis.jar，commons-discovery-0.2.jar。

1)将附件中的axis.jar，commons-discovery-0.2.jar两个jar包拷贝到oracle路径.. sqljlib下。我的oracle路径是：F:oracleproduct10.2.0db_1sqljlib。根据oracle安装路径自行修改。

2)加载axis.jar，commons-discovery-0.2.jar到oracle中

在cmd窗口中，切换到F:oracleproduct10.2.0db_1sqljlib下，运行下列指令：

loadjava -u system/oracle -r -v -f -genmissing -s -grant public axis.jar commons-discovery-0.2.jar

system/oracle：数据库用户名/密码

指令执行完之后，显示：

3)加载java文件到oracle中

在cmd中运行下列指令：

loadjava -r -f -o -user system/oracle@orcl f:Main.java

4)至此，java文件被成功加载到oracle中了。

4. 存储过程

打开oralce自带的sqlplus工具，创建存储过程并调用java代码。

create or replace procedure service(name varchar2) as language java name 'Main.service(java.lang.String)';

/

如下图：

赋权限：

在sqlplus中用超级管理员登录，给system用户赋权限。

conn /as sysdba

exec dbms_java.grant_permission( 'SYSTEM','SYS:java.lang.RuntimePermission', 'createClassLoader', '' );

commit;

exec dbms_java.grant_permission( 'SYSTEM','SYS:java.lang.RuntimePermission', 'getClassLoader', '' );

commit;

exec dbms_java.grant_permission( 'SYSTEM','SYS:java.net.SocketPermission', 'localhost', 'resolve' );

commit;

exec dbms_java.grant_permission( 'SYSTEM', 'SYS:java.net.SocketPermission', '127.0.0.1:8800', 'connect,resolve' );

commit;

如下图：

5. Oracle触发器

创建一个基于wjq.operator表(我的数据库中的一个表)，每行数据有更新的触发器，并调用存储过程，如下：

在sqlplus中执行，用system用户登录：

CREATE OR REPLACE TRIGGER trigger_update

before update

ON wjq.operator

FOR EACH ROW

BEGIN

service('张三');

END ;

/

如下图：

6. 测试

在sqlplus中测试，执行更新语句操作。

wjq.operator中只有两行数据：

执行update wjq.operator set sex='1';时所有的数据都要更新，触发器被执行两次。

执行update wjq.operator set sex='1' where sex ='2';时有一条数据需要被更新，触发器被执行一次。

如下图：