PLSQL程序嵌入JAVA程序.docx

众所周知,目前在国内最流行的开发语言是JAVA语言，虽然国外有更多流行的开发语言，JAVA仅是百花齐放中的一朵。
但对国内而言JAVA在近段时期内仍占据霸主地位，国内的开发水平一直是在应用级别，而非研究级别。国内有着华丽外衣
的程序猿们也只是码农的级别，这也是导致大部分软件企业偏重于业务及架构人才。
    09年SUN被ORACLE收购，也是否代表着JAVA衰落的开始，事实应该并非吧。SUN公司的主打是大型服务器，JAVA只是SUN
公司的附带产品，更说白了初始只是一个码农James Gosling的想法。其实从ORACLE 8版本开始，ORACLE开始提供对JAVA的
支持，随后的版本则继续增强了ORACLE数据库的JAVA性能，在ORACLE8I开始支持用JAVA编写存储过程。
    PLSQL存储过程在数据处理方面确实是个卓越的创新，因为在以往的单会话状态下，每次执行只能支持单个SQL语句。
初做JAVA时，数据库从来都是被当做黑盒在使用，后来才知道有存储过程这个东东，在做JAVA开发时候只是通过CallableStatement
接口来调用过存储过程，也写过几个比较简单的存储过程。后来做ORACLE数据库开发，过了最初上路的煎熬，慢慢的拆卸了下数据库
这个黑盒的一部分。后来无意中看到一个简单的程序，HelloWorld这个应该是每个JAVA码农们的初恋吧,再回忆下这个println吧
package pra;
/**
*java学习
*@author hehe
*@version practise
*/
public class HelloWorld{
  public static void main(String [] args){
   System.out.println("HelloWorld !");
 }
}
也再回忆下当时很牛X，现在还依然感觉很酷的纯命令编译程序吧
编译带包的java类（以包名为pra，类名为HelloWorld为例）：
javac -d . HelloWorld.java
运行带包的类：
java pra.HelloWorld
生成API文档(生成在docs文件夹下)：
javadoc -d   .\docs HelloWorld.java
生成带相应描述的API文档：
javadoc -version -author  -d  .\docs HelloWorld.java
打jar包：jar -cvf pra.jar
解压jar包：jar -xvf pra.jar
运行jar包中的类：
java -classpath pra.jar pra.HelloWorld 或者java -cp pra.jar pra.HelloWorld
在介绍PLSQL中嵌入JAVA程序编译输出HelloWorld之前，对钟爱于JAVA的码农们说句话:"JAVA的魅力依旧是ORACLE取代不了的"
1.下面是个简单的PLSQL程序嵌入JAVA类并编译输出的代码。
CREATE OR REPLACE AND COMPILE JAVA SOURCE NAMED HELLOWORLD AS
public class HelloWorld
{
  public static String entry()
  {
   return "Hello World!";
  }
}

CREATE OR REPLACE FUNCTION FU_HELLOWORLD RETURN VARCHAR2
AS LANGUAGE JAVA
NAME 'HelloWorld.entry() return java.lang.String';
SELECT FU_HELLOWORLD FROM DUAL;
2.PLSQL对数据的强大处理功能是毋庸置疑的，但在应用级别还是有居多限制，不过ORACLE官方提供了许多功能还不错的内置包。
现在先来介绍下后续功能的核心包UTL_FILE,ORACLE提供的内置包，包含多种过程及方法，可以实现目录(DIRECTORY ORACLE不能
访问操作系统级的文件夹，需要创建特定目录才能够访问)下的文件读取写入，具体实现加密，无从了解其实现原理，其应用可以
与JAVA中的基本流比照。其功能有极大限制，但是可以实现基本的文件读取写入等操作。
前段时间写了个东东，代码如下，GGMM们可以瞧下，消遣下。
--创建配置表
DECLARE
    --action:创建存储目录文件表
    --author:hehe
    --date:2014-01-23
    V_COUNT  NUMBER(2);
    V_SQL    VARCHAR2(32767);
