較老得plsql不能處理與OS的交互，比如獲得文件目錄，獲得文件的大小等等，

plsql從9I開始支持javasource使用java處理OS交互。

例如?

需求 :導(dǎo)入到指定目錄下面所有的文件到數(shù)據(jù)庫，文件類型可能是圖片，PDF，WORD等。

?

INPUT?

１.??指定的目錄(包含子文件夾)

２.??指定的文件類型(suffix such as .pdf,take all is *) Such as

? ? ? ?exec pkg_file.FILE_INPUT('D:\SYSTEM','*');

???????????

EXPORT

１.??指定的文件名(包含全路經(jīng))

２.??指定的數(shù)據(jù)庫中導(dǎo)出文件的文件ID Suchas

? ? ? ?execpkg_file.FILE_EXPORT('D:\kaokaokao.jpg',708);

Java IO FILE refer

• http://download.oracle.com/javase/6/docs/api/java/io/File.html

GRANT JAVAUSERPRIV TO SCOTT; GRANT Create ANY Directory TO SCOTT; GRANT DROP ANY Directory TO SCOTT; DECLAREl_schema VARCHAR2(30) := 'SCOTT'; BEGINDBMS_JAVA.grant_permission(l_schema, 'java.io.FilePermission', '<<ALL FILES>>', 'read ,write, execute, delete');DBMS_JAVA.grant_permission(l_schema, 'SYS:java.lang.RuntimePermission', 'writeFileDescriptor', '');DBMS_JAVA.grant_permission(l_schema, 'SYS:java.lang.RuntimePermission', 'readFileDescriptor', ''); END; /CREATE SEQUENCE SEQ_FILE START WITH 1 INCREMENT BY 1;CREATE TABLE FILE_LIST_INFO ( FILE_ID NUMBER(10) PRIMARY KEY,FILE_NAME VARCHAR(200 CHAR) NOT NULL,FILE_PATH VARCHAR(200 CHAR) NOT NULL,FILE_TYPE VARCHAR(20 CHAR),FILE_LENGTH NUMBER(20) NOT NULL,FILE_CREATE_TIME VARCHAR(20 CHAR),FILE_MODIFY_TIME VARCHAR(20 CHAR),FILE_UPDATE_TIME DATE NOT NULL,FILE_LIST_ID NUMBER(10) ) ROWDEPENDENCIES;CREATE TABLE FILE_LIST ( LIST_ID NUMBER(10) PRIMARY KEY,LIST_DATE DATE DEFAULT SYSDATE,LIST_FILE BLOB ) ROWDEPENDENCIES;create or replace and compile java source named DirList asimport java.lang.*;import java.io.*;import java.sql.*;import oracle.jdbc.*;import oracle.sql.*;import java.util.*;import java.text.*;public class DirList{ static void Process(File path_file,String path_suffix) throws SQLException{String v_file_name;String v_file_path;String v_parent_path;String v_file_type;long v_file_length;long v_file_modify;if(path_file.isFile()){v_file_name =path_file.getName();v_file_path =path_file.getPath();v_parent_path=path_file.getParent();v_file_type ="FILE";v_file_length =path_file.length();v_file_modify =path_file.lastModified(); Date d = new Date(v_file_modify);SimpleDateFormat sdf = new SimpleDateFormat("dd-MM-yyyy hh:mm:ss");String v_file_dateString = sdf.format(d);if (path_suffix.equals("*")){Connection conn = null;CallableStatement cs = null;String val = null;conn = DriverManager.getConnection("jdbc:default:connection");cs = conn.prepareCall("{ call PKG_FILE.FILE_INPUT_DB(?,?,?,?,?,?) }");cs.setString(1, v_file_name);cs.setString(2, v_file_path);cs.setString(3, v_file_type);cs.setFloat(4, v_file_length);cs.setString(5, v_file_dateString);cs.setString(6, v_parent_path);cs.execute();cs.close();conn.close();}else{if (v_file_name.endsWith(path_suffix)){Connection conn = null;CallableStatement cs = null;String val = null;conn = DriverManager.getConnection("jdbc:default:connection");cs = conn.prepareCall("{ call PKG_FILE.FILE_INPUT_DB(?,?,?,?,?,?) }");cs.setString(1, v_file_name);cs.setString(2, v_file_path);cs.setString(3, v_file_type);cs.setFloat(4, v_file_length);cs.setString(5, v_file_dateString);cs.setString(6, v_parent_path);cs.execute();cs.close();conn.close();}}}else if (path_file.isDirectory()){v_file_name =path_file.getName();v_file_path =path_file.getPath();v_parent_path=path_file.getParent();v_file_type ="DIRECTORY";v_file_length =0;v_file_modify =path_file.lastModified(); Date d = new Date(v_file_modify);SimpleDateFormat sdf = new SimpleDateFormat("dd-MM-yyyy hh:mm:ss");String v_file_dateString = sdf.format(d);Connection conn = null;CallableStatement cs = null;String val = null;conn = DriverManager.getConnection("jdbc:default:connection");cs = conn.prepareCall("{ call PKG_FILE.FILE_INPUT_DB(?,?,?,?,?,?) }");cs.setString(1, v_file_name);cs.setString(2, v_file_path);cs.setString(3, v_file_type);cs.setFloat(4, v_file_length);cs.setString(5, v_file_dateString);cs.setString(6, v_parent_path);cs.execute();cs.close();conn.close();File[] listOfFiles = path_file.listFiles();if(listOfFiles!=null){for (int j = 0; j < listOfFiles.length; j++){Process(listOfFiles[j],path_suffix);}} }}public static void Inputfile(String directory,String suffix)throws SQLException{File path = new File( directory );#sql { truncate table FILE_LIST_INFO};#sql { truncate table FILE_LIST};Process(path,suffix);}public static void Exportfile(String myFile, BLOB myBlob) throws Exception{// Bind the image object to the database object// Open streams for the output file and the blobFile binaryFile = new File(myFile);FileOutputStream outStream = new FileOutputStream(binaryFile);InputStream inStream = myBlob.getBinaryStream();// Get the optimum buffer size and use this to create the read/write bufferint size = myBlob.getBufferSize();byte[] buffer = new byte[size];int length = -1;// Transfer the datawhile ((length = inStream.read(buffer)) != -1){outStream.write(buffer, 0, length);outStream.flush();}// Close everything downinStream.close();outStream.close();} }; /CREATE OR REPLACE PACKAGE PKG_FILE ASPROCEDURE FILE_INPUT(P_DIRECTORY IN VARCHAR2, P_SUFFIX IN VARCHAR2);PROCEDURE FILE_INPUT_DB(P_FILENAME IN VARCHAR2,P_FILEPATH IN VARCHAR2,P_FILETYPE IN VARCHAR2,P_FILELENGTH IN NUMBER DEFAULT 0,P_FILEMODIFY IN VARCHAR2,P_PARENTPATH IN VARCHAR2);PROCEDURE FILE_EXPORT_JAVA(P_FILE IN VARCHAR2, P_BLOB IN BLOB);PROCEDURE FILE_EXPORT(P_FILEPATH IN VARCHAR2,P_FILEID IN NUMBER); END; /CREATE OR REPLACE PACKAGE BODY PKG_FILE ASPROCEDURE FILE_INPUT(p_directory IN VARCHAR2, p_suffix IN VARCHAR2) ASLANGUAGE JAVA NAME 'DirList.Inputfile( java.lang.String , java.lang.String)';PROCEDURE FILE_INPUT_DB(P_FILENAME IN VARCHAR2,P_FILEPATH IN VARCHAR2,P_FILETYPE IN VARCHAR2,P_FILELENGTH IN NUMBER DEFAULT 0,P_FILEMODIFY IN VARCHAR2,P_PARENTPATH IN VARCHAR2) ISl_blob BLOB;l_bfile BFILE;v_sql_insert VARCHAR2(200);BEGIN--dynamic create the direcory FILE_DIRBEGINv_sql_insert := 'Create Or Replace Directory FILE_DIR As ' || '''' ||P_PARENTPATH || '\''';EXECUTE IMMEDIATE v_sql_insert;EXCEPTIONWHEN OTHERS THENRAISE_APPLICATION_ERROR(-20017,'Can Not Dynamic Create the FILE_DIR Directory.' ||SQLERRM);END;IF P_FILETYPE = 'FILE' THENINSERT INTO FILE_LIST_INFO(FILE_ID,FILE_NAME,FILE_PATH,FILE_TYPE,FILE_LENGTH,FILE_UPDATE_TIME,FILE_MODIFY_TIME,FILE_LIST_ID)VALUES(SEQ_FILE.NEXTVAL,P_FILENAME,P_FILEPATH,P_FILETYPE,P_FILELENGTH,SYSDATE,P_FILEMODIFY,SEQ_FILE.CURRVAL);INSERT INTO FILE_LIST(LIST_ID, LIST_FILE)VALUES(SEQ_FILE.CURRVAL, empty_blob())RETURNING LIST_FILE INTO l_blob;l_bfile := bfilename('FILE_DIR', P_FILENAME);dbms_lob.fileopen(l_bfile);dbms_lob.loadfromfile(l_blob, l_bfile, dbms_lob.getlength(l_bfile));dbms_lob.fileclose(l_bfile);ELSEINSERT INTO FILE_LIST_INFO(FILE_ID,FILE_NAME,FILE_PATH,FILE_TYPE,FILE_LENGTH,FILE_UPDATE_TIME,FILE_MODIFY_TIME)VALUES(SEQ_FILE.NEXTVAL,P_FILENAME,P_FILEPATH,P_FILETYPE,P_FILELENGTH,SYSDATE,P_FILEMODIFY);END IF;COMMIT;END;PROCEDURE FILE_EXPORT_JAVA(P_FILE IN VARCHAR2, P_BLOB IN BLOB) ASLANGUAGE JAVA NAME 'DirList.Exportfile( java.lang.String, oracle.sql.BLOB)';PROCEDURE FILE_EXPORT(P_FILEPATH IN VARCHAR2, P_FILEID IN NUMBER) ISv_fileid NUMBER(10);v_filename VARCHAR(200);v_filetype VARCHAR(20);v_blob BLOB;BEGIN--check the file idBEGINSELECT FILE_LIST_INFO.FILE_LIST_ID,FILE_LIST_INFO.FILE_NAME,FILE_LIST_INFO.FILE_TYPE,FILE_LIST.LIST_FILEINTO v_fileid, v_filename, v_filetype, v_blobFROM FILE_LIST_INFO, FILE_LISTWHERE FILE_LIST_INFO.FILE_LIST_ID = FILE_LIST.LIST_IDAND FILE_LIST_INFO.FILE_LIST_ID = P_FILEID;EXCEPTIONWHEN NO_DATA_FOUND THENRAISE_APPLICATION_ERROR(-20017,'Can Not Find The File ID.' ||SQLERRM);END;FILE_EXPORT_JAVA(P_FILEPATH,v_blob);END; END PKG_FILE; /

總結(jié)

以上是生活随笔為你收集整理的Oracle JAVA SORCE and BLOB OBJECT的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。