大佬教程收集整理的这篇文章主要介绍了postgresql_fdw 跨数据库查询，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。
--POSTGResql的数据库逻辑上是相互独立的，和Oracle类似，如果要访问其他数据库，需要做跨库操作， --POSTGRes本身提供了一些扩展，比如dblink,pgsql_fdw等，高版本的建议使用PostgreS_fDW，也就是pgsql_fDW的升级版。 远端数据准备 POSTGRes=# show search_path; search_path ------------- scheR_321_11845@a_fDW (1 row) POSTGRes=# create table tbl_kenyon (ID int,REMARK text); create table POSTGRes=# insert into tbl_kenyon SELEct generate_serIEs(1,100),'Kenyon Go!'; INSERT 0 100 二、安装使用 安装分4步走 1.本地安装extension --安装的扩展名是来自于share/extension/*.control中的文件名*，比如postgres_fDW.control POSTGRes=# create extension POSTGRes_fDW; CREATE EXTENSION POSTGRes=# SELEct * from pg_extension ; extname | extowner | extnamespace | extrelocatable | extversion | extconfig | extcondition -------------------+----------+--------------+----------------+------------+-----------+ plpgsql | 10 | 11 | f | 1.0 | | pg_stat_statements | 10 | 2200 | t | 1.1 | | POSTGRes_fDW | 10 | 2200 | t | 1.0 | | (3 rows) POSTGRes=# SELEct * from pg_foreign_data_wrapper; fDWname | fDWowner | fDWhandler | fDWvalIDator | fDWacl | fDWoptions ------------+----------+------------+--------------+--------+------------ POSTGRes_fDW | 10 | 154356 | 154357 | | (1 row) 或 POSTGRes=# \dx List of installed extensions name | Version | scheR_321_11845@a | Description -----------------+---------+------------+----------------------------------------------------- pg_stat_statements | 1.1 | public |track execution statistics of all sql statements executed plpgsql | 1.0 | pg_catalog | PL/pgSQL procedural language POSTGRes_fDW | 1.0 | public | foreign-data wrapper for remote POSTGResql servers (3 rows) 2.本地创建server并查看 该server作用是在本地配置一个连接远程的信息，下面的配置是要连接到远程DB名称是POSTGRes数据库 POSTGRes=# create server server_remote_rudy_01 foreign data wrapper POSTGRes_fDW options(host 'rudy_01',port '5432',dbname 'POSTGRes'); CREATE SERVER POSTGRes=# SELEct * from pg_foreign_server ; srvname | srvowner | srvfDW | srvtype | srvversion | srvacl | srvoptions --------------+----------+--------+---------+------------+--------+-------------------------- server_remote_rudy_01 | 10 | 154358 | | |{host=10.1.11.71,port=5432,dbname=POSTGRes} (1 row) 或者 POSTGRes=# \des List of foreign servers name | owner | foreign-data wrapper ------------------+----------+---------------------- server_remote_rudy_01 | POSTGRes | POSTGRes_fDW (1 row) 3.@R_422_10589@匹配信息并查看,在本地 --for后面的POSTGRes是本地登录执行的用户名,option里存储的是远程的用户密码 POSTGRes=# create user mapPing for Postgres server server_remote_rudy_01 options(user 'POSTGRes',password '123456'); CREATE USER MAPPing POSTGRes=# SELEct * from pg_user_R_321_11845@apPings; umID | srvID | srvname | umuser | usename | umoptions --------+--------+------------------+--------+----------+----------------------------------- 154360 | 154359 | server_remote_rudy_01 | 10 | POSTGRes | {user=usr_pg_fDW,password=123456} (1 row) 或 POSTGRes=# \deu+ List of user mapPings Server | User name | FDW Options ------------------+-----------+------------------------------------------ server_remote_rudy_01 | POSTGRes | ("user" 'usr_pg_fDW',password '123456') (1 row) 4.本地创建外部表，指定server POSTGRes=# CREATE foreign table test1(ID int,REMARK text) server server_remote_rudy_01 options (Schema_name 'public',table_name 'tbl_kenyon'); CREATE foreign table --导入整个scheR_321_11845@下面的表 create scheR_321_11845@a test; --视用户不同授予不同的权限 grant all on scheR_321_11845@a test to rudy_02; grant all on foreign data wrapper POSTGRes_fDW to rudy_02; grant all on foreign server server_remote_rudy_01 to rudy_02; --导入指定的表，也可以不导入指定的表，也可以导入整个scheR_321_11845@a下面的表 import FOREIGN scheR_321_11845@A public FROM SERVER server_remote_rudy_01 INTO test; import FOREIGN scheR_321_11845@A public limit to(t1) FROM SERVER server_remote_rudy_01 INTO test; --通过使用\d查看表，注意不通过使用\dt查看表，而且如果远端的表有drop或者create,在本地会察觉不到 \d test. POSTGRes=> SELEct * FROM test.t1 ; ERROR: relation "test.t1" does not exist --查看系统中有哪些外部表，可查看如下的sql SELEct * from pg_foreign_table; --注意如果要删除外部表，千万千万不要直接删除pg_foreign_table表中的数据 --delete from pg_foreign_table ; --否则不能再导入import FOREIGN 删除的表，也不能执行 SELEct froeign table 查询删除的表，也不能drop server,都会报如下的错 ERROR: cache lookup Failed for foreign table 49251 --再插入删除的数据 POSTGRes=# \d+ pg_foreign_table; table "pg_catalog.pg_foreign_table" column | Type | ModifIErs | Storage | Stats target | Description -----------+--------+-----------+----------+--------------+------------- ftrelID | oID | not null | plain | | 在本地pg_class表中对应的 relfilenode ftserver | oID | not null | plain | | 在本的pg_foreign_server表的oID ftoptions | text[] | | extended | | 对应foreign server的scheR_321_11845@a和table名字 POSTGRes=> insert into pg_foreign_table values(49251,49247,arraY['Schema_name=public','table_name=POSTGRes']); --而后再删除外部表 POSTGRes=> drop foreign table test.POSTGRes_log ; DROP foreign table -- POSTGRes_fDW 为了性能其会把where查询发送到远端 POSTGRes_fDW attempts to optimize remote querIEs to reduce the amount of data transferred from foreign servers The query that is actually sent to the Remote Server for execution can be examined using EXPLAIN VERBOSE
以上是大佬教程为你收集整理的postgresql_fdw 跨数据库查询全部内容，希望文章能够帮你解决postgresql_fdw 跨数据库查询所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。