1. 支持简单SQL实现的函数

2. 支持plpgsql实现的函数

3. 支持C实现的函数

4. 支持独立的升降级，与内核升降级无关

5. 可以通过管控面平台，快速发布升级

--为当前数据库绑定方言插件
--1. 自动安装了sql_dialect插件
--2. 自动执行了插件中的sql_dialect_mysql.sql文件，并在__mysql__的schema下有了插件自带函数
--3. 当前会话已可直接使用这些插件函数
alterdatabase xxx set sql_dialect='mysql';

--发送信号，通知其它在线会话优先使用__mysql__的schema下的函数，优先级高于pg_catalog
select pg_reload_conf();

--从pg_extension中可以查询到自动安装的sql_dialect插件
select * from pg_extension where extname='sql_dialect';
      extname      | extowner | extnamespace | extrelocatable | extversion | extconfig | extcondition 
-------------------+----------+--------------+----------------+------------+-----------+--------------
 sql_dialect       |       10 |           11 | f              | 1.0.0      |           | 
(1 row)

--从pg_namespace中可以查到自动创建的schema
select * from pg_namespace where nspname='__dialect_mysql__';
      nspname      | nspowner | nsptimeline | nspacl | permspace | usedspace | nsptype 
-------------------+----------+-------------+--------+-----------+-----------+---------
 __dialect_mysql__ |       10 |           0 |        |        -1 |         0 | i
(1 row)

--从pg_proc中可以查到方言插件自带的函数，它们的选取优先级会高于内核，且不必用户指定schema使用
select proname,nspname,prosrc from pg_proc,pg_namespace n where pronamespace=n.oid and nspname='__dialect_mysql__';
    proname    |      nspname      |                   prosrc                    
---------------+-------------------+---------------------------------------------
 rlike         | __dialect_mysql__ | select $1 ~ $2

--为当前数据库卸载方言插件
drop extension sql_dialect;

-- 确认当前数据库支持的扩展版本
SELECT * FROM pg_extension;
 
-- 升级扩展到最新版本
ALTER EXTENSION extension_name UPDATE;

-- 升级扩展到指定版本
ALTER EXTENSION extension_name UPDATE TO 'x.y.z';

• VOLATILE（默认）： 表示函数返回值在一次表扫描内随时可以改变，例如：random, currval, timeofday等。这也导致这些函数不会被做任何优化。

• STABLE： 表示对相同函数入参，在同一次表扫描里，该函数的返回值不会变，但是在同一会话的不同SQL多次调用时可能会变化。

• IMMUTABLE： 表示该函数在相同入参时总是返回同样的结果。

1. 函数中引用了表，视图等对象，因为当表的数据发生变化的时候，函数的返回值可能发生变化。

2. 函数中引用了STABLE/VOALATILE类型的函数，那么该函数不能定义为IMMUTABLE。

3. 函数中有不下推的因素，因为IMMUTABLE意味着要下推到DN执行，与函数体内部的不下推因素相互冲突。典型场景例如，包含不下推的函数、语法等。

4. 函数中含有聚合运算，但聚合运算的运算需要生成STREAM计划才能完成计算的（部分结果在DN计算，部分结果在CN计算，例如listagg函数等）。
   

• SHIPPABLE：表示该函数可以下推到DN上执行。

• NOT SHIPPABLE（默认）：表示该函数不可以下推到DN上执行。

• 对于IMMUTABLE函数，不管SHIPPABLE如何设置，函数始终可以下推到DN上执行。

• 对于STABLE/VOLATILE函数，当且仅当函数属性是SHIPPABLE的时候，函数才可以下推到DN执行。

• 定义SHIPPABLE属性时需特别慎重，SHIPPABLE意味着整个函数会下推到DN上执行，如果设置不当，会导致结果错误等严重问题。

1. 如果函数内部引用了表，并且表为HASH分布，那么该函数通常不能定义为SHIPPABLE。

2. 函数内部有不可下推的因素，函数，语法等，那么该函数不能定义为SHIPPABLE，可参考语句下推调优。

3. 函数内部的计算过程可能需要跨DN数据，这种情况该函数通常不能定义为SHIPPABLE，例如一些聚合运算等。
   

• CALLED ON NULL INPUT（默认）：表明该函数的某些参数是NULL的时候可以按照正常的方式调用该函数，函数开发者需自己做判空处理。

• RETURNS NULL ON NULL INPUT或STRICT：如果声明了这个参数，当有NULL值参数时该函数不会被执行；而只是自动返回一个NULL结果。

• FENCED模式（默认）：则函数在新fork的进程执行，这样函数的异常不会影响CN或者DN进程。

