Processus général de requête pour PostgreSQL

Le client passe parpgLe processus approximatif de requête du serveur est le suivant

Un.、 Établir une connexion

Le client doit d'abord se connecterpgServeur,Après avoir établi une connexion avec le clientforkUn sous - processus traite les demandes des clients suivants,Le serveur attend ensuite la connexion du client suivant.

2.、Envoyer la demande

Le client envoie les données demandées àpgServeur,pgDemande de lecture du sous - processus.

• Le client envoie la demande
  Comme la ligne de commande,Lire l'entrée de l'utilisateur,Envoyer au serveur
  src/bin/psql/mainloop.c

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

• Le serveur reçoit la demande

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

Trois、Analyse

Prenons l'exemple d'une simple requête.Le serveur a reçu une chaîne, Il faut analyser et comprendre ces données pour effectuer .

src/backend/tcop/postgres.c

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

Analyse lexicale et grammaticale , Construire un arbre syntaxique original .

Quatre、Optimisation

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);

     ..
}

Convertit l'Arbre syntaxique Original en un arbre de requête , Et optimiser et réécrire l'arbre de requête , Augmenter la vitesse d'exécution .

Cinq、Mise en œuvre

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

Six、Retour aux résultats

La fonction spécifique est également trouvée pour