pl proxy 集群示例配置过程

零、参考资料

1、http://plproxy.projects.pgfoundry.org/doc/tutorial.html

2、http://www.tbdata.org/archives/723

一、缘起

本来淘宝这篇博客已经说得很清楚了,但是它需要三台虚拟机,呃,自己对虚拟机完全不熟悉,加上硬盘不够,就不想折腾了,然后找单机版的pl proxy方法,到处没有找到,然后就只有看官方文档了,就是第一个参考资料了啦,发现其实可以在一个linux下建立3个数据库就可以模拟了。

二、基本信息

1、linux版本:ubuntu 12.10

2、postgresql版本:9.1

3、pl proxy版本:postgresql-9.1-plproxy

4、postgresql已经能使用了

5、在pgadmin3中执行sql语句的方法如下

(1)打开query tool(按住ctrl+E)就可以打开

(2)在query tool中粘贴sql语句

(3)按F5就可以执行了

(4)执行成功或者失败都会有提醒,挺好使。

三、配置过程

1、emacs /etc/postgresql/9.1/main/pg_hba.conf

—>改变行:host all all 127.0.0.1/32 md5

—>修改为:host all all 127.0.0.1/32 trust

2、创建三个数据库,分别是proxy,database0,database1,我用的创建工具是pgadmin3,创建数据库的sql代码分别如下(把其中的proxy代替为database0,database1就可以分别使用了)

-- Database: proxy
-- DROP DATABASE proxy;
CREATE DATABASE proxy
  WITH OWNER = postgres
       ENCODING = 'UTF8'
       TABLESPACE = pg_default
       LC_COLLATE = 'en_US.UTF-8'
       LC_CTYPE = 'en_US.UTF-8'
       CONNECTION LIMIT = -1;

3、在bash或zsh等shell中输入如下命令

psql -U postgres -h 127.0.0.1 -f /usr/share/postgresql/9.1/extension/plproxy--2.4.0.sql proxy 

4、在pgadmin3中选择proxy数据库,打开query tool,输入如下sql语句并按f5执行

create language plpgsql;

得到的结果是

ERROR:  language "plpgsql" already exists

********** Error **********

ERROR: language "plpgsql" already exists
SQL state: 42710

证明这一步没有必要做,其实已经有了

5、在pgadmin3中选择proxy数据库,打开query tool,输入如下语句并执行

create schema plproxy

6、在pgadmin3中选择proxy数据库的plproxy模式(刚创建的),打开query tool ,输入如下建立3个函数的语句并执行

(1)建立plproxy.get_cluster_config函数

CREATE OR REPLACE FUNCTION plproxy.get_cluster_config(IN cluster_name text, OUT key text, OUT val text)
  RETURNS SETOF record AS
$BODY$
BEGIN
key := 'statement_timeout';--就是给 key 变量赋值,赋的值为’statement_timeout’
val := 60;--就是给 val 变量赋值,赋的值为 60
RETURN NEXT;
RETURN;
END;
$BODY$
  LANGUAGE plpgsql VOLATILE
  COST 100
  ROWS 1000;
ALTER FUNCTION plproxy.get_cluster_config(text)
  OWNER TO postgres;

(2)建立plproxy.get_cluster_partitions函数

CREATE OR REPLACE FUNCTION plproxy.get_cluster_partitions(cluster_name text)
  RETURNS SETOF text AS
$BODY$
BEGIN
IF cluster_name = 'testcluster' THEN --cluster_name 是群集的名字
RETURN NEXT 'dbname=database0 host=127.0.0.1'; --数据库节点的数据库名和 IP 地址
RETURN NEXT 'dbname=database1 host=127.0.0.1'; --数据库节点的数据库名和 IP 地址
RETURN;
END IF;
RAISE EXCEPTION 'Unknown cluster'; --如果群集名不存在,抛出异常,这个是在数据库内部处理的,最终会写入日志中。‘Unknown cluster’是报错信息
END;
$BODY$
  LANGUAGE plpgsql VOLATILE
  COST 100
  ROWS 1000;
ALTER FUNCTION plproxy.get_cluster_partitions(text)
  OWNER TO postgres;

(3)建立 plproxy.get_cluster_version函数

CREATE OR REPLACE FUNCTION plproxy.get_cluster_version(cluster_name text)
  RETURNS integer AS
$BODY$
BEGIN
IF cluster_name = 'testcluster' THEN
RETURN 1;
END IF;
RAISE EXCEPTION 'Unknown cluster';
END;
$BODY$
  LANGUAGE plpgsql VOLATILE
  COST 100;
