軟硬體環境 軟體 版本 操作系統 Redhat 7 及以上版本,麒麟V10 DM 資料庫 DM 8.0 及以上版本 CPU 架構 x86、ARM、龍芯、飛騰等國內外主流 CPU DM-Oracle 環境準備 在DM伺服器中完成Dblink環境準備工作。 配置Oracle oci客戶端 在Oracle ...
目錄
軟硬體環境
軟體 | 版本 |
---|---|
操作系統 | Redhat 7 及以上版本,麒麟V10 |
DM 資料庫 | DM 8.0 及以上版本 |
CPU 架構 | x86、ARM、龍芯、飛騰等國內外主流 CPU |
DM-Oracle
環境準備
在DM伺服器中完成Dblink環境準備工作。
- 在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
- 檢查依賴,並安裝缺失依賴:
# 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中的配置文件
- 重啟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事務驗證:commit和rollback
commit; --會話1
SELECT * FROM YY_T_CRUD@ocldblink; --會話2
存儲過程中使用Dblink
- 創建存儲過程
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;
/
在游標中使用Dblink
- 在游標中使用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;
/
通過游標進行刪改操作:
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環境準備工作。
[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中的保持一致,皆驗證通過。
測試用例如下:
----增刪查改驗證
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環境準備工作。
-- 解壓上傳的介質包
#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
/usr/local/bin/tsql -H 10.63.34.173 -p 1433 -U test -P test12345 -D test
$ cp -r /usr/local/lib/* /data/dm/dmdbms/bin
- 動編寫【freetds.conf】內容如下:
#vi /usr/local/etc/freetds.conf
[mssqlserver]
host = 10.63.34.173
port = 1433
tds version = 7.3
client charset = UTF-8
- 測試通過伺服器條目進行連接,測試連接成功:
#/usr/local/bin/tsql -S mssqlserver -U test -P test12345
- 編寫【odbcinst.ini】內容如下
# vi /usr/local/etc/odbcinst.ini
[FreeTDS]
Description=ODBC of FreeTDS for MS SQL 2019
Driver=/usr/local/lib/libtdsodbc.so
- 編寫【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
- 測試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中的保持一致,皆驗證通過。
測試用例如下:
----增刪查改驗證
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