本文主要是介绍Vastbase编程利器:PL/pgSQL原理简介,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
PL/pgSQL是Vastbase提供的一种过程语言,在普通SQL语句的使用上增加了编程语言的特点,可以用于创建函数、存储过程、触发器过程以及创建匿名块等。
本文介绍Vastbase中PL/pgSQL的执行流程,包括PL/pgSQL的编译与运行。
1、编译
PL/pgSQL的编译部分核心是解释出可以被内核识别的变量、命名空间和语句节点链表。
1.1 编译上下文
typedef struct PLpgSQL_compile_context {struct PLpgSQL_datum** plpgsql_Datums;struct PLpgSQL_function* plpgsql_curr_compile;struct PLpgSQL_nsitem* ns_top;
}
PLpgSQL_compile_context结构用来保存编译期间的上下文信息,其核心成员是plpgsql_Datums、ns_top和plpgsql_curr_compile。
- plpgsql_Datums:保存识别出的变量,是一个数组
- ns_top:保存识别出的命名空间,是一个链表
- plpgsql_curr_compile:保存识别出的语句节点链表
1.2 变量数组
typedef struct PLpgSQL_datum { /* Generic datum array item */int dtype; /* 变量类型 */int dno; /* 变量在变量数组的下标,即变量是变量数组的第几个元素 */
} PLpgSQL_datum;
PL/pgSQL支持多种类型的变量,包括普通的变量、表达式、复合类型和数组类型等。不同的变量类型用相应的结构表示,例如:普通变量使用PLpgSQL_var表示,表达式使用PLpgSQL_expr表示等。
Vastbase使用面向对象的思想,设计PL/pgSQL的变量,PLpgSQL_datum结构表示变量的抽象父类,共有4个结构体成员,PLpgSQL_var和PLpgSQL_expr等表示子类,子类结构的前4个成员与PLpgSQL_datum结构保持一致。
PL/pgSQL变量的来源主要有:
- 函数的入参
- 声明部分声明的变量
- 内置变量,例如found变量和游标变量等
1.3 命名空间链表
typedef struct PLpgSQL_nsitem { /* Item in the compilers namespace tree */int itemtype; /* 命名空间类型 */int itemno; /* 命名空间关联的变量在变量数组的下标 */struct PLpgSQL_nsitem* prev; /* 指向上一个命名空间 */char name[FLEXIBLE_ARRAY_MEMBER]; /* 命名空间字符串 */
} PLpgSQL_nsitem;
PL/pgSQL里,命名空间(namespace)表示变量或标签的名称。主要有以下类型的命名空间:
PL/pgSQL在运行语句时,通过标识符查找命名空间链表,若查找到命名空间,则根据命名空间的itemno在变量数组里获取变量,进行相应的操作。
1.4 语法解析
Vastbase的PL/pgSQL有独立的词法分析和语法分析器。PL/pgSQL主要有两种大类的块:声明块和语句块。
声明块
声明块是以DECLARE关键字作为开始标记,以BEGIN关键字作为结束标记的语句块。
在声明块内可以声明变量和定义类型。新定义的类型会被记录到系统表元信息中。声明的变量会被记录到变量数组和命名空间链表里,对于复合类型的变量,PL/pgSQL会对其进行展开,即会创建${变量名}.${属性}这样的变量和命名空间。
语句块
语句块是指以BEGIN关键字作为开始标记,以END关键字作为结束标记的语句块。
语句块内可以嵌套新的声明块和语句块。内层语句块可以访问外层声明块的类型和变量,反之不允许。
语句块以分号作为语句分隔符,每个语句都会被解析为不同类型的语句节点。
typedef struct { /* One EXCEPTION ... WHEN clause */PLpgSQL_condition* conditions;List* action; /* List of statements */
} PLpgSQL_exception;typedef struct PLpgSQL_stmt_block {List* body; /* List of statements */PLpgSQL_exception_block* exceptions;
} PLpgSQL_stmt_block;
PL/pgSQL使用PLpgSQL_stmt_block结构表示经过语法解析后的PL/pgSQL语句块,PLpgSQL_stmt_block结构有两个核心的成员,分别是body和exceptions。
body是语句块内正常运行的语句节点链表。
exceptions是PLpgSQL_exception类型变量链表。
当语句节点链表内的语句发生异常时,进入exceptions成员表示的异常处理流程。PLpgSQL_exception结构里,conditions成员表示该异常处理块的异常类型,action成员就是该类型异常的处理语句节点链表,当运行时发生了匹配conditions的异常,则执行该异常的action进行异常处理。
PL/pgSQL支持的语句类型比较丰富,以下是一些常用的语句类型归类:
- 嵌套语句块:PLPGSQL_STMT_BLOCK
- 赋值语句:PLPGSQL_STMT_ASSIGN
- 条件分支:PLPGSQL_STMT_IF/PLPGSQL_STMT_GOTO/PLPGSQL_STMT_CASE
- 循环控制:PLPGSQL_STMT_LOOP/PLPGSQL_STMT_WHILE/PLPGSQL_STMT_FORI/PLPGSQL_STMT_FORS/PLPGSQL_STMT_FORC/PLPGSQL_STMT_FOREACH_A/PLPGSQL_STMT_EXIT
- 返回语句:PLPGSQL_STMT_RETURN/PLPGSQL_STMT_RETURN_NEXT/PLPGSQL_STMT_RETURN_QUERY
- 打印输出:PLPGSQL_STMT_RAISE
- 执行语句:PLPGSQL_STMT_EXECSQL/PLPGSQL_STMT_DYNEXECUTE/PLPGSQL_STMT_DYNFORS/PLPGSQL_STMT_PERFORM
- 游标相关:PLPGSQL_STMT_OPEN/PLPGSQL_STMT_FETCH/PLPGSQL_STMT_CLOSE
- 事务控制:PLPGSQL_STMT_COMMIT/PLPGSQL_STMT_ROLLBACK/PLPGSQL_STMT_SAVEPOINT
- 其他:PLPGSQL_STMT_GETDIAG/PLPGSQL_STMT_NULL/PLPGSQL_STMT_SIGNAL/PLPGSQL_STMT_RESIGNAL
1.5 编译缓存
PL/pgSQL的编译是一个耗时操作,每次运行前都重新编译对性能来说影响非常大。为解决这个问题,对于使用PL/pgSQL定义的函数/存储过程,Vastbase 把编译结果缓存在会话的内存中。在会话运行期间,如果函数/存储过程的定义没有发生变化,则只需要编译一次,后续函数/存储过程的运行会从缓存获取编译结果。
2、运行
PL/pgSQL运行依赖SPI(Server Programming Interface)机制,把需要运行的SQL语句发送到内核模块中,内核模块通过预定义的钩子函数对语句中引用的变量进行解析处理。
2.1 SPI机制
SPI机制提供了一系列接口连接并访问数据库内核,
PLPGSQL_STMT_EXECSQL语句节点的工作流程大致如下图:
- 流程说明
- SPI_connect:PL/pgSQL语句块执行前,连接到内核服务端,整个语句块的执行只需要连接一次
- SPI_prepare_params:发送待执行的sql语句到服务端,获取执行计划
- setup_param_list:设置语句的参数
- SPI_execute_plan_with_paramlist:发送参数到服务的,执行语句
- SPI_finish:断开与内核服务端的连接,释放资源
2.2 执行语句块
PL/pgSQL经过编译后,编译上下文保存了变量数组、命名空间链表和语句节点链表。如下图,执行语句实际上就是遍历语句节点链表,根据不同的语句节点类型,调用不同的处理函数。
2.3 异常处理
如下图所示,异常处理块实际上是通过PG_TRY/PG_CATCH/PG_END_TRY实现。
当调用exec_stmt_block执行的语句块时,如果PLpgSQL_stmt_block的exceptions成员不为空,即定义了异常处理块,则使用PG_TRY/PG_CATCH/PG_END_TRY异常处理工具进行exec_stmts(block→body)的调动,捕获异常后,调用exec_stmts(exception→action)进行异常处理。
2.4 参数处理
PL/pgSQL内允许语句内引用声明块内声明的变量或函数入参,代码如下:
CREATE TABLE t_test(id INT);
DECLARE id INT;
BEGINid := 1;INSERT INTO t_test values (id);
END;
/
第6行的INSERT语句会被语法解析器解析成PLPGSQL_STMT_EXECSQL语句节点,PL/pgSQL会把整个语句原封不动发送到内核服务端中并生成计划,那么内核的语义分析模块就需要识别出括号内的id标识符是一个参数。
Vastbase通过钩子函数实现参数识别和值替换,代码如下:
struct ParseState {PreParseColumnRefHook p_pre_columnref_hook;PostParseColumnRefHook p_post_columnref_hook;ParseParamRefHook p_paramref_hook;
}
typedef struct ParamListInfoData {ParamFetchHook paramFetch; /* parameter fetch hook */
} ParamListInfoData;
通过设置ParseState结构p_post_columnref_hook钩子,内核在进行对写入字段进行语义分析时,会调用钩子函数,该钩子函数对命名空间链表进行查找,如果查找到则构造Param节点记录变量在PL/pgSQL变量里数组中的位置和类型,并挂载Query树上。
通过设置ParamListInfoData结构paramFetch钩子,内核在生成执行计划的预处理表达式阶段,调用该钩子,根据Param结构信息拿到该参数的在变量值,并把该Param结构替换为Const结构。
通过两个钩子函数,使得PL/pgSQL执行sql语句时,可以引用声明块内声明的变量或函数入参。
3、总结
通过上述介绍可以看出,Vastbase的PL/pgSQL模块与常规的编程语言类似,均支持赋值、条件分支、循环等多种语句类型,通过PL/pgSQL模块,可以在Vastbase服务端编写较为复杂的逻辑。其生命周期分为编译和运行两个阶段,使用PL/pgSQL编写函数/存储过程时,还通过缓存编译结果,使得函数调用变得更加高效。
这篇关于Vastbase编程利器:PL/pgSQL原理简介的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!