ALTER FUNCTION plproxy.get_cluster_version(text)
  OWNER TO postgres;

7、在pgadmin3中选择proxy数据库的public模式(默认就有的),打开query tool ,输入如下建立3个函数的语句并执行

(1)建立public.ddlexec(sql_request text)函数

CREATE OR REPLACE FUNCTION ddlexec(query text)
  RETURNS SETOF integer AS
$BODY$
CLUSTER 'testcluster';
RUN ON ALL;
$BODY$
  LANGUAGE plproxy VOLATILE
  COST 100
  ROWS 1000;
ALTER FUNCTION ddlexec(text)
  OWNER TO postgres;

(2)建立public.dmlexec(sql_request text)函数

CREATE OR REPLACE FUNCTION dmlexec(query text)
  RETURNS SETOF integer AS
$BODY$
CLUSTER 'testcluster';
RUN ON ANY;
$BODY$
  LANGUAGE plproxy VOLATILE
  COST 100
  ROWS 1000;
ALTER FUNCTION dmlexec(text)
  OWNER TO postgres;

(3)建立public.dqlexec(sql_request text)函数

CREATE OR REPLACE FUNCTION dqlexec(query text)
  RETURNS SETOF record AS
$BODY$
CLUSTER 'testcluster';
RUN ON ALL;
$BODY$
  LANGUAGE plproxy VOLATILE
  COST 100
  ROWS 1000;
ALTER FUNCTION dqlexec(text)
  OWNER TO postgres;

8、在pgadmin3中选择database0 和database1数据库,打开query tool,输入如下sql语句并按f5执行

create language plpgsql;

如果已经有这个语言了,就会和上面第四步一样报错,不管,继续往下走就行了。

9、在pgadmin3中选择database0 和database1数据库的public模式(默认就有的),打开query tool ,输入如下建立3个函数的语句并执行

(1)建立public.ddlexec(sql_request text)函数

CREATE OR REPLACE FUNCTION ddlexec(query text)
RETURNS integer AS
$BODY$
declare
ret integer;
begin
execute query;
return 1;
end;
$BODY$
LANGUAGE 'plpgsql' VOLATILE
COST 100;

(2)建立public.dmlexec(sql_request text)函数

CREATE OR REPLACE FUNCTION dmlexec(query text)
RETURNS integer AS
$BODY$
declare
ret integer;
begin
execute query;
return 1;
end;
$BODY$
LANGUAGE 'plpgsql' VOLATILE
COST 100;

(3)建立public.dqlexec(sql_request text)函数

CREATE OR REPLACE FUNCTION dqlexec(query text)
RETURNS SETOF record AS
$BODY$
declare
ret record;
begin
for ret in execute query loop
return next ret;
end loop;
return;
end;
$BODY$
LANGUAGE 'plpgsql' VOLATILE
COST 100
ROWS 1000;

10、到此为止,集群就创建成功了,现在就可以通过proxy这个节点对database0和database1进行建表、插入数据、查询数据的操作了

(1)创建表usertable

在pgadmin3中选择proxy数据库,打开query tool ,输入如下建立usertable的语句并执行

select ddlexec('create table usertable(id integer)');

上述语句执行完,在database0和database1数据库的public模式中就应该有usertable这个表了,如果没有这个表,那就是前面某一步出错了啦。

(2)在usertable表中插入数据

在pgadmin3中选择proxy数据库,打开query tool ,输入如下建立usertable的语句并执行

select dmlexec('insert into usertable values(0)');
select dmlexec('insert into usertable values(1)');
select dmlexec('insert into usertable values(2)');
select dmlexec('insert into usertable values(3)');
select dmlexec('insert into usertable values(4)');
select dmlexec('insert into usertable values(5)');
select dmlexec('insert into usertable values(6)');
select dmlexec('insert into usertable values(7)');
select dmlexec('insert into usertable values(8)');
select dmlexec('insert into usertable values(9)');
select dmlexec('insert into usertable values(10)');

上述语句执行完之后能看到database0和database1这两个数据库的usertable表中已经有10行数据了啦。

(3)搜索usertable表中数据

在pgadmin3中选择proxy数据库,打开query tool ,输入如下建立usertable的语句并执行

select * from dqlexec('select * from usertable ') as (id integer);

获得结果是

3
4
5
6
7
8
10
0
1
2
9

好了,到这就算完成了。。。。

添加新评论