postgres源码学习之简单sql查询

sql查询的主流程

参考postgres的处理流程

由上一节，我们可以看到，当有新的连接通过权限认证之后，将进入等待接收sql语句，并执行sql语句的过程。

读取sql

建立连接后，服务端postgres就等待接收命令

解析sql

解析sql语句函数为pg_parse_query，其调用栈如下：

重写sql

重写sql语句函数为parse_analyze_fixedparams，其调用栈如下：

获得执行计划

获得执行计划函数为pg_plan_queries，调用栈如下：

执行查询操作

查询操作调用顺序为PortalRun–>PortRunSelect–>ExecutorRun–>standard_ExecutorRun–>ExecutePlan

结果返回

在ExecutePlan中，会将结果集返回给客户端，调用栈如下：

涉及到查询结果返回的，会调用到printtup函数。
其函数主要内容如下：

/** send the attributes of this tuple*/for (i = 0; i < natts; ++i){PrinttupAttrInfo *thisState = myState->myinfo + i;Datum		attr = slot->tts_values[i];if (slot->tts_isnull[i]){pq_sendint32(buf, -1);continue;}if (thisState->typisvarlena)VALGRIND_CHECK_MEM_IS_DEFINED(DatumGetPointer(attr),VARSIZE_ANY(attr));if (thisState->format == 0){/* Text output */char	   *outputstr;outputstr = OutputFunctionCall(&thisState->finfo, attr);pq_sendcountedtext(buf, outputstr, strlen(outputstr));}else{/* Binary output */bytea	   *outputbytes;outputbytes = SendFunctionCall(&thisState->finfo, attr);pq_sendint32(buf, VARSIZE(outputbytes) - VARHDRSZ);pq_sendbytes(buf, VARDATA(outputbytes),VARSIZE(outputbytes) - VARHDRSZ);}}

其输出形式和之前介绍的Mysql Resultset 解析记录中介绍的结果集存储有着相似的地方。