VastbaseG100

基于openGauss内核开发的企业级关系型数据库。

Menu

DBMS_LOB

功能描述

DBMS_LOB用于提供一组对blob(二进制数据类型)、clob(字符数据类型)和bfile数据类型(存储数据库外的大型对象,指向操作系统物理文件)操作的函数或过程。

注意事项

  • 该功能仅在数据库兼容模式为Oracle时能够使用(即创建DB时DBCOMPATIBILITY='A'),在其他数据库兼容模式下不能使用该特性。
  • write函数和append函数仅Vastbase G100 V2.2 Build 10(Patch No.12)及以后补丁版本支持此功能。

子程序

该内置包支持以下子程序:

子程序 描述
GETLENGTH 获取blob、clob和bfile数据类型的长度。
FILEOPEN 打开一个bfile文件。
READ 读取 LOB 的一部分,并从 LOB 开头的绝对偏移量开始,向缓冲区参数返回指定的数量。
支持读取BLOB、CLOB、BFILE对象类型。
FILECLOSE 关闭一个bfile文件。
OPEN 根据传入的参数打开对应的LOB对象。
COPY 根据传入的参数从指定位置开始将源LOB复制到目标LOB。
WRITEAPPEND 将指定数据添加到一个大对象的末尾。
CREATETEMPORARY 用来在临时表空间中创建临时BLOB或CLOB。
FREETEMPORARY 释放临时表空间中的临时BLOB或CLOB。
INSTR 该函数用来返回LOB中指定模式第n次出现的匹配位置,从指定的偏移量开始。
WRITE 从BOLB(CLOB)开头的指定偏移量offset开始,将指定数量amount的数据写入BLOB(CLOB)中,数据从缓冲区写入。
如果从BLOB(CLOB)指定偏移量开始有数据存在,WRITE函数会从偏移位置开始覆盖指定长度amount的数据。
APPEND 将源BLOB(CLOB)数据追加到目标BLOB(CLOB)数据后。

GETLENGTH

语法格式

BLOB对象类型:由于存储的内容即为二进制数据,直接返回二进制内容的字节数即可,函数原型为:

DBMS_LOB.GETLENGTH (
   lob_loc    IN  BLOB) 
  RETURN INTEGER;

CLOB对象类型:该对象存储的数据格式为字符数据,返回值为字符数。函数原型为:

DBMS_LOB.GETLENGTH (
lob_loc    IN  CLOB) 
RETURN INTEGER; 

BFILE对象类型:函数返回bfile数据指向的操作系统物理文件的长度,以字节为单位,bfile文件的长度包含了文件结尾符(eof)。函数原型为:

DBMS_LOB.GETLENGTH (
 file_loc   IN  BFILE) 
 RETURN INT8;

参数说明

file_loc:将要返回其长度的文件位置。

示例

示例1:

1、创建测试表并插入数据。

create table testclob (data clob);
insert into testclob values('中文测试');

2、查询数据长度。

select dbms_lob. getlength (data) from testclob;

返回结果为:

 getlength
-----------
         4
(1 row)

示例2:

1、创建测试表并插入数据。

create table testblob (data blob);
insert into testblob values(utl_raw.cast_to_raw('中文测试'));

2、查询数据长度。

select dbms_lob. getlength (data) from testblob;

返回结果为:

 getlength
-----------
        12
(1 row)

FILEOPEN

语法格式

DBMS_LOB.FILEOPEN (
file_loc   IN OUT BFILE, 
open_mode  IN   BINARY_INTEGER ); 

参数说明

  • file_loc:要打开的文件定位。

  • open_mode:文件访问模式。

READ

语法格式

DBMS_LOB.READ (
   file_loc   IN             BFILE,
   amount    IN OUT   INTEGER,
   offset    IN              INTEGER,
   buffer    OUT             RAW);

参数说明

  • file_loc:lob要检查的文件。
  • amount:读取文件的长度。为了防止打开的文件过大,单次读取的内容超过机器缓冲区导致系统崩溃,规定单次读取的字节数不能大于32767字节,即amount为大于0小于等于32767的正整数。
  • offset:用于多次读取文件时设置读取的起始位置,如果offset参数指向bfile文件结尾或超出文件结尾,则将amount参数设置为0,并抛出异常。
  • buffer:读取操作的输出缓冲区。

示例

读取BFILE请参考DBMS_LOB.FILEOPEN。以下是一个DBMS_LOB.READ读取BLOB的示例:

