<kbd id="afajh"><form id="afajh"></form></kbd>
<strong id="afajh"><dl id="afajh"></dl></strong>
    <del id="afajh"><form id="afajh"></form></del>
        1. <th id="afajh"><progress id="afajh"></progress></th>
          <b id="afajh"><abbr id="afajh"></abbr></b>
          <th id="afajh"><progress id="afajh"></progress></th>

          PL Proxy

          聯(lián)合創(chuàng)作 · 2023-09-30 20:08

          PL/Proxy和PostgreSQL集群的結(jié)構(gòu)關(guān)系可以用下圖清楚地表示

          下面是詳細(xì)的安裝方法:


          以下操作是在三臺(tái)不同機(jī)器上執(zhí)行的情況,其中plproxy節(jié)點(diǎn)的機(jī)器名是P1,數(shù)據(jù)庫(kù)節(jié)點(diǎn)的機(jī)器名分別是D1和D2。機(jī)器硬件配置如下,同時(shí)需要Linux-4.2、postgresql-8.3.0和plproxy-2.0.4,pgbouncer的安裝過程略去。

          plproxy節(jié)點(diǎn):
          hostname: P1
          inet addr:10.0.0.1
          OS: Linux 2.6.9-42.ELsmp
          CPU:Intel(R) Xeon(R) CPU L5320 @ 1.86GHz
          MemTotal: 514440 kB

          node1節(jié)點(diǎn):
          hostname:D1
          inet addr:10.0.0.2
          OS: Linux 2.6.9-42.ELsmp
          CPU:Intel(R) Xeon(R) CPU L5320 @ 1.86GHz
          MemTotal: 254772 kB

          node2節(jié)點(diǎn):
          hostname:D2
          inet addr:10.0.0.3
          OS: Linux 2.6.9-42.ELsmp
          CPU:Intel(R) Xeon(R) CPU L5320 @ 1.86GHz
          MemTotal: 254772 kB

          1. 在P1, D1,D2上安裝postgresql-8.3.0,并創(chuàng)建URTCluster數(shù)據(jù)庫(kù)

          ## Compile and install
          gunzip postgresql-8.3.0.tar.gz
          tar xf postgresql-8.3.0.tar
          cd postgresql-8.3.0
          ./configure –prefix=/home/y/pgsql –with-perl
          gmake
          gmake check
          sudo gmake install

          ## Add Unix User
          sudo adduser postgres
          sudo mkdir /home/y/pgsql/data
          sudo chown postgres /home/y/pgsql/data

          ## Init DB and Start service
          sudo -u postgres /home/y/pgsql/bin/initdb -D /home/y/pgsql/data
          sudo -u postgres /home/y/pgsql/bin/postgres -D /home/y/pgsql/data >logfile 2>&1 &

          ## Create DB and Use Local Connection
          sudo -u postgres /home/y/pgsql/bin/createdb URTCluster

          ##檢查數(shù)據(jù)庫(kù)是否已經(jīng)創(chuàng)建
          sudo -u postgres /home/y/pgsql/bin/psql -d URTCluster

          #D1,D2必須允許P1訪問
          #編輯postgresql.conf,打開tcp連接端口
          sudo vim /home/y/pgsql/data/postgresql.conf
          listen_addresses = ‘*’
          port = 5432

          #添加postgres用戶的認(rèn)證
          sudo vim /home/y/pgsql/data/pg_hba.conf
          host URTCluster postgres 10.0.0.0/16 trust

          # 重起服務(wù)器
          sudo -u postgres /home/y/pgsql/bin/pg_ctl -D /home/y/pgsql/data stop
          sudo -u postgres /home/y/pgsql/bin/postgres -D /home/y/pgsql/data >logfile 2>&1 &
          sudo -u postgres /home/y/pgsql/bin/pg_ctl -D /home/y/pgsql/data reload

          2. 在P1上安裝plproxy-2.0.4

          #檢查$PATH變量里是否有/home/y/pgsql/bin目錄,如果沒有,修改你的.bash_profile文件,添加/home/y/pgsql/bin到path里。
          echo $PATH

          gunzip plproxy-2.0.4.tar.gz
          tar xf plproxy-2.0.4.tar
          cd plproxy-2.0.4
          gmake
          sudo gmake install

          #創(chuàng)建plproxy
          sudo -u postgres /home/y/pgsql/bin/psql -f
          /home/y/pgsql/share/contrib/plproxy.sql URTCluster

          3. 在P1, D1,D2上安裝plpgsql

          sudo -u postgres /home/y/pgsql/bin/createlang plpgsql URTCluster

          4. 在P1上創(chuàng)建schema

          sudo -u postgres /home/y/pgsql/bin/psql -d URTCluster
          URTCluster=# create schema plproxy;

          5. 在P1上初始化設(shè)置

          #plproxy的配置是通過三個(gè)函數(shù)(過程)實(shí)現(xiàn)的,這三個(gè)函數(shù)的標(biāo)準(zhǔn)模版如下:

          #這個(gè)函數(shù)是讓plproxy可以找到對(duì)應(yīng)的集群
          CREATE OR REPLACE FUNCTION plproxy.get_cluster_partitions(cluster_name text)
          RETURNS SETOF text AS $$
          BEGIN
          IF cluster_name =’URTCluster’ THEN
          RETURN NEXT ‘dbname=URTCluster host=10.0.0.2′;
          RETURN NEXT ‘dbname=URTCluster host=10.0.0.3′;
          RETURN;
          END IF;
          RAISE EXCEPTION ‘Unknown cluster’;
          END;
          $$ LANGUAGE plpgsql;

          #這個(gè)函數(shù)是plproxy用于判斷是否給前端返回已經(jīng)cache過的結(jié)果用的
          CREATE OR REPLACE FUNCTION plproxy.get_cluster_version(cluster_name text)
          RETURNS int4 AS $$
          BEGIN
          IF cluster_name = ‘URTCluster’ THEN
          RETURN 1;
          END IF;
          RAISE EXCEPTION ‘Unknown cluster’;
          END;
          $$ LANGUAGE plpgsql;

          #這個(gè)函數(shù)是獲取不同的集群的配置
          create or replace function plproxy.get_cluster_config(cluster_name text, out key text, out val text)
          returns setof record as $$
          begin
          key := ’statement_timeout’;
          val := 60;
          return next;
          return;
          end;
          $$ language plpgsql;

          #把這三個(gè)函數(shù)放在一個(gè)URTClusterInit.sql文件里,并執(zhí)行
          sudo -u postgres /home/y/pgsql/bin/psql -f URTClusterInit.sql -d URTCluster -h 10.0.0.1

          6. 在D1,D2節(jié)點(diǎn)上設(shè)置

          #給每個(gè)數(shù)據(jù)庫(kù)節(jié)點(diǎn)都創(chuàng)建一張表users
          CREATE TABLE users (
          username text,
          email text
          );

          #給每個(gè)數(shù)據(jù)庫(kù)節(jié)點(diǎn)都創(chuàng)建一個(gè)插入函數(shù)
          CREATE OR REPLACE FUNCTION insert_user(i_username text, i_emailaddress text)
          RETURNS integer AS $$
          INSERT INTO users (username, email) VALUES ($1,$2);
          SELECT 1;
          $$ LANGUAGE SQL;

          #把函數(shù)保存在 URTClusterNodesInit_1.sql文件里,并執(zhí)行
          sudo -u postgres /home/y/pgsql/bin/psql -f URTClusterNodesInit_1.sql -h 10.0.0.2 -d URTCluster
          sudo -u postgres /home/y/pgsql/bin/psql -f URTClusterNodesInit_1.sql -h 10.0.0.3 -d URTCluster

          7. 在P1節(jié)點(diǎn)上設(shè)置

          #在 plproxy 節(jié)點(diǎn)上創(chuàng)建一個(gè)同名的插入函數(shù),用于進(jìn)行集群檢索
          CREATE OR REPLACE FUNCTION insert_user(i_username text, i_emailaddress text)
          RETURNS integer AS $$
          CLUSTER ‘URTCluster’;
          RUN ON hashtext(i_username);
          $$ LANGUAGE plproxy;

          #在 plproxy 節(jié)點(diǎn)上創(chuàng)建一個(gè)查詢函數(shù),用于進(jìn)行集群檢索
          CREATE OR REPLACE FUNCTION get_user_email(i_username text)
          RETURNS text AS $$
          CLUSTER ‘URTCluster’;
          RUN ON hashtext(i_username) ;
          SELECT email FROM users WHERE username = i_username;
          $$ LANGUAGE plproxy;

          #把函數(shù)保存在 URTClusterProxyExec.sql文件里,并執(zhí)行
          sudo -u postgres /home/y/pgsql/bin/psql -f URTClusterProxyExec_1.sql -h 10.0.0.1 -d URTCluster

          8. 在P1上測(cè)試結(jié)果

          sudo -u postgres /home/y/pgsql/bin/psql -d URTCluster

          SELECT insert_user(’Sven’,’[email protected]’);
          #被保存到D2, 可以用select hashtext(’Sven’) & 1驗(yàn)證,被hash到 partition 1

          SELECT insert_user(’Marko’, ‘[email protected]’);
          #被保存到D2, 可以用select hashtext(’Marko’) & 1驗(yàn)證,被hash到 partition 1

          SELECT insert_user(’Steve’,’[email protected]’);
          #被保存到D1, 可以用select hashtext(’Steve’) & 1驗(yàn)證,,被hash到 partition 0

          SELECT get_user_email(’Sven’);
          SELECT get_user_email(’Marko’);
          SELECT get_user_email(’Steve’);

           

          瀏覽 25
          點(diǎn)贊
          評(píng)論
          收藏
          分享

          手機(jī)掃一掃分享

          編輯 分享
          舉報(bào)
          評(píng)論
          圖片
          表情
          推薦
          點(diǎn)贊
          評(píng)論
          收藏
          分享

          手機(jī)掃一掃分享

          編輯 分享
          舉報(bào)
          <kbd id="afajh"><form id="afajh"></form></kbd>
          <strong id="afajh"><dl id="afajh"></dl></strong>
            <del id="afajh"><form id="afajh"></form></del>
                1. <th id="afajh"><progress id="afajh"></progress></th>
                  <b id="afajh"><abbr id="afajh"></abbr></b>
                  <th id="afajh"><progress id="afajh"></progress></th>
                  操操综合网 | 久久777 | 中文无码一区二区三区 | 大香蕉1区 | 放荡少妇三p黄色毛片 |