專案中有個需求是資料庫自動定時掃描資料庫，給符合要求的使用者傳送推送訊息，這就需要在儲存過程中自動呼叫傳送推送的程式，由於程式複雜，所以利用orcle 的pl/sql傳送http請求來間接呼叫外部程式。

1.首先，在orcle中建立傳送http請求的java程式碼。

java source資料夾是用來存放java方法的，裡面的程式碼通過orale中的jdk編譯，可以在儲存過程中直接執行。

在資料夾中新建類HttpInvoker，其實就是普通的HttpClient傳送post請求的java方法，注意開頭要寫create or replace and compile java source named httpinvoker as。

create or replace and compile java source named httpinvoker as
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.URL;
import java.net.HttpURLConnection;
import java.net.URLConnection;
import java.util.*;
import java.net.URLEncoder;

public class HttpInvoker
{
    
     public static String sendRequest(String name, String userId,String orderNum) throws Exception{
         //處理引數
        String re=""; 
        re="訂單‘"+name+"’已選中你，快去接單吧";
      
        Map<String,String> p=new HashMap<String,String>();
        //全體傳送pushtype為ALL，不寫target
        p.put("pushType","ALIAS");
        p.put("alert",re);
        p.put("target",userId);
        p.put("msgCode","1005");
        p.put("orderNum",orderNum);
        //活動id
        p.put("activityId","");
        String s="";
        for (Map.Entry<String, String> entry : p.entrySet()) {
            s+="&"+entry.getKey()+"="+entry.getValue();
        }
        s=s.substring(1);
        //請求地址
        String url="http://112.64.35.222:9002/itcast/jpush/push";
        //請求引數
        String param=s;       
         //傳送post請求程式碼開始
         PrintWriter out = null;
        BufferedReader in = null;
        String result = "";
        try {
            URL realUrl = new URL(url);
            // 開啟和URL之間的連線
            URLConnection conn = realUrl.openConnection();
            // 設定通用的請求屬性
            conn.setRequestProperty("accept", "application/json, text/javascript, */*; q=0.01");
            conn.setRequestProperty("Accept-Encoding", "gzip, deflate");
            conn.setRequestProperty("Connection", "keep-alive");
            conn.setRequestProperty("Accept-Language", "zh-CN,zh;q=0.8");
            conn.setRequestProperty("Content-Length", "80");
            conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");
            conn.setRequestProperty("User-Agent", "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/52.0.2743.116 Safari/537.36");
                
            conn.setRequestProperty("user-agent",
                    "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
            // 傳送POST請求必須設定如下兩行
            conn.setDoOutput(true);
            conn.setDoInput(true);
            // 獲取URLConnection物件對應的輸出流
            OutputStreamWriter outWriter = new OutputStreamWriter(conn.getOutputStream(), "utf-8");  
            out = new PrintWriter(outWriter);
            // 傳送請求引數
            out.print(param);
            // flush輸出流的緩衝
            out.flush();
            // 定義BufferedReader輸入流來讀取URL的響應
            in = new BufferedReader(
                    new InputStreamReader(conn.getInputStream(),"UTF-8"));
            String line;
            while ((line = in.readLine()) != null) {
                result += line;
            }
        } catch (Exception e) {
            System.out.println("傳送 POST 請求出現異常！"+e);
            e.printStackTrace();
            result=e.getMessage();
        }
        //使用finally塊來關閉輸出流、輸入流
        finally{
            try{
                if(out!=null){
                    out.close();
                }
                if(in!=null){
                    in.close();
                }
            }
            catch(IOException ex){
                ex.printStackTrace();
            }
        }
        return result;
    }
    
}
 

2.在functions資料夾中建立呼叫java程式的過程

function 和procedure儲存過程很像，不過function必須返回一個結果，procedure可以返回也可以不反回

create or replace function HttpInvoker(name VARCHAR2, userId VARCHAR2 ,orderNum VARCHAR2) return    VARCHAR2
      as language java name
      --加密函式
      'HttpInvoker.sendRequest (java.lang.String,java.lang.String,java.lang.String) return java.lang.String';
 

注意我建立的是function，所以必須返回結果，如果你建立的是procedure，則可以不返回

3.在你的儲存過程程式碼中呼叫function

IV_RESULT:=HttpInvoker(orderInfo.order_name,IV_TAKER_USER_ID,orderInfo.order_num);

在需要呼叫的地方呼叫，傳入引數即可

4.這時你test測試時會發現connection連線時報錯，根本傳送不出去，這是因為沒有給使用者配置許可權

java.security.AccessControlException: the Permission (java.net.SocketPermission localhost:10000 listen,resolve) has not been granted to RADIUS. The PL/SQL to grant this is dbms_java.grant_permission( 'RADIUS', 'SYS:java.net.SocketPermission', 'localhost:10000', 'listen,resolve' )

5.如果還不行，可能是acl的問題

定義ACL,若沒有ACL，則無法訪問網路。

1. --定義ACL 取名：httprequestpermission.xml
2. BEGIN
3.     dbms_network_acl_admin.create_acl(acl         => 'httprequestpermission.xml',  
4.                                       DESCRIPTION => 'Normal Access',  
5.                                       principal   => 'CONNECT',  
6.                                       is_grant    => TRUE,  
7.                                       PRIVILEGE   => 'connect',  
8.                                       start_date  => NULL,  
9.                                       end_date    => NULL);  
10. END;  

1. --檢視ACL是否增加成功
2. SELECT any_path  
3. FROM resource_view   
4. where any_path  like'/sys/acls/%.xml'
5. ;  
6. --給使用者增加acl許可權，這裡是 SD_JY 注意是大寫，小寫不識別
7. begin  dbms_network_acl_admin.add_privilege(acl     => 'httprequestpermission.xml',  
8.                                          principal  => 'SD_JY',  
9.                                          is_grant   => TRUE,  
10.                                          privilege  => 'connect',  
11.                                          start_date => null,  
12.                                          end_date   => null);  
13. end;  
14. --新增對應主機 ，將對應主機和埠新增到ACL。這裡是 192.168.0.156 和 8080 ，這個ip和埠要和上面儲存過程中定義的地址一致
15. begin
16.     dbms_network_acl_admin.assign_acl(acl        => 'httprequestpermission.xml',  
17.                                       host       => '192.168.0.156',  
18.                                       lower_port => 8080,  
19.                                       upper_port => NULL);  
20. end;  

ACL的增加過程為：建立新的acl檔案，對該檔案中，使用者授權，對該檔案中，URL和埠授權。

可檢視對應的ACL資訊是否新增上

1. SELECT  acl,  
2.        principal,  
3.        privilege,  
4.        is_grant,  
5.        TO_CHAR(start_date, 'DD-MON-YYYY') AS start_date,  
6.        TO_CHAR(end_date, 'DD-MON-YYYY') AS end_date  
7.   FROM dba_network_acl_privileges;