postgres_connection.c File Reference

#include "c_common/postgres_connection.h"
#include <string.h>
#include "utils/builtins.h"
#include "catalog/pg_type.h"
#include "c_common/debug_macro.h"

Include dependency graph for postgres_connection.c:

Go to the source code of this file.

Functions
char *	pgr_cstring2char (const char *inStr)
void	pgr_send_error (int errcode)
void	pgr_SPI_connect (void)
Portal	pgr_SPI_cursor_open (SPIPlanPtr SPIplan)
void	pgr_SPI_finish (void)
SPIPlanPtr	pgr_SPI_prepare (char *sql)

Function Documentation

pgr_cstring2char()

char* pgr_cstring2char

(

const char *

inStr

)

Definition at line 53 of file postgres_connection.c.

                                    {
    if (!inStr) return NULL;
 
    char *outStr;
    outStr = palloc(strlen(inStr));
    if (!outStr) return NULL;
 
    memcpy(outStr, inStr, strlen(inStr));
 
    outStr[strlen(inStr)] = '\0';
 
    return outStr;
}

Referenced by pgr_error().

pgr_send_error()

void pgr_send_error

(

int

errcode

)

Definition at line 36 of file postgres_connection.c.

                            {
    switch (errcode) {
        case 1:
            elog(ERROR, "Unexpected point(s) with same pid but different"
                   " edge/fraction/side combination found.");
            break;
        case 2:
            elog(ERROR, "Internal: Unexpected mismatch "
                   "count and sequence number on results");
            break;
        default:
            elog(ERROR, "Unknown exception");
    }
}

pgr_SPI_connect()

void pgr_SPI_connect

(

void

)

Definition at line 82 of file postgres_connection.c.

                      {
#if 0
    PGR_DBG("Connecting to SPI");
#endif
    int SPIcode;
    SPIcode = SPI_connect();
    if (SPIcode  != SPI_OK_CONNECT) {
        elog(ERROR, "Couldn't open a connection to SPI");
    }
}

References PGR_DBG.

Referenced by compute(), compute_trsp(), process(), and process_combinations().

pgr_SPI_cursor_open()

Portal pgr_SPI_cursor_open

(

SPIPlanPtr

SPIplan

)

Definition at line 107 of file postgres_connection.c.

                                        {
#if 0
    PGR_DBG("Opening Portal");
#endif
    Portal SPIportal;
    SPIportal = SPI_cursor_open(NULL, SPIplan, NULL, NULL, true);
    if (SPIportal == NULL) {
        elog(ERROR, "SPI_cursor_open returns NULL");
    }
    return SPIportal;
}

References PGR_DBG.

Referenced by get_combinations_2_columns(), get_edges_5_columns(), get_edges_9_columns(), get_edges_basic(), get_edges_costFlow(), get_edges_flow(), pgr_get_coordinates(), pgr_get_delauny(), pgr_get_matrixRows(), pgr_get_pd_orders_general(), pgr_get_points(), pgr_get_restrictions(), pgr_get_vehicles_general(), and pgr_point_input().

pgr_SPI_finish()

void pgr_SPI_finish

(

void

)

Definition at line 71 of file postgres_connection.c.

                     {
#if 0
    PGR_DBG("Disconnecting SPI");
#endif
    int code = SPI_finish();
    if (code != SPI_OK_FINISH) {  // SPI_ERROR_UNCONNECTED
        elog(ERROR, "There was no connection to SPI");
    }
}

References PGR_DBG.

Referenced by compute(), compute_trsp(), process(), and process_combinations().

pgr_SPI_prepare()

SPIPlanPtr pgr_SPI_prepare

(

char *

sql

)

Definition at line 94 of file postgres_connection.c.

                           {
#if 0
    PGR_DBG("Preparing Plan");
#endif
    SPIPlanPtr SPIplan;
    SPIplan = SPI_prepare(sql, 0, NULL);
    if (SPIplan  == NULL) {
        elog(ERROR, "Couldn't create query plan via SPI: %s", sql);
    }
    return SPIplan;
}

References PGR_DBG.

Referenced by get_combinations_2_columns(), get_edges_5_columns(), get_edges_9_columns(), get_edges_basic(), get_edges_costFlow(), get_edges_flow(), pgr_get_coordinates(), pgr_get_delauny(), pgr_get_matrixRows(), pgr_get_pd_orders_general(), pgr_get_points(), pgr_get_restrictions(), pgr_get_vehicles_general(), and pgr_point_input().