在知识库中专注阅读，并随时返回相关工具与课程
原文地址：https://oracle-base.com/articles/21c/dbmscloud-packagehttps://oracle-base.com/articles/21c/dbmscloud-package 原文作者：Tim Hall 本文介绍了 DBMSCLOUD 包的基本用法。 @TOC目录 自治数据库中引入了 DBMSCLOUD 包，以提供一种与数据库中的对象存储进行交互
原文地址：https://oracle-base.com/articles/21c/dbms_cloud-package 原文作者：Tim Hall
本文介绍了 DBMS_CLOUD 包的基本用法。
自治数据库中引入了 DBMS_CLOUD 包，以提供一种与数据库中的对象存储进行交互的简单方法。它可用于版本 19c 和 21c 的本地安装。 它同样适用于 AWS S3 存储 buckets 或 Oracle Cloud Object Storage 存储 buckets。
本章目标：掌握本章核心知识点 前置要求：完成前序章节学习 预计时长：60 分钟
本文中的大多数示例都使用 DBMS_CLOUD 包的本地安装，但某些功能似乎只能在自治数据库上正常工作，过程中我将强调这些限制出现的地方。
DBMS_CLOUD 包默认存在于自治数据库中，它未安装在 Oracle 19c 或 21c 安装中，因此必须手动安装，此 MOS 说明中描述了安装。
可以参考下方的安装示例：
对于某些示例，我们需要一个对象存储 buckets。这可以是 Oracle Cloud Object Store 存储 buckets 或 AWS S3 存储 buckets。以下文章介绍了如何创建 Oracle Cloud Object Store 存储 buckets。
我们创建一个测试用户，确保用户可以创建凭据，并授予其访问 DBMS_CLOUD 包的权限。
1conn sys/SysPassword1@//localhost:1521/pdb1 as sysdba23--drop user testuser1 cascade;4create user testuser1 identified by testuser1 quota unlimited on users;5grant connect, resource to testuser1;67grant create credential to testuser1;8grant execute on dbms_cloud to testuser1;我们需要一个本地目录对象来与数据库文件服务器上的文件进行交互，授予 test 用户和 C##CLOUD$SERVICE 用户访问此目录的权限。
1create or replace directory tmp_files_dir as '/tmp/files';2grant read, write on directory tmp_files_dir to testuser1, C##CLOUD$SERVICE;外部表功能需要访问名为 DATA_PUMP_DIR 的目录对象，因此在 PDB 中创建它并向测试用户授予读/写访问权限。
1alter session set "_oracle_script"=TRUE;2create or replace directory data_pump_dir as '/u01/app/oracle/admin/cdb1/dpdump/';3alter session set "_oracle_script"=FALSE;4grant read, write on directory data_pump_dir to testuser1;连接到测试用户并创建下表：
1conn testuser1/testuser1@//localhost:1521/pdb123create table emp (4 empno number(4,0), 5 ename varchar2(10 byte), 6 job varchar2(9 byte), 7 mgr number(4,0), 8 hiredate date, 9 sal number(7,2), 10 comm number(7,2), 11 deptno number(2,0), 12 constraint pk_emp primary key (empno)13);14 15insert into emp (empno,ename,job,mgr,hiredate,sal,comm,deptno) values (7369,'SMITH','CLERK',7902,to_date('17-DEC-80','DD-MON-RR'),800,null,20);16insert into emp (empno,ename,job,mgr,hiredate,sal,comm,deptno) values (7499,'ALLEN','SALESMAN',7698,to_date('20-FEB-81','DD-MON-RR'),1600,300,30);17insert into emp (empno,ename,job,mgr,hiredate,sal,comm,deptno) values (7521,'WARD','SALESMAN',7698,to_date('22-FEB-81','DD-MON-RR'),1250,500,30);18insert into emp (empno,ename,job,mgr,hiredate,sal,comm,deptno) values (7566,'JONES','MANAGER',7839,to_date('02-APR-81','DD-MON-RR'),2975,null,20);19insert into emp (empno,ename,job,mgr,hiredate,sal,comm,deptno) values (7654,'MARTIN','SALESMAN',7698,to_date('28-SEP-81','DD-MON-RR'),1250,1400,30);20insert into emp (empno,ename,job,mgr,hiredate,sal,comm,deptno) values (7698,'BLAKE','MANAGER',7839,to_date('01-MAY-81','DD-MON-RR'),2850,null,30);21insert into emp (empno,ename,job,mgr,hiredate,sal,comm,deptno) values (7782,'CLARK','MANAGER',7839,to_date('09-JUN-81','DD-MON-RR'),2450,null,10);22insert into emp (empno,ename,job,mgr,hiredate,sal,comm,deptno) values (7788,'SCOTT','ANALYST',7566,to_date('19-APR-87','DD-MON-RR'),3000,null,20);23insert into emp (empno,ename,job,mgr,hiredate,sal,comm,deptno) values (7839,'KING','PRESIDENT',null,to_date('17-NOV-81','DD-MON-RR'),5000,null,10);24insert into emp (empno,ename,job,mgr,hiredate,sal,comm,deptno) values (7844,'TURNER','SALESMAN',7698,to_date('08-SEP-81','DD-MON-RR'),1500,0,30);25insert into emp (empno,ename,job,mgr,hiredate,sal,comm,deptno) values (7876,'ADAMS','CLERK',7788,to_date('23-MAY-87','DD-MON-RR'),1100,null,20);26insert into emp (empno,ename,job,mgr,hiredate,sal,comm,deptno) values (7900,'JAMES','CLERK',7698,to_date('03-DEC-81','DD-MON-RR'),950,null,30);27insert into emp (empno,ename,job,mgr,hiredate,sal,comm,deptno) values (7902,'FORD','ANALYST',7566,to_date('03-DEC-81','DD-MON-RR'),3000,null,20);28insert into emp (empno,ename,job,mgr,hiredate,sal,comm,deptno) values (7934,'MILLER','CLERK',7782,to_date('23-JAN-82','DD-MON-RR'),1300,null,10);29commit;本文中所有 SQL 操作均由测试用户执行，除非特殊说明。
1conn testuser1/testuser1@//localhost:1521/pdb1对于本文中的许多示例，我们使用对象存储 URI。对于 Oracle Cloud，URI 可以采用这些形式之一。
1https://swiftobjectstorage.{region}.oraclecloud.com/v1/{namespace}/{bucket}/{objectname}23https://objectstorage.{region}.oraclecloud.com/n/{namespace}/b/{bucket}/o/{objectname}本文主要使用 swiftobjectstorage URI，但两者都有效。 在本文的其余部分，我们将使用 swiftobjectstorage URI。
AWS S3 和 Azure blob 存储 URI 通常如下所示：
1AWS S3: https://s3-{region}.amazonaws.com/{bucket}/{objectname}2Azure Blog Storage: https://{account}.blob.core.windows.net/{container}/{objectname}DBMS_CLOUD 包包含来自 DBMS_CREDENTIAL 包的过程的副本。这两个包可以互换使用，因为它们做同样的事情。
使用 CREATE_CREDENTIAL 过程为您的对象存储创建凭证。对于 Oracle 对象存储桶，我们使用我们的 Oracle Cloud 电子邮件和我们生成的身份验证令牌。
1begin2 dbms_cloud.create_credential (3 credential_name => 'obj_store_cred',4 username => 'me@example.com',5 password => '{my-Auth-Token}'6 ) ;7end;8/对于 AWS 存储 buckets，我们使用我们的 AWS 访问密钥和秘密访问密钥。
1begin2 dbms_cloud.create_credential (3 credential_name => 'obj_store_cred',4 username => 'my AWS access key',5 password => 'my AWS secret access key'6 );7end;8/可以使用 USER_CREDENTIALS 视图显示有关凭证的信息。
1column credential_name format a252column username format a2034select credential_name,5 username,6 enabled7from user_credentials8order by credential_name;910CREDENTIAL_NAME USERNAME ENABL11------------------------- -------------------- -----12OBJ_STORE_CRED me@example.com TRUE1314SQL>DISABLE_CREDENTIAL 和 ENABLE_CREDENTIAL 过程分别禁用和启用凭据。
1begin2 dbms_credential.disable_credential('obj_store_cred');34 dbms_credential.enable_credential('obj_store_cred');5end;/UPDATE_CREDENTIALS 过程允许我们编辑凭证的属性。
1begin2 dbms_credential.update_credential(3 credential_name => 'obj_store_cred',4 attribute => 'username', 5 value => 'me@example.com');67 dbms_credential.update_credential(8 credential_name => 'obj_store_cred',9 attribute => 'password', 10 value => '{my-Auth-Token}');11end;12/DROP_CREDENTIAL 过程删除命名凭据。
1begin2 dbms_cloud.drop_credential(credential_name => 'obj_store_cred');3end;4/以下示例需要有效凭据。
有几个例程可用于操作本地数据库文件系统上的文件和云对象存储中的对象。
在数据库服务器文件系统上创建一个文件。
1mkdir -p /tmp/files2echo "This is a test file" > /tmp/files/test1.txt我们使用 PUT_OBJECT 过程将文件从目录对象位置传输到云对象存储。
1begin2 dbms_cloud.put_object (3 credential_name => 'obj_store_cred',4 object_uri => 'https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/test1.txt',5 directory_name => 'tmp_files_dir',6 file_name => 'test1.txt');7end;8/PUT_OBJECT 过程有一个重载，用于将 BLOB 的内容传输到对象存储。
1declare2 l_file blob;3begin4 l_file := utl_raw.cast_to_raw('This is another test file');56 dbms_cloud.put_object (7 credential_name => 'obj_store_cred',8 object_uri => 'https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/test2.txt',9 contents => l_file);10end;11/LIST_OBJECTS 表函数列出对象存储 URI 指向的位置中的对象。
1set linesize 1502column object_name format a123column checksum format a354column created format a355column last_modified format a3567select *8from dbms_cloud.list_objects(9 credential_name => 'obj_store_cred',10 location_uri => 'https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket');1112OBJECT_NAME BYTES CHECKSUM CREATED LAST_MODIFIED13------------ ---------- ----------------------------------- ----------------------------------- -----------------------------------14test1.txt 20 5dd39cab1c53c2c77cd352983f9641e1 11-SEP-21 08.45.42.779000 AM +00:0015test2.txt 25 d0914057907f9d04dd9e68b1c1e180f0 11-SEP-21 08.45.54.148000 AM +00:001617SQL>我们使用 GET_METADATA 函数返回有关特定对象的信息。
1select dbms_cloud.get_metadata(2 credential_name => 'obj_store_cred',3 object_uri => 'https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/test2.txt') as metadata4from dual;56METADATA7--------------------------------------------------------------------------------8{"Content-Length":25}910SQL>我们使用 GET_OBJECT 过程将对象从云对象存储传输到目录对象位置。
1begin2 dbms_cloud.get_object (3 credential_name => 'obj_store_cred',4 object_uri => 'https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/test2.txt',5 directory_name => 'tmp_files_dir',6 file_name => 'test2.txt');7end;8/有一个 GET_OBJECT 函数可以将对象从云对象存储传输到 BLOB。
1declare2 l_file blob;3begin4 l_file := dbms_cloud.get_object (5 credential_name => 'obj_store_cred',6 object_uri => 'https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/test2.txt');7end;8/DELETE_OBJECT 过程从云对象存储中删除对象。
1begin2 dbms_cloud.delete_object(3 credential_name => 'obj_store_cred',4 object_uri => 'https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/test1.txt');56 dbms_cloud.delete_object(7 credential_name => 'obj_store_cred',8 object_uri => 'https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/test2.txt');9end;10/DELETE_FILE 过程从目录对象位置删除文件。
1begin2 dbms_cloud.delete_file(3 directory_name => 'tmp_files_dir',4 file_name => 'test1.txt');56 dbms_cloud.delete_file(7 directory_name => 'tmp_files_dir',8 file_name => 'test2.txt');9end;10/LIST_FILES 表函数列出指定 Oracle 目录对象指向的位置中的文件。 文档说它只支持映射到 Oracle 文件系统 (OFS) 或数据库文件系统 (DBFS) 文件系统的目录对象，所以我们不能将它用于常规文件系统。 它确实在自治数据库上提供的位置工作。
1select *2from dbms_cloud.list_files(directory_name => 'data_pump_dir');本节介绍基于云对象存储中的文件创建外部表。
我们使用以下内容创建一个名为“emp.dat”的文件并将其放入我们的对象存储中。 它是一个没有标题的管道分隔文件。
17369|"SMITH"|"CLERK"|7902|17-DEC-80|800||2027499|"ALLEN"|"SALESMAN"|7698|20-FEB-81|1600|300|3037521|"WARD"|"SALESMAN"|7698|22-FEB-81|1250|500|3047566|"JONES"|"MANAGER"|7839|02-APR-81|2975||2057654|"MARTIN"|"SALESMAN"|7698|28-SEP-81|1250|1400|3067698|"BLAKE"|"MANAGER"|7839|01-MAY-81|2850||3077782|"CLARK"|"MANAGER"|7839|09-JUN-81|2450||1087788|"SCOTT"|"ANALYST"|7566|19-APR-87|3000||2097839|"KING"|"PRESIDENT"||17-NOV-81|5000||10107844|"TURNER"|"SALESMAN"|7698|08-SEP-81|1500|0|30117876|"ADAMS"|"CLERK"|7788|23-MAY-87|1100||20127900|"JAMES"|"CLERK"|7698|03-DEC-81|950||30137902|"FORD"|"ANALYST"|7566|03-DEC-81|3000||20147934|"MILLER"|"CLERK"|7782|23-JAN-82|1300||10CREATE_EXTERNAL_TABLE 过程基于云对象存储中的文件创建名为 EMP_EXT 的外部表。
1--drop table emp_ext;23begin4 dbms_cloud.create_external_table(5 table_name => 'emp_ext',6 credential_name => 'obj_store_cred',7 file_uri_list => 'https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/emp.dat',8 column_list => 'empno number(4),9 ename varchar2(10),10 job varchar2(9),11 mgr number(4),12 hiredate date,13 sal number(7,2),14 comm number(7,2),15 deptno number(2)',16 format => json_object('ignoremissingcolumns' value 'true', 'removequotes' value 'true')17 );18end;19/我们查询外部表，它从云对象存储中读取数据。
1select * from emp_ext;23 EMPNO ENAME JOB MGR HIREDATE SAL COMM DEPTNO4---------- ---------- --------- ---------- --------- ---------- ---------- ----------5 7369 SMITH CLERK 7902 17-DEC-80 800 206 7499 ALLEN SALESMAN 7698 20-FEB-81 1600 300 307 7521 WARD SALESMAN 7698 22-FEB-81 1250 500 308 7566 JONES MANAGER 7839 02-APR-81 2975 209 7654 MARTIN SALESMAN 7698 28-SEP-81 1250 1400 3010 7698 BLAKE MANAGER 7839 01-MAY-81 2850 3011 7782 CLARK MANAGER 7839 09-JUN-81 2450 1012 7788 SCOTT ANALYST 7566 19-APR-87 3000 2013 7839 KING PRESIDENT 17-NOV-81 5000 1014 7844 TURNER SALESMAN 7698 08-SEP-81 1500 0 3015 7876 ADAMS CLERK 7788 23-MAY-87 1100 2016 7900 JAMES CLERK 7698 03-DEC-81 950 3017 7902 FORD ANALYST 7566 03-DEC-81 3000 2018 7934 MILLER CLERK 7782 23-JAN-82 1300 10192014 rows selected.2122SQL>FORMAT 参数允许我们调整加载过程以适应数据文件内容。 可以在此处找到格式选项的完整列表，以下示例适用于 CSV 文件。
我们使用以下内容创建一个名为“emp.csv”的文件并将其放入我们的对象存储中。 它是一个带有标题行的 CSV 文件。
1"EMPNO","ENAME","JOB","MGR","HIREDATE","SAL","COMM","DEPTNO"27369,"SMITH","CLERK",7902,17-DEC-80,800,,2037499,"ALLEN","SALESMAN",7698,20-FEB-81,1600,300,3047521,"WARD","SALESMAN",7698,22-FEB-81,1250,500,3057566,"JONES","MANAGER",7839,02-APR-81,2975,,2067654,"MARTIN","SALESMAN",7698,28-SEP-81,1250,1400,3077698,"BLAKE","MANAGER",7839,01-MAY-81,2850,,3087782,"CLARK","MANAGER",7839,09-JUN-81,2450,,1097788,"SCOTT","ANALYST",7566,19-APR-87,3000,,20107839,"KING","PRESIDENT",,17-NOV-81,5000,,10117844,"TURNER","SALESMAN",7698,08-SEP-81,1500,0,30127876,"ADAMS","CLERK",7788,23-MAY-87,1100,,20137900,"JAMES","CLERK",7698,03-DEC-81,950,,30147902,"FORD","ANALYST",7566,03-DEC-81,3000,,20157934,"MILLER","CLERK",7782,23-JAN-82,1300,,10CREATE_EXTERNAL_TABLE 过程基于云对象存储中的文件创建名为 EMP_CSV_EXT 的外部表。
1--drop table emp_csv_ext;23begin4 dbms_cloud.create_external_table(5 table_name => 'emp_csv_ext',6 credential_name => 'obj_store_cred',7 file_uri_list => 'https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/emp.csv',8 column_list => 'empno number(4),9 ename varchar2(10),10 job varchar2(9),11 mgr number(4),12 hiredate date,13 sal number(7,2),14 comm number(7,2),15 deptno number(2)',16 format => json_object('type' value 'csv', 'skipheaders' value '1')17 );18end;19/我们查询外部表，它从云对象存储中读取数据。
1select * from emp_csv_ext;23 EMPNO ENAME JOB MGR HIREDATE SAL COMM DEPTNO4---------- ---------- --------- ---------- --------- ---------- ---------- ----------5 7369 SMITH CLERK 7902 17-DEC-80 800 206 7499 ALLEN SALESMAN 7698 20-FEB-81 1600 300 307 7521 WARD SALESMAN 7698 22-FEB-81 1250 500 308 7566 JONES MANAGER 7839 02-APR-81 2975 209 7654 MARTIN SALESMAN 7698 28-SEP-81 1250 1400 3010 7698 BLAKE MANAGER 7839 01-MAY-81 2850 3011 7782 CLARK MANAGER 7839 09-JUN-81 2450 1012 7788 SCOTT ANALYST 7566 19-APR-87 3000 2013 7839 KING PRESIDENT 17-NOV-81 5000 1014 7844 TURNER SALESMAN 7698 08-SEP-81 1500 0 3015 7876 ADAMS CLERK 7788 23-MAY-87 1100 2016 7900 JAMES CLERK 7698 03-DEC-81 950 3017 7902 FORD ANALYST 7566 03-DEC-81 3000 2018 7934 MILLER CLERK 7782 23-JAN-82 1300 10192014 rows selected.2122SQL>VALIDATE_EXTERNAL_TABLE 过程允许我们检查外部表的有效性。
1begin2 dbms_cloud.validate_external_table('emp_csv_ext');3end;4/使用以下查询创建四个 CSV 文件：
1set markup csv on quote on2set trimspool on linesize 1000 feedback off pagesize 034spool /tmp/files/gbr1.txt5select 'GBR',6 object_id,7 owner,8 object_name9from all_objects10where object_id <= 200011and rownum <= 1000;12spool off1314spool /tmp/files/gbr2.txt15select 'GBR',16 object_id,17 owner,18 object_name19from all_objects20where object_id BETWEEN 2000 AND 399921and rownum <= 1000;22spool off2324spool /tmp/files/ire1.txt25select 'IRE',26 object_id,27 owner,28 object_name29from all_objects30where object_id <= 200031and rownum <= 1000;32spool off3334spool /tmp/files/ire2.txt35select 'IRE',36 object_id,37 owner,38 object_name39from all_objects40where object_id BETWEEN 2000 AND 399941and rownum <= 1000;42spool off4344set markup csv off45set trimspool on linesize 1000 feedback off pagesize 14在上传文件之前，您可能需要稍微清理文件的开头和结尾。 将文件复制到对象存储：
1begin2 dbms_cloud.put_object (3 credential_name => 'obj_store_cred',4 object_uri => 'https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/gbr1.txt',5 directory_name => 'tmp_files_dir',6 file_name => 'gbr1.txt');7end;8/910begin11 dbms_cloud.put_object (12 credential_name => 'obj_store_cred',13 object_uri => 'https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/gbr2.txt',14 directory_name => 'tmp_files_dir',15 file_name => 'gbr2.txt');16end;17/1819begin20 dbms_cloud.put_object (21 credential_name => 'obj_store_cred',22 object_uri => 'https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/ire1.txt',23 directory_name => 'tmp_files_dir',24 file_name => 'ire1.txt');25end;26/2728begin29 dbms_cloud.put_object (30 credential_name => 'obj_store_cred',31 object_uri => 'https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/ire2.txt',32 directory_name => 'tmp_files_dir',33 file_name => 'ire2.txt');34end;35/CREATE_EXTERNAL_PART_TABLE 过程基于云对象存储中的文件创建名为 COUNTRY_PART_TAB_EXT 的外部分区表。
1--drop table country_part_tab_ext;23begin4 dbms_cloud.create_external_part_table(5 table_name => 'country_part_tab_ext',6 credential_name => 'obj_store_cred',7 format => json_object('type' value 'csv', 'skipheaders' value '1'),8 column_list => 'country_code varchar2(3),9 object_id number,10 owner varchar2(128),11 object_name varchar2(128)',12 partitioning_clause => 'partition by list (country_code) (13 partition part_gbr values (''GBR'') location (14 ''https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/gbr1.txt'',15 ''https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/gbr2.txt''16 ),17 partition part_ire values (''IRE'') location (18 ''https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/ire1.txt'',19 ''https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/ire2.txt''20 )21 )'22 );23end;24/我们查询外部表，它从云对象存储中读取数据。
1select country_code, count(*) as amount2from country_part_tab_ext3group by country_code4order by country_code;56COU AMOUNT7--- ----------8GBR 20009IRE 20001011SQL>VALIDATE_EXTERNAL_PART_TABLE 过程允许我们检查外部分区表的有效性。
1begin2 dbms_cloud.validate_external_part_table('country_part_tab_ext');3end;4/CREATE_HYBRID_PART_TABLE 过程基于云对象存储中的文件创建一个名为 COUNTRY_HYBRID_PART_TAB_EXT 的外部混合分区表。
1--drop table country_hybrid_part_tab_ext;23begin4 dbms_cloud.create_hybrid_part_table(5 table_name => 'country_hybrid_part_tab_ext',6 credential_name => 'obj_store_cred',7 format => json_object('type' value 'csv', 'skipheaders' value '1'),8 column_list => 'country_code varchar2(3),9 object_id number,10 owner varchar2(128),11 object_name varchar2(128)',12 partitioning_clause => 'partition by list (country_code) (13 partition part_gbr values (''GBR'') external location (14 ''https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/gbr1.txt'',15 ''https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/gbr2.txt''16 ),17 partition part_ire values (''IRE'') external location (18 ''https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/ire1.txt'',19 ''https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/ire2.txt''20 ),21 partition part_usa values (''USA'')22 )'23 );24end;25/我们在常规分区中插入一行。
1insert into country_hybrid_part_tab_ext values ('USA', 123, 'banana', 'banana');2commit;我们查询外部表，它从云对象存储中读取数据。
1select country_code, count(*) as amount2from country_hybrid_part_tab_ext3group by country_code4order by country_code;56COU AMOUNT7--- ----------8GBR 20009IRE 200010USA 11112SQL>VALIDATE_HYBRID_PART_TABLE 过程允许我们检查外部混合分区表的有效性。
1begin2 dbms_cloud.validate_hybrid_part_table('country_hybrid_part_tab_ext');3end;4/COPY_DATA 过程允许我们将数据从云对象存储复制到现有表中。
我们使用以下内容创建一个名为“emp.csv”的文件并将其放入我们的对象存储中。 它是一个带有标题行的 CSV 文件。
1"EMPNO","ENAME","JOB","MGR","HIREDATE","SAL","COMM","DEPTNO"27369,"SMITH","CLERK",7902,17-DEC-80,800,,2037499,"ALLEN","SALESMAN",7698,20-FEB-81,1600,300,3047521,"WARD","SALESMAN",7698,22-FEB-81,1250,500,3057566,"JONES","MANAGER",7839,02-APR-81,2975,,2067654,"MARTIN","SALESMAN",7698,28-SEP-81,1250,1400,3077698,"BLAKE","MANAGER",7839,01-MAY-81,2850,,3087782,"CLARK","MANAGER",7839,09-JUN-81,2450,,1097788,"SCOTT","ANALYST",7566,19-APR-87,3000,,20107839,"KING","PRESIDENT",,17-NOV-81,5000,,10117844,"TURNER","SALESMAN",7698,08-SEP-81,1500,0,30127876,"ADAMS","CLERK",7788,23-MAY-87,1100,,20137900,"JAMES","CLERK",7698,03-DEC-81,950,,30147902,"FORD","ANALYST",7566,03-DEC-81,3000,,20157934,"MILLER","CLERK",7782,23-JAN-82,1300,,10我们截断本地 EMP 表并使用 COPY_DATA 过程从云对象存储重新加载数据。
1truncate table emp;23begin4 dbms_cloud.copy_data(5 table_name => 'emp',6 credential_name => 'obj_store_cred',7 file_uri_list => 'https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/emp.csv',8 format => json_object('type' value 'csv', 'skipheaders' value '1')9 );10end;11/我们查询EMP表，可以看到数据已经加载完毕。
1select * from emp;23 EMPNO ENAME JOB MGR HIREDATE SAL COMM DEPTNO4---------- ---------- --------- ---------- --------- ---------- ---------- ----------5 7369 SMITH CLERK 7902 17-DEC-80 800 206 7499 ALLEN SALESMAN 7698 20-FEB-81 1600 300 307 7521 WARD SALESMAN 7698 22-FEB-81 1250 500 308 7566 JONES MANAGER 7839 02-APR-81 2975 209 7654 MARTIN SALESMAN 7698 28-SEP-81 1250 1400 3010 7698 BLAKE MANAGER 7839 01-MAY-81 2850 3011 7782 CLARK MANAGER 7839 09-JUN-81 2450 1012 7788 SCOTT ANALYST 7566 19-APR-87 3000 2013 7839 KING PRESIDENT 17-NOV-81 5000 1014 7844 TURNER SALESMAN 7698 08-SEP-81 1500 0 3015 7876 ADAMS CLERK 7788 23-MAY-87 1100 2016 7900 JAMES CLERK 7698 03-DEC-81 950 3017 7902 FORD ANALYST 7566 03-DEC-81 3000 2018 7934 MILLER CLERK 7782 23-JAN-82 1300 10192014 rows selected.2122SQL>与外部表示例类似，FORMAT 参数允许我们定制加载过程以适应数据文件内容。
EXPORT_DATA 过程获取查询生成的数据，并以请求的格式将其导出到云对象存储。 这似乎不适用于 DBMS_CLOUD 包的本地版本，但适用于自治数据库。
1begin2 dbms_cloud.export_data (3 credential_name => 'obj_store_cred',4 file_uri_list => 'https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/emp.json',5 query => 'select * from emp',6 format => '{"type" : "JSON"}'7 );8end;9/1011begin12 dbms_cloud.export_data (13 credential_name => 'obj_store_cred',14 file_uri_list => 'https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/emp.csv',15 query => 'select * from emp',16 format => '{"type" : "CSV"}'17 );18end;19/Oracle 数据库可用作使用简单 Oracle 文档访问 (SODA) 的文档存储。 您可以在此处阅读有关 SODA 的信息。
我们创建一个名为“TestCollection1”的新集合。
1set serveroutput on23declare4 l_collection soda_collection_t;5begin6 l_collection := dbms_soda.create_collection('TestCollection1');78 if l_collection is not null then9 dbms_output.put_line('Collection ID : ' || l_collection.get_name());10 else11 dbms_output.put_line('Collection does not exist.'); 12 end if;13end;14/15Collection ID : TestCollection1161718PL/SQL procedure successfully completed.1920SQL>使用以下内容创建一个名为“fruit.json”的文件并将其上传到您的云对象存储。
1{"fruit": "banana"}COPY_COLLECTION 过程将数据从我们的云对象存储加载到集合中。
1begin2 dbms_cloud.copy_collection(3 collection_name => 'TestCollection1',4 credential_name => 'obj_store_cred',5 file_uri_list => 'https://swiftobjectstorage.uk-london-1.oraclecloud.com/v1/my-namespace/ob-bucket/fruit.json',6 format => json_object('unpackarrays' value 'true')7 );8end;9/我们可以使用以下查询查看集合中的数据。
1select json_document2from "TestCollection1";34JSON_DOCUMENT5--------------------------------------------------------------------------------6{"fruit":"banana"}78SQL>许多 DBMS_CLOUD 操作会产生额外的文件（日志文件、坏文件、临时文件等）。 一旦操作完成，这些需要清理。 上面显示的几个过程具有返回操作 ID 值的重载，该值可与 DELETE_OPERATION 过程一起使用以清理额外的文件。 或者，可以使用 USER_LOAD_OPERATIONS 视图显示当前会话的操作。
1SQL> desc user_load_operations2 Name Null? Type3 ----------------------------------------------------- -------- ------------------------------------4 ID NOT NULL NUMBER5 TYPE NOT NULL VARCHAR2(128)6 SID NOT NULL NUMBER7 SERIAL# NOT NULL NUMBER8 START_TIME TIMESTAMP(6) WITH TIME ZONE9 UPDATE_TIME TIMESTAMP(6) WITH TIME ZONE10 STATUS VARCHAR2(9)11 OWNER_NAME VARCHAR2(128)12 TABLE_NAME VARCHAR2(128)13 PARTITION_NAME VARCHAR2(128)14 SUBPARTITION_NAME VARCHAR2(128)15 FILE_URI_LIST VARCHAR2(4000)16 ROWS_LOADED NUMBER17 LOGFILE_TABLE VARCHAR2(128)18 BADFILE_TABLE VARCHAR2(128)19 TEMPEXT_TABLE VARCHAR2(128)2021SQL>我们使用 USER_LOAD_OPERATIONS 视图返回当前会话的操作。
1column type format a1023select id, type4from user_load_operations5order by 1;67 ID TYPE8---------- ----------9 1 COPY10 11 COPY1112SQL>DELETE_OPERATION 过程允许我们清除与特定操作相关的附加文件。
1begin2 dbms_cloud.delete_operation(1);3end;4/567select id, type8from user_load_operations9order by 1;1011 ID TYPE12---------- ----------13 11 COPY1415SQL>DELETE_ALL_OPERATIONS 过程允许我们清理所有操作的附加文件，或者如果我们指定类型值，则清理特定类型操作的附加文件。
1-- Delete only COPY operations.2begin3 dbms_cloud.delete_all_operations('COPY');4end;5/67-- Delete all operations.8begin9 dbms_cloud.delete_all_operations;10end;11/