oracle之FUNCTION管见

oracle之FUNCTION拙见

一、介绍

函数（Function）为一命名的存储程序，可带参数（有无均可），有返回值

函数和过程的结构类似，但必须有一个RETURN子句，用于返回函数值。

函数说明要指定函数名、返回值的类型，以及参数类型等，如CREATE OR REPLACE FUNCTION access_hel_by_dbws(username in varchar2) RETURN VARCHAR2

二、语法

CREATE [OR REPLACE] FUNCTION 函数名(参数列表)  -- 参数类型与函数返回值类型不用标注类型大小，即varchar2即可
 RETURN  函数值类型
AS
PLSQL子程序体；

三、简单例子：计算两个数字的和

3.1、函数定义

CREATE OR REPLACE FUNCTION add_numbers(d1 in number, d2 in number) -- 函数声明，包括名称、参数名称及类型
  return number -- 返回值类型声明
as -- 或者写作is，均可
begin -- begin与end中间为pl sql 代码块，可执行查询、插入、更新、删除操作
  return d1+d2; -- return子句返回两数字之和
end;

如何执行上述代码建立函数？当做sql语句在sql window(pl sql)窗口里执行即可，或者其他客户端相应执行sql语句的窗口

3.2、调用方式

（1）、执行sql查询语句

select add_numbers(1,2) from dual;

（2）、执行pl sql代码块

以pl sql客户端为例，打开sql window，在sql栏里粘贴如下代码，在output一栏里即可看到结果

declare -- declare部分可有可无，若无变量需要声明，则可去掉，只留begin、end
  sum_ number;
begin
  sum_:=add_numbers(1,2);
  dbms_output.put_line('sum is:' || sum_);
end;

截图如下：

（3）、在触发器，存储过程中均可调用函数，即在pl sql代码块范围内、sql语句中均可调用。

（4）、在java程序中调用存储函数

package zxn.function.test;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class Test {
	public static void main(String[] args) throws SQLException {
		/**
		 * jdbc方式连接oracle数据库
		 */
		Connection connection = null;  
        try {  
           Class.forName("oracle.jdbc.driver.OracleDriver");  
           String url = "jdbc:oracle:thin:@localhost:1521:orcl";  
           String user = "sys as sysdba";  
           String pwd = "orcl";           
           connection = DriverManager.getConnection(url,user,pwd);  
       } catch (ClassNotFoundException e) {  
           e.printStackTrace();  
       } catch (SQLException e) {  
           e.printStackTrace();  
       }  
       /** 调用oracle函数 */
       CallableStatement callableStatement=connection.prepareCall("{?=call add_numbers(?, ?)}");
       /** 设置第一个问号占位符的类型，第一个问号表示函数输出结果 ，顺序从1开始 */
       callableStatement.registerOutParameter(1, oracle.jdbc.OracleTypes.NUMERIC);
       /** 设置第二个参数与第三个参数的类型及值，即设置两个加数 */
       callableStatement.setDouble(2, 3.6566);
       callableStatement.setDouble(3, 3);
       /** 执行存储函数 */
       callableStatement.execute();  
       /** 得到函数执行结果 */
       System.out.println(callableStatement.getString(1));
	}
}

4、复杂例子：在存储函数中使用UTL_DBWS调用webservice

4、1前提是oracle数据库导入utl_dbws包，并能正常使用。

CREATE OR REPLACE FUNCTION access_hello_by_dbws(username in varchar2, age in integer)
RETURN VARCHAR2
AS
l_service  UTL_DBWS.service; -- 定义service服务
l_call     UTL_DBWS.call; -- 定义调用对象
l_wsdl_url         VARCHAR2(32767);
l_namespace        VARCHAR2(32767);
l_service_qname    UTL_DBWS.qname;
l_port_qname       UTL_DBWS.qname;
l_operation_qname  UTL_DBWS.qname;
request sys.XMLTYPE; -- 响应xml
response sys.XMLTYPE; -- 请求xml

BEGIN
l_wsdl_url        := 'http://localhost:7878/hello?wsdl'; -- webservice服务的wsdl地址
l_namespace       := 'http://test.xiangnan.it/'; -- targetNamespace属性的值，最后的/不能少，否则报...does not contains port...

l_service_qname   := UTL_DBWS.to_qname(l_namespace, 'HelloWorldService'); -- service节点name属性值
l_port_qname      := UTL_DBWS.to_qname(l_namespace, 'HelloWorldPort'); -- port节点name属性值
l_operation_qname := UTL_DBWS.to_qname(l_namespace, 'hello'); -- operation节点name属性值

l_service := UTL_DBWS.create_service ( -- 根据wsdl与service name创建service对象
wsdl_document_location => URIFACTORY.getURI(l_wsdl_url),
service_name           => l_service_qname);

l_call := UTL_DBWS.create_call ( -- 创建调用对象
service_handle => l_service,
port_name      => l_port_qname,
operation_name => l_operation_qname);

sys.utl_dbws.set_target_endpoint_address(l_call, 'http://localhost:7878/hello'); -- 设置调用对象的endpoint，也可不设置，
-- 该属性可通过soap UI查看

request := sys.XMLTYPE('<test:hello   xmlns:test="http://test.xiangnan.it/"> -- 拼接request，可通过soap ui查看request进行拼接
                            <arg0>'||username||'</arg0> -- ||||之间为定义的变量
                            <arg1>'||age||'</arg1>
                            </test:hello>
                            ');
              
response := utl_dbws.invoke(l_call, request); -- 发出请求，并接受响应

UTL_DBWS.release_call (call_handle => l_call); -- 释放call对象
UTL_DBWS.release_service (service_handle => l_service); -- 释放service对象
-- 获取响应值，可通过soap ui查看response内容
return response.extract('/ns2:helloResponse/return/text()', ' xmlns:ns2="http://test.xiangnan.it/"').getstringval();
EXCEPTION
  WHEN OTHERS THEN
    dbms_output.put_line(sqlerrm); -- 输出错误
    return sqlerrm;
END;

4.2、测试

在pl sql 中functions列表下面，选中定义的函数，右键点击，选择Test，如图：

输入对应的测试参数，得到结果，如图：