BEGIN
  --判断表存在
  SELECT COUNT(*) INTO V_COUNT FROM USER_TABLES WHERE TABLE_NAME='T_DIRLIST';
  IF V_COUNT=1 THEN
    --如果存在DROP掉
    EXECUTE IMMEDIATE 'DROP TABLE T_DIRLIST';
  END IF;
  --如果不存在,重新创建
  V_SQL:='CREATE TABLE T_DIRLIST(FILENAME VARCHAR2(255),FILESIZE NUMBER,FILEDATE DATE)';
  EXECUTE IMMEDIATE V_SQL;
  EXECUTE IMMEDIATE 'COMMENT ON TABLE T_DIRLIST IS ''存储目录文件表''';
  EXECUTE IMMEDIATE 'COMMENT ON COLUMN  T_DIRLIST.FILENAME IS  ''文件名称''';
  EXECUTE IMMEDIATE 'COMMENT ON COLUMN  T_DIRLIST.FILESIZE IS  ''文件大小''';
  EXECUTE IMMEDIATE 'COMMENT ON COLUMN  T_DIRLIST.FILESIZE IS  ''文件最后操作时间''';
  --创建序列
  SELECT COUNT(*) INTO V_COUNT FROM USER_SEQUENCES WHERE SEQUENCE_NAME='SEQ';
  IF V_COUNT=0 THEN
    EXECUTE IMMEDIATE 'CREATE SEQUENCE  SEQ START WITH 1';
  END IF;
END;
/

--创建java类用于文件夹操作
create or replace and compile java source named dirlist as
import java.io.*;
import java.sql.*;
public class DirList
/**
  action:获取目录下文件
  author:hehe
  date:2014-01-23
*/
{
public static void getList(String directory) throws SQLException
{
   //创建文件对象
   File path=new File(directory);
   String[] fileList=path.list();
   String fileName;
   long fileSize;
   long fileDate;
   //清除表中的所有记录
   #sql{delete from t_dirlist};
   #sql{commit};
   //循环取出获取目录中的文件名及创建时间
   for (int i=0;i<fileList.length; i++)
   {
     fileName=fileList;
     //创建文件对象
     File fpath=new File(directory+'/'+fileName);
     //获取对象大小
     fileSize=fpath.length();
     //获取对象的最后修改时间
     fileDate=fpath.lastModified();
     //向表中插入记录
     #sql{insert into t_dirlist(filename, filesize, filedate)
     values(:fileName,:fileSize,to_date('01/01/1970','mm/dd/yyyy')+:fileDate/(24*60*60*1000))};
   }
   //提交事务
   #sql{commit};
}
}
--具体实现包
CREATE OR REPLACE PACKAGE PA_FILE
AS
   PROCEDURE PR_GETDIRLIST(I_DIRECTORY  VARCHAR2);
     --action:获取目录下的所有文件
     --author:hehe
     --date:2014-01-23
     /*参数说明
     *I_DIRECTORY 目录名称
     */
   PROCEDURE PR_READTOWRITE_FILE(I_READ_DIR   VARCHAR2,
                                 I_WRITE_DIR  VARCHAR2,
                                 I_WRITE_FILE VARCHAR2);
     --action:读取I_READ_DIR 目录下的所有文件，到I_WRITE_DIR目录下的对应文件
     --author:hehe
     --date:2014-01-23
     /*参数说明
     *I_READ_DIR   读取文件的目录
     *I_WRITE_DIR  写入文件的目录
     *I_WRITE_FILE 写入的文件名
     */
   PROCEDURE PR_READTOWRITE_DECLARE(I_READ_DIR   VARCHAR2,
                                    I_READ_FILE  VARCHAR2 DEFAULT 'DECLARE.SQL',
                                    I_WRITE_DIR  VARCHAR2,
                                    I_WRITE_FILE VARCHAR2);
     --action:读取I_READ_DIR 目录下的I_READ_FILE文件，到I_WRITE_DIR目录下的对应文件
     --author:hehe
     --date:2014-01-23
     /*参数说明
     *I_READ_DIR   读取文件的目录
     *I_READ_FILE  读取的文件名
     *I_WRITE_DIR  写入文件的目录
     *I_WRITE_FILE 写入的文件名
     */