仅Vastbase G100 V2.2 Build 10(Patch No.17)及以后版本支持CLOB和BLOB。

set serveroutput on;  --使信息从存储过程传输回应用程序并输出在屏幕上
declare
lob blob:=utl_raw.cast_to_raw('123456');
amount int := 4;
off_set int := 3;
buf varchar2(100);
begin
dbms_lob.read(lob,amount,off_set,buf);
dbms_output.put_line(buf);
end;
/

输出读取操作的缓冲区:

33343536
ANONYMOUS BLOCK EXECUTE

FILECLOSE

语法格式

DBMS_LOB.FILECLOSE (
    file_loc IN OUT BFILE); 

参数说明

file_loc:要关闭的文件。

OPEN存储过程

语法格式

DBMS_LOB.OPEN (
   lob_loc   IN OUT NOCOPY BLOB,
   open_mode IN            BINARY_INTEGER);
   
DBMS_LOB.OPEN (
   lob_loc   IN OUT NOCOPY CLOB CHARACTER SET ANY_CS,
   open_mode IN            BINARY_INTEGER);
 
DBMS_LOB.OPEN (
   file_loc  IN OUT NOCOPY BFILE,
   open_mode IN            BINARY_INTEGER := file_readonly);

参数说明

  • lob_loc:LOB类型的对象名。
  • open_mode:打开模式。对于BLOB,CLOB对象,可以选择LOB_READONLY或者LOB_READWRITE。对于BFILE类型,只能是FILE_READONLY。(LOB_READONLY:只读。LOB_READWRITE:可读写。FILE_READONLY:只读。)

示例

1、创建含blob、clob类型字段的表。

create table testtable(id int,c_lob clob,b_lob blob);
insert into testtable values(1,'clob测试',utl_raw.cast_to_raw('blob'));

2、调用open存储过程。

set serveroutput on;
declare 
  v_clob clob;
  v_clob2 clob;
  len int;
begin
  select c_lob into v_clob from testtable where id=1;
  dbms_lob.open(v_clob,dbms_lob.lob_readwrite);
  dbms_output.put_line('clob1:'||v_clob);
  dbms_lob.close(v_clob);
end;
/

返回结果为:

clob1:clob测试
ANONYMOUS BLOCK EXECUTE

COPY存储过程

语法格式

DBMS_LOB.COPY (
  dest_lob    IN OUT NOCOPY BLOB,
  src_lob     IN            BLOB,
  amount      IN            INTEGER,
  dest_offset IN            INTEGER := 1,
  src_offset  IN            INTEGER := 1);

DBMS_LOB.COPY ( 
  dest_lob    IN OUT NOCOPY CLOB  CHARACTER SET ANY_CS,
  src_lob     IN            CLOB  CHARACTER SET dest_lob%CHARSET,
  amount      IN            INTEGER,
  dest_offset IN            INTEGER := 1,
  src_offset  IN            INTEGER := 1);

参数说明

  • dest_lob:目标LOB对象。
  • src_lob:源LOB对象。
  • amount:复制的长度。
  • dest_offset:目标LOB中的偏移量。
  • src_offset:源LOB中的偏移量。

示例

存储过程调用copy函数,输入参数中的dest_lob为clob类型。

1、创建含blob类型字段的表并插入数据。

create table testtable_01(id int,c_lob clob);
insert into testtable_01 values(1,'blobtest1测试测试');
insert into testtable_01 values(2,'blobtest2测试测试');

2、调用COPY函数。

set serveroutput on;
DECLARE
vdest_lob CLOB;
vsrc_lob CLOB;
amount NUMBER;
dest_offset NUMBER;
src_offset NUMBER;
BEGIN
SELECT c_lob INTO vdest_lob FROM testtable_01 WHERE id = 1 ;
SELECT c_lob INTO vsrc_lob FROM testtable_01 WHERE id = 2 ;
amount := DBMS_LOB.GETLENGTH(vsrc_lob);
dest_offset := DBMS_LOB.GETLENGTH(vdest_lob) + 1;
src_offset := 1;
DBMS_LOB.COPY(vdest_lob, vsrc_lob, amount, dest_offset, src_offset);
DBMS_OUTPUT.PUT_LINE('拷贝结果为: ' || vdest_lob);
END;
/

返回结果为:

拷贝结果为: blobtest1测试测试blobtest2测试测试
ANONYMOUS BLOCK EXECUTE

WRITEAPPEND存储过程

语法格式

