/*
 * $Id: db_res.c 2470 2007-07-18 09:57:30Z henningw $
 *
 * POSTGRES module, portions of this code were templated using
 * the mysql module, thus it's similarity.
 *
 * Copyright (C) 2003 August.Net Services, LLC
 * Copyright (C) 2006 Norman Brandinger
 *
 * This file is part of openser, a free SIP server.
 *
 * openser is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version
 *
 * openser is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License 
 * along with this program; if not, write to the Free Software 
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 *
 * ---
 *
 * History
 * -------
 * 2003-04-06 initial code written (Greg Fausak/Andy Fullford)
 *
 * 2006-07-26 added BPCHAROID as a valid type for DB_STRING conversions
 *            this removes the "unknown type 1042" log messages (norm)
 *
 * 2006-10-27 Added fetch support (norm)
 *            Removed dependency on aug_* memory routines (norm)
 *            Added connection pooling support (norm)
 *            Standardized API routines to pg_* names (norm)
 *
 */

#include <stdlib.h>
#include <string.h>
#include "../../db/db_id.h"
#include "../../db/db_res.h"
#include "../../db/db_con.h"
#include "../../dprint.h"
#include "../../mem/mem.h"
#include "dbase.h"
#include "defs.h"
#include "pg_con.h"
#include "pg_type.h"

/**
 * Create a new result structure and initialize it
 * The elements of the structure can be accessed using the following helpers:
 *
 * RES_NAMES(r)		((r)->col.names)	Column Names
 * RES_TYPES(r)		((r)->col.types)	Column Data Types
 * RES_COL_N(r)		((r)->col.n)		Number of Columns
 * RES_ROWS(r)		((r)->rows)		Row Structure
 * RES_ROW_N(r)		((r)->n)		Number of Rows in the current Fetch
 * RES_LAST_ROW(r)	((r)->last_row)		Last Row Processed
 * RES_NUM_ROWS(r)	((r)->res_rows)		Number of total Rows in the Query
 *
 */
db_res_t* pg_new_result(void)
{
	db_res_t* _res = NULL;

	_res = (db_res_t*)pkg_malloc(sizeof(db_res_t));
	LOG(L_DBG, "PG[new_result]: %p=pkg_malloc(%lu) _res\n", _res, (unsigned long)sizeof(db_res_t));
        if (!_res) {
                LOG(L_ERR, "PG[new_result]: Failed to allocate %lu bytes for result structure\n", (unsigned long)sizeof(db_res_t));
                return NULL;
        }
	
	memset(_res, 0, sizeof(db_res_t));

	return _res;
}

/**
 * Fill the result structure with data from the query
 */
int pg_convert_result(db_con_t* _con, db_res_t* _res)
{

#ifdef PARANOID
        if (!_con)  {
                LOG(L_ERR, "PG[convert_result]: db_con_t parameter cannot be NULL\n");
                return -1;
        }

        if (!_res) {
                LOG(L_ERR, "PG[convert_result]: db_res_t parameter cannot be NULL\n");
                return -1;
        }
#endif

        if (pg_get_columns(_con, _res) < 0) {
                LOG(L_ERR, "PG[convert_result]: Error while getting column names\n");
                return -2;
        }

        if (pg_convert_rows(_con, _res, 0, PQntuples(CON_RESULT(_con))) < 0) {
                LOG(L_ERR, "PG[convert_result]: Error while converting rows\n");
                pg_free_columns(_res);
                return -3;
        }

        return 0;
}

/**
 * Get and convert columns from a result set
 */
int pg_get_columns(db_con_t* _con, db_res_t* _res)
{
	int cols, col, len;

#ifdef PARANOID
        if (!_con)  {
                LOG(L_ERR, "PG[get_columns]: db_con_t parameter cannot be NULL\n");
                return -1;
        }

        if (!_res) {
                LOG(L_ERR, "PG[get_columns]: db_res_t parameter cannot be NULL\n");
                return -1;
        }
#endif

        /* PQntuples: Returns the number of rows (tuples) in the query result. */
	RES_NUM_ROWS(_res) = PQntuples(CON_RESULT(_con));


	/* PQnfields: Returns the number of columns (fields) in each row of the query result. */
	cols = PQnfields(CON_RESULT(_con));

        if (!cols) {
                LOG(L_DBG, "PG[get_columns]: No columns returned from the query\n");
                return -2;
	} else {
		LOG(L_DBG, "PG[get_columns]: %d column(s) returned from the query\n", cols);
        }

	/* Allocate storage to hold a pointer to each column name */
        RES_NAMES(_res) = (db_key_t*)pkg_malloc(sizeof(db_key_t) * cols);
	LOG(L_DBG, "PG[get_columns]: %p=pkg_malloc(%lu) RES_NAMES\n", RES_NAMES(_res), (unsigned long)(sizeof(db_key_t) * cols));
	if (!RES_NAMES(_res)) {
                LOG(L_ERR, "PG[get_columns]: Failed to allocate %lu bytes for column names\n", (unsigned long)(sizeof(db_key_t) * cols));
                return -3;
        }

	/* Allocate storage to hold the type of each column */
        RES_TYPES(_res) = (db_type_t*)pkg_malloc(sizeof(db_type_t) * cols);
	LOG(L_DBG, "PG[get_columns]: %p=pkg_malloc(%lu) RES_TYPES\n", RES_TYPES(_res), (unsigned long)(sizeof(db_type_t) * cols));
        if (!RES_TYPES(_res)) {
                LOG(L_ERR, "PG[get_columns]: Failed to allocate %lu bytes for column types\n", (unsigned long)(sizeof(db_type_t) * cols));
		/* Free previously allocated storage that was to hold column names */
		LOG(L_DBG, "PG[get_columns]: %p=pkg_free() RES_NAMES\n", RES_NAMES(_res));
		pkg_free(RES_NAMES(_res));
                return -4;
        }

	/* Save number of columns in the result structure */
        RES_COL_N(_res) = cols;

	/* 
	 * For each column both the name and the OID number of the data type are saved.
	 */
	for(col = 0; col < cols; col++) {
		int ft;

		/*
		 * PQfname: Returns the column name associated with the given column number.
		 * Column numbers start at 0. 
		 * The caller should not free the result directly. 
		 * It will be freed when the associated PGresult handle is passed to PQclear.
		 * NULL is returned if the column number is out of range.
		 *
		 */
		len = strlen(PQfname(CON_RESULT(_con),col));
		RES_NAMES(_res)[col] = pkg_malloc(len+1);
		LOG(L_DBG, "PG[get_columns]: %p=pkg_malloc(%d) RES_NAMES[%d]\n", RES_NAMES(_res)[col], len+1, col);
		if (! RES_NAMES(_res)[col]) {
			LOG(L_ERR, "PG[get_columns]: Failed to allocate %d bytes to hold column name\n", len+1);
			return -1;
		}
		memset((char *)RES_NAMES(_res)[col], 0, len+1);
		strncpy((char *)RES_NAMES(_res)[col], PQfname(CON_RESULT(_con),col), len); 

		LOG(L_DBG, "PG[get_columns]: RES_NAMES(%p)[%d]=[%s]\n", RES_NAMES(_res)[col], col, RES_NAMES(_res)[col]);

		/* PQftype: Returns the data type associated with the given column number.
		 * The integer returned is the internal OID number of the type.
		 * Column numbers start at 0.
		 */
		switch(ft = PQftype(CON_RESULT(_con),col))
		{
			case INT2OID:
			case INT4OID:
			case INT8OID:
				RES_TYPES(_res)[col] = DB_INT;
			break;

			case FLOAT4OID:
			case FLOAT8OID:
			case NUMERICOID:
				RES_TYPES(_res)[col] = DB_DOUBLE;
			break;

			case DATEOID:
			case TIMESTAMPOID:
			case TIMESTAMPTZOID:
				RES_TYPES(_res)[col] = DB_DATETIME;
			break;

			case BOOLOID:
			case CHAROID:
			case VARCHAROID:
			case BPCHAROID:
			case TEXTOID:
				RES_TYPES(_res)[col] = DB_STRING;
			break;

			case BYTEAOID:
				RES_TYPES(_res)[col] = DB_BLOB;
			break;

			case BITOID:
			case VARBITOID:
				RES_TYPES(_res)[col] = DB_BITMAP;
			break;

			default:
				LOG(L_WARN, "PG[get_columns]: Unhandled data type column (%s) OID (%d), defaulting to STRING\n", RES_NAMES(_res)[col], ft);
				RES_TYPES(_res)[col] = DB_STRING;
			break;
		}		
	}
	return 0;
}