END PA_FILE;
/

CREATE OR REPLACE PACKAGE BODY PA_FILE
AS
   PROCEDURE PR_GETDIRLIST(I_DIRECTORY IN VARCHAR2) AS
     --action:获取目录下的所有文件
     --author:hehe
     --date:2014-01-23
     /*参数说明
     *I_DIRECTORY 目录名称
     */
     LANGUAGE JAVA NAME 'DirList.getList(java.lang.String)';
   PROCEDURE PR_READTOWRITE_FILE(I_READ_DIR   VARCHAR2,
                                 I_WRITE_DIR  VARCHAR2,
                                 I_WRITE_FILE VARCHAR2)
     AS
     --action:读取I_READ_DIR 目录下的所有文件，到I_WRITE_DIR目录下的对应文件
     --author:hehe
     --date:2014-01-23
     /*参数说明
     *I_READ_DIR   读取文件的目录
     *I_WRITE_DIR  写入文件的目录
     *I_WRITE_FILE 写入的文件名
     */
     V_READ_DIR    VARCHAR2(1000)  :=TRIM(UPPER(I_READ_DIR));
     V_WRITE_DIR   VARCHAR2(1000)  :=TRIM(UPPER(I_WRITE_DIR));
     V_WRITE_FILE  VARCHAR2(1000)  :=TRIM(UPPER(I_WRITE_FILE));
     V_OWNER       VARCHAR2(38)    :=SYS_CONTEXT('USERENV','CURRENT_USER');
     V_DIR         VARCHAR2(32767);
     V_FILE_WRITE  UTL_FILE.FILE_TYPE;
     V_FILE_READ   UTL_FILE.FILE_TYPE;
     V_BUFFER      VARCHAR2(32767);
     V_FILENAME    VARCHAR2(32767);
     V_GOL         VARCHAR2(32767);
     V_SQL         VARCHAR2(32767);
     V_CUR         SYS_REFCURSOR;
     CURSOR CUR_FILENAME IS
        SELECT  FILENAME FROM T_DIRLIST  
          WHERE FILENAME<>'DECLARE.SQL'
                AND SUBSTR(TRIM(UPPER(FILENAME)),INSTR(TRIM(FILENAME),'.'))='.SQL'
            ORDER BY FILENAME;
   BEGIN
     --获取读取文件的目录下的所有文件
     --授予java访问目录权限
     V_SQL:='SELECT DIRECTORY_PATH  FROM DBA_DIRECTORIES WHERE DIRECTORY_NAME IN('''
            ||V_READ_DIR||''','''||V_WRITE_DIR||''')';
     OPEN V_CUR FOR V_SQL;
     FETCH V_CUR INTO V_DIR;
     WHILE V_CUR%FOUND
     LOOP
       V_SQL:='CALL  dbms_java.grant_permission('''||V_OWNER||''''
              ||',''SYS:java.io.FilePermission'','''
              ||V_DIR||''', ''read'')';
       --DBMS_OUTPUT.put_line(V_SQL);
       EXECUTE IMMEDIATE V_SQL;
       V_SQL:='CALL dbms_java.grant_permission('''||V_OWNER||''''
              ||', ''SYS:java.io.FilePermission'','''
              ||V_DIR||'\*'', ''read'')';
       EXECUTE IMMEDIATE V_SQL;
       FETCH V_CUR INTO V_DIR;
     END LOOP;
     SELECT DIRECTORY_PATH INTO V_DIR  FROM DBA_DIRECTORIES WHERE DIRECTORY_NAME=V_READ_DIR;
     PR_GETDIRLIST(V_DIR);
     --首次清除所有记录
     V_FILE_WRITE :=UTL_FILE.FOPEN(V_WRITE_DIR,V_WRITE_FILE,'W');--W覆盖写入
     --写入空
     UTL_FILE.PUT_LINE(V_FILE_WRITE,'');
     UTL_FILE.FFLUSH(V_FILE_WRITE);
     UTL_FILE.FCLOSE(V_FILE_WRITE);
     -----------------------------------------------------------
     --打开要写入的文件
     V_FILE_WRITE :=UTL_FILE.FOPEN(V_WRITE_DIR,V_WRITE_FILE,'A');--A 追加
     -----------------------------------------------------------
     --循环读取文件下的文件
     FOR CUR_GET_FILENAME IN CUR_FILENAME
       LOOP
         --获取文件名
         V_FILENAME:=TRIM(CUR_GET_FILENAME.FILENAME);
         --写入空行
         UTL_FILE.PUT_LINE(V_FILE_WRITE,' ');
         --写入注释
         V_GOL:='SET ECHO ON;';
         UTL_FILE.PUT_LINE(V_FILE_WRITE,V_GOL);
         V_GOL:='REM 创建'||SUBSTR(V_FILENAME,1,INSTR(V_FILENAME,'.')-1);
         UTL_FILE.PUT_LINE(V_FILE_WRITE,V_GOL);
         V_GOL:='SET ECHO OFF;';
         UTL_FILE.PUT_LINE(V_FILE_WRITE,V_GOL);
         --打开文件
         V_FILE_READ:=UTL_FILE.FOPEN(V_READ_DIR,V_FILENAME,'R');
        LOOP
          BEGIN
            --读取文件
            UTL_FILE.GET_LINE(V_FILE_READ,V_BUFFER);
            --写入文件
            UTL_FILE.PUT_LINE(V_FILE_WRITE,V_BUFFER);
          EXCEPTION
            WHEN NO_DATA_FOUND THEN
              EXIT;
          END;
        END LOOP;
        --冲刷写入系统文件
        UTL_FILE.FFLUSH(V_FILE_WRITE);
        UTL_FILE.FCLOSE(V_FILE_READ);
    END LOOP;
    --全部重新刷新输出释放
    UTL_FILE.FFLUSH(V_FILE_WRITE);
    UTL_FILE.FCLOSE(V_FILE_WRITE);
    UTL_FILE.FCLOSE(V_FILE_READ);
  EXCEPTION
    --异常处理，读取不到数据时,关闭流
    WHEN NO_DATA_FOUND THEN
      UTL_FILE.FCLOSE(V_FILE_WRITE);
      UTL_FILE.FCLOSE(V_FILE_READ);
    WHEN OTHERS THEN
      RAISE;
   END PR_READTOWRITE_FILE;
   PROCEDURE PR_READTOWRITE_DECLARE(I_READ_DIR   VARCHAR2,
                                    I_READ_FILE  VARCHAR2 DEFAULT 'DECLARE.SQL',
                                    I_WRITE_DIR  VARCHAR2,
                                    I_WRITE_FILE VARCHAR2)
   AS
     --action:读取I_READ_DIR 目录下的I_READ_FILE文件，到I_WRITE_DIR目录下的对应文件
     --author:hehe
     --date:2014-01-23
     /*参数说明
     *I_READ_DIR   读取文件的目录
     *I_READ_FILE  读取的文件名
     *I_WRITE_DIR  写入文件的目录
     *I_WRITE_FILE 写入的文件名
     */
     V_READ_DIR    VARCHAR2(1000)  :=TRIM(UPPER(I_READ_DIR));
     V_READ_FILE   VARCHAR2(1000)  :=TRIM(I_READ_FILE);
     V_WRITE_DIR   VARCHAR2(1000)  :=TRIM(UPPER(I_WRITE_DIR));
     V_WRITE_FILE  VARCHAR2(1000)  :=TRIM(I_WRITE_FILE);
     V_OWNER       VARCHAR2(38)    :=SYS_CONTEXT('USERENV','CURRENT_USER');
     V_DIR         VARCHAR2(32767);
     V_SEQ         NUMBER(38);
     V_FILE_WRITE  UTL_FILE.FILE_TYPE;
     V_FILE_READ   UTL_FILE.FILE_TYPE;
     V_BUFFER      VARCHAR2(32767);
     V_GOL         VARCHAR2(32767);
     V_SQL         VARCHAR2(32767);
     V_CUR         SYS_REFCURSOR;
   BEGIN
     --授予java访问目录权限
     V_SQL:='SELECT DIRECTORY_PATH  FROM DBA_DIRECTORIES WHERE DIRECTORY_NAME IN('''
            ||V_READ_DIR||''','''||V_WRITE_DIR||''')';
     OPEN V_CUR FOR V_SQL;
     FETCH V_CUR INTO V_DIR;
     WHILE V_CUR%FOUND
     LOOP
       V_SQL:='CALL  dbms_java.grant_permission('''||V_OWNER||''''
              ||',''SYS:java.io.FilePermission'','''
              ||V_DIR||''', ''read'')';
       --DBMS_OUTPUT.put_line(V_SQL);
       EXECUTE IMMEDIATE V_SQL;
       V_SQL:='CALL dbms_java.grant_permission('''||V_OWNER||''''
              ||', ''SYS:java.io.FilePermission'','''
              ||V_DIR||'\*'', ''read'')';
       EXECUTE IMMEDIATE V_SQL;
       FETCH V_CUR INTO V_DIR;
     END LOOP;
     --打开写文件，并写入 注释部分
     V_FILE_WRITE :=UTL_FILE.FOPEN(V_WRITE_DIR,V_WRITE_FILE,'A');--A 追加
     --写入空
     UTL_FILE.PUT_LINE(V_FILE_WRITE,' ');
     --写入注释
     V_GOL:='SET ECHO ON;';
     UTL_FILE.PUT_LINE(V_FILE_WRITE,V_GOL);
     SELECT TO_CHAR(SEQ.NEXTVAL) INTO V_SEQ FROM DUAL;
     V_GOL:='REM 创建'||V_SEQ;
     UTL_FILE.PUT_LINE(V_FILE_WRITE,V_GOL);
     V_GOL:='SET ECHO OFF;';
     UTL_FILE.PUT_LINE(V_FILE_WRITE,V_GOL);
     --打开文件
     V_FILE_READ:=UTL_FILE.FOPEN(V_READ_DIR,V_READ_FILE,'R');
        LOOP
          BEGIN
            --读取文件
            UTL_FILE.GET_LINE(V_FILE_READ,V_BUFFER);
            --写入文件
            UTL_FILE.PUT_LINE(V_FILE_WRITE,V_BUFFER);
          EXCEPTION
            WHEN NO_DATA_FOUND THEN
              EXIT;
          END;
        END LOOP;
    --全部重新刷新输出释放
    UTL_FILE.FFLUSH(V_FILE_WRITE);
    UTL_FILE.FCLOSE(V_FILE_WRITE);
    UTL_FILE.FCLOSE(V_FILE_READ);
  EXCEPTION
    --异常处理，读取不到数据时,关闭流
    WHEN NO_DATA_FOUND THEN
      UTL_FILE.FCLOSE(V_FILE_WRITE);
      UTL_FILE.FCLOSE(V_FILE_READ);
    WHEN OTHERS THEN
      RAISE;
   END PR_READTOWRITE_DECLARE;
END PA_FILE;
/