ApsaraDB RDS:Pemisahan horizontal (PL/Proxy)

Buat fungsi insert_user di setiap node data:

CREATE OR REPLACE FUNCTION insert_user(i_id int, i_name text)
RETURNS integer AS $$
    INSERT INTO users (userid, name) VALUES ($1, $2);
    SELECT 1;
$$ LANGUAGE SQL;

Buat fungsi proxy di node proxy. PL/Proxy mencocokkan panggilan berdasarkan nama fungsi, sehingga fungsi proxy dan fungsi di node data harus memiliki nama yang sama.

CREATE OR REPLACE FUNCTION insert_user(i_id int, i_name text)
RETURNS integer AS $$
    CLUSTER 'cluster_srv1';
    RUN ON ANY;
$$ LANGUAGE plproxy;

Buat fungsi baca di node proxy. RUN ON ALL mengkueri setiap node data dan menggabungkan hasilnya.

CREATE OR REPLACE FUNCTION get_user_name()
RETURNS TABLE(userid int, name text) AS $$
    CLUSTER 'cluster_srv1';
    RUN ON ALL;
    SELECT userid, name FROM users;
$$ LANGUAGE plproxy;

Masukkan 10 catatan dari node proxy:

SELECT insert_user(1001, 'Sven');
SELECT insert_user(1002, 'Marko');
SELECT insert_user(1003, 'Steve');
SELECT insert_user(1004, 'lottu');
SELECT insert_user(1005, 'rax');
SELECT insert_user(1006, 'ak');
SELECT insert_user(1007, 'jack');
SELECT insert_user(1008, 'molica');
SELECT insert_user(1009, 'pg');
SELECT insert_user(1010, 'oracle');

Kueri setiap node data untuk melihat bagaimana data didistribusikan:

RUN ON ANY mengarahkan operasi tulis secara acak, sehingga distribusinya tidak merata.

-- Di pl_db0
SELECT * FROM users;
 userid |  name
--------+--------
   1001 | Sven
   1003 | Steve
   1004 | lottu
   1005 | rax
   1006 | ak
   1007 | jack
   1008 | molica
   1009 | pg
(8 baris)

-- Di pl_db1
SELECT * FROM users;
 userid |  name
--------+--------
   1002 | Marko
   1010 | oracle
(2 baris)

Baca kembali semua baris melalui node proxy:

SELECT userid, name FROM get_user_name();
 userid |  name
--------+--------
   1001 | Sven
   1003 | Steve
   1004 | lottu
   1005 | rax
   1006 | ak
   1007 | jack
   1008 | molica
   1009 | pg
   1002 | Marko
   1010 | oracle
(10 baris)

Buat fungsi trunc_user di setiap node data dan di node proxy:

-- Di pl_db0 dan pl_db1
CREATE OR REPLACE FUNCTION trunc_user()
RETURNS integer AS $$
    TRUNCATE TABLE users;
    SELECT 1;
$$ LANGUAGE SQL;

-- Di node proxy
CREATE OR REPLACE FUNCTION trunc_user()
RETURNS SETOF integer AS $$
    CLUSTER 'cluster_srv1';
    RUN ON ALL;
$$ LANGUAGE plproxy;

Truncate tabel di semua node:

SELECT trunc_user();
 trunc_user
------------
          1
          1
(2 baris)

Buat fungsi insert replikasi di node proxy. TARGET insert_user memberi tahu PL/Proxy untuk memanggil fungsi insert_user (yang sudah didefinisikan di node data) di setiap node:

CREATE OR REPLACE FUNCTION insert_user_2(i_id int, i_name text)
RETURNS SETOF integer AS $$
    CLUSTER 'cluster_srv1';
    RUN ON ALL;
    TARGET insert_user;
$$ LANGUAGE plproxy;

Masukkan 4 catatan:

SELECT insert_user_2(1004, 'lottu');
SELECT insert_user_2(1005, 'rax');
SELECT insert_user_2(1006, 'ak');
SELECT insert_user_2(1007, 'jack');

Verifikasi bahwa kedua node data berisi data yang identik:

-- Di pl_db0
SELECT * FROM users;
 userid | name
--------+-------
   1004 | lottu
   1005 | rax
   1006 | ak
   1007 | jack
(4 baris)

-- Di pl_db1
SELECT * FROM users;
 userid | name
--------+-------
   1004 | lottu
   1005 | rax
   1006 | ak
   1007 | jack
(4 baris)

Baca melalui node proxy menggunakan RUN ON ANY — karena semua node menyimpan data yang identik, node mana pun akan mengembalikan hasil lengkap:

CREATE OR REPLACE FUNCTION get_user_name_2()
RETURNS TABLE(userid int, name text) AS $$
    CLUSTER 'cluster_srv1';
    RUN ON ANY;
    SELECT userid, name FROM users;
$$ LANGUAGE plproxy;

SELECT userid, name FROM get_user_name_2();
 userid | name
--------+-------
   1004 | lottu
   1005 | rax
   1006 | ak
   1007 | jack
(4 baris)