Oracle中大對象(LOB)處理方法
目錄
- 一、LOB數據類型分類
- 1、按存儲數據的類型分
- 2、按存儲方式分
- 3、Null LOBs與Empty LOBs
- 二、LOB寫入
- 三、LOB讀取
- 四、BFile文件大對象(存儲在操作系統文件中的數據)
- 1. 創建
- 2. 讀取
- 五、將文件系統數據庫通過BFile導入到LOB字段中
- 六、C#讀寫Oracle BOLB數據。
- (1)寫入數據到Orable Blob字段中。
- (2)讀取Oracle Blob到文件中。
一、LOB數據類型分類
1、按存儲數據的類型分
- 字符類型:
CLOB:存儲大量 單字節 字符數據。
NLOB:存儲定寬 多字節 字符數據。 - 二進制類型:
BLOB:存儲較大無結構的二進制數據。 - 二進制文件類型:
BFILE:將二進制文件存儲在數據庫外部的操作系統文件中。存放文件路徑。
2、按存儲方式分
- 存儲在內部表空間:
CLOB,NLOB和BLOB - 指向外部操作系統文件:
BFILE
3、Null LOBs與Empty LOBs
DECLARE some_clob CLOB; BEGIN IF some_clob IS NULL THEN dbms_output.put_line("a"); --NULL 表示該 LOB 字段或變量中連 LOB 指針都沒有 ELSIF dbms_lob.getlength(some_clob) = 0 THEN dbms_output.put_line("b"); --empty LOB 是指該 LOB 字段或變量中保存了一個 LOB 指針,但這個指針并沒有指向任何 LOB 數據 ELSE dbms_output.put_line("c"); --指針有實際內容 END IF; END;
二、LOB寫入
Blob數據不能象其它類型數據一樣直接插入(INSERT)。插入前必須先插入一個空的Blob對象,BLOB類型的空對象為EMPTY_BLOB(),之后通過SELECT命令查詢得到先前插入的記錄并鎖定,繼而將空對象修改為所要插入的Blob對象。
當獲取到一個可用的 LOB 指針(定位器)后,就可以通過該指針寫入 LOB 數據了。有兩種寫入數據的系統函數:
- DBMS_LOB.WRITE :將數據隨機地寫入 LOB 中。
- DBMS_LOB.WRITEAPPEND :從 LOB 的最后開始寫入數據。
運用dbms_lob包用dbms_lob.write()寫入只能存儲32k以下的圖片。
注意:這里并不需要使用 UPDATE 來更新列 falls_myclob,因為這個 LOB 指針并沒有發生變化,我們只是將數據寫入它所指向的位置。
declare myclob clob; amount binary_integer; offset integer; first_direction varchar2(100); more_myclob varchar2(500); begin --刪除所有“munining Falls”的現有行,然后 delete from waterfalls where falls_name = "Munising Falls"; insert into waterfalls (falls_name, falls_myclob) values ("Munising Falls", EMPTY_CLOB()); --使用EMPTY_CLOB()插入新行來創建LOB定位器 select falls_myclob into myclob from waterfalls where falls_name = "Munising Falls"; --檢索由前面的INSERT語句創建的LOB定位器 --或直接 INSERT into waterfalls(falls_name, falls_myclob) values("Munising Falls" EMPTY_CLOB()); returning falls_myclob into myclob; DBMS_LOB.OPEN(myclob, DBMS_LOB.LOB_READWRITE); --打開LOB;不是嚴格必要的,但是最好打開/關閉lob。 first_direction := "Follow I-75 across the Mackinac Bridge."; amount := LENGTH(first_direction); --要寫的字符數 offset := 1; --開始寫CLOB的第一個字符 DBMS_LOB.WRITE(myclob, amount, offset, first_direction); --使用DBMS_LOB。開始寫 more_myclob := " Take US-2 west from St. Ignace to Blaney Park." || " From Seney, take M-28 west to Munising."; --使用DBMS_LOB.WRITEAPPEND添加更多的myclob DBMS_LOB.WRITEAPPEND(myclob, LENGTH(more_myclob), more_myclob); more_myclob := " In front of the paper mill, turn right on H-58." || " Sand Point Road."; --添加更多的myclob DBMS_LOB.WRITEAPPEND(myclob, LENGTH(more_myclob), more_myclob); DBMS_LOB.CLOSE(myclob); --關閉LOB,就完成了。 end;
三、LOB讀取
使用系統函數 DBMS_LOB.READ( ) 來讀取 LOB 中的數據,當然,首先要得到這個 LOB 指針。比如讀取 CLOB 數據,應該指定字符串的偏移量(offset),從指定的偏移量的位置開始讀取數據。
CLOB 的第一個字符的偏移量是1;也需要指定讀取的字符串長度。如果這個 CLOB 數據太大,應該多次讀取數據。對于 BLOB 數據,也是這樣處理,唯一的區別就是它是按字節存儲的。
DBMS_LOB.READ 中的第二個參數 chars_read_1,是 IN OUT 參數。
調用時按照該參數指定的長度來讀取數據,讀取完畢后,將其更新為實際讀取的字符(字節)長度。
當讀取后,該參數的值比你原來的值小,則說明已經讀取到 LOB 的末尾了。
declare myclob clob; myclob_1 varchar2(300); myclob_2 varchar2(300); chars_read_1 binary_integer; chars_read_2 binary_integer; offset integer; begin select falls_myclob into myclob from waterfalls where falls_name = "Munising Falls"; --檢索之前插入的LOB定位器 offset := 1; --從第一個字符開始閱讀 chars_read_1 := 229; --嘗試讀取myclob的229個字符時,chars_read_1將使用實際讀取的字符數進行更新 DBMS_LOB.READ(myclob, chars_read_1, offset, myclob_1); if chars_read_1 = 229 then --如果讀取229個字符,則更新偏移量并嘗試讀取255個字符。 offset := offset + chars_read_1; chars_read_2 := 255; DBMS_LOB.READ(myclob, chars_read_2, offset, myclob_2); else chars_read_2 := 0; myclob_2 := ""; end if; DBMS_OUTPUT.PUT_LINE("Characters read = " || TO_CHAR(chars_read_1 + chars_read_2)); --顯示讀取的字符總數 DBMS_OUTPUT.PUT_LINE(myclob_1); --顯示myclob DBMS_OUTPUT.PUT_LINE(myclob_2); end;
四、BFile文件大對象(存儲在操作系統文件中的數據)
PL/SQL中的Bfile只能讀取Bfile數據,而不能寫入。
BLOB,CLOB,NCLOB 存儲在數據庫內,而 BFILE 存儲在數據庫外。BFILE 和其他三種大字段類型相比,BFILE 有以下三點不同:
- BFILE 的數據是存儲在操作系統文件中的,而不是在數據庫中;
- BFILE 數據不參與事務處理,也就是說,BFILE 數據的改變不能被提交和回滾(但 BFILE 指針的改變是可以提交或回滾的);
- 從 PL/SQL 中,只能讀取 BFILE 數據,而不能寫入。必須得在數據庫外先創建 BFILE 文件,再創建 BFILE 指針。
在 PL/SQL 中操作 BFILE,其實也是操作 LOB 指針。只是對于 BFILE 的指針來說,它指向的 BFILE 數據在數據庫外。
所以,一個 BFILE 列的兩行,可以存儲指向同一個文件的 BFILE 指針。
1. 創建
BFILE 指針由目錄(Oracle服務器上)和文件名組成(而實際的目錄和文件可以不存在),將這兩部分信息作為參數傳入 BFILENAME 函數,該函數會返回一個 BFILE 指針。
create directory BFILE_DATA as "D:/temp"; declare waterfall_picture bfile; begin waterfall_picture := BFILENAME("BFILE_DATA","waterfall.gif"); --調用BFILENAME來創建BFILE定位器 insert into waterfalls (falls_name, falls_web_page) values ("my waterfall",waterfall_picture); --保存我們的新定位在waterfalls en
2. 讀取
declare waterfall bfile; piece raw(60); amount binary_integer := 60; offset integer := 1; begin select falls_web_page into waterfall from waterfalls where falls_name="my waterfall"; --檢索LOB定位器 DBMS_LOB.OPEN(waterfall); --打開定位器,讀取60個字節,然后關閉定位器 DBMS_LOB.READ(waterfall, amount, 1, piece); DBMS_LOB.CLOSE(waterfall); DBMS_OUTPUT.PUT_LINE(RAWTOHEX(piece));--十六進制顯示結果 --將原始結果轉換為我們可以讀取的字符串 --DBMS_OUTPUT.PUT_LINE(UTL_RAW.CAST_TO_VARCHAR2(piece)); end;
五、將文件系統數據庫通過BFile導入到LOB字段中
BFILE 提供了一種從數據庫中訪問文件系統中數據的方法。可能你想將這些數據保存到 BLOB 或 CLOB 字段中。
可以使用系統函數實現:
- dbms_lob.loadfrombfile
- dbms_lob.loadclobfrombfile
- dbms_lob.loadblobfrombfile
下面我們將圖片 watarfall.gif 保存到 BLOB 列中:
declare My_Falls_bfile bfile := BFILENAME("BFILE_DATA", "waterfall.gif"); photo blob; destination_offset integer := 1; source_offset integer := 1; begin delete from waterfalls where falls_name = "my waterfall"; --刪除Tannery Falls的行,所以這個例子可以運行多次。 insert into waterfalls (falls_name, FALLS_PHOTO) values ("my waterfall", EMPTY_BLOB());--使用EMPTY_BLOB()插入新行來創建LOB定位器 select FALLS_PHOTO into photo from waterfalls where falls_name = "my waterfall"; --檢索由前面的INSERT語句創建的LOB定位器 DBMS_LOB.OPEN(photo, DBMS_LOB.LOB_READWRITE);--打開目標BLOB和源BFILE DBMS_LOB.OPEN(My_Falls_bfile); DBMS_LOB.LOADBLOBFROMFILE(photo, My_Falls_bfile, DBMS_LOB.LOBMAXSIZE, destination_offset, source_offset); --Load the contents of the BFILE into the BLOB column DBMS_LOB.CLOSE(photo); --關閉兩個lob DBMS_LOB.CLOSE(My_Falls_bfile); end;
六、C#讀寫Oracle BOLB數據。
(1)寫入數據到Orable Blob字段中。
首先要在BLob字段中插入一個Empty_blob(),才能寫入下面的數據。
* 在調用此函數之前需要寫插入一個字符串到 BLOB 中比如: *"CREATE TABLE tablewithlobs (a int, b BLOB, c CLOB, d NCLOB)"; *"INSERT INTO tablewithlobs values (1, "AA", "AAA", N"AAAA")"; * 否則程序會在 OracleLob tempLob = reader.GetOracleLob(0) 處出錯。
寫入:
conn.Open(); OracleCommand cmd = conn.CreateCommand(); OracleTransaction transaction = cmd.Connection.BeginTransaction(); // 利用事務處理(必須) cmd.Transaction = transaction; // 獲得 OracleLob 指針 cmd.CommandText = "select fulls_myblob from waterfalls where fulls_name = "myabc" FOR UPDATE"; using (OracleDataReader reader = cmd.ExecuteReader()) { reader.Read(); //Obtain the first row of data. OracleBlob tempLob = reader.GetOracleBlobForUpdate(0); //Obtain a LOB. FileStream fs = new FileStream("c:\\1.txt", FileMode.Open); // 將文件寫入 BLOB 中 tempLob.BeginChunkWrite(); int length = 10485760; byte[] Buffer = new byte[length]; int i; while ((i = fs.Read(Buffer, 0, length)) > 0) { tempLob.Write(Buffer, 0, i); } fs.Close(); tempLob.EndChunkWrite(); cmd.Parameters.Clear(); } transaction.Commit(); // 提交事務 conn.Close();
(2)讀取Oracle Blob到文件中。
conn.Open(); OracleCommand cmd = conn.CreateCommand(); OracleTransaction trans = cmd.Connection.BeginTransaction();// 利用事務處理(必須) cmd.Transaction = trans; // 獲得 OracleLob 指針 string sql = "select fulls_myblob from waterfalls where fulls_name = "myabc""; cmd.CommandText = sql; OracleDataReader dr = cmd.ExecuteReader(); dr.Read(); OracleBlob tempLob = dr.GetOracleBlob(0); dr.Close(); // 讀取 BLOB 中數據,寫入到文件中 FileStream fs = new FileStream("c:\\1.txt", FileMode.Create); int length = 1048576; byte[] Buffer = new byte[length]; int i; while ((i = tempLob.Read(Buffer, 0, length)) > 0) { fs.Write(Buffer, 0, i); } fs.Close(); tempLob.Clone(); cmd.Parameters.Clear(); trans.Commit(); // 提交事務 conn.Close();
到此這篇關于Oracle中大對象(LOB)處理方法的文章就介紹到這了。希望對大家的學習有所幫助,也希望大家多多支持。
相關文章: