v953版本创建dblink拉取数据

步骤概览

1.部署透明网关

2.配置透明网关

3.启动透明网关

4.配置透明网关目标库信息

5.创建dblink

6.使用dblink

7.重启透明网关

8.数据导入

9.数据校验

具体步骤

1. 部署透明网关

[root@gbase3 gbase]# tar -xvf GBase8a_MPP_Cluster_Gateway_8.5.1.2_build4.23.tar

[root@gbase3 gbase]# chmod -R +x GBase8a_MPP_Cluster_Gateway_8.5.1.2_build4.23

[root@gbase3 gbase]# ll

1. 配置透明网关

系统参数配置文件:[安装目录]/conf/conf.properties。用户一般采用默 认配置即可。 

内容如下: 

需修改gbase.gt.load.data.type=0

8a 集群数据源配置文件:[安装目 录]/conf/datedSource/gc_link.properties 

内容如下: 每个库都需要新建如下配置文件，其中文件名gc_link.properties与创建dblink sql中存在对应关系，如下

gc_link.properties

gbase> create database link testdba134  connect to '' identified by '' using 'gc_link';

1. 启动透明网关

[root@gbase3 GBase8a_MPP_Cluster_Gateway_8.5.1.2_build4.23]# sh gbaseGatewayServer.sh  start

[root@gbase3 GBase8a_MPP_Cluster_Gateway_8.5.1.2_build4.23]# ps -ef | grep gateway

1. 配置透明网关目标库信息

网关为 GBase8a_MPP_Cluster_Gateway_8.5.1.2_build4.8 及以上版本 在[安装目录]/conf/gcluster/gbase8a_gcluster.properties 中配置 

[gbase@gbase3 config]$ cp gbase_8a_gcluster.cnf gbase_8a_gcluster.cnf_bak

[gbase@gbase3 config]$ vi gbase_8a_gcluster.cnf

[gbase@gbase3 dataSource]$ cat /data/192.168.138.136/gcluster/config/gbase_8a_gcluster.cnf

注：在gc层gbase_8a_gcluster.cnf配置文件中[gbased]中添加如下参数

gbase_dblink_gateway_ip = 192.168.138.136 #步骤4中目标库ip

gbase_dblink_gateway_port = 9898 #步骤1种透明网关端口号

gcluster_dblink_direct_data_exchange = 0

1. 创建dblink

gbase> create database link testdba134  connect to '' identified by '' using 'gc_link';

gbase> select * from gbase.db_links;

1. 使用dblink

gbase> use testdba;

gbase> select * from t1@testdba134;

gbase> use testdbb;

gbase> select * from t2@testdbb134;

注：需要在目标库中创建源库相同表名的库，且需要先use进入到对应库中才可以使用dblink。

1. 重启透明网关

注：修改步骤2、4后需重启透明网关，重启方式如下：

[gbase@gbase3 GBase8a_MPP_Cluster_Gateway_8.5.1.2_build4.23]$  ps -ef | grep gateway

[gbase@gbase3 GBase8a_MPP_Cluster_Gateway_8.5.1.2_build4.23]$ kill -9 6397

[gbase@gbase3 GBase8a_MPP_Cluster_Gateway_8.5.1.2_build4.23]$ sh gbaseGatewayServer.sh start

1. 数据导入

使用gcdump将源库表结构导出，在目标库中将表创建。

[gbase@gbase3 ~]$ gccli -ugbase -pgbase

gbase> use testdba;

gbase> insert into t1 select * from t1@testdba134;

gbase> select * from testdba.t1;

1. 数据校验

源端

[gbase@gbase1 gcinstall]$ gccli -ugbase -pgbase

gbase> desc vc1.testdba.t;

gbase> select sum(crc32(c1)+crc32(c2)+……) from vc1.testdb.t;

目的端

[gbase@gbase1 gcinstall]$ gccli -ugbase -pgbase

gbase> desc vc2.testdba.t;

gbase> select sum(crc32(c1)+crc32(c2)+……) from vc2.testdb.t;

核验sum值，sum值一致，源数据一致。