postgresql之整體查詢大致過程

客戶端通過pg服務器查詢的大致過程如下

一、 建立連接

客戶端首先需要連接上pg服務器，服務器在和客戶端建立連接後fork一個子進程處理後續客戶端的請求，服務器然後等待下一個客戶端的連接。

二、發送請求

客戶端發送請求數據給pg服務器，pg子進程讀取請求。

• 客戶端發送請求
  比如命令行，讀取用戶輸入，發送給服務器
  src/bin/psql/mainloop.c

int
MainLoop(FILE *source)
{
    
    ...
	SendQuery(query_buf->data);
    ...
}

• 服務器接收請求

void
PostgresMain(int argc, char *argv[],
			 const char *dbname,
			 const char *username)
{
    
    ...
    for (;;)
	{
    
    	...
        firstchar = ReadCommand(&input_message);    
    	...
    }
}

三、解析

以簡單查詢為例子。服務器接收到的是一串字符串，需要解析理解這個數據才能執行。

src/backend/tcop/postgres.c

static void
exec_simple_query(const char *query_string)
{
    
    ...
    parsetree_list = pg_parse_query(query_string);
    ...
}

通過詞法以及語法解析，構建一個原始的語法樹。

四、優化

static void
exec_simple_query(const char *query_string)
{
    
    ...
    querytree_list = pg_analyze_and_rewrite(parsetree, query_string,
                                            NULL, 0, NULL);

    plantree_list = pg_plan_queries(querytree_list, query_string,
                                    CURSOR_OPT_PARALLEL_OK, NULL);

     ..
}

將原始的語法樹轉化為一個查詢樹，並且對查詢樹進行優化以及重寫，提昇執行速度。

五、執行

static void
exec_simple_query(const char *query_string)
{
    
    ...
    (void) PortalRun(portal,
                     FETCH_ALL,
                     true,	/* always top level */
                     true,
                     receiver,
                     receiver,
                     &qc);
    ...
}

六、返回結果

具體函數還為找到