Forums PostgreSQL.fr

/* Etablir la connecxion à base de données */
PGconn *ConnectDB(const char* conninfo)
{
	PGconn *conn = NULL;

	// Etablir la connecxion à base de données
	conn = PQconnectdb(conninfo);

	if (PQstatus(conn) != CONNECTION_OK)
    {
        printf("Connecxion à la base de données non établie !");
        CloseConn(conn);
    }

	printf("Connecxion à la base réussie - OK\n");

	return conn;
}
/* Récupérer les résultats de l'exécution de la procédure*/
void fetchResults(PGconn *conn, char query[])
{
	// Pour contenir le nombre des champs retournés
	int nFields;

	// Commencer une transaction
	PGresult *res  = PQexec(conn, "begin");

    if (PQresultStatus(res) != PGRES_COMMAND_OK)
    {
		printf("BEGIN command failed : %s", PQerrorMessage(conn));
        PQclear(res);
        CloseConn(conn);
    }

	printf("Transaction démarrée.....");

	// Initialiser le resultat
    PQclear(res);

    // récupérer le nom du curseur automatique (portal) contenant les résulats
    res = PQexec(conn, query);
    if (PQresultStatus(res) != PGRES_TUPLES_OK)
    {
		printf("Echec récupération nom curseur : %d - %s", PQerrorMessage(conn), PQresultStatus(res));
        PQclear(res);
        CloseConn(conn);
    }

	// récupérer nom curseur retourné
	char* cursorName = NULL;

	// récupérer le nombre des champs
    nFields = PQnfields(res);

	// Préparer l'entête avec le nom des colonnes
	printf("\Affichage nom du cuseur :");
	printf("\n********************************************************************\n");
    for (int i = 0; i < nFields; i++)
        printf("%-30s", PQfname(res, i));
    printf("\n********************************************************************\n");

    // afficher les enregistrements retournés
    for (int i = 0; i < PQntuples(res); i++)
    {
        for (int j = 0; j < nFields; j++)
		{
			cursorName = PQgetvalue(res, i, j);
            printf("%-30s", PQgetvalue(res, i, j));
		}
        printf("\n");
    }

	// récupérer les résultat contenus dans le curseur
	sprintf(query,"FETCH ALL IN \"%s\"", cursorName);
    res = PQexec(conn, query);

    if (PQresultStatus(res) != PGRES_TUPLES_OK)
    {
		printf("FETCH ALL failed : %s", PQerrorMessage(conn));
        PQclear(res);
        CloseConn(conn);
    }

    // récupérer le nombre des champs
    nFields = PQnfields(res);

	// Préparer l'entête avec le nom des colonnes
	printf("\nAffichage contenu du curseur :");
	printf("\n********************************************************************\n");
    for (int i = 0; i < nFields; i++)
        printf("%-30s", PQfname(res, i));
    printf("\n********************************************************************\n");

    // afficher les enregistrements retournés
    for (int i = 0; i < PQntuples(res); i++)
    {
        for (int j = 0; j < nFields; j++)
            printf("%-30s", PQgetvalue(res, i, j));
        printf("\n");
    }
  
    PQclear(res);

    // fermer le curseur
	sprintf(query,"CLOSE \"%s\"", cursorName);
    res = PQexec(conn, query);
    PQclear(res);

    // Fermer la transaction
    res = PQexec(conn, "END");

	// Effecer le resultat
    PQclear(res);

}
int main(int argc, char **argv)
{
	// déclaration et initialisation des variables
	PGconn *pgsqlConn = NULL;
    const char *conninfo = "host = '127.0.0.1' port = 5432 dbname = 'mabase' user = 'postgres' password = '*******'"; 
	
	// paramétrer la requete selon la procédure stockée et ses arguments
	char query[150] = "select theriaque.get_the_result(13183)";
	
	// connexion à la base de données
	pgsqlConn = ConnectDB(conninfo);
	
	// afficher les données
	fetchResults(pgsqlConn, query);

	// quitter
	printf("\nPress ENTER to remove all records & table.....\n");
	CloseConn(pgsqlConn);

	return 0;
}

// connexion à la base de données
pgsqlConn = ConnectDB(conninfo);

// Commencer une transaction
PGresult *res  = PQexec(conn, "BEGIN");

if (PQresultStatus(res) != PGRES_COMMAND_OK)
{
	printf("Echec création transaction : %s", PQerrorMessage(conn));
        PQclear(res);
        CloseConn(conn);
}

// Initialiser le resultat
PQclear(res);

// récupérer nom curseur 
res = PQexec(conn, "SELECT get_the_results ('13183')");
if (PQresultStatus(res) != PGRES_COMMAND_OK)
 {
        printf("Echec récupération nom curseur : %s", PQerrorMessage(conn));
        PQclear(res);
        CloseConn(conn);
    }

	// récupérer nom curseur retourné
	char* curName = PQgetvalue(res, 0, 0);

// Clear result
    PQclear(res);

	// parcourir le curseur
	query = "";
	sprintf(query,"FETCH ALL IN \"%s\"", curName);
    res = PQexec(conn, query);

    if (PQresultStatus(res) != PGRES_TUPLES_OK)
    {
		printf("FETCH ALL failed : %s", PQerrorMessage(conn));
        PQclear(res);
        CloseConn(conn);
    }

    // récupérer le nombre des champs
    nFields = PQnfields(res);

	// Préparer l'entête avec le nom des colonnes
	printf("\nFetch employee record:");
	printf("\n********************************************************************\n");
    for (int i = 0; i < nFields; i++)
        printf("%-30s", PQfname(res, i));
    printf("\n********************************************************************\n");

    // afficher les enregistrements retournés
    for (int i = 0; i < PQntuples(res); i++)
    {
        for (int j = 0; j < nFields; j++)
            printf("%-30s", PQgetvalue(res, i, j));
        printf("\n");
    }
  
    PQclear(res);

    // fermer le curseur
    res = PQexec(conn, "CLOSE emprec");
    PQclear(res);

    // Fermer la transaction
    res = PQexec(conn, "END");

  // Effecer le resultat
    PQclear(res);