Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Contoh menggunakan kueri federasi

Contoh berikut menunjukkan cara menjalankan kueri federasi. Jalankan SQL menggunakan SQL klien Anda yang terhubung ke database Amazon Redshift.

Contoh menggunakan kueri federasi dengan Postgre SQL

Contoh berikut menunjukkan cara menyiapkan kueri federasi yang mereferensikan database Amazon Redshift, database Aurora SQL Postgre, dan Amazon S3. Contoh ini menggambarkan cara kerja kueri federasi. Untuk menjalankannya di lingkungan Anda sendiri, ubahlah agar sesuai dengan lingkungan Anda. Untuk prasyarat untuk melakukan ini, lihat. Memulai dengan menggunakan kueri federasi ke Postgre SQL

Buat skema eksternal yang mereferensikan database Aurora PostgreSQL.

CREATE EXTERNAL SCHEMA apg
FROM POSTGRES
DATABASE 'database-1' SCHEMA 'myschema'
URI 'endpoint to aurora hostname'
IAM_ROLE 'arn:aws:iam::123456789012:role/Redshift-SecretsManager-RO'
SECRET_ARN 'arn:aws:secretsmanager:us-west-2:123456789012:secret:federation/test/dataplane-apg-creds-YbVKQw';

Buat skema eksternal lain yang mereferensikan Amazon S3, yang menggunakan Amazon Redshift Spectrum. Juga, berikan izin untuk menggunakan skema untukpublic.

CREATE EXTERNAL SCHEMA s3 
FROM DATA CATALOG 
DATABASE 'default' REGION 'us-west-2' 
IAM_ROLE 'arn:aws:iam::123456789012:role/Redshift-S3'; 

GRANT USAGE ON SCHEMA s3 TO public;

Tampilkan jumlah baris di tabel Amazon Redshift.

SELECT count(*) FROM public.lineitem;
            
  count
----------
25075099

Tampilkan hitungan baris di tabel Aurora SQL Postgre.

SELECT count(*) FROM apg.lineitem;
            
count
-------
11760

Tampilkan jumlah baris di Amazon S3.

SELECT count(*) FROM s3.lineitem_1t_part;
            
   count
------------
6144008876

Buat tampilan tabel dari Amazon Redshift, Aurora Postgre, SQL dan Amazon S3. Tampilan ini digunakan untuk menjalankan kueri federasi Anda.

CREATE VIEW lineitem_all AS
  SELECT l_orderkey,l_partkey,l_suppkey,l_linenumber,l_quantity,l_extendedprice,l_discount,l_tax,l_returnflag,l_linestatus,
         l_shipdate::date,l_commitdate::date,l_receiptdate::date, l_shipinstruct ,l_shipmode,l_comment 
  FROM s3.lineitem_1t_part 
  UNION ALL SELECT * FROM public.lineitem 
  UNION ALL SELECT * FROM apg.lineitem 
     with no schema binding;

Tampilkan jumlah baris dalam tampilan lineitem_all dengan predikat untuk membatasi hasil.

SELECT count(*) from lineitem_all WHERE l_quantity = 10;
               
   count
-----------
123373836

Cari tahu berapa banyak penjualan satu item yang ada pada bulan Januari setiap tahun.

SELECT extract(year from l_shipdate) as year,
       extract(month from l_shipdate) as month,
       count(*) as orders
FROM lineitem_all
WHERE extract(month from l_shipdate) = 1
AND l_quantity < 2
GROUP BY 1,2
ORDER BY 1,2;

 year | month | orders
------+-------+---------
 1992 |     1 |  196019
 1993 |     1 | 1582034
 1994 |     1 | 1583181
 1995 |     1 | 1583919
 1996 |     1 | 1583622
 1997 |     1 | 1586541
 1998 |     1 | 1583198
 2016 |     1 |   15542
 2017 |     1 |   15414
 2018 |     1 |   15527
 2019 |     1 |     151

Contoh menggunakan nama mixed-case

Untuk menanyakan database SQL jarak jauh Postgre yang didukung yang memiliki nama kasus campuran dari database, skema, tabel, atau kolom, lalu atur ke. enable_case_sensitive_identifier true Untuk informasi selengkapnya tentang parameter sesi ini, lihatenable_case_sensitive_identifier.

SET enable_case_sensitive_identifier TO TRUE;

Biasanya, nama database dan skema dalam huruf kecil. Contoh berikut menunjukkan bagaimana Anda dapat terhubung ke database SQL jarak jauh Postgre yang didukung yang memiliki nama huruf kecil untuk database dan skema dan nama huruf campuran untuk tabel dan kolom.

Buat skema eksternal yang mereferensikan database Aurora SQL Postgre yang memiliki nama database huruf kecil () dan nama skema huruf kecil dblower (). schemalower

CREATE EXTERNAL SCHEMA apg_lower
FROM POSTGRES
DATABASE 'dblower' SCHEMA 'schemalower'
URI 'endpoint to aurora hostname'
IAM_ROLE 'arn:aws:iam::123456789012:role/Redshift-SecretsManager-RO'
SECRET_ARN 'arn:aws:secretsmanager:us-west-2:123456789012:secret:federation/test/dataplane-apg-creds-YbVKQw';

Dalam sesi di mana kueri berjalan, atur enable_case_sensitive_identifier ketrue.

SET enable_case_sensitive_identifier TO TRUE;

Jalankan kueri federasi untuk memilih semua data dari database PostgreSQL. Tabel (MixedCaseTab) dan kolom (MixedCaseName) memiliki nama kasus campuran. Hasilnya adalah satu baris (Harry).

select * from apg_lower."MixedCaseTab";

 MixedCaseName
-------
 Harry

Contoh berikut menunjukkan bagaimana Anda dapat terhubung ke database SQL jarak jauh Postgre yang didukung yang memiliki nama kasus campuran untuk database, skema, tabel, dan kolom.

Setel enable_case_sensitive_identifier ke true sebelum Anda membuat skema eksternal. Jika tidak enable_case_sensitive_identifier disetel ke true sebelum membuat skema eksternal, maka terjadi kesalahan database tidak ada.

Buat skema eksternal yang mereferensikan database Aurora SQL Postgre yang memiliki nama database kasus campuran () dan schema UpperDB (). UpperSchema

CREATE EXTERNAL SCHEMA apg_upper
FROM POSTGRES
DATABASE 'UpperDB' SCHEMA 'UpperSchema'
URI 'endpoint to aurora hostname'
IAM_ROLE 'arn:aws:iam::123456789012:role/Redshift-SecretsManager-RO'
SECRET_ARN 'arn:aws:secretsmanager:us-west-2:123456789012:secret:federation/test/dataplane-apg-creds-YbVKQw';

Jalankan kueri federasi untuk memilih semua data dari database PostgreSQL. Tabel (MixedCaseTab) dan kolom (MixedCaseName) memiliki nama kasus campuran. Hasilnya adalah satu baris (Harry).

select * from apg_upper."MixedCaseTab";

 MixedCaseName
-------
 Harry

Contoh menggunakan kueri federasi dengan My SQL

Contoh berikut menunjukkan cara menyiapkan kueri federasi yang mereferensikan database Aurora MySQL. Contoh ini menggambarkan cara kerja kueri federasi. Untuk menjalankannya di lingkungan Anda sendiri, ubahlah agar sesuai dengan lingkungan Anda. Untuk prasyarat untuk melakukan ini, lihat. Memulai dengan menggunakan kueri federasi ke My SQL

Contoh ini tergantung pada prasyarat berikut:

Buat skema eksternal yang mereferensikan database Aurora MySQL.

CREATE EXTERNAL SCHEMA amysql
FROM MYSQL
DATABASE 'functional'
URI 'endpoint to remote hostname'
IAM_ROLE 'arn:aws:iam::123456789012:role/Redshift-SecretsManager-RO'
SECRET_ARN 'arn:aws:secretsmanager:us-west-2:123456789012:secret:federation/test/dataplane-apg-creds-YbVKQw';

Jalankan contoh SQL pilih Aurora My SQL table untuk menampilkan satu baris dari tabel karyawan di Aurora My. SQL

SELECT level FROM amysql.employees LIMIT 1;
            
 level
-------
     8