postgresql中PLProxy如何配置

43次阅读
没有评论

共计 7396 个字符,预计需要花费 19 分钟才能阅读完成。

丸趣 TV 小编给大家分享一下 postgresql 中 PLProxy 如何配置,希望大家阅读完这篇文章之后都有所收获,下面让我们一起去探讨吧!

1. 下载 plproxy-2.6.tar.gz

网址:https://plproxy.github.io/

root 用户上传到 /home/soft 目录

# cd /home/

# chown postgres.postgres soft

# cd soft

# chown postgres.postgres plproxy-2.6.tar.gz

2. 编译安装

前提:postgresql 9.5.2 源码安装,/opt/pgsql/9.5.2

postgres 用户 PATH 环境变量

[postgres@pgtest ~]$ more .bash_profile 

# .bash_profile

# Get the aliases and functions

if [-f ~/.bashrc]; then

        . ~/.bashrc

fi

# User specific environment and startup programs

export LD_LIBRARY_PATH=/usr/local/mysql/lib/mysql:/opt/pgsql/9.5.2/lib

export PATH=/usr/local/mysql/bin:/opt/pgbouncer/1.7.2/bin:/opt/pgsql/9.5.2/bin:$PATH

export MANPATH=/opt/pgsql/9.5.2/share/man:$MANPATH

[postgres@pgtest ~]$

postgres 用户执行以下命令

$ tar zxvf plproxy-2.6.tar.gz

$ make

……

……

……

gcc -Wall -Wmissing-prototypes -Wpointer-arith -Wdeclaration-after-statement -Wendif-labels -Wmissing-format-attribute -Wformat-security -fno-strict-aliasing -fwrapv -O2 -fpic -I/opt/pgsql/9.5.2/include/server -I/opt/pgsql/9.5.2/include -DNO_SELECT=0 -I. -I./ -I/opt/pgsql/9.5.2/include/server -I/opt/pgsql/9.5.2/include/internal -D_GNU_SOURCE   -c -o src/aatree.o src/aatree.c

gcc -Wall -Wmissing-prototypes -Wpointer-arith -Wdeclaration-after-statement -Wendif-labels -Wmissing-format-attribute -Wformat-security -fno-strict-aliasing -fwrapv -O2 -fpic -shared -o plproxy.so src/scanner.o src/parser.tab.o src/cluster.o src/execute.o src/function.o src/main.o src/query.o src/result.o src/type.o src/poll_compat.o src/aatree.o -L/opt/pgsql/9.5.2/lib -Wl,–as-needed -Wl,-rpath, /opt/pgsql/9.5.2/lib ,–enable-new-dtags  -L/opt/pgsql/9.5.2/lib -lpq 

echo create extension plproxy; sql/plproxy.sql 

cat sql/plproxy_lang.sql sql/plproxy_fdw.sql sql/plproxy–2.6.0.sql

cat sql/ext_update_validator.sql sql/plproxy–2.3.0–2.6.0.sql

cat sql/ext_update_validator.sql sql/plproxy–2.4.0–2.6.0.sql

cat sql/ext_update_validator.sql sql/plproxy–2.5.0–2.6.0.sql

cat sql/ext_unpackaged.sql sql/plproxy–unpackaged–2.6.0.sql

$

$ make install

/bin/mkdir -p /opt/pgsql/9.5.2/lib

/bin/mkdir -p /opt/pgsql/9.5.2/share/extension

/bin/mkdir -p /opt/pgsql/9.5.2/share/extension

/usr/bin/install -c -m 755  plproxy.so /opt/pgsql/9.5.2/lib/plproxy.so

/usr/bin/install -c -m 644 .//plproxy.control /opt/pgsql/9.5.2/share/extension/

/usr/bin/install -c -m 644  sql/plproxy–2.6.0.sql sql/plproxy–2.3.0–2.6.0.sql sql/plproxy–2.4.0–2.6.0.sql sql/plproxy–2.5.0–2.6.0.sql sql/plproxy–unpackaged–2.6.0.sql /opt/pgsql/9.5.2/share/extension/

