程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 數據庫知識 >> Oracle數據庫 >> Oracle數據庫基礎 >> Oracle存儲過程讀寫文件

Oracle存儲過程讀寫文件

編輯:Oracle數據庫基礎

Oracle存儲過程讀寫文件是實現文件與數據庫表之間交互的重要手段,下面就為您詳細介紹Oracle存儲過程讀寫文件方面的知識,希望對您能有所幫助。

有時候我們需要在文件與數據庫表之間利用程序來實現兩者的交互,這裡可以利用UTL_FILE包實現對文件的I/O操作.下面就分別介紹文件寫表以及表數據寫文件.

[1]表信息導出到文件

在SUSE上建議一個文件夾/home/zxin10/file,然後對其chmod g+w file進行授權(否則無法導出到文件),再對您指定的路徑(/home/zxin10/file)向Oracle的系統表sys.dir$進行注冊(否則也是無法成功將信息導出到文件),操作完後可以查詢sys.dir$可以看到表中的OS_PATH中有您指定的路徑位置.

注冊方式:執行SQL語句create or replace directory BBB as '/home/zxin10/file'; 即可

存儲過程如下:(寫文件時,文件名可以不用先創建,程序中會自動創建指定文件)

  1. CREATE OR REPLACE PROCEDURE V3_SUB_FETCH_TEST_2  
  2. (  
  3.    V_TEMP VARCHAR2,  
  4.    --1為成功,0為失敗  
  5.    v_retvalue   OUT NUMBER   
  6.  )  
  7. AS  
  8.   --游標定義  
  9.   type ref_cursor_type is REF CURSOR;  
  10.   cursor_select   ref_cursor_type;  
  11.   select_cname    varchar2(1000);  
  12.     
  13.   v_file_handle   utl_file.file_type;  
  14.     
  15.   v_sql varchar2(1000);  
  16.   v_filepath Varchar2(500);  
  17.   v_filename Varchar2(500);  
  18.   --緩沖區  
  19.   v_results Varchar2(500);  
  20.     
  21.   v_pid varchar2(1000);  
  22.   v_cpcnshortname Varchar2(500);  
  23.    
  24.   begin  
  25.       v_filepath :V_TEMP;  
  26.       if v_filepath is null then  
  27.          v_filepath :'/home/zxin10/file3';  
  28.       end if;  
  29.       v_filename:='free_'|| substr(to_char(sysdate,'YYYYMMDDHH24MI'),1,10) ||'.all' ;  
  30.       --游標開始  
  31.       select_cname:='select cpid,cpcnshortname from zxdbm_ismp.scp_basic';   
  32.       --打開一個文件句柄 ,同時fopen的第一個參數必須是大寫     
  33.       v_file_handle:=utl_file.fopen('BBB',v_filename,'A');  
  34.       Open cursor_select For select_cname;     
  35.       Fetch  cursor_select into v_pid,v_cpcnshortname;  
  36.       While  cursor_select%Found     
  37.       Loop  
  38.       v_results :v_pid||'|'||v_cpcnshortname;  
  39.       --將v_results寫入文件  
  40.       utl_file.put_line(v_file_handle,v_results);     
  41.       Fetch  cursor_select into v_pid,v_cpcnshortname;        
  42.       End Loop;  
  43.         
  44.       Close cursor_select;--關閉游標  
  45.       utl_file.fClose(v_file_handle);--關閉句柄  
  46.       v_retvalue :=1;  
  47.   exception when others then  
  48.          v_retvalue :=0;   
  49.   end V3_SUB_FETCH_TEST_2; 

[2]將文件信息導入到表中

和上面一樣,先對指定文件路徑進行chmod,然後想Oracle的sys.dir$進行路徑注冊.

文件zte.apsuic位於/home/zxin10/file下,其數據格式:
1|22|cheng
2|33|zhou
3|44|heng
4|55|yaya

表LOADDATA腳本:

  1. -- Create table  
  2. create table LOADDATA  
  3. (  
  4.   ID   VARCHAR2(50),  
  5.   AGE  VARCHAR2(50),  
  6.   NAME VARCHAR2(50)  
  7. )  
  8.     / 