DBMS_LOB.WRITEAPPEND (
   lob_loc IN OUT NOCOPY BLOB, 
   amount  IN            INTEGER, 
   buffer  IN            RAW); 
   
DBMS_LOB.WRITEAPPEND (
   lob_loc IN OUT NOCOPY CLOB CHARACTER SET ANY_CS, 
   amount  IN            INTEGER, 
   buffer  IN            VARCHAR2 CHARACTER SET lob_loc%CHARSET);

参数说明

  • lob_loc:LOB类型的对象名。
  • amount:追加的长度。
  • buffer:待追加的内容。

示例

调用writeappend函数将数据添加对lob的末尾,lob_loc类型为clob。

1、创建含测试表。

create table bak_dbms_lob(
bak_id number(4),
bak_comment clob
);

2、插入测试数据。

insert into bak_dbms_lob(bak_id,bak_comment) values(1,'a');
insert into bak_dbms_lob(bak_id,bak_comment) values(2,'ab');
insert into bak_dbms_lob(bak_id,bak_comment) values(3,'abcdefgccccccc');
insert into bak_dbms_lob(bak_id,bak_comment) values(4,'a bcdefg');
select * from bak_dbms_lob;

返回结果为:

 bak_id |  bak_comment
--------+----------------
      1 | a
      2 | ab
      3 | abcdefgccccccc
      4 | a bcdefg
(4 rows)

3、调用调用writeappend函数。

set serveroutput on;
declare
lob_loc clob;
amount integer:= 18;
buffer_text varchar2(20) := 'added text to clob';
begin
select bak_comment into lob_loc from bak_dbms_lob where bak_id = 2;
dbms_lob.writeappend(lob_loc,amount,buffer_text);
dbms_output.put_line('添加后的字段为:' || lob_loc);
end;
/

返回结果为:

添加后的字段为:abadded text to clob
ANONYMOUS BLOCK EXECUTE

CREATETEMPORARY存储过程

语法格式

DBMS_LOB.CREATETEMPORARY (
   lob_loc IN OUT NOCOPY BLOB,
   cache   IN            BOOLEAN,
   dur     IN            PLS_INTEGER := DBMS_LOB.SESSION);
  
DBMS_LOB.CREATETEMPORARY (
   lob_loc IN OUT NOCOPY CLOB CHARACTER SET ANY_CS,
   cache   IN            BOOLEAN,
   dur     IN            PLS_INTEGER := 10);

参数说明

  • lob_loc:LOB类型的对象名。
  • cache:是否将LOB读取到缓冲区。
  • dur:指定何时清除临时LOB(10/ SESSION:会话结束时;12/ CALL:调用结束时)。

示例

调用createtemporary存储过程,创建临时clob。

set serveroutput on;
DECLARE
v_clob CLOB;
v_amount INT;
v_offset INT;
v_char VARCHAR2(100);
BEGIN
v_char := 'Chinese中国人';
v_offset := 1;
v_amount := 8;
dbms_lob.createtemporary(v_clob,TRUE,12);
FOR i IN 1..2 LOOP
dbms_lob.writeappend(v_clob,v_amount,v_char);
dbms_output.put_line(v_clob||' 字符长度:'||dbms_lob.getlength(v_clob));
END LOOP;
END;
/

返回结果为:

Chinese中 字符长度:8
Chinese中Chinese中 字符长度:16
ANONYMOUS BLOCK EXECUTE

FREETEMPORARY存储过程

语法格式

DBMS_LOB.FREETEMPORARY (
   lob_loc  IN OUT  NOCOPY BLOB); 

DBMS_LOB.FREETEMPORARY (
   lob_loc  IN OUT  NOCOPY CLOB CHARACTER SET ANY_CS);

参数说明

lob_loc:LOB类型的对象名。

示例

调用freetemporary存储过程,创建临时clob后释放。

set serveroutput on;
DECLARE
v_clob CLOB;
v_amount INT;
v_offset INT;
v_char VARCHAR2(100);
BEGIN
v_char := 'Chinese中国人';
v_offset := 1;
v_amount := 8;
dbms_lob.createtemporary(v_clob,TRUE,12);
dbms_lob.writeappend(v_clob,v_amount,v_char);
dbms_output.put_line(v_clob||' 字符长度:'||dbms_lob.getlength(v_clob));
dbms_lob.freetemporary(v_clob);
dbms_output.put_line(' 释放后再输出:'||v_clob);
END;
/

返回结果为:

Chinese中 字符长度:8
释放后再输出:
ANONYMOUS BLOCK EXECUTE

INSTR函数

语法格式

DBMS_LOB.INSTR (
   lob_loc    IN   BLOB,
   pattern    IN   RAW,
   offset     IN   INTEGER := 1,
   nth        IN   INTEGER := 1)
  RETURN INTEGER;
  
DBMS_LOB.INSTR (
   lob_loc    IN   CLOB      CHARACTER SET ANY_CS,
   pattern    IN   VARCHAR2  CHARACTER SET lob_loc%CHARSET,
   offset     IN   INTEGER := 1,
   nth        IN   INTEGER := 1)
  RETURN INTEGER;
  
DBMS_LOB.INSTR (
   file_loc   IN   BFILE,
   pattern    IN   RAW,
   offset     IN   INTEGER := 1,
   nth        IN   INTEGER := 1)
  RETURN INTEGER;

参数说明

  • lob_loc:待查找的LOB对象。
  • file_loc:待查找的BFILE类型LOB对象。
  • pattern:以字节为单位或以字符为单位的模式,用于匹配大对象中的内容。如果lob_loc代表BLOB类型大对象或file_loc代表BFILE类型大对象,那么模式必须是RAW类型。如果lob_loc代表CLOB类型大对象,那么模式必须是VARCHAR2类型。
  • offset:参数lob_loc或file_loc代表的大对象中搜索模式时的开始位置。第一个字节或字符是位置1。默认值为1。
  • nth:由给定的偏移量指定起始位置,开始搜索指定模式第n次出现时的位置。默认值为1。

返回值

匹配模式的起始偏移量,以字节或字符为单位。如果找不到模式,则返回0。

以下几种情况下返回NULL:

  • 任何一个或多个IN参数为NULL或无效。

  • offset < 1 或者 offset > LOBMAXSIZE。

  • nth < 1 或者 nth > LOBMAXSIZE

示例

调用instr函数。

select dbms_lob.instr('blob test'::clob,'test',1,1);

返回结果为:

 instr
-------
     6
(1 row)

WRITE函数

语法格式

DBMS_LOB.WRITE(
    lob_loc IN OUT NOCOPY BLOB,
    amount IN INTEGER,
    offset IN INTEGER,
    buffer IN RAW);

DBMS_LOB.WRITE(
    lob_loc IN OUT NOCOPY CLOB CHARACTER SET ANY_CS,
    amount IN INTEGER,
    offset IN INTEGER,
    buffer IN VARCHAR2 CHARACTER SET lob_loc%CHARSET);

参数说明

  • lob_loc

    LOB 的locator。

  • amount

    要写入的BLOB字节数或者CLOB的字符数。

  • offset

    写操作中从BLOB开头的字节数偏移量,或者CLOB开头的字符数偏移量,起始处下标为1。

  • buffer

    写入操作的输入缓冲区。

返回值

  • 传入BLOB时返回RAW类型。

  • 传入CLOB时返回TEXT类型。

使用DBMS_LOB.WRITE函数时,以下情况将出现报错: - 传入lob_loc、amount、offset参数的任何一个为NULL,超出范围或无效时; - 传入amount<1、amount>32767、offset<1、offset>LOBMAXSIZE时。

示例1: 入参lob_loc为BLOB。

1、使用vsql工具连接至客户端。

vsql -d vastbase -p 5432 -r

2、创建并切换至兼容模式为Oracle的数据库db_oracle下。

CREATE DATABASE db_oracle dbcompatibility='A';    
\c db_oracle

3、允许将dbms_output.put_line的输出信息输出至vsql的命令界面的屏幕上。

set serveroutput on;

4、调用DBMS_LOB.WRITE函数,根据指定偏移量对输入的BLOB内容进行覆盖。

declare
b1 blob :=utl_raw.cast_to_raw('测试ABC123');
amount INTEGER :=3;
off_set INTEGER :=4;
b2 blob :=utl_raw.cast_to_raw('abc');
BEGIN
dbms_lob.write(b1,amount,off_set,b2);
dbms_output.put_line(utl_raw.cast_to_varchar2(b1));
end;
/

返回结果如下:

测abcABC123
ANONYMOUS BLOCK EXECUTE

示例2: 入参lob_loc为CLOB。

1、使用vsql工具连接至客户端。

vsql -d vastbase -p 5432 -r

2、创建并切换至兼容模式为Oracle的数据库db_oracle下。

CREATE DATABASE db_oracle dbcompatibility='A';    
\c db_oracle

