#include <stdio.h>
#include <stdlib.h>
#include <libpq-fe.h>

/*Objeto de conexão*/
PGconn *conn = NULL;

/*Ponteiro de resultado*/
PGresult *result;

/*Arquivo que irá conter o fluxo de saída*/
FILE *output_stream;

/*Estrutura de opções*/
PQprintOpt print_options;

int main()
{
    /*realiza a conexão*/
    conn = PQconnectdb("host=localhost dbname=TESTE");
    
    if(PQstatus(conn) == CONNECTION_OK)
    {
        printf("Conexão com efetuada com sucesso. ");
    }
    else
    {
        printf("Falha na conexão. Erro: %s", PQerrorMessage(conn));
        PQfinish(conn);
        return -1;
    }

    /*Executa o comando*/
    result = PQexec(conn, "SELECT * FROM contatos");
    
    if(!result)
    {
        printf("Erro executando comando. ");
    }
    else
    {
        switch(PQresultStatus(result))
        {
            case PGRES_EMPTY_QUERY:
                printf("Nada aconteceu. ");
                break;
            case PGRES_TUPLES_OK:
                printf("A query retornou %d linhas. ", PQntuples(result));
                break;
            case PGRES_FATAL_ERROR:
                printf("Error in query: %s ", PQresultErrorMessage(result));
                break;
            case PGRES_COMMAND_OK:
                printf("%s linhas afetadas. ", PQcmdTuples(result));
                break;
            default:
                printf("Algum outro resultado ocorreu. ");
                break;
        }
        
        /*Define o nosso arquivo de saída*/
        output_stream = fopen("/dev/tty", "w");

        if(output_stream == NULL)
            printf("Erro abrindo o arquivo. ");
        else
        {
            
            memset(&print_options, '\0', sizeof(print_options));
            
            print_options.header = 1;
            print_options.align = 1;
            print_options.html3 = 0;
            print_options.fieldSep = "|";
            print_options.fieldName = NULL;
            
            PQprint(output_stream, result, &print_options);
        }
                
        /*Libera o nosso objeto*/
        PQclear(result);
    }

  
    /*Verifica se a conexão está aberta e a encerra*/
    if(conn != NULL)
        PQfinish(conn);
}