CentOS plproxy查询安装pgsql编译源码
CentOS plproxy经过长时间的发展，这里我发表一下个人理解，下面就这就来讲术CentOS plproxy。CentOS plproxy需求: 工作需要3种集群模式.
pgCluster全热备集群都读写每台节点都保持数据完整 pg Slony-I or II主从集群从只读主读写 pg plporxy分流特性负载平衡分布到节点上
目的: 在 CentOS plproxy 上做查询,从node返回结果环境: 3台centos: 1台做CentOS plproxy 2台做node步骤: 如下:
1 安装pgsql,所有pgsql都要装版本3xx编译源码,rpm 都可以安装方法看readme或者install文档源码安装默认都装在/usr/local/pgsql/下处理一下环境变量的问题export PATH=$PATH:/usr/local/pgsql/bin初始化数据库目录initdb -D /usr/local/pgsql/data
生成一个数据库createdb 数据库名添加plpgsql语言支持createlang plpgsql 数据库名修改 pgsql 的配置文件vi /usr/local/pgsql/data/postgresqlconf取消注释listen_addresses = '*'port = 5432添加用户认证host 数据库名 用户名 ip地址 trust
2 安装CentOS plproxy只在proxy上安装,node不用安装解包make && make install添加CentOS plproxy支持psql -f /usr/local/pgsql/share/contrib/plproxysql 数据库名在P1上创建schema psql testproxy 用psql客户端连接数据库create schema plproxy; 生成schemavi MyClusterInitsql,然后把下面的内容保存:(去掉注释)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';<----节点ip RETURN NEXT 'dbname=test2 host=1921681193';<----节点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执行上述sql语句以上CentOS plproxy设置完成开始节点的设置:给每个节点都创建一个函数:方法同上:
vi到一个文件中,然后执行这个文件内容如下:
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地址