PolarDB:マルチテナント管理

マルチテナントアプリケーションでは、ブロードキャストクエリによるパフォーマンス低下や、データ分布の不均一性に起因するリソースの無駄遣いが一般的な課題です。PolarDB for PostgreSQL (Distributed Edition) は、ネイティブのマルチテナント管理機能を提供し、行ベースのシャーディング および スキーマベースのシャーディング の 2 つのモードをサポートします。この機能により、特定のテナントに対するクエリが単一のデータノード（DN）にルーティングされ、ブロードキャストクエリを回避するとともに、効率的な読み取りおよび書き込みを実現します。また、テナント間のデータ分布を均等化することで、データスキューを防止し、リソース利用率を向上させます。

-- 1. テーブルを作成します。tenant_id 列はテナントを区別するために使用されます。
CREATE TABLE test_table (tenant_id text primary key, data text);

-- 2. test_table を分散テーブルとして設定し、tenant_id を分布列として指定します。
SELECT create_distributed_table('test_table', 'tenant_id');

-- company1 テナント向けのクエリプランを表示します。
EXPLAIN SELECT * FROM test_table WHERE tenant_id = 'company1';

-- サンプル結果：
                                                       QUERY PLAN                                                       
------------------------------------------------------------------------------------------------------------------------
 Custom Scan (PolarCluster Adaptive)  (cost=0.00..0.00 rows=0 width=0)
   Task Count: 1
   Tasks Shown: All
   ->  Task
         Node: host=10.0.0.1 port=5432 dbname=testdb
         ->  Index Scan using test_table_pkey_102185 on test_table_102185 test_table  (cost=0.15..2.37 rows=1 width=64)
               Index Cond: (tenant_id = 'company1'::text)
(7 rows)

-- 1. company_test_1 テナント向けのスキーマを作成します。
CREATE SCHEMA company_test_1;

-- 2. スキーマを分散スキーマとして設定します。
SELECT polar_cluster_schema_distribute('company_test_1');

-- 1. company_test_1 テナントのスキーマに切り替えます。
SET search_path TO company_test_1;

-- 2. このスキーマ内に業務テーブルを作成します。
CREATE TABLE users (id SERIAL, name TEXT);
CREATE TABLE orders (id SERIAL, user_id INT);

-- 1. search_path が対象テナントに正しく設定されていることを確認します。
SET search_path TO company_test_1;

-- 2. クエリプランを表示します。
EXPLAIN SELECT * FROM users WHERE id = 1;

-- サンプル結果：
                                   QUERY PLAN                                   
--------------------------------------------------------------------------------
 Custom Scan (PolarCluster Adaptive)  (cost=0.00..0.00 rows=0 width=0)
   Task Count: 1
   Tasks Shown: All
   ->  Task
         Node: host=10.0.0.1 port=5432 dbname=testdb
         ->  Seq Scan on users_102191 users  (cost=0.00..25.88 rows=6 width=36)
               Filter: (id = 1)
(7 rows)