ApsaraDB RDS:水平分割 (PL/Proxy)

各データノードに insert_user 関数を作成します：

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;

プロキシノードにプロキシ関数を作成します。PL/Proxy は関数名で呼び出しを照合するため、プロキシ関数とデータノード関数は同じ名前を共有する必要があります。

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

プロキシノードに読み取り関数を作成します。RUN ON ALL はすべてのデータノードにクエリを実行し、結果をマージします。

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;

プロキシノードから 10 件のレコードを挿入します：

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');

各データノードにクエリを実行して、データがどのように分散されたかを確認します：

RUN ON ANY は書き込みをランダムにルーティングするため、分散は不均一になります。

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

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

プロキシノードを介してすべての行を読み取ります：

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 rows)

各データノードとプロキシノードに trunc_user 関数を作成します：

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

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

すべてのノードでテーブルを切り詰めます：

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

プロキシノードにレプリケーション用の挿入関数を作成します。TARGET insert_user は、PL/Proxy に、すべてのノードで (データノードにすでに定義されている) insert_user 関数を呼び出すように指示します：

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;

4 件のレコードを挿入します：

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

両方のデータノードに同一のデータが含まれていることを確認します：

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

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

RUN ON ANY を使用してプロキシノード経由で読み取ります。すべてのノードが同一のデータを保持しているため、どのノードも完全な結果を返します：

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 rows)