快捷導(dǎo)航

PostgreSQL通過(guò)mysql_fdw連通MySQL實(shí)戰(zhàn)

更新時(shí)間：2026年03月03日 10:12:03 作者：IT邦德

mysql_fdw就像是PostgreSQL和MySQL數(shù)據(jù)庫(kù)之間的一座雙向橋梁,本文就來(lái)詳細(xì)的介紹一下PostgreSQL通過(guò)mysql_fdw連通MySQL實(shí)戰(zhàn),感興趣的可以了解一下

mysql_fdw 就像是 PostgreSQL 和 MySQL 數(shù)據(jù)庫(kù)之間的一座雙向橋梁。它允許你在 PostgreSQL 中創(chuàng)建一個(gè)“外部表”，這個(gè)表直接映射到遠(yuǎn)程 MySQL 數(shù)據(jù)庫(kù)中的真實(shí)表。之后，你就可以像操作本地 PostgreSQL 表一樣，對(duì)這個(gè)外部表進(jìn)行查詢（SELECT）、插入（INSERT）、更新（UPDATE）和刪除（DELETE）? 操作，而 mysql_fdw 會(huì)在背后自動(dòng)完成所有與 MySQL 數(shù)據(jù)庫(kù)的通信和數(shù)據(jù)轉(zhuǎn)換工作。

1. 安裝插件

你需要在 PostgreSQL 所在的服務(wù)器上安裝 mysql_fdw，它依賴 MySQL 的客戶端開(kāi)發(fā)庫(kù)。從GitHub或PGXN網(wǎng)站下載mysql_fdw源碼包。

mysql_fdw GitHub下載地址：

https://github.com/EnterpriseDB/mysql_fdw

1）使用yum安裝依賴和開(kāi)發(fā)包
yum install postgresql-server-devel mysql-devel
2) 解壓編譯安裝
unzip /opt/mysql_fdw-REL-2_9_3.zip -d /home/postgres
cd myql_fdw-REL-2_9_3
make USE_PGXS=1
make USE_PGXS=1 install

安裝成功后，你需要重啟 PostgreSQL服務(wù)，
或者至少讓正在使用的數(shù)據(jù)庫(kù)重新加載共享庫(kù)。

2. 啟用插件服務(wù)

以下是一個(gè)簡(jiǎn)單的使用示例，所有命令在 PoatgreSQL 中執(zhí)行：

1)加載擴(kuò)展插件
CREATE EXTENSION mysql_fdw;
2)創(chuàng)建服務(wù)器對(duì)象
CREATE SERVER mysql_server 
FOREIGN DATA WRAPPER mysql_fdw 
OPTIONS (host '192.168.3.11', port '3306');
3) 授權(quán)
GRANT USAGE ON FOREIGN 
SERVER mysql_server TO postgres;

3. 建立用戶映射

CREATE USER MAPPING FOR postgres
SERVER mysql_server
OPTIONS (username 'root', password 'root@A123');

4. 處理數(shù)據(jù)

橋梁已經(jīng)接通，最后一步就是在 PostgreSQL 這端創(chuàng)建一個(gè)“入口”，也就是外部表（Foreign Table）。這張表的列名和數(shù)據(jù)類型應(yīng)該與 MySQL 中的源表相對(duì)應(yīng)。

CREATE FOREIGN TABLE warehouse (
warehouse_id int,
warehouse_name text,
warehouse_created timestamp
)SERVER mysql_server
OPTIONS (dbname 'aidb', table_name 'warehouse');

這里要注意，mysql_fdw 的一個(gè)核心限制是為了確保能準(zhǔn)確追蹤和操作遠(yuǎn)程表中的特定行，它要求外部表定義中的第一列，必須對(duì)應(yīng)遠(yuǎn)程MySQL表中的一個(gè)唯一列（如主鍵或具有唯一約束的列）。

接下里我們就可以在PostgreSQL 中處理相關(guān)的數(shù)據(jù)了

1）插入數(shù)據(jù) 
INSERT INTO warehouse values (1, 'UPS', current_date);
INSERT INTO warehouse values (2, 'TV', current_date);
INSERT INTO warehouse values (3, 'Table', current_date);
2）刪除更新數(shù)據(jù)
DELETE FROM warehouse where warehouse_id = 3;
UPDATE warehouse set warehouse_name = 'UPS_NEW' where warehouse_id = 1;
3）查看 執(zhí)行計(jì)劃
EXPLAIN VERBOSE 
SELECT warehouse_id, warehouse_name 
FROM warehouse 
WHERE warehouse_name LIKE 'TV' limit 1;

如果需要映射一個(gè)模式（Schema）下的多張表，使用 IMPORT FOREIGN SCHEMA命令會(huì)非常高效，它可以自動(dòng)為你創(chuàng)建所有表的外部表定義。

IMPORT FOREIGN SCHEMA someschema
FROM SERVER mysql_server
INTO public;

5.運(yùn)維管理

當(dāng)通過(guò) mysql_fdw 連接 MySQL 進(jìn)行運(yùn)維時(shí)，可以查詢以下 PostgreSQL 系統(tǒng)表和目錄視圖來(lái)查看和管理外部對(duì)象

查看所有外部表的定義
SELECT * FROM pg_foreign_table;
以標(biāo)準(zhǔn) SQL 視角查看外部表
SELECT * FROM 
information_schema.foreign_tables;
查看 mysql_fdw 服務(wù)器的連接配置
SELECT * FROM pg_foreign_server;
查看連接到 MySQL 所用的用戶名映射
SELECT * FROM pg_user_mappings;

總結(jié)

mysql_fdw 是一個(gè)極其便捷的“數(shù)據(jù)橋梁”工具。它讓跨數(shù)據(jù)庫(kù)的數(shù)據(jù)訪問(wèn)變得像訪問(wèn)本地表一樣自然，特別適合混合架構(gòu)下的數(shù)據(jù)查詢、遷移過(guò)渡期以及臨時(shí)的數(shù)據(jù)整合需求。

到此這篇關(guān)于PostgreSQL通過(guò)mysql_fdw連通MySQL實(shí)戰(zhàn)的文章就介紹到這了,更多相關(guān)PostgreSQL連通MySQL內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: