達夢-DBLINK數據庫鏈接

aliases: [達夢 DBlink]
tags: [數據庫,DM,Blog]

link:
date: 2022-09-06

說明：DM-Oracle指的是在DM中創建鏈接至Oracle的Dblink。

軟硬件環境

軟件	版本
操作系統	Redhat 7 及以上版本，麒麟V10
DM 數據庫	DM 8.0 及以上版本
CPU 架構	x86、ARM、龍芯、飛騰等國內外主流 CPU

DM-Oracle

環境准備

在DM服務器中完成Dblink環境准備工作：

• 配置Oracle oci客戶端

1. 在Oracle官網根據DM服務器系統下載oci包，instantclient-basic-linux.x64-12.2.0.1.0.zip，解壓后將其中的*so* 文件上傳至服務器/lib64目錄中。

方式二：可以將解壓后的整個目錄上傳，並將該目錄加至系統環境變量LD_LIBRARY_PATH：LD_LIBRARY_PATH="$LD_LIBRARY_PATH:/usr/instantclient_12_2"。

或者添加到 /etc/ld.so.conf.d目錄下指定的配置文件中：
[root@localhost ~]# echo /usr/instantclient_12_2 > /etc/ld.so.conf.d/liboci.conf
[root@localhost ~]# ldconfig

  然后創建軟連接：

$ ln -s libclntsh.so.12.1 libclntsh.so

2. 檢查依賴,並安裝缺失依賴:

$ ldd libclntsh.so.12.1
$ yum install libnsl
# 如果不能聯網，則到官方yum源中下載對應rpm包【libnsl-2.28-36.1.ky10.x86_64.rpm】，上傳后到對應目錄執行離線安裝：
$ rpm -ivh libnsl-2.28-36.1.ky10.x86_64.rpm
$ ldconfig

采用方式二時，需要將不在動態鏈接庫中的文件加入LD_LIBRARY_PATH或/etc/ld.so.conf.d中的配置文件

3. 重啟DM數據庫服務，使其加載 Oracle OCI 驅動

# systemctl restart DmServiceDMSERVER.service

建立DBLink

在DM中建立至Oracle的Dblink：

CREATE OR REPLACE public link ocldblink CONNECT 'ORACLE' WITH testdblink IDENTIFIED BY testdblink USING '10.63.33.45/xircw2';

功能驗證

在Oracle中准備測試表及數據：

DBlink增刪查改

• 通過DBlink查詢
  
• 通過DBLink新增
  
• 通過DBLink修改
  
• 通過DBLink刪除
  

Dblink事務驗證：commit和rollback

1. 會話1：新增數據，未commit
   
2. 會話2：查詢時，無法查到新增的數據
   
3. 會話1：commit后，會話2再查詢即可查到新增數據：

commit; --會話1
SELECT * FROM  YY_T_CRUD@ocldblink; --會話2

4. 執行兩次insert，然后rollback，新增事務已被回滾，無法查詢到新增的數據：
   

存儲過程中使用Dblink

1. 創建存儲過程

CREATE OR replace PROCEDURE p_test(operate IN varchar, code IN varchar, name IN varchar)
AS 
	v_code varchar2(50) :=code;
	v_name varchar2(50) :=name;
BEGIN
	CASE operate
		WHEN 'INSERT' THEN INSERT INTO YY_T_CRUD@ocldblink(code,name) VALUES (v_code,v_name);
		WHEN 'DELETE' THEN DELETE FROM YY_T_CRUD@ocldblink WHERE code = v_code;
		WHEN 'UPDATE' THEN UPDATE YY_T_CRUD@ocldblink SET name = v_name WHERE code = v_code;
		ELSE DBMS_OUTPUT.PUT_LINE ('operate[' ||operate|| '] not support !');
		--ELSE PRINT 'operate[' ||operate|| '] not support !';
	END;
END;
/

2. 存儲過程使用Dblink-新增數據
   
3. 存儲過程使用Dblink-更新數據
   
4. 存儲過程使用Dblink-刪除數據
   

在游標中使用Dblink

1. 在游標中使用Dblink，並直接獲取相關數據：

DECLARE
	CURSOR cur_row IS SELECT CODE,NAME FROM YY_T_CRUD@ocldblink;
BEGIN
	FOR v_row IN cur_row LOOP
		DBMS_OUTPUT.PUT_LINE('測試數據code='|| v_row.CODE || ',name=' || v_row.NAME);
	END LOOP;
END;
/

執行結果：

2. 在游標中使用Dblink，進行刪改操作
   准備數據
   

通過游標進行刪改操作：

DECLARE
	CURSOR cur_row IS SELECT CODE,NAME FROM YY_T_CRUD@ocldblink;
BEGIN
	FOR v_row IN cur_row LOOP
		IF v_row.CODE = 'crud_cursor_update' THEN 
			DBMS_OUTPUT.PUT_LINE('更新數據code='|| v_row.CODE || ',name=' || v_row.NAME);
			UPDATE YY_T_CRUD@ocldblink SET NAME = '游標使用示例_update by cursor' WHERE code = v_row.CODE;
			COMMIT;
		ELSEIF v_row.CODE = 'crud_cursor_delete' THEN 
			DBMS_OUTPUT.PUT_LINE('刪除數據code='|| v_row.CODE || ',name=' || v_row.NAME);
			DELETE FROM YY_T_CRUD@ocldblink WHERE code = v_row.CODE;
			COMMIT;
		ELSE
			DBMS_OUTPUT.PUT_LINE('跳過數據code='|| v_row.CODE || ',name=' || v_row.NAME);
		END IF;
	END LOOP;
END;
/

執行結果：

常見問題

• DM 數據庫使用 ODBC 方式創建 DBLINK 訪問 Oracle 時報錯 “[-70037]:字符串不完整” 或者中文顯示為問號

  方法1： 使用 Oracle OCI 的方式創建 DBLINK。如果數據庫啟動時未加載 Oracle OCI 驅動，需要重啟數據庫加載 Oracle OCI 驅動。

  方法2： 配置與Oracle相同的NLS環境：

  [dmdba@localhost bin]$ vim ~/.bash_profile   ---添加下面內容
  export NLS_LANG="AMERICAN_AMERICA.ZHS16GBK"
  
  [dmdba@localhost bin]$ source ~/.bash_profile
  [dmdba@localhost bin]$ env|grep NLS_LANG
  NLS_LANG=AMERICAN_AMERICA.ZHS16GBK
  

  NLS_LANG 環境變量並生效后，在當前窗口重啟 DM 數據庫服務。

• dm 通過 dblink 查詢 Oracle 表，報錯：字符串截斷

  dm 通過 dblink 查詢 Oracle 表時，需要與 Oracle 字符集保持一致。如果 Oracle 端字符集為 GB，dm 端為 UTF-8，則會報字符串截斷問題。

DM-DM

環境准備及建立DBLink

在DM中完成Dblink環境准備工作：

• 准備兩台安裝了DM數據庫的服務器（A,B）
• A、B服務器開通相關端口，並關閉防火牆
• A、B數據庫修改實例【路徑：dm/dmarch/實例名/】下的dm.ini文件：MAL_INI由0改為1
• A、B分別在實例【路徑：dm/dmarch/實例名/】目錄下新建文件：dmmal.ini文件，內容如下：

[yypoc_inst1] --DM-A
mal_inst_name  = DAMENG
mal_host       = 10.63.34.143
mal_port       = 5237
mal_inst_host       = 10.63.34.143
mal_inst_port       = 5236
[dbtest_inst2] --DM-B
mal_inst_name  = DMSERVER
mal_host       = 10.63.34.173
mal_port       = 5237
mal_inst_host       = 10.63.34.173
mal_inst_port       = 5236

mal_inst_name為dm.ini中的實例名，兩個實例名不能相同
mal_inst_port為dm.ini中的實例端口號
mal_port為對外通訊端口號，自定義配置，不與實例端口相同
A、B服務器的dmmal.ini內容需相同

建立DBlink

在DM-A中建立至DM-B的Dblink：

CREATE OR REPLACE PUBLIC LINK dmdblink CONNECT 'DAMENG' WITH "TEST" IDENTIFIED BY "test12345" USING 'DMSERVER';

功能驗證

在DM-B中准備測試表及數據：

--DM dblink test
CREATE TABLE YY_T_CRUD (
	code varchar2(50),
	name varchar2(50),
	defnum NUMBER,
	memo varchar2(100),
	dr int DEFAULT 0,
	ts char(19) DEFAULT to_char(sysdate, 'yyyy-MM-dd hh24:mi:ss')
);

INSERT INTO YY_T_CRUD VALUES ('crud','增刪查改示例',235.22,'備注',0,to_char(sysdate, 'yyyy-MM-dd hh24:mi:ss'));

將DM-Oracle測試用例中的ocldblink替換為dmdblink后，進行增刪查改、存儲過程、游標測試，結果與DM-Oracle中的保持一致，皆驗證通過。

• DBlink增刪查改
• DBlink的commit和rollback事務
• DBlink的存儲過程使用
• DBlink的游標使用

測試用例如下：

----增刪查改驗證
INSERT INTO YY_T_CRUD@dmdblink VALUES ('crud_CUD','update示例',22235.22,'備注',0,to_char(sysdate, 'yyyy-MM-dd hh24:mi:ss'));
SELECT * FROM YY_T_CRUD@dmdblink;
UPDATE YY_T_CRUD@dmdblink SET memo = '更新by dblink' WHERE code = 'crud_CUD';
SELECT * FROM YY_T_CRUD@dmdblink;
DELETE FROM YY_T_CRUD@dmdblink WHERE code = 'crud_CUD';
SELECT * FROM YY_T_CRUD@dmdblink;

----事務驗證
--會話1
INSERT INTO YY_T_CRUD@dmdblink VALUES ('crud_commit_rollback','事務驗證示例',2.23,'備注',0,to_char(sysdate, 'yyyy-MM-dd hh24:mi:ss'));
SELECT * FROM YY_T_CRUD@dmdblink;
COMMIT;

INSERT INTO YY_T_CRUD@dmdblink VALUES ('crud_commit_rollback2','事務驗證示例2',2,'備注',0,to_char(sysdate, 'yyyy-MM-dd hh24:mi:ss'));
INSERT INTO YY_T_CRUD@dmdblink VALUES ('crud_commit_rollback3','事務驗證示例3',3,'備注',0,to_char(sysdate, 'yyyy-MM-dd hh24:mi:ss'));
SELECT * FROM YY_T_CRUD@dmdblink;
ROLLBACK;

--會話2
SELECT * FROM YY_T_CRUD@dmdblink;

----存儲過程驗證
CREATE OR replace PROCEDURE p_dm_test(operate IN varchar, code IN varchar, name IN varchar)
AS 
	v_code varchar2(50) :=code;
	v_name varchar2(50) :=name;
BEGIN
	CASE operate
		WHEN 'INSERT' THEN INSERT INTO YY_T_CRUD@dmdblink(code,name) VALUES (v_code,v_name);
		WHEN 'DELETE' THEN DELETE FROM YY_T_CRUD@dmdblink WHERE code = v_code;
		WHEN 'UPDATE' THEN UPDATE YY_T_CRUD@dmdblink SET name = v_name WHERE code = v_code;
		ELSE DBMS_OUTPUT.PUT_LINE ('operate[' ||operate|| '] not support !');
		--ELSE PRINT 'operate[' ||operate|| '] not support !';
	END;
END;
/

p_dm_test('INSERT','crud_proc','存儲過程示例');
SELECT * FROM YY_T_CRUD@dmdblink;

p_dm_test('UPDATE','crud_proc','存儲過程示例-update');
SELECT * FROM YY_T_CRUD@dmdblink;

p_dm_test('DELETE','crud_proc','存儲過程示例-update');
SELECT * FROM YY_T_CRUD@dmdblink;
p_dm_test('other','code','name');


----游標驗證
DECLARE
	CURSOR cur_row IS SELECT CODE,NAME FROM YY_T_CRUD@dmdblink;
BEGIN
	FOR v_row IN cur_row LOOP
		DBMS_OUTPUT.PUT_LINE('測試數據code='|| v_row.CODE || ',name=' || v_row.NAME);
	END LOOP;
END;
/

--游標更新數據
p_dm_test('INSERT','crud_cursor','游標使用示例');
p_dm_test('INSERT','crud_cursor_update','游標使用示例');
p_dm_test('INSERT','crud_cursor_delete','游標使用示例');
SELECT * FROM YY_T_CRUD@dmdblink;

DECLARE
	CURSOR cur_row IS SELECT CODE,NAME FROM YY_T_CRUD@dmdblink;
BEGIN
	FOR v_row IN cur_row LOOP
		IF v_row.CODE = 'crud_cursor_update' THEN 
			DBMS_OUTPUT.PUT_LINE('更新數據code='|| v_row.CODE || ',name=' || v_row.NAME);
			UPDATE YY_T_CRUD@dmdblink SET NAME = '游標使用示例_update by cursor' WHERE code = v_row.CODE;
			COMMIT;
		ELSEIF v_row.CODE = 'crud_cursor_delete' THEN 
			DBMS_OUTPUT.PUT_LINE('刪除數據code='|| v_row.CODE || ',name=' || v_row.NAME);
			DELETE FROM YY_T_CRUD@dmdblink WHERE code = v_row.CODE;
			COMMIT;
		ELSE
			DBMS_OUTPUT.PUT_LINE('跳過數據code='|| v_row.CODE || ',name=' || v_row.NAME);
		END IF;
	END LOOP;
END;
/

DM-SQLServer

環境准備及建立DBLink

在DM中完成Dblink環境准備工作：

• 安裝UnixODBC及Freetds（安裝包自行網上下載）：

-- 解壓上傳的介質包
$ tar -zxvf unixODBC-2.3.0.tar.gz
$ tar -zxvf freetds-1.2.21.tar.gz

-- 編譯解壓的安裝包，編譯命令如下，編譯過程省略
$ cd unixODBC-2.3.0/
$ ./configure
$ make && make install

$ cd ../freetds-1.2.21/
$ ./configure
$ make && make install

• 防火牆關閉、數據庫啟動，在DM中測試連接SQLServer

$ /usr/local/bin/tsql -H 10.63.34.173 -p 1433 -U test -P test12345 -D test

• 將驅動拷貝至達夢的bin目錄

$ cp -r /usr/local/lib/*  /data/dm/dmdbms/bin

• 配置Freetds驅動

1. 編寫【freetds.conf】內容如下：

   $ vi /usr/local/etc/freetds.conf
   [mssqlserver]
   	host = 10.63.34.173
   	port = 1433
   	tds version = 7.3
   	client charset = UTF-8
   

2. 測試通過服務器條目進行連接，測試連接成功：

   $ /usr/local/bin/tsql -S mssqlserver -U test -P test12345
   

• 配置ODBC驅動

1. 編寫【odbcinst.ini】內容如下

   $ vi /usr/local/etc/odbcinst.ini
   [FreeTDS]
   Description=ODBC of FreeTDS for MS SQL 2019
   Driver=/usr/local/lib/libtdsodbc.so
   

2. 編寫【odbc.ini】內容如下

   $ vi /usr/local/etc/odbc.ini
   [mssql] 
   Description = SQLServer
   Driver = /usr/local/lib/libtdsodbc.so
   Trace = on
   Server = 10.63.34.173
   Port = 1433
   User = test
   Password = test12345
   Database = test
   TDS_Version = 7.3
   

3. 測試ODBC連接SQL Server數據庫

   $ isql -v mssql test test12345
   

   

建立DBlink

在DM建立至SQLServer的Dblink：

CREATE OR REPLACE PUBLIC LINK "ZXZQ_DM_POC"."TESTMS" connect 'ODBC' with "test" identified by "test12345" using 'mssql';

drop link "ZXZQ_DM_POC"."TESTMS";

功能驗證

在SQLServer中准備測試表及數據：

create table testtable (
id int,
name varchar(10),
sex char(2),
adress varchar(30)
)
go

insert into testtable values(1,'小宇','男','貴州');
insert into testtable values(2,'小麗','女','雲南');
insert into testtable values(3,'小對','男','廣東');

select * from testtable;

將DM-Oracle測試用例中的ocldblink及表替換為TESTMS后，進行增刪查改、存儲過程、游標測試，結果與DM-Oracle中的保持一致，皆驗證通過。

• DBlink增刪查改
• DBlink的commit和rollback事務
• DBlink的存儲過程使用
• DBlink的游標使用

測試用例如下：

----增刪查改驗證
insert into testtable@testms values(4,'小紅','女','深圳');
SELECT * FROM testtable@testms;
update testtable@testms set “adress”=’香港’ where “id”=4;
SELECT * FROM testtable@testms;
delete from testtable@testms where “id”=4;
SELECT * FROM testtable@testms;

----事務驗證
--會話1
insert into testtable@testms values(4,'小紅','女','深圳');
SELECT * FROM testtable@testms;
COMMIT;

insert into testtable@testms values(2,'小麗','女','雲南');
insert into testtable@testms values(3,'小對','男','廣東');
SELECT * FROM testtable@testms;
ROLLBACK;

--會話2
SELECT * FROM testtable@testms;

----存儲過程驗證
CREATE OR replace PROCEDURE p_ss_test(operate IN varchar, code IN INT, name IN varchar, sex IN varchar, adress IN varchar)
AS 
	v_code NUMBER :=code;
	v_name varchar2(50) :=name;
    v_sex varchar2(50) :=sex;
   	v_adress varchar2(50) :=adress;
BEGIN
	CASE operate
		WHEN 'INSERT' THEN INSERT INTO testtable@testms("id","name","sex","adress") VALUES (v_code,v_name,v_sex,v_adress);
		WHEN 'DELETE' THEN DELETE FROM testtable@testms WHERE "id" = v_code;
		WHEN 'UPDATE' THEN UPDATE testtable@testms SET "adress" = v_adress WHERE "id" = v_code;
		ELSE DBMS_OUTPUT.PUT_LINE ('operate[' ||operate|| '] not support !');
		--ELSE PRINT 'operate[' ||operate|| '] not support !';
	END;
END;
/


p_ss_test('INSERT',99,'存儲過程','男','香港');
SELECT * FROM testtable@testms;

p_ss_test('UPDATE',99,'存儲過程','男','武漢');
SELECT * FROM testtable@testms;

p_ss_test('DELETE',99,'存儲過程','男','武漢');
SELECT * FROM testtable@testms;
p_ss_test('other',99,'存儲過程','男','武漢');


----游標驗證
DECLARE
	CURSOR cur_row IS SELECT "id","name","adress" FROM testtable@testms;
BEGIN
	FOR v_row IN cur_row LOOP
		DBMS_OUTPUT.PUT_LINE('測試數據id='|| v_row."id" || ',name=' || v_row."name" || ',adress=' || v_row."adress");
	END LOOP;
END;
/

--游標更新數據
p_ss_test('INSERT',80,'游標','男','香港');
p_ss_test('INSERT',81,'游標','男','香港');
p_ss_test('INSERT',82,'游標','男','香港');
DELETE FROM testtable@testms WHERE "id" IN (80,81,82);
SELECT * FROM testtable@testms;

DECLARE
	CURSOR cur_row IS SELECT "id","name","adress" FROM testtable@testms;
BEGIN
	FOR v_row IN cur_row LOOP
		IF v_row."id" = 81 THEN 
			DBMS_OUTPUT.PUT_LINE('更新數據id='|| v_row."id" || ',name=' || v_row."name" || ',adress=' || v_row."adress");
			UPDATE testtable@testms SET "name" = '游標up' WHERE "id" = v_row."id";
			COMMIT;
		ELSEIF v_row."id" = 82 THEN 
			DBMS_OUTPUT.PUT_LINE('刪除數據id='|| v_row."id" || ',name=' || v_row."name" || ',adress=' || v_row."adress");
			DELETE FROM testtable@testms WHERE "id" = v_row."id";
			COMMIT;
		ELSE
			DBMS_OUTPUT.PUT_LINE('輸出數據id='|| v_row."id" || ',name=' || v_row."name" || ',adress=' || v_row."adress");
		END IF;
	END LOOP;
END;
/

注意事項

• 數據庫連接目前只支持 DM、Oracle 或 ODBC。
• DM-DM 的同構數據庫鏈接不支持 MPP 環境，DM 與異構數據庫的數據庫鏈接支持 MPP 環境。
• 增刪改不支持 INTO 語句。
• 不支持使用游標進行增刪改操作。
• 不支持操作遠程表的復合類型列。
• DBLINK 理論上不支持 LOB 類型列的操作，但支持簡單的增刪改語句中使用常量來對 LOB 類型列進行操作。

參考文獻

https://eco.dameng.com/docs/zh-cn/sql-dev/practice-dblink.html
https://eco.dameng.com/docs/zh-cn/faq/faq-dm-databse.html