GaussDB(DWS)遷移：一種執行高效的TereData的marco遷移方案-有解無憂

摘要：提供一種執行高效的TereData的marco遷移方案，

本文分享自華為云社區《GaussDB(DWS)遷移 - teredata兼容 -- macro兼容 # 【玩轉PB級數倉GaussDB(DWS)】》，作者：譡里個檔，

Teradata的宏是一組可以接受引數的SQL陳述句，通過呼叫宏名稱來執行一段SQL陳述句，執行上類似于DWS的存盤程序，在遷移的時候也建議使用DWS的函式替換TeraData的宏，

測驗表定義

CREATE SCHEMA test;
CREATE TABLE test.salary(
 employeeno integer,
 netpay integer
)
WITH (orientation=row, compression=no)
DISTRIBUTE BY ROUNDROBIN;
INSERT INTO test.salary VALUES (1, 1);

TereData宏定義

CREATE MACRO get_emp_salary(employeeno integer) AS ( 
 SELECT 
 employeeno, 
 netpay 
 FROM test.salary 
 WHERE employeeno = :employeeno; 
);

DWS遷移的函式定義

CREATE OR REPLACE FUNCTION public.get_emp_salary(
 employeeno integer,
 OUT employeeno integer,
 OUT netpay integer
)
 RETURNS SETOF record
 LANGUAGE sql
NOT SHIPPABLE STABLE
AS $function$
 SELECT 
 employeeno, 
 netpay 
 FROM test.salary 
 WHERE employeeno = $1; 
$function$;

Note：函式定義中屬性要如上定義，需要明確的是

1) 必須是STABLE

2) 函式語言必須是SQL語言

3) 查詢陳述句的回傳值型別和函式的出參型別一致

4) 必須是NOT SHIPPABLE(默認就是NOT SHIPPABLE屬性)

5) 不能定義為STRICT屬性(默認就是非STRICT屬性)

6) 不能定義配置引數(默認就是非STRICT屬性)

7) 函式的權限屬性為SECURITY INVOKER(默認就是SECURITY INVOKER屬性)

這樣定義的好處是就是當函式體中是簡單的單查詢陳述句時，函式呼叫可以直接優化為對函式體內的SQL陳述句的呼叫，執行上避開FuctionSCan的換成層以及SQL不下推的問題，執行上更加高效(具體見下面的case)

陳述句執行效果

postgres=# EXPLAIN VERBOSE SELECT * FROM get_emp_salary(1);
                                              QUERY PLAN
------------------------------------------------------------------------------------------------------
  id |                      operation                      | E-rows | E-distinct | E-width | E-costs
 ----+-----------------------------------------------------+--------+------------+---------+---------
 1 | -> Data Node Scan on salary "_REMOTE_TABLE_QUERY_" | 1 | | 8 | 0.00
 Targetlist Information (identified by plan id)
 ------------------------------------------------------------------------------------------
 1 --Data Node Scan on salary "_REMOTE_TABLE_QUERY_"
         Output: salary.employeeno, salary.netpay
         Node/s: All datanodes
         Remote query: SELECT employeeno, netpay FROM ONLY test.salary WHERE employeeno = 1
(10 rows)

點擊關注，第一時間了解華為云新鮮技術~

轉載請註明出處，本文鏈接：https://www.uj5u.com/shujuku/543826.html

標籤：其他

上一篇：Hive 在作業中的調優總結

下一篇：SQL執行慢的原因分析以及調優手段