程序如下:(讀取文件時,指定文件名一定要預先存在,否則程序會失敗)

  1. create or replace directory BBB as '/home/zxin10/file';  
  2. /  
  3. --作用法是將特定的文件路徑信息想Oracle注冊(注冊信息存放在sys.dir$表中)  
  4.  
  5. CREATE OR REPLACE PROCEDURE V3_SUB_FETCH_TEST_3  
  6. (  
  7.    --文件中的信息導入表中  
  8.      V_TEMP VARCHAR2,  
  9.      v_retvalue   OUT NUMBER --1 成功 ,0失敗  
  10. AS   
  11.   v_file_handle   utl_file.file_type;    
  12.   v_sql varchar2(1000);  
  13.   v_filepath Varchar2(500);  
  14.   v_filename Varchar2(500);    
  15.   --文件到表字段的映射  
  16.   v_id varchar2(1000);  
  17.   v_age varchar2(1000);  
  18.   v_name varchar2(1000);  
  19.   --緩沖區  
  20.   v_str varchar2(1000);  
  21.   --列指針  
  22.   v_i number;  
  23.   --字符串定位解析指針  
  24.   v_sposition1 number;  
  25.   v_sposition2 number;  
  26.   begin  
  27.       v_filepath :V_TEMP;  
  28.       if v_filepath is null then  
  29.          v_filepath :'/home/zxin10/file';  
  30.       end if;  
  31.       v_filename:='zte.apsuic';  
  32.       --v_sql:= 'create or replace directory CCC as '''|| v_filepath || '''';  
  33.       --execute immediate v_sql;   
  34.         
  35.       v_file_handle:=utl_file.fopen('CCC',v_filename,'r');         
  36.       Loop  
  37.              --將文件信息讀取到緩沖區v_str中,每次讀取一行  
  38.              utl_file.get_line(v_file_handle,v_str);  
  39.              --dbms_output.put_line(v_str);   
  40.              --針對每行的列數  
  41.              v_i :1;  
  42.              --針對字符串每次的移動指針  
  43.              v_sposition1 :1;  
  44.              --文件中每行信息3列,循環3次  
  45.              FOR I IN 1..3 loop                 
  46.              --當instr(v_str, '|', 6)其中v_str為1|22|wuzhuocheng ,它返回0  
  47.              v_sposition2 :instr(v_str, '|', v_sposition1);  
  48.              --字符串解析正常情況  
  49.              if v_sposition2 <> 0 then  
  50.                if v_i=1     then  
  51.                   v_id :substr(v_str, v_sposition1, v_sposition2 - v_sposition1);      --第一列                 
  52.                elsif  v_i=2 then  
  53.                     v_age :substr(v_str, v_sposition1, v_sposition2 - v_sposition1); --第二列  
  54.                elsif v_i=3  then  
  55.                   v_name :substr(v_str, v_sposition1, v_sposition2 - v_sposition1);    --第三列   
  56.                else  
  57.                   return;  
  58.                end if;                              
  59.              --字符串解析異常情況  
  60.              else   
  61.                if v_i=1    then  
  62.                 v_id :substr(v_str, v_sposition1);      --第一列  
  63.                elsif v_i=2 then  
  64.                   v_age :substr(v_str, v_sposition1); --第二列  
  65.                elsif v_i=3 then  
  66.                 v_name :substr(v_str, v_sposition1);    --第三列   
  67.                else  
  68.                 return;  
  69.                end if;    
  70.              end if;     
  71.              v_sposition1 :v_sposition2 + 1;  
  72.              v_i :v_i+1;  
  73.              end loop;   
  74.              --每列循環完後將信息insert into表中  
  75.              insert into zxdbm_ismp.loaddata values(v_id,v_age,v_name);                    
  76.       End Loop;  
  77.       --關閉句柄  
  78.       utl_file.fClose(v_file_handle);  
  79.       v_retvalue :=1;  
  80.   exception when others then  
  81.          v_retvalue :=0;   
  82.   end V3_SUB_FETCH_TEST_3;  
  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved