PolarDB:Indeks kolom terdistribusi

Horizontal sharding (berdasarkan tenant_id)

Pertimbangkan tabel bisnis bernama orders yang menggunakan tenant_id sebagai kunci sharding.

• Agregasi data untuk satu tenant: Hitung total dan rata-rata jumlah pesanan untuk tenant tertentu.

  SELECT SUM(amount) AS total_amount, AVG(amount) AS avg_amount
  FROM orders
  WHERE tenant_id = 1001;

• Agregasi data lintas semua tenant: Hitung total dan rata-rata jumlah pesanan untuk semua tenant, dikelompokkan berdasarkan tenant.

  SELECT tenant_id, SUM(amount) AS total_amount, AVG(amount) AS avg_amount
  FROM orders
  GROUP BY tenant_id;

Vertical sharding (berdasarkan schema)

Pertimbangkan bahwa data setiap tenant disimpan dalam schema terpisah, dan nama tabelnya adalah orders di semua schema.

• Agregasi data untuk satu schema: Hitung total dan rata-rata jumlah pesanan dalam schema tertentu.

  SELECT SUM(amount) AS total_amount, AVG(amount) AS avg_amount
  FROM tenant_a.orders;

• Agregasi data lintas semua tenant: Hitung total dan rata-rata jumlah pesanan untuk semua tenant dengan menggunakan UNION ALL.

  SELECT 'tenant_a' AS tenant, SUM(amount) AS total_amount, AVG(amount) AS avg_amount FROM tenant_a.orders
  UNION ALL
  SELECT 'tenant_b' AS tenant, SUM(amount) AS total_amount, AVG(amount) AS avg_amount FROM tenant_b.orders;

Langkah 1: Aktifkan IMCI terdistribusi

Anda dapat mengubah parameter berikut di Konsol PolarDB atau dalam sesi database:

SET polar_cluster_enable_imci = on;
SET polar_csi.enable_anyall_to_in = on;
SET pg_hint_plan.polar_enable_distributed_hint = on;

Langkah 2: Buat slot replikasi

Gunakan akun dengan hak istimewa tinggi untuk menjalankan perintah berikut pada CN primary. Ini akan membuat slot replikasi di semua node untuk sinkronisasi antara row-store dan column-store.

SELECT run_command_on_all_nodes($$ SELECT polar_csi_start_sync() $$);

Langkah 3: Buat dan shard tabel tenant

-- Buat tabel bisnis awal dengan tenant_id sebagai bagian dari primary key
CREATE TABLE orders (
  order_id   bigint,
  tenant_id  int NOT NULL,
  amount     numeric(20,2),
  status     text,
  create_time timestamp,
  PRIMARY KEY (tenant_id, order_id)
);

-- Ubah menjadi tabel sharded terdistribusi
SELECT create_distributed_table('orders', 'tenant_id');

-- Buat schema untuk tenant
CREATE SCHEMA tenant1;

-- Aktifkan manajemen terdistribusi untuk schema
SELECT polar_cluster_schema_distribute('tenant1');

-- Buat tabel bisnis
SET search_path TO tenant1;

CREATE TABLE orders (
  order_id   bigint,
  tenant_id  int NOT NULL,
  amount     numeric(20,2),
  status     text,
  create_time timestamp,
  PRIMARY KEY (tenant_id, order_id)
);

Langkah 4: Buat indeks kolom

Buat indeks kolom (CSI) pada tabel:

-- Buat indeks kolom pada semua kolom
CREATE INDEX csi_orders ON orders USING CSI;

-- Buat indeks kolom pada kolom tertentu (misalnya, untuk kueri pada tenant_id, order_id, dan amount)
CREATE INDEX csi_orders_part ON orders1 USING CSI(tenant_id, order_id, amount);

-- Buat indeks kolom tanpa mengunci tabel (Direkomendasikan)
CREATE INDEX CONCURRENTLY csi_orders ON orders USING CSI;

Langkah 5: Jalankan kueri dengan indeks kolom

Dua parameter mengontrol apakah kueri menggunakan indeks kolom:

Kami merekomendasikan menggunakan hint untuk memaksa kueri tertentu menggunakan indeks kolom:

/*+SET (polar_csi.enable_query on) SET(polar_csi.cost_threshold 0)*/
SELECT tenant_id, SUM(amount) AS total_amount, AVG(amount) AS avg_amount
FROM orders
GROUP BY tenant_id;

Anda juga dapat mengatur parameter ini secara global atau per akun pengguna. Untuk mengaturnya secara global, ubah parameter di Konsol PolarDB. Untuk mengaturnya per pengguna, jalankan pernyataan berikut pada CN primary:

-- Prioritaskan penggunaan indeks kolom untuk pengguna 'test'
ALTER ROLE test SET polar_csi.enable_query = ON;
ALTER ROLE test SET polar_csi.cost_threshold = 0;

Langkah 6: Verifikasi penggunaan indeks kolom

Anda dapat menggunakan EXPLAIN untuk analisis. Jika CSI Executor muncul dalam rencana eksekusi, hal ini menunjukkan bahwa indeks kolom berhasil digunakan:

/*+SET (polar_csi.enable_query on) SET(polar_csi.cost_threshold 0)*/
EXPLAIN (COSTS OFF) SELECT tenant_id, SUM(amount) AS total_amount, AVG(amount) AS avg_amount
FROM orders
GROUP BY tenant_id;

Cuplikan output contoh (Kemunculan CSI Executor menunjukkan bahwa kueri menggunakan mesin column-store):

                       QUERY PLAN
---------------------------------------------------------
 Custom Scan (PolarCluster Adaptive)
   Task Count: 32
   Tasks Shown: One of 32
   ->  Task
         Node: host=127.0.0.1 port=45719 dbname=postgres
         ->  CSI Executor:
             ┌───────────────────────────┐
             │       HASH_GROUP_BY       │
             │    ────────────────────   │
             │        Aggregates:        │
             │          sum(#1)          │
             │          avg(#2)          │
             └─────────────┬─────────────┘
             ┌─────────────┴─────────────┐
             │         SEQ_SCAN          │
             │    ────────────────────   │
             │    Table: orders_102008   │
             │   Type: Sequential Scan   │
             └───────────────────────────┘