postgresql添加mysql_fdw测试过程

请先确认已经安装好mysql_fdw,如果没有配置好点这:https://www.cnblogs.com/ohsolong/p/13041989.html

1.切换至postgres用户,输入密码登录 。注:如果安装了postgresql系统会自动创建该用户

 su postgres 

2.登录postgres数据库。注:安装postgresql时默认生成的数据库, 也可以登录自己创建的数据库,这里为了方便直接登录默认提供的数据库。

$ psql
psql (10.12 (Ubuntu 10.12-0ubuntu0.18.04.1))
Type "help" for help.

postgres=#

2.接下来按照官方文档流程使用mysql_fdw,官方文档点这:https://pgxn.org/dist/mysql_fdw/

  使用的命令说明在postgresql文档中,点这:http://postgres.cn/docs/10/postgres-fdw.html

 第一步:加载mysql_fdw扩展

CREATE EXTENSION mysql_fdw;

第二步:创建连接外部数据库的连接对象

CREATE SERVER mysql_server
     FOREIGN DATA WRAPPER mysql_fdw
     OPTIONS (host '127.0.0.1', port '3306');

第三步:创建用户映射,postgresql用户映射mysql服务器的用户(postgresql数据库用户:postgres; mysql数据库用户:foo)

CREATE USER MAPPING FOR postgres
SERVER mysql_server
OPTIONS (username 'foo', password 'bar');  

第四步:创建与mysql中对应的外部表。注:表名称,列名一致,对应列数据类型可以不同但能够转换(依赖与数据库本身)

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

在postgresql中向mysql外部数据库插入数据,发现出出错。

postgres=# insert into warehouse values (1,'ups',now());
ERROR:  failed to connect to MySQL: Access denied for user 'foo'@'localhost' (using password: YES)

3.上面出错的原因是我没有安装mysql_server,

   以及没有在mysql中添加上面映射的 foo 用户,

 以及没有创建名为db的数据库并在其中创建warehouse表,接下来进行配置。

    第一步:安装mysql_server,启动mysql服务,切换至root用户登录mysql

安装数据库
$ sudo apt install mysql-server

启动数据库 $ service mysql start

登录mysql并创建远程用户 $ su root # mysql -uroot Welcome to the MySQL monitor. Commands end with ; or \g. Your MySQL connection id is 14 Server version: 5.7.30-0ubuntu0.18.04.1 (Ubuntu) Copyright (c) 2000, 2020, Oracle and/or its affiliates. All rights reserved. Oracle is a registered trademark of Oracle Corporation and/or its affiliates. Other names may be trademarks of their respective owners. Type 'help;' or '\h' for help. Type '\c' to clear the current input statement. mysql> create user foo identified by 'bar'; Query OK, 0 rows affected (0.00 sec)

给用户授权 mysql> grant all privileges on *.* to 'foo'@'%'identified by 'bar' with grant option; Query OK, 0 rows affected, 1 warning (0.00 sec)

创建数据库 mysql> create database db; Query OK, 1 row affected (0.00 sec)

计入数据库
mysql> user db;

创建表 mysql> create table warehouse( warehouse_id int, warehouse_name text, warehouse_created timestamp); Query OK, 0 rows affected (0.03 sec)

4.在postgresql上向外表插入数据,发现没有创建表的唯一索引

postgres=# insert into warehouse values (1, 'ups', now());
ERROR:  first column of remote table must be unique for INSERT/UPDATE/DELETE operation  

mysql表中创建唯一索引

mysql> create unique index warehouse_index on warehouse(warehouse_id);

5.最后测试

 postgresql插入数据 mysql中查询成功(INSERT INTO) 

postgres=# insert into warehouse values (1,'ups',now());
INSERT 0 1
postgres=# 
mysql> select * from warehouse;
+--------------+----------------+---------------------+
| warehouse_id | warehouse_name | warehouse_created   |
+--------------+----------------+---------------------+
|            1 | ups            | 2020-06-04 15:41:51 |
+--------------+----------------+---------------------+
1 row in set (0.00 sec)

mysql> 

postgresql更新数据 mysql中查询成功(UPDATE)  

postgres=# update warehouse set warehouse_name = 'ups_new' ,warehouse_created = now() where warehouse_id=1;
UPDATE 1
postgres=# 
mysql> select * from warehouse;
+--------------+----------------+---------------------+
| warehouse_id | warehouse_name | warehouse_created   |
+--------------+----------------+---------------------+
|            1 | ups_new        | 2020-06-04 16:53:01 |
+--------------+----------------+---------------------+
1 row in set (0.00 sec)

mysql> 

postgresql删除数据 mysql中查询成功(DELETE)  

postgres=# delete from warehouse where warehouse_id=1;
DELETE 1
postgres=# 
mysql> select * from warehouse;
Empty set (0.00 sec)

mysql> 

 done

第一次使用外部数据功能,看了一些文档,总的来说不难。吧整个流程整理了一下,以后用到有迹可循,也希望能够帮助到大家。  

  

  

 

 

  

 

 

 

上一篇:C++中参数传递方式


下一篇:ANTVUE项目实战三