/**
 * Convert rows from PostgreSQL to db API representation
 */
int pg_convert_rows(db_con_t* _con, db_res_t* _res, int row_start, int row_count)
{
	int row, cols, col;
	char **row_buf, *s;
	int len, fetch_count;

#ifdef PARANOID
        if (!_con)  {
                LOG(L_ERR, "PG[convert_rows]: db_con_t parameter cannot be NULL\n");
                return -1;
        }

        if (!_res)  {
                LOG(L_ERR, "PG[convert_rows]: db_res_t parameter cannot be NULL\n");
                return -1;
        }

#endif

	if (row_count == 0) {
		LOG(L_DBG, "PG[convert_rows]: No rows requested from the query\n");
		return 0;
	}

	if (!RES_NUM_ROWS(_res)) {
		LOG(L_DBG, "PG[convert_rows]: No rows returned from the query\n");
		return 0;
	}

        if (row_start < 0)  {
                LOG(L_ERR, "PG[convert_rows]: starting row (%d) cannot be less then zero, setting it to zero\n", row_start);
                row_start = 0;
        }

        if ((row_start + row_count) > RES_NUM_ROWS(_res))  {
                LOG(L_ERR, "PG[convert_rows]: Starting row + row count cannot be > total rows. Setting row count to read remainder of result set\n");
                row_count = RES_NUM_ROWS(_res) - row_start;
        }

	/* Save the number of rows in the current fetch */
	RES_ROW_N(_res) = row_count;

	/* Save the number of columns in the result query */
	cols = RES_COL_N(_res);

	/*
	 * I'm not sure of the usefulness of the following two blocks of code.
	 * It appears that if, anywhere in the result, a zero length field exists, 
	 * this routine quits and sets the number of rows in this Fetch to zero.
	 * norm
	 */

	/*
	 * Check the data length of each column and each row in the query result.
	 * If a zero length is found ANYWHERE, set the value flag.
	 * 
	 * PQgetlength: Returns the actual length of a field value in bytes. 
	 * Row and column numbers start at 0. 
	 * This is the actual data length for the particular data value, that is, the size of the object pointed to by PQgetvalue.
	 * For text data format this is the same as strlen().
	 * For binary format this is essential information.
	 * Note that one should not rely on PQfsize to obtain the actual data length.
	 *
	 */

	// value = 0;

	// for(row = row_start; row < (row_start + row_count); row++) {
	//	for(col = 0; col < cols; col++) {
	//		if(PQgetlength(CON_RESULT(_con), row, col))
	//			value = 1;
	//	}
	//}
	/* Looking for the row instance with no values */
	//if(!value){
	//	LOG(L_ERR, "PG[convert_rows]: Row instance, does not have a column value!\n");
	//	/* Set the number of rows in this Fetch to zero */
	//	RES_ROW_N(_res) = 0;
	//	return 0;
	//}

	/*
	 * Allocate an array of pointers one per column.
	 * It that will be used to hold the address of the string representation of each column.
	 *
	 */
	len = sizeof(char *) * cols;
	row_buf = (char **)pkg_malloc(len);
	LOG(L_DBG, "PG[convert_rows]: %p=pkg_malloc(%d) row_buf %d pointers\n", row_buf, len, cols);
        if (!row_buf) {
               LOG(L_ERR, "PG[_convert_rows]: Failed to allocate %d bytes for row buffer\n", len);
               return -1;
        }
	memset(row_buf, 0, len);

	/* Allocate a row structure for each row in the current fetch. */
	len = sizeof(db_row_t) * row_count;
	RES_ROWS(_res) = (db_row_t*)pkg_malloc(len);
	LOG(L_DBG, "PG[convert_rows]: %p=pkg_malloc(%d) RES_ROWS %d rows\n", RES_ROWS(_res), len, row_count);
        if (!RES_ROWS(_res)) {
                LOG(L_ERR, "PG[convert_rows]: Failed to allocate %d bytes %d rows for row structure\n", len, row_count);
                return -1;
        }
	memset(RES_ROWS(_res), 0, len);

	fetch_count = 0;
	for(row = row_start; row < (row_start + row_count); row++) {
		for(col = 0; col < cols; col++) {
			/* 
			 * PQgetisnull: Tests a field for a null value. Row and column numbers start at 0.
			 * This function returns 1 if the field is null and 0 if it contains a non-null value.
			 * (Note that PQgetvalue will return an empty string, not a null pointer, for a null field.)
			 *
			 * Not sure of the usefullness of the following code used to set a NULL to an empty
			 * string.  The doc for PQgetvalue (below) seems to indicate that this is taken care of
			 * by PostgreSQL. norm 
			 *
			 */
			// if(PQgetisnull(CON_RESULT(_con), row, col)) {
				/*
				** I don't believe there is a NULL
				** representation, so, I'll cheat
				*/
		 	//	s = "";
			// } else {
				/*
				 * PQgetvalue: Returns a single field value of one row of a PGresult.
				 * Row and column numbers start at 0.
				 * The caller should not free the result directly.
				 * It will be freed when the associated PGresult handle is passed to PQclear. 
				 * For data in text format, the value returned by PQgetvalue is a null-terminated
				 * character string representation of the field value. For data in binary format,
				 * the value is in the binary representation determined by the data type's typsend
				 * and typreceive functions. (The value is actually followed by a zero byte in this
				 * case too, but that is not ordinarily useful, since the value is likely to contain
				 * embedded nulls.)
				 * An empty string is returned if the field value is null.
				 * See PQgetisnull to distinguish null values from empty-string values.
				 * The pointer returned by PQgetvalue points to storage that is part of the PGresult structure.
				 * One should not modify the data it points to, and one must explicitly copy the data into
				 * other storage if it is to be used past the lifetime of the PGresult structure itself.
				 */
				s = PQgetvalue(CON_RESULT(_con), row, col);
			// }
			LOG(L_DBG, "PG[convert_rows]: PQgetvalue(%p,%d,%d)=[%s]\n", _con, row, col, s);
			len = strlen(s);
			row_buf[col] = pkg_malloc(len+1);
        		if (!row_buf[col]) {
               			LOG(L_ERR, "PG[_convert_rows]: Failed to allocate %d bytes for row_buf[%d]\n", len+1, col);
               			return -1;
        		}
			memset(row_buf[col], 0, len+1);
			LOG(L_DBG, "PG[convert_rows]: %p=pkg_malloc(%d) row_buf[%d]\n", row_buf[col], len, col);

			strncpy(row_buf[col], s, len);
			
			LOG(L_DBG, "PG[convert_rows]: [%d][%d] Column[%s]=[%s]\n", row, col, RES_NAMES(_res)[col], row_buf[col]);
		}

		/*
		** ASSERT: row_buf contains an entire row in strings
		*/
		if (pg_convert_row(_con, _res, &(RES_ROWS(_res)[fetch_count]), row_buf) < 0) {

			LOG(L_ERR, "PG[convert_rows]: Error converting row #%d\n",  row);
			RES_ROW_N(_res) = row - row_start;
			for (col=0; col<cols; col++) {
				LOG(L_DBG, "PG[convert_rows]: Error: %p=pkg_free() row_buf[%d]\n", (char *)row_buf[col], col);
				pkg_free((char *)row_buf[col]);	
			}
			LOG(L_DBG, "PG[convert_rows]: Error %p=pkg_free() row_buf\n", row_buf);
			pkg_free(row_buf);
			return -4;
		}
		
		/* pkg_free() must be done for the above allocations now that the row has been converted.
		 * During pg_convert_row (and subsequent pg_str2val) processing, data types that don't need to be
		 * converted (namely STRINGS and STR) have their addresses saved.  These data types should not have
		 * their pkg_malloc() allocations freed here because they are still needed.  However, some data types
		 * (ex: INT, DOUBLE) should have their pkg_malloc() allocations freed because during the conversion
		 * process, their converted values are saved in the union portion of the db_val_t structure.
		 * BLOB will be copied during PQunescape in str2val, thus it has to be freed here AND in pg_free_row().
		 *
		 * Warning: when the converted row is no longer needed, the data types whose addresses
		 * were saved in the db_val_t structure must be freed or a memory leak will happen.
		 * This processing should happen in the pg_free_row() subroutine.  The caller of
		 * this routine should ensure that pg_free_rows(), pg_free_row() or pg_free_result()
		 * is eventually called.
		 */
		for (col=0; col<cols; col++) {
                  switch (RES_TYPES(_res)[col]) {
                    case DB_STRING:
                    case DB_STR:
        		break;
                    default:
                      LOG(L_DBG, "PG[convert_rows]: [%d][%d] Col[%s] Type[%d] "
                        "Freeing row_buf[%p]\n", row, col,
                        RES_NAMES(_res)[col], RES_TYPES(_res)[col],
			row_buf[col]);
                      LOG(L_DBG, "PG[convert_rows]: %p=pkg_free() row_buf[%d]\n",
                        (char *)row_buf[col], col);
			pkg_free((char *)row_buf[col]);
		       }
			/* The following housekeeping may not be technically required, but it is a good practice
			 * to NULL pointer fields that are no longer valid.  Note that DB_STRING fields have not
			 * been pkg_free(). NULLing DB_STRING fields would normally not be good to do because a memory
			 * leak would occur.  However, the pg_convert_row() routine has saved the DB_STRING pointer
			 * in the db_val_t structure.  The db_val_t structure will eventually be used to pkg_free()
			 * the DB_STRING storage.
			 */
			row_buf[col] = (char *)NULL;
		}
	fetch_count++;
	}

	LOG(L_DBG, "PG[convert_rows]: %p=pkg_free() row_buf\n", row_buf);
	pkg_free(row_buf);
	row_buf = NULL;
	return 0;
}