3、允许将dbms_output.put_line的输出信息输出至vsql的命令界面的屏幕上。

set serveroutput on;

4、调用DBMS_LOB.WRITE函数,根据指定偏移量对输入的CLOB内容进行覆盖。

declare
b1 clob :='测试ABC123';
amount INTEGER :=3;
off_set INTEGER :=4;
b2 clob :='abc';
BEGIN
dbms_lob.write(b1,amount,off_set,b2);
dbms_output.put_line(b1);
end;
/

返回结果如下:

测试Aabc23
ANONYMOUS BLOCK EXECUTE

APPEND函数

语法格式

DBMS_LOB.APPEND(
    dest_lob IN OUT NOCOPY BLOB,
    src_lob IN BLOB);

DBMS_LOB.APPEND(
    dest_lob IN OUT NOCOPY CLOB CHARACTER SET ANY_CS,
    src_lob IN CLOB CHARACTER SET dest lob%CHARSET);

参数说明

  • dest_lob

    要向其添加数据的目标BLOB(CLOB)的locator。

  • src_lob

    要从中读取数据的源BLOB(CLOB)的locator。

返回值

  • 传入BLOB时返回RAW类型。

  • 传入CLOB时返回TEXT类型。

    传入的dest_lob或者src_lob为空时,报错。

示例1: 入参lob_loc为BLOB。

1、使用vsql工具连接至客户端。

vsql -d vastbase -p 5432 -r

2、创建并切换至兼容模式为Oracle的数据库db_oracle下。

CREATE DATABASE db_oracle dbcompatibility='A';    
\c db_oracle

3、允许将dbms_output.put_line的输出信息输出至vsql的命令界面的屏幕上。

set serveroutput on;

4、调用DBMS_LOB.APPEND函数,将源BLOB追加到目标BLOB后。

declare
b1 blob :=utl_raw.cast_to_raw('测试ABC123');
b2 blob :=utl_raw.cast_to_raw('abc');
BEGIN
dbms_lob.append(b1,b2);
dbms_output.put_line(utl_raw.cast_to_varchar2(b1));
end;
/

返回结果如下:

测试ABC123abc
ANONYMOUS BLOCK EXECUTE

示例2: 入参lob_loc为CLOB。

1、使用vsql工具连接至客户端。

vsql -d vastbase -p 5432 -r

2、创建并切换至兼容模式为Oracle的数据库db_oracle下。

CREATE DATABASE db_oracle dbcompatibility='A';    
\c db_oracle

3、允许将dbms_output.put_line的输出信息输出至vsql的命令界面的屏幕上。

set serveroutput on;

4、调用DBMS_LOB.APPEND函数,将源CLOB追加到目标CLOB后。

declare
b1 clob :='测试ABC123';
amount INTEGER :=3;
off_set INTEGER :=4;
b2 clob :='abc';
BEGIN
dbms_lob.write(b1,amount,off_set,b2);
dbms_output.put_line(b1);
end;
/

返回结果如下:

测试Aabc23
ANONYMOUS BLOCK EXECUTE

示例

1、操作系统环境下创建文件,并输入数据。

 vi /home/vastbase/bfile.data
 cat /home/vastbase/bfile.data

文件内容为:

张三
李四

2、在数据库中执行如下命令创建目录和表。

create directory d_bfile as '/home/vastbase';
create table testbfile1(id number,bfile_name bfile);

3、调用bfilename函数构造bfile数据并插入到表中。

insert into testbfile1 values(1,bfilename('d_bfile', 'bfile.data'));
set serveroutput on;

4、创建函数。

create or replace function f_read_bfile() returns void as $$
declare
buff raw;
amount int := 0 ;
offset int :=0;
lob_loc bfile;
filesize int;
begin
select bfile_name into lob_loc from testbfile1 where id=1;
--打开BFILE文件
dbms_lob.fileopen(lob_loc,0);
--获取文件大小
filesize := dbms_lob.getlength(lob_loc);
raise notice 'amount:%',amount;
--读取文件全部内容
amount = filesize;
dbms_lob.read(lob_loc,amount,0,buff);
dbms_output.put_line('file data:');
dbms_output.put_line(utl_raw.cast_to_varchar2(buff));
--关闭bfile文件
dbms_lob.fileclose(lob_loc);
return;
end;
$$ language plpgsql;

5、调用函数。

select f_read_bfile();

返回结果为:

file data:
张三
李四

 f_read_bfile
--------------

(1 row)