CentOS plproxy查詢安裝pgsql編譯源碼
CentOS plproxy經(jīng)過長時間的發(fā)展，這里我發(fā)表一下個人理解，下面就這就來講術(shù)CentOS plproxy。CentOS plproxy需求: 工作需要3種集群模式.
- pgCluster全熱備集群都讀寫每臺節(jié)點都保持數(shù)據(jù)完整
- pg Slony-I or II主從集群從只讀主讀寫
- pg plporxy分流特性負載平衡分布到節(jié)點上
目的: 在 CentOS plproxy 上做查詢,從node返回結(jié)果環(huán)境: 3臺centos: 1臺做CentOS plproxy 2臺做node步驟: 如下:
1 安裝pgsql,所有pgsql都要裝版本3xx編譯源碼,rpm 都可以安裝方法看readme或者install文檔源碼安裝默認都裝在/usr/local/pgsql/下處理一下環(huán)境變量的問題export PATH=$PATH:/usr/local/pgsql/bin初始化數(shù)據(jù)庫目錄initdb -D /usr/local/pgsql/data
生成一個數(shù)據(jù)庫createdb 數(shù)據(jù)庫名添加plpgsql語言支持createlang plpgsql 數(shù)據(jù)庫名修改 pgsql 的配置文件vi /usr/local/pgsql/data/postgresqlconf取消注釋listen_addresses = '*'port = 5432添加用戶認證host 數(shù)據(jù)庫名 用戶名 ip地址 trust
2 安裝CentOS plproxy只在proxy上安裝,node不用安裝解包make && make install添加CentOS plproxy支持psql -f /usr/local/pgsql/share/contrib/plproxysql 數(shù)據(jù)庫名在P1上創(chuàng)建schema psql testproxy 用psql客戶端連接數(shù)據(jù)庫create schema plproxy; 生成schemavi MyClusterInitsql,然后把下面的內(nèi)容保存:(去掉注釋)begin
- CREATE OR REPLACE FUNCTION plproxyget_cluster_partitions(cluster_name text)
- RETURNS SETOF text AS $$
- BEGIN
- IF cluster_name = 'MyCluster' THEN
- RETURN NEXT 'dbname=test1 host=1921681190';<----節(jié)點ip
- RETURN NEXT 'dbname=test2 host=1921681193';<----節(jié)點ip
- RETURN;
- END IF;
- RAISE EXCEPTION 'Unknown cluster';
- END;
- $$ LANGUAGE plpgsql;
- CREATE OR REPLACE FUNCTION plproxyget_cluster_version(cluster_name text)
- RETURNS int4 AS $$
- BEGIN
- IF cluster_name = 'MyCluster' THEN
- RETURN 1;
- END IF;
- RAISE EXCEPTION 'Unknown cluster';
- END;
- $$ LANGUAGE plpgsql;
- create or replace function plproxyget_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;
end psql -f MyClusterInitsql -d testproxy執(zhí)行上述sql語句以上CentOS plproxy設(shè)置完成開始節(jié)點的設(shè)置:給每個節(jié)點都創(chuàng)建一個函數(shù):方法同上:
vi到一個文件中,然后執(zhí)行這個文件內(nèi)容如下:
begin create or replace function publicdquery(query text) returns setof record as $$declare ret record;beginfor ret in execute query loopreturn next ret;end loop;return;end;$$ language plpgsql;create or replace function publicddlExec(query text) returns integer as $$declare ret integer;begin execute query; return 1;end;$$ language plpgsql;create or replace function publicdmlExec(query text) returns integer as $$declare ret integer;begin execute query; return 1;end;$$ language plpgsql; end psql -f 這個文件名 -d database name -h ip地址
4 然后在proxy上建立相同的函數(shù),用于集群檢索建立,執(zhí)行方法同上:
CREATE OR REPLACE FUNCTION publicdquery(query text) RETURNS setofrecord AS $$CLUSTER 'MyCluster';RUN ON ALL;$$ LANGUAGE CentOS plproxy;CREATE OR REPLACE FUNCTION publicddlexec(query text) RETURNS setof integerAS $$CLUSTER 'MyCluster';RUN ON ALL;$$ LANGUAGE CentOS plproxy;CREATE OR REPLACE FUNCTION publicdmlexec(query text) RETURNS setof integerAS $$CLUSTER 'MyCluster';RUN ON ANY;$$ LANGUAGE plproxy; done
5 CentOS plproxy測試 方法:在proxy,nodes上建立相同的表 用select,insert,del 在proxy執(zhí)行然后每個node上都有響應(yīng) 代碼: select * from publicddlexec( 'create table usertable(id primary key,username varchar(20)' );在數(shù)據(jù)節(jié)點上生成一個表usertable,然后可以插入一些數(shù)據(jù)測試:
select * from publicddlexec(
'insert into usertable(id,username) values(1,'aaa')');
6 CentOS plproxy如果失敗請: 參考 pgsql 官方手冊
【編輯推薦】