/**
 * Convert a row from the result query into db API representation
 */
int pg_convert_row(db_con_t* _con, db_res_t* _res, db_row_t* _row, char **row_buf)
{
        int col, len;

#ifdef PARANOID
        if (!_con)  {
                LOG(L_ERR, "PG[convert_row]: db_con_t parameter cannot be NULL\n");
                return -1;
        }

        if (!_res)  {
                LOG(L_ERR, "PG[convert_row]: db_res_t parameter cannot be NULL\n");
                return -1;
        }

        if (!_row)  {
                LOG(L_ERR, "PG[convert_row]: db_row_t parameter cannot be NULL\n");
                return -1;
        }
#endif

	/* Allocate storage to hold the data type value converted from a string */
	/* because PostgreSQL returns (most) data as strings */
	len = sizeof(db_val_t) * RES_COL_N(_res);
	ROW_VALUES(_row) = (db_val_t*)pkg_malloc(len);
        LOG(L_DBG, "PG[convert_row]: %p=pkg_malloc(%d) ROW_VALUES for %d columns\n", ROW_VALUES(_row), len, RES_COL_N(_res));

        if (!ROW_VALUES(_row)) {
                LOG(L_ERR, "PG[convert_row]: No memory left\n");
                return -1;
        }
	memset(ROW_VALUES(_row), 0, len);

	/* Save the number of columns in the ROW structure */
        ROW_N(_row) = RES_COL_N(_res);

	/* For each column in the row */
        for(col = 0; col < ROW_N(_row); col++) {
		LOG(L_DBG, "PG[convert_row]: col[%d]\n", col);
		/* Convert the string representation into the value representation */
		if (pg_str2val(RES_TYPES(_res)[col], &(ROW_VALUES(_row)[col]), row_buf[col], strlen(row_buf[col])) < 0) {
                        LOG(L_ERR, "PG[convert_row]: Error while converting value\n");
        		LOG(L_DBG, "PG[convert_row]: %p=pkg_free() _row\n", _row);
                        pg_free_row(_row);
                        return -3;
                }
        }
        return 0;
}