• NOT FENCED模式：函数的执行在CN或者DN进程中进行；

• 正在开发或者调试的Function使用FENCED模式。开发测试完成，使用NOT FENCED模式执行，减少fork进程以及通信的开销。

• 复杂的操作系统操作，例：打开文件，信号处理，线程处理等操作，使用FENCED模式。否则可能影响GaussDB(DWS)数据库的执行。

• C函数必须是FENCED模式
  

• SECURITY INVOKER或AUTHID CURRENT_USER（默认）：表明该函数将带着调用它的用户的权限执行。该参数可以省略。

• SECURITY DEFINER或AUTHID DEFINER：声明该函数将以创建它的用户的权限执行。

CREATE FUNCTION func_add_sql(integer, integer) RETURNS integer
AS 'select $1 + $2;'
LANGUAGE SQL IMMUTABLE;

postgres=# explain verbose select func_add_sql(a, b) from t1;
                                        QUERY PLAN                                        
------------------------------------------------------------------------------------------
  id |          operation           | E-rows | E-distinct | E-memory | E-width | E-costs 
----+------------------------------+--------+------------+----------+---------+---------
   1 | ->  Streaming (type: GATHER) |      1 |            |          |       8 | 9.01    
   2 |    ->  Seq Scan on public.t1 |      1 |            | 1MB      |       8 | 1.01    

      Targetlist Information (identified by plan id)     
--------------------------------------------------------
   1 --Streaming (type: GATHER)
         Output: ((a + b))
         Node/s: All datanodes (node_group, bucket:16384)
   2 --Seq Scan on public.t1
         Output: (a + b)

1. 函数类型，LANGUAGE必须是SQL类型。

2. 函数易变性，不能是VOLATILE，且易变性不高于函数体内的语句。例如：函数体内调用的函数其易变性为STABLE，则该函数只能是STABLE，不能是IMMUTABLE。从高到底按照IMMUTABLE STABLE VOLATILE排序。

3. 函数strict属性，必须与函数体内包含的函数strict一致。

4. 函数体，函数中必须为简单的单条select语句，不含group by等复杂逻辑。

5. 函数返回值，函数内语句返回类型必须与该函数返回类型一致，且不能是set和record等复杂类型。
   

• 申请的内存要用完及放

• 保护模式必须显示定义为DENCED模式

• 入参和返回值类型严格注意，避免类型不一致或强制转换导致core或结果集问题。
  

CREATE OR REPLACE FUNCTION func_increment_plsql(i integer) RETURNS integer 
SET autoanalyze=off --放这里，不会跨CN进行设置
AS $$  
BEGIN
    SET autoanalyze=off; --放这里，会跨CN进行设置，有通信开销
    RETURN i + 1;
END;
$$ LANGUAGE plpgsql;

• 应该返回timestamptz，而返回了text。结果看似一样，实际无法使用。

• 应该返回timestamptz，而返回了timestamp，丢失了时区，未注意到。

• 不兼容类型的强制转换，导致C函数调用core。

• 调用内存C函数时，需要传入timestamptz类型，却给了timestamp类型，导致时区转换错误。
  

CREATE FUNCTION func_add_sql(integer, integer) RETURNS integer
AS 'select $1 + $2;'
LANGUAGE SQL IMMUTABLE;

CREATE OR REPLACE FUNCTION func_increment_plsql(i integer) RETURNS integer 
AS $$  
BEGIN
    RETURN i + 1;
END;
$$ LANGUAGE plpgsql;

PG_FUNCTION_INFO_V1(rand_seed);
extern "C" Datum rand_seed(PG_FUNCTION_ARGS);
Datum rand_seed(PG_FUNCTION_ARGS)
{
    int128 n = PG_ARGISNULL(0) ? 0 : PG_GETARG_INT64(0);

    int elevel = ERROR;

    if (unlikely(n > PG_UINT64_MAX)) {
        elog(elevel, "Truncated incorrect DECIMAL value");
        n = PG_UINT64_MAX;
    } else if (unlikely(n < PG_INT64_MIN)) {
        elog(elevel, "Truncated incorrect DECIMAL value");
        n = PG_INT64_MIN;
    }
    gs_srandom((unsigned int)n);
    float8 result;
    /* result [0.0 - 1.0) */
    result = (double)gs_random()  ((double)MAX_RANDOM_VALUE + 1);

    PG_RETURN_FLOAT8(result);
}

CREATE OR REPLACE FUNCTION __dialect_mysql__.rand_seed(int) 
returns double precision 
LANGUAGE C 
volatile NOT FENCED
as 
'$libdir/libsql_dialect', 'rand_seed';