3.proxy

proxy 节点:

ipaddress:192.168.199.201

user: proxy

password: proxy

database:proxy

data 节点

ipaddress:192.168.199.201

user: datauser

password: datauser

database:db0、db1、db2、db3

[postgres@pgtest ~]$ psql

psql (9.5.2)

Type help for help.

postgres=# \l

                                  List of databases

   Name    |  Owner   | Encoding |   Collate   |    Ctype    |   Access privileges  

———–+———-+———-+————-+————-+———————–

 postgres  | postgres | UTF8     | en_US.UTF-8 | en_US.UTF-8 | 

 template0 | postgres | UTF8     | en_US.UTF-8 | en_US.UTF-8 | =c/postgres          +

           |          |          |             |             | postgres=CTc/postgres

 template1 | postgres | UTF8     | en_US.UTF-8 | en_US.UTF-8 | =c/postgres          +

           |          |          |             |             | postgres=CTc/postgres

(3 rows)

创建 role

postgres=# create role proxy nosuperuser login encrypted password proxy

CREATE ROLE

创建 proxy 数据库

postgres=# create database proxy;

CREATE DATABASE

postgres=# \c proxy

You are now connected to database proxy as user postgres .

加载扩展 proxy

proxy=# create extension plproxy;

CREATE EXTENSION

proxy=# 

调整 proxy 库权限

proxy=# grant all on database proxy to proxy;

GRANT

proxy=# \c proxy proxy

You are now connected to database proxy as user proxy .

proxy=  

创建 workschema schema, 目的是和数据节点的 schema 匹配, 这样的话可以省去在代理函数中写 target 强行指定 schema.

数据节点也建立这个 schema。

proxy= create schema workschema;

CREATE SCHEMA

proxy=  

创建 data 节点数据库

proxy= \c postgres postgres

You are now connected to database postgres as user postgres .

postgres=# create role datauser nosuperuser login encrypted password datauser

CREATE ROLE 

postgres=# create database db0;

CREATE DATABASE

postgres=# create database db1;

CREATE DATABASE

postgres=# create database db2;

CREATE DATABASE

postgres=# create database db3;

CREATE DATABASE

postgres=# 

调整权限, 赋予给后面将要给 user mapping 中配置的 option user 权限.

postgres=# grant all on database db0 to datauser;

GRANT

postgres=# grant all on database db1 to datauser;

GRANT

postgres=# grant all on database db2 to datauser;

GRANT

postgres=# grant all on database db3 to datauser;

GRANT

postgres=# 

每个库创建 schema

postgres=# \c db0 datauser

You are now connected to database db0 as user datauser .

db0= create schema workschema;

CREATE SCHEMA

db0= \c db1 datauser

You are now connected to database db1 as user datauser .

db1= create schema workschema;

CREATE SCHEMA

db1= \c db2 datauser

You are now connected to database db2 as user datauser .

db2= create schema workschema;

CREATE SCHEMA

db2= \c db3 datauser

You are now connected to database db3 as user datauser .

db3= create schema workschema;

CREATE SCHEMA

db3=

使用超级用户在 proxy 数据库中创建 server.

postgres=# \c proxy postgres

proxy=#CREATE SERVER cluster_srv1 FOREIGN DATA WRAPPER plproxy options (connection_lifetime 1800 ,

p0 dbname=db0 hostaddr=192.168.199.201 port=1921 application_name=test ,

p1 dbname=db1 hostaddr=192.168.199.201 port=1921 ,

p2 dbname=db2 hostaddr=192.168.199.201 port=1921 ,

p3 dbname=db3 hostaddr=192.168.199.201 port=1921

CREATE SERVER

proxy=# 

创建 server 时可以使用 libpq 中的选项. 例如本例使用了 application_name.

将 server 权限赋予给 proxy 用户.

proxy=# GRANT usage ON FOREIGN SERVER cluster_srv1 to proxy;

GRANT

proxy=#