/**
 * Release memory used by rows
 */
int pg_free_rows(db_res_t* _res)
{
	int row;

#ifdef PARANOID
        if (!_res)  {
                LOG(L_ERR, "PG[free_rows]: db_res_t parameter cannot be NULL\n");
                return -1;
        }
#endif

	LOG(L_DBG, "PG[free_rows]: Freeing %d rows\n", RES_ROW_N(_res));

	for(row = 0; row < RES_ROW_N(_res); row++) {
		LOG(L_DBG, "PG[free_rows]: Row[%d]=%p\n", row, &(RES_ROWS(_res)[row]));
		pg_free_row(&(RES_ROWS(_res)[row]));
	}
	RES_ROW_N(_res) = 0;

        if (RES_ROWS(_res)) {
                LOG(L_DBG, "PG[free_rows]: %p=pkg_free() RES_ROWS\n", RES_ROWS(_res));
		pkg_free(RES_ROWS(_res));
		RES_ROWS(_res) = NULL;
	}

        return 0;
}

/**
 * Release memory used by row
 */
int pg_free_row(db_row_t* _row)
{
	int	col;
	db_val_t* _val;

#ifdef PARANOID
        if (!_row) {
                LOG(L_ERR, "PG[free_row]: db_row_t parameter cannot be NULL\n");
                return -1;
        }
#endif

	/* 
	 * Loop thru each columm, then check to determine if the storage pointed to by db_val_t structure must be freed.
	 * This is required for all data types which use a pointer to a buffer like DB_STRING, DB_STR and DB_BLOB.
	 * If this is not done, a memory leak will happen.
	 */
	for (col = 0; col < ROW_N(_row); col++) {
          switch (VAL_TYPE(_val)) {
            case DB_STRING:
              LOG(L_DBG, "PG[free_row]: %p=pkg_free() VAL_STRING[%d]\n", (char *)VAL_STRING(_val), col);
              pkg_free((char *)(VAL_STRING(_val)));
               VAL_STRING(_val) = (char *)NULL;
              break;
            case DB_STR:
              LOG(L_DBG, "PG[free_row]: %p=pkg_free() VAL_STR[%d]\n", (char *)(VAL_STR(_val).s), col);
              pkg_free((char *)(VAL_STR(_val).s));
              VAL_STR(_val).s = (char *)NULL;
              break;
            case DB_BLOB:
              LOG(L_DBG, "PG[free_row]: %p=pkg_free() VAL_BLOB[%d]\n", (char *)(VAL_BLOB(_val).s), col);
              PQfreemem(VAL_BLOB(_val).s);
              VAL_BLOB(_val).s = (char *)NULL;
              break;
            default:
              break;
          }    
	}
	/* Free db_val_t structure. */
        if (ROW_VALUES(_row)) {
                LOG(L_DBG, "PG[free_row]: %p=pkg_free() ROW_VALUES\n", ROW_VALUES(_row));
                pkg_free(ROW_VALUES(_row));
		ROW_VALUES(_row) = NULL;
	}
        return 0;
}

