ORACLE批量導(dǎo)入圖片到BLOB字段代碼示例

-- Create directory 
create or replace directory 圖片目錄
 as 'E:\照片';

CREATE OR REPLACE PROCEDURE PRO_插入圖片(V_表名 IN VARCHAR2) IS
 P_FILENAME VARCHAR2(50); --照片名，動(dòng)態(tài)拼接得到
 P_證件號碼 VARCHAR2(50);
 P_姓名   VARCHAR2(50);--這個(gè)照片名是通過姓名+證件號拼接得到的，因?yàn)榛A(chǔ)測試數(shù)據(jù)沒有提供真實(shí)的證件號碼，就選擇用手機(jī)號來代替
 P_查詢SQL VARCHAR2(500);
 P_更新SQL VARCHAR2(5000);
 P_LOB   BLOB;
 P_FILE   BFILE;
 TYPE P_REF_CURSOR IS REF CURSOR; --定義動(dòng)態(tài)游標(biāo)變量類型
 P_CURSOR P_REF_CURSOR; --定義動(dòng)態(tài)游標(biāo)變量，因?yàn)橐淮我迦肴淼恼掌?，所以選擇用游標(biāo)來處理
 TYPE P_ROW_RECORD IS RECORD(
  證件號碼 VARCHAR2(50),
  姓名   VARCHAR2(50));
 C_ROW P_ROW_RECORD;
 V_ERR VARCHAR2(300);
BEGIN
 P_更新SQL := 'update ' || V_表名 || ' set 證件號碼=手機(jī)號碼 WHERE 證件號碼 IS NULL';
--用手機(jī)號來代替證件號碼為空的數(shù)據(jù)
 EXECUTE IMMEDIATE P_更新SQL;
 COMMIT;
 P_查詢SQL := 'SELECT 證件號碼,姓名 FROM ' || V_表名 ||
       ' WHERE 證件號碼 IS NOT NULL and 照片 IS NULL order by 證件號碼';
 OPEN P_CURSOR FOR P_查詢SQL;
 LOOP
  begin
   FETCH P_CURSOR
    INTO C_ROW;
   EXIT WHEN P_CURSOR%NOTFOUND;

   P_證件號碼 := C_ROW.證件號碼;
   P_姓名   := C_ROW.姓名;
   SELECT REPLACE(P_證件號碼, ' ', '') INTO P_證件號碼 FROM DUAL;
   SELECT substr(P_證件號碼, 1, 11) INTO P_證件號碼 FROM DUAL;
   SELECT REPLACE(P_姓名, ' ', '') INTO P_姓名 FROM DUAL;
   P_FILENAME := P_證件號碼 || P_姓名 || '.jpg';
   SELECT REPLACE(P_FILENAME, ' ', '') INTO P_FILENAME FROM DUAL;
--以下便是插入圖片的核心代碼
   INSERT INTO TA_照片總表_TEMP
    (證件號碼, 姓名, 照片)
   VALUES
    (P_證件號碼, P_姓名, EMPTY_BLOB()) RETURN 照片 INTO P_LOB;
   --獲取指定目錄下的文件
   P_FILE := BFILENAME('圖片目錄', P_FILENAME);
   --以只讀的方式打開文件
   DBMS_LOB.FILEOPEN(P_FILE, DBMS_LOB.FILE_READONLY);
   --傳遞對象
   DBMS_LOB.LOADFROMFILE(P_LOB, P_FILE, DBMS_LOB.GETLENGTH(P_FILE));
   --關(guān)閉原始文件
   DBMS_LOB.FILECLOSE(P_FILE);
   COMMIT;

   P_更新SQL := 'UPDATE ' || V_表名 ||
         ' A SET a.照片=(SELECT 照片 FROM TA_照片總表_TEMP b 
         WHERE A.證件號碼 = B.證件號碼 and a.姓名=b.姓名 AND ROWNUM=1)
   WHERE EXISTS (SELECT 1 FROM TA_照片總表_TEMP B WHERE A.證件號碼 = B.證件號碼 and a.姓名=b.姓名)';
   EXECUTE IMMEDIATE P_更新SQL;
   COMMIT;
  EXCEPTION

   WHEN OTHERS THEN
    rollback;
    V_ERR := SUBSTR(SQLERRM, 1, 150) || '照片名:' || P_FILENAME;

    INSERT INTO TA_程序運(yùn)行異常記錄
    VALUES
     (SQ_異常序列.NEXTVAL, 'PRO_插入圖片', V_ERR, SYSDATE);
    COMMIT;
  end;
 END LOOP;
 CLOSE P_CURSOR;
 COMMIT;
 DELETE TA_照片總表_TEMP;
 COMMIT;
END PRO_插入圖片;