配置 proxy 用户的连接 cluster_srv1 的选项.

proxy=# GRANT usage ON FOREIGN SERVER cluster_srv1 to proxy;

GRANT

proxy=# CREATE USER MAPPING FOR PROXY SERVER cluster_srv1 options(user datauser

CREATE USER MAPPING

proxy=# 

用户 proxy 连接到 cluster_srv1 时使用 datauser 用户连接, 这里不需要配置 password, 因为我们将使用 trust 认证.

修改数据节点的 pg_hba.conf

从 proxy 节点使用 datauser 用户连接数据库 db0, db1, db2,db3 使用 trust 认证.

# TYPE  DATABASE        USER            ADDRESS                 METHOD

# local is for Unix domain socket connections only

local   all             all                                     trust

# IPv4 local connections:

host    all             all             127.0.0.1/32            trust

host    db0             datauser        192.168.199.0/24        trust  

host    db1             datauser        192.168.199.0/24        trust

host    db2             datauser        192.168.199.0/24        trust

host    db3             datauser        192.168.199.0/24        trust

$ pg_ctl reload -D /pgdata95/

server signaled

在 plproxy 节点创建代理函数

使用超级用户创建 plproxy 函数, 然后把函数权限赋予给 proxy 权限.

postgres=# \c proxy

You are now connected to database proxy as user postgres .

proxy=# CREATE OR REPLACE FUNCTION workschema.dy(sql text)

proxy-# RETURNS SETOF record AS 

proxy-# $BODY$

proxy$#    cluster cluster_srv1

proxy$#    run on all;

proxy$# $BODY$

proxy-# LANGUAGE plproxy

CREATE FUNCTION 

proxy=# grant execute on function workschema.dy(text) to proxy;

GRANT

proxy=# 

在数据节点创建实体函数

db0\db1\db2\db3 数据库 datauser 用户

CREATE OR REPLACE FUNCTION workschema.dy(sql text)

RETURNS SETOF record 

AS $BODY$

       declare rec record;

       begin

            for rec in execute sql loop

                return next rec;

            end loop;

            return;

       end;

   $BODY$

LANGUAGE plpgsql

在 proxy 节点中就可以访问数据节点了。

# \c proxy proxy

proxy= select * from workschema.dy(select count(*) from pg_class ) as t(i int8);

  i  

—–

 311

 311

 311

 311

(4 rows)

proxy= select sum(i) from workschema.dy(select count(*) from pg_class ) as t(i int8);

 sum  

——

 1244

(1 row)

proxy=  

plproxy 节点测试

在数据节点创建测试表.

db0\db1\db2\db3 数据库 datauser 用户  

创建表

create table t(id int);

创建实体函数

CREATE OR REPLACE FUNCTION workschema.f_test4()

RETURNS int

AS $$

    declare 

    begin

    insert into t(id) values(1);

    return 0;

    end;

   $$

LANGUAGE plpgsql

proxy 创建代理函数

在 proxy 节点创建代理函数, 并且将执行权限赋予给 proxy 用户.

proxy= \c proxy postgres

CREATE OR REPLACE FUNCTION workschema.f_test4() 

RETURNS int 

AS $$

cluster cluster_srv1

run on 0;

$$ 

LANGUAGE plproxy strict;

proxy=# grant execute on function workschema.f_test4() to proxy;

GRANT

执行代理函数

proxy=# \c proxy proxy

You are now connected to database proxy as user proxy .

proxy=  

proxy=  

proxy=  

proxy= select * from workschema.f_test4();

 f_test4 

———

       0

(1 row)

proxy=  

看完了这篇文章,相信你对“postgresql 中 PLProxy 如何配置”有了一定的了解,如果想了解更多相关知识,欢迎关注丸趣 TV 行业资讯频道,感谢各位的阅读!

正文完
 
丸趣
版权声明:本站原创文章,由 丸趣 2023-07-19发表,共计7396字。
转载说明:除特殊说明外本站除技术相关以外文章皆由网络搜集发布,转载请注明出处。
评论(没有评论)