/**
 * Release memory used by columns
 */
int pg_free_columns(db_res_t* _res)
{
	int col;

#ifdef PARANOID
        if (!_res) {
                LOG(L_ERR, "PG[free_columns]: db_res_t parameter cannot be NULL\n");
                return -1;
        }
#endif

	/* Free memory previously allocated to save column names */
        for(col = 0; col < RES_COL_N(_res); col++) {
                LOG(L_DBG, "PG[free_columns]: Freeing RES_NAMES(%p)[%d] -> free(%p) '%s'\n", _res, col, RES_NAMES(_res)[col], RES_NAMES(_res)[col]);
                LOG(L_DBG, "PG[free_columns]: %p=pkg_free() RES_NAMES[%d]\n", RES_NAMES(_res)[col], col);
                pkg_free((char *)RES_NAMES(_res)[col]);
		RES_NAMES(_res)[col] = (char *)NULL;
	}
 
        if (RES_NAMES(_res)) {
                LOG(L_DBG, "PG[free_columns]: %p=pkg_free() RES_NAMES\n", RES_NAMES(_res));
		pkg_free(RES_NAMES(_res));
		RES_NAMES(_res) = NULL;
	}
        if (RES_TYPES(_res)) {
                LOG(L_DBG, "PG[free_columns]: %p=pkg_free() RES_TYPES\n", RES_TYPES(_res));
		pkg_free(RES_TYPES(_res));
		RES_TYPES(_res) = NULL;
	}

	return 0;
}

/**
 * Release memory used by the result structure
 */
int pg_free_result(db_res_t* _res)
{

#ifdef PARANOID
        if (!_res) {
                LOG(L_ERR, "PG[free_result]: db_res_t parameter cannot be NULL\n");
                return -1;
        }
#endif

        pg_free_columns(_res);
        pg_free_rows(_res);

        LOG(L_DBG, "PG[free_result]: %p=pkg_free() _res\n", _res);
        pkg_free(_res);
	_res = NULL;
        return 0;
}