-- PARTITIONNEMENT : diviser une grosse table en sous-tables physiques
-- Le partitionnement par plage (RANGE) est idéal pour des données temporelles
CREATE TABLE commandes (
    id        BIGINT,
    client_id INTEGER,
    montant   DECIMAL(10, 2),
    cree_le   DATE NOT NULL
) PARTITION BY RANGE (cree_le);

CREATE TABLE commandes_2024 PARTITION OF commandes
    FOR VALUES FROM ('2024-01-01') TO ('2025-01-01');

CREATE TABLE commandes_2025 PARTITION OF commandes
    FOR VALUES FROM ('2025-01-01') TO ('2026-01-01');

-- Une requête filtrée sur cree_le n'accède qu'à la partition concernée (partition pruning)
EXPLAIN SELECT * FROM commandes WHERE cree_le >= '2025-06-01' AND cree_le < '2025-07-01';
-- -> ne scanne QUE commandes_2025, pas commandes_2024

-- Partitionnement par LISTE (valeurs discrètes)
CREATE TABLE clients (
    id INTEGER,
    pays VARCHAR(2) NOT NULL,
    nom VARCHAR(100)
) PARTITION BY LIST (pays);

CREATE TABLE clients_fr PARTITION OF clients FOR VALUES IN ('FR');
CREATE TABLE clients_be PARTITION OF clients FOR VALUES IN ('BE', 'LU');
CREATE TABLE clients_autres PARTITION OF clients DEFAULT;

-- Partitionnement par HASH (répartition équilibrée sans logique métier)
CREATE TABLE evenements (
    id BIGINT,
    utilisateur_id INTEGER NOT NULL,
    payload JSONB
) PARTITION BY HASH (utilisateur_id);

CREATE TABLE evenements_p0 PARTITION OF evenements FOR VALUES WITH (MODULUS 4, REMAINDER 0);
CREATE TABLE evenements_p1 PARTITION OF evenements FOR VALUES WITH (MODULUS 4, REMAINDER 1);
CREATE TABLE evenements_p2 PARTITION OF evenements FOR VALUES WITH (MODULUS 4, REMAINDER 2);
CREATE TABLE evenements_p3 PARTITION OF evenements FOR VALUES WITH (MODULUS 4, REMAINDER 3);

-- REPLICATION : concepts (configuration réelle hors du langage SQL pur)
-- Réplication physique en streaming (PostgreSQL) : le réplica rejoue le WAL du primaire
-- postgresql.conf sur le primaire :
--   wal_level = replica
--   max_wal_senders = 10
-- Sur le réplica :
--   primary_conninfo = 'host=primaire port=5432 user=replicateur'

-- Vérifier le décalage de réplication (lag) depuis le primaire
SELECT client_addr, state, sent_lsn, replay_lsn,
       (pg_current_wal_lsn() - replay_lsn) AS octets_de_retard
FROM pg_stat_replication;

-- Répartir la charge : écritures sur le primaire, lectures sur les réplicas
-- (routage applicatif : requêtes SELECT -> pool de connexion "réplica",
--  INSERT/UPDATE/DELETE -> connexion "primaire")

-- Sharding (partitionnement horizontal ENTRE plusieurs serveurs, pas seulement dans un seul)
-- Chaque shard héberge un sous-ensemble de clients (ex: par hash(client_id) % nb_shards)
-- Compromis : les JOIN cross-shard deviennent impossibles ou très coûteux
-- -> à réserver aux tables qui dépassent les capacités d'un seul serveur