#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:

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

◆ 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 79 of file postgres_connection.c.

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

Referenced by process().

◆ pgr_SPI_cursor_open()

Portal pgr_SPI_cursor_open ( SPIPlanPtr SPIplan )

Definition at line 98 of file postgres_connection.c.

                                         {
     Portal SPIportal;
     SPIportal = SPI_cursor_open(NULL, SPIplan, NULL, NULL, true);
     if (SPIportal == NULL) {
         elog(ERROR, "SPI_cursor_open returns NULL");
     }
     return SPIportal;
 }

Referenced by db_get_breaks(), db_get_jobs(), db_get_matrix(), db_get_shipments(), db_get_time_windows(), db_get_vehicles(), get_matrixRows_general(), get_timeMultipliersGeneral(), and pgr_get_pd_orders_general().

◆ pgr_SPI_finish()

void pgr_SPI_finish ( void )

Definition at line 71 of file postgres_connection.c.

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

Referenced by process().

◆ pgr_SPI_prepare()

SPIPlanPtr pgr_SPI_prepare ( char * sql )

Definition at line 88 of file postgres_connection.c.

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