/*

+----------------------------------------------------------------------+

| PHP Version 7 |

+----------------------------------------------------------------------+

| Copyright (c) 1997-2018 The PHP Group |

+----------------------------------------------------------------------+

| This source file is subject to version 3.01 of the PHP license, |

| that is bundled with this package in the file LICENSE, and is |

| available through the world-wide-web at the following url: |

| http://www.php.net/license/3_01.txt |

| If you did not receive a copy of the PHP license and are unable to |

| obtain it through the world-wide-web, please send a note to |

| license@php.net so we can mail you a copy immediately. |

+----------------------------------------------------------------------+

| Authors: Zeev Suraski <zeev@zend.com> |

| Jouni Ahto <jouni.ahto@exdec.fi> |

| Yasuo Ohgaki <yohgaki@php.net> |

| Youichi Iwakiri <yiwakiri@st.rim.or.jp> (pg_copy_*) |

| Chris Kings-Lynne <chriskl@php.net> (v3 protocol) |

+----------------------------------------------------------------------+

*/

/* $Id$ */

#include <stdlib.h>

#define PHP_PGSQL_PRIVATE 1

#ifdef HAVE_CONFIG_H

#include "config.h"

#endif

#define SMART_STR_PREALLOC 512

#include "php.h"

#include "php_ini.h"

#include "ext/standard/php_standard.h"

#include "zend_smart_str.h"

#include "ext/pcre/php_pcre.h"

#ifdef PHP_WIN32

# include "win32/time.h"

#endif

#undef PACKAGE_BUGREPORT

#undef PACKAGE_NAME

#undef PACKAGE_STRING

#undef PACKAGE_TARNAME

#undef PACKAGE_VERSION

#include "php_pgsql.h"

#include "php_globals.h"

#include "zend_exceptions.h"

#if HAVE_PGSQL

#ifndef InvalidOid

#define InvalidOid ((Oid) 0)

#endif

#define PGSQL_ASSOC 1<<0

#define PGSQL_NUM 1<<1

#define PGSQL_BOTH (PGSQL_ASSOC|PGSQL_NUM)

#define PGSQL_NOTICE_LAST 1 /* Get the last notice */

#define PGSQL_NOTICE_ALL 2 /* Get all notices */

#define PGSQL_NOTICE_CLEAR 3 /* Remove notices */

#define PGSQL_STATUS_LONG 1

#define PGSQL_STATUS_STRING 2

#define PGSQL_MAX_LENGTH_OF_LONG 30

#define PGSQL_MAX_LENGTH_OF_DOUBLE 60

#if ZEND_LONG_MAX < UINT_MAX

#define PGSQL_RETURN_OID(oid) do { \

if (oid > ZEND_LONG_MAX) { \

smart_str s = {0}; \

smart_str_append_unsigned(&s, oid); \

smart_str_0(&s); \

RETURN_NEW_STR(s.s); \

} \

RETURN_LONG((zend_long)oid); \

} while(0)

#else

#define PGSQL_RETURN_OID(oid) RETURN_LONG((zend_long)oid)

#endif

#if HAVE_PQSETNONBLOCKING

#define PQ_SETNONBLOCKING(pg_link, flag) PQsetnonblocking(pg_link, flag)

#else

#define PQ_SETNONBLOCKING(pg_link, flag) 0

#endif

#define CHECK_DEFAULT_LINK(x) if ((x) == NULL) { php_error_docref(NULL, E_WARNING, "No PostgreSQL link opened yet"); }

#define FETCH_DEFAULT_LINK() PGG(default_link)

#ifndef HAVE_PQFREEMEM

#define PQfreemem free

#endif

ZEND_DECLARE_MODULE_GLOBALS(pgsql)

static PHP_GINIT_FUNCTION(pgsql);

/* {{{ arginfo */

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_connect, 0, 0, 1)

ZEND_ARG_INFO(0, connection_string)

ZEND_ARG_INFO(0, connect_type)

ZEND_ARG_INFO(0, host)

ZEND_ARG_INFO(0, port)

ZEND_ARG_INFO(0, options)

ZEND_ARG_INFO(0, tty)

ZEND_ARG_INFO(0, database)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_pconnect, 0, 0, 1)

ZEND_ARG_INFO(0, connection_string)

ZEND_ARG_INFO(0, host)

ZEND_ARG_INFO(0, port)

ZEND_ARG_INFO(0, options)

ZEND_ARG_INFO(0, tty)

ZEND_ARG_INFO(0, database)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_connect_poll, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

#if HAVE_PQPARAMETERSTATUS

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_parameter_status, 0, 0, 1)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, param_name)

ZEND_END_ARG_INFO()

#endif

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_close, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_dbname, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_last_error, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_options, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_port, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_tty, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_host, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_version, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_ping, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_query, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, query)

ZEND_END_ARG_INFO()

#if HAVE_PQEXECPARAMS

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_query_params, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, query)

ZEND_ARG_INFO(0, params)

ZEND_END_ARG_INFO()

#endif

#if HAVE_PQPREPARE

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_prepare, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, stmtname)

ZEND_ARG_INFO(0, query)

ZEND_END_ARG_INFO()

#endif

#if HAVE_PQEXECPREPARED

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_execute, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, stmtname)

ZEND_ARG_INFO(0, params)

ZEND_END_ARG_INFO()

#endif

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_num_rows, 0, 0, 1)

ZEND_ARG_INFO(0, result)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_num_fields, 0, 0, 1)

ZEND_ARG_INFO(0, result)

ZEND_END_ARG_INFO()

#if HAVE_PQCMDTUPLES

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_affected_rows, 0, 0, 1)

ZEND_ARG_INFO(0, result)

ZEND_END_ARG_INFO()

#endif

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_last_notice, 0, 0, 1)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, option)

ZEND_END_ARG_INFO()

#ifdef HAVE_PQFTABLE

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_field_table, 0, 0, 2)

ZEND_ARG_INFO(0, result)

ZEND_ARG_INFO(0, field_number)

ZEND_ARG_INFO(0, oid_only)

ZEND_END_ARG_INFO()

#endif

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_field_name, 0, 0, 2)

ZEND_ARG_INFO(0, result)

ZEND_ARG_INFO(0, field_number)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_field_size, 0, 0, 2)

ZEND_ARG_INFO(0, result)

ZEND_ARG_INFO(0, field_number)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_field_type, 0, 0, 2)

ZEND_ARG_INFO(0, result)

ZEND_ARG_INFO(0, field_number)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_field_type_oid, 0, 0, 2)

ZEND_ARG_INFO(0, result)

ZEND_ARG_INFO(0, field_number)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_field_num, 0, 0, 2)

ZEND_ARG_INFO(0, result)

ZEND_ARG_INFO(0, field_name)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_fetch_result, 0, 0, 1)

ZEND_ARG_INFO(0, result)

ZEND_ARG_INFO(0, row_number)

ZEND_ARG_INFO(0, field_name)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_fetch_row, 0, 0, 1)

ZEND_ARG_INFO(0, result)

ZEND_ARG_INFO(0, row)

ZEND_ARG_INFO(0, result_type)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_fetch_assoc, 0, 0, 1)

ZEND_ARG_INFO(0, result)

ZEND_ARG_INFO(0, row)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_fetch_array, 0, 0, 1)

ZEND_ARG_INFO(0, result)

ZEND_ARG_INFO(0, row)

ZEND_ARG_INFO(0, result_type)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_fetch_object, 0, 0, 1)

ZEND_ARG_INFO(0, result)

ZEND_ARG_INFO(0, row)

ZEND_ARG_INFO(0, class_name)

ZEND_ARG_INFO(0, l)

ZEND_ARG_INFO(0, ctor_params)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_fetch_all, 0, 0, 1)

ZEND_ARG_INFO(0, result)

ZEND_ARG_INFO(0, result_type)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_fetch_all_columns, 0, 0, 1)

ZEND_ARG_INFO(0, result)

ZEND_ARG_INFO(0, column_number)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_result_seek, 0, 0, 2)

ZEND_ARG_INFO(0, result)

ZEND_ARG_INFO(0, offset)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_field_prtlen, 0, 0, 1)

ZEND_ARG_INFO(0, result)

ZEND_ARG_INFO(0, row)

ZEND_ARG_INFO(0, field_name_or_number)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_field_is_null, 0, 0, 1)

ZEND_ARG_INFO(0, result)

ZEND_ARG_INFO(0, row)

ZEND_ARG_INFO(0, field_name_or_number)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_free_result, 0, 0, 1)

ZEND_ARG_INFO(0, result)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_last_oid, 0, 0, 1)

ZEND_ARG_INFO(0, result)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_trace, 0, 0, 1)

ZEND_ARG_INFO(0, filename)

ZEND_ARG_INFO(0, mode)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_untrace, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_lo_create, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, large_object_id)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_lo_unlink, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, large_object_oid)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_lo_open, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, large_object_oid)

ZEND_ARG_INFO(0, mode)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_lo_close, 0, 0, 1)

ZEND_ARG_INFO(0, large_object)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_lo_read, 0, 0, 1)

ZEND_ARG_INFO(0, large_object)

ZEND_ARG_INFO(0, len)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_lo_write, 0, 0, 2)

ZEND_ARG_INFO(0, large_object)

ZEND_ARG_INFO(0, buf)

ZEND_ARG_INFO(0, len)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_lo_read_all, 0, 0, 1)

ZEND_ARG_INFO(0, large_object)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_lo_import, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, filename)

ZEND_ARG_INFO(0, large_object_oid)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_lo_export, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, objoid)

ZEND_ARG_INFO(0, filename)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_lo_seek, 0, 0, 2)

ZEND_ARG_INFO(0, large_object)

ZEND_ARG_INFO(0, offset)

ZEND_ARG_INFO(0, whence)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_lo_tell, 0, 0, 1)

ZEND_ARG_INFO(0, large_object)

ZEND_END_ARG_INFO()

#if HAVE_PG_LO_TRUNCATE

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_lo_truncate, 0, 0, 1)

ZEND_ARG_INFO(0, large_object)

ZEND_ARG_INFO(0, size)

ZEND_END_ARG_INFO()

#endif

#if HAVE_PQSETERRORVERBOSITY

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_set_error_verbosity, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, verbosity)

ZEND_END_ARG_INFO()

#endif

#if HAVE_PQCLIENTENCODING

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_set_client_encoding, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, encoding)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_client_encoding, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

#endif

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_end_copy, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_put_line, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, query)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_copy_to, 0, 0, 2)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, table_name)

ZEND_ARG_INFO(0, delimiter)

ZEND_ARG_INFO(0, null_as)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_copy_from, 0, 0, 3)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, table_name)

ZEND_ARG_INFO(0, rows)

ZEND_ARG_INFO(0, delimiter)

ZEND_ARG_INFO(0, null_as)

ZEND_END_ARG_INFO()

#if HAVE_PQESCAPE

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_escape_string, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, data)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_escape_bytea, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, data)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_unescape_bytea, 0, 0, 1)

ZEND_ARG_INFO(0, data)

ZEND_END_ARG_INFO()

#endif

#if HAVE_PQESCAPE

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_escape_literal, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, data)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_escape_identifier, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, data)

ZEND_END_ARG_INFO()

#endif

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_result_error, 0, 0, 1)

ZEND_ARG_INFO(0, result)

ZEND_END_ARG_INFO()

#if HAVE_PQRESULTERRORFIELD

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_result_error_field, 0, 0, 2)

ZEND_ARG_INFO(0, result)

ZEND_ARG_INFO(0, fieldcode)

ZEND_END_ARG_INFO()

#endif

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_connection_status, 0, 0, 1)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

#if HAVE_PGTRANSACTIONSTATUS

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_transaction_status, 0, 0, 1)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

#endif

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_connection_reset, 0, 0, 1)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_cancel_query, 0, 0, 1)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_connection_busy, 0, 0, 1)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_send_query, 0, 0, 2)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, query)

ZEND_END_ARG_INFO()

#if HAVE_PQSENDQUERYPARAMS

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_send_query_params, 0, 0, 3)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, query)

ZEND_ARG_INFO(0, params)

ZEND_END_ARG_INFO()

#endif

#if HAVE_PQSENDPREPARE

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_send_prepare, 0, 0, 3)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, stmtname)

ZEND_ARG_INFO(0, query)

ZEND_END_ARG_INFO()

#endif

#if HAVE_PQSENDQUERYPREPARED

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_send_execute, 0, 0, 3)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, stmtname)

ZEND_ARG_INFO(0, params)

ZEND_END_ARG_INFO()

#endif

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_get_result, 0, 0, 1)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_result_status, 0, 0, 1)

ZEND_ARG_INFO(0, result)

ZEND_ARG_INFO(0, result_type)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_get_notify, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_ARG_INFO(0, e)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_get_pid, 0, 0, 0)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_socket, 0, 0, 1)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_consume_input, 0, 0, 1)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_flush, 0, 0, 1)

ZEND_ARG_INFO(0, connection)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_meta_data, 0, 0, 2)

ZEND_ARG_INFO(0, db)

ZEND_ARG_INFO(0, table)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_convert, 0, 0, 3)

ZEND_ARG_INFO(0, db)

ZEND_ARG_INFO(0, table)

ZEND_ARG_INFO(0, values)

ZEND_ARG_INFO(0, options)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_insert, 0, 0, 3)

ZEND_ARG_INFO(0, db)

ZEND_ARG_INFO(0, table)

ZEND_ARG_INFO(0, values)

ZEND_ARG_INFO(0, options)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_update, 0, 0, 4)

ZEND_ARG_INFO(0, db)

ZEND_ARG_INFO(0, table)

ZEND_ARG_INFO(0, fields)

ZEND_ARG_INFO(0, ids)

ZEND_ARG_INFO(0, options)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_delete, 0, 0, 3)

ZEND_ARG_INFO(0, db)

ZEND_ARG_INFO(0, table)

ZEND_ARG_INFO(0, ids)

ZEND_ARG_INFO(0, options)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pg_select, 0, 0, 3)

ZEND_ARG_INFO(0, db)

ZEND_ARG_INFO(0, table)

ZEND_ARG_INFO(0, ids)

ZEND_ARG_INFO(0, options)

ZEND_ARG_INFO(0, result_type)

ZEND_END_ARG_INFO()

/* }}} */

/* {{{ pgsql_functions[]

*/

static const zend_function_entry pgsql_functions[] = {

/* connection functions */

PHP_FE(pg_connect, arginfo_pg_connect)

PHP_FE(pg_pconnect, arginfo_pg_pconnect)

PHP_FE(pg_connect_poll, arginfo_pg_connect_poll)

PHP_FE(pg_close, arginfo_pg_close)

PHP_FE(pg_connection_status, arginfo_pg_connection_status)

PHP_FE(pg_connection_busy, arginfo_pg_connection_busy)

PHP_FE(pg_connection_reset, arginfo_pg_connection_reset)

PHP_FE(pg_host, arginfo_pg_host)

PHP_FE(pg_dbname, arginfo_pg_dbname)

PHP_FE(pg_port, arginfo_pg_port)

PHP_FE(pg_tty, arginfo_pg_tty)

PHP_FE(pg_options, arginfo_pg_options)

PHP_FE(pg_version, arginfo_pg_version)

PHP_FE(pg_ping, arginfo_pg_ping)

#if HAVE_PQPARAMETERSTATUS

PHP_FE(pg_parameter_status, arginfo_pg_parameter_status)

#endif

#if HAVE_PGTRANSACTIONSTATUS

PHP_FE(pg_transaction_status, arginfo_pg_transaction_status)

#endif

/* query functions */

PHP_FE(pg_query, arginfo_pg_query)

#if HAVE_PQEXECPARAMS

PHP_FE(pg_query_params, arginfo_pg_query_params)

#endif

#if HAVE_PQPREPARE

PHP_FE(pg_prepare, arginfo_pg_prepare)

#endif

#if HAVE_PQEXECPREPARED

PHP_FE(pg_execute, arginfo_pg_execute)

#endif

PHP_FE(pg_send_query, arginfo_pg_send_query)

#if HAVE_PQSENDQUERYPARAMS

PHP_FE(pg_send_query_params, arginfo_pg_send_query_params)

#endif

#if HAVE_PQSENDPREPARE

PHP_FE(pg_send_prepare, arginfo_pg_send_prepare)

#endif

#if HAVE_PQSENDQUERYPREPARED

PHP_FE(pg_send_execute, arginfo_pg_send_execute)

#endif

PHP_FE(pg_cancel_query, arginfo_pg_cancel_query)

/* result functions */

PHP_FE(pg_fetch_result, arginfo_pg_fetch_result)

PHP_FE(pg_fetch_row, arginfo_pg_fetch_row)

PHP_FE(pg_fetch_assoc, arginfo_pg_fetch_assoc)

PHP_FE(pg_fetch_array, arginfo_pg_fetch_array)

PHP_FE(pg_fetch_object, arginfo_pg_fetch_object)

PHP_FE(pg_fetch_all, arginfo_pg_fetch_all)

PHP_FE(pg_fetch_all_columns, arginfo_pg_fetch_all_columns)

#if HAVE_PQCMDTUPLES

PHP_FE(pg_affected_rows,arginfo_pg_affected_rows)

#endif

PHP_FE(pg_get_result, arginfo_pg_get_result)

PHP_FE(pg_result_seek, arginfo_pg_result_seek)

PHP_FE(pg_result_status,arginfo_pg_result_status)

PHP_FE(pg_free_result, arginfo_pg_free_result)

PHP_FE(pg_last_oid, arginfo_pg_last_oid)

PHP_FE(pg_num_rows, arginfo_pg_num_rows)

PHP_FE(pg_num_fields, arginfo_pg_num_fields)

PHP_FE(pg_field_name, arginfo_pg_field_name)

PHP_FE(pg_field_num, arginfo_pg_field_num)

PHP_FE(pg_field_size, arginfo_pg_field_size)

PHP_FE(pg_field_type, arginfo_pg_field_type)

PHP_FE(pg_field_type_oid, arginfo_pg_field_type_oid)

PHP_FE(pg_field_prtlen, arginfo_pg_field_prtlen)

PHP_FE(pg_field_is_null,arginfo_pg_field_is_null)

#ifdef HAVE_PQFTABLE

PHP_FE(pg_field_table, arginfo_pg_field_table)

#endif

/* async message function */

PHP_FE(pg_get_notify, arginfo_pg_get_notify)

PHP_FE(pg_socket, arginfo_pg_socket)

PHP_FE(pg_consume_input,arginfo_pg_consume_input)

PHP_FE(pg_flush, arginfo_pg_flush)

PHP_FE(pg_get_pid, arginfo_pg_get_pid)

/* error message functions */

PHP_FE(pg_result_error, arginfo_pg_result_error)

#if HAVE_PQRESULTERRORFIELD

PHP_FE(pg_result_error_field, arginfo_pg_result_error_field)

#endif

PHP_FE(pg_last_error, arginfo_pg_last_error)

PHP_FE(pg_last_notice, arginfo_pg_last_notice)

/* copy functions */

PHP_FE(pg_put_line, arginfo_pg_put_line)

PHP_FE(pg_end_copy, arginfo_pg_end_copy)

PHP_FE(pg_copy_to, arginfo_pg_copy_to)

PHP_FE(pg_copy_from, arginfo_pg_copy_from)

/* debug functions */

PHP_FE(pg_trace, arginfo_pg_trace)

PHP_FE(pg_untrace, arginfo_pg_untrace)

/* large object functions */

PHP_FE(pg_lo_create, arginfo_pg_lo_create)

PHP_FE(pg_lo_unlink, arginfo_pg_lo_unlink)

PHP_FE(pg_lo_open, arginfo_pg_lo_open)

PHP_FE(pg_lo_close, arginfo_pg_lo_close)

PHP_FE(pg_lo_read, arginfo_pg_lo_read)

PHP_FE(pg_lo_write, arginfo_pg_lo_write)

PHP_FE(pg_lo_read_all, arginfo_pg_lo_read_all)

PHP_FE(pg_lo_import, arginfo_pg_lo_import)

PHP_FE(pg_lo_export, arginfo_pg_lo_export)

PHP_FE(pg_lo_seek, arginfo_pg_lo_seek)

PHP_FE(pg_lo_tell, arginfo_pg_lo_tell)

#if HAVE_PG_LO_TRUNCATE

PHP_FE(pg_lo_truncate, arginfo_pg_lo_truncate)

#endif

/* utility functions */

#if HAVE_PQESCAPE

PHP_FE(pg_escape_string, arginfo_pg_escape_string)

PHP_FE(pg_escape_bytea, arginfo_pg_escape_bytea)

PHP_FE(pg_unescape_bytea, arginfo_pg_unescape_bytea)

PHP_FE(pg_escape_literal, arginfo_pg_escape_literal)

PHP_FE(pg_escape_identifier, arginfo_pg_escape_identifier)

#endif

#if HAVE_PQSETERRORVERBOSITY

PHP_FE(pg_set_error_verbosity, arginfo_pg_set_error_verbosity)

#endif

#if HAVE_PQCLIENTENCODING

PHP_FE(pg_client_encoding, arginfo_pg_client_encoding)

PHP_FE(pg_set_client_encoding, arginfo_pg_set_client_encoding)

#endif

/* misc function */

PHP_FE(pg_meta_data, arginfo_pg_meta_data)

PHP_FE(pg_convert, arginfo_pg_convert)

PHP_FE(pg_insert, arginfo_pg_insert)

PHP_FE(pg_update, arginfo_pg_update)

PHP_FE(pg_delete, arginfo_pg_delete)

PHP_FE(pg_select, arginfo_pg_select)

/* aliases for downwards compatibility */

PHP_FALIAS(pg_exec, pg_query, arginfo_pg_query)

PHP_FALIAS(pg_getlastoid, pg_last_oid, arginfo_pg_last_oid)

#if HAVE_PQCMDTUPLES

PHP_FALIAS(pg_cmdtuples, pg_affected_rows, arginfo_pg_affected_rows)

#endif

PHP_FALIAS(pg_errormessage, pg_last_error, arginfo_pg_last_error)

PHP_FALIAS(pg_numrows, pg_num_rows, arginfo_pg_num_rows)

PHP_FALIAS(pg_numfields, pg_num_fields, arginfo_pg_num_fields)

PHP_FALIAS(pg_fieldname, pg_field_name, arginfo_pg_field_name)

PHP_FALIAS(pg_fieldsize, pg_field_size, arginfo_pg_field_size)

PHP_FALIAS(pg_fieldtype, pg_field_type, arginfo_pg_field_type)

PHP_FALIAS(pg_fieldnum, pg_field_num, arginfo_pg_field_num)

PHP_FALIAS(pg_fieldprtlen, pg_field_prtlen, arginfo_pg_field_prtlen)

PHP_FALIAS(pg_fieldisnull, pg_field_is_null, arginfo_pg_field_is_null)

PHP_FALIAS(pg_freeresult, pg_free_result, arginfo_pg_free_result)

PHP_FALIAS(pg_result, pg_fetch_result, arginfo_pg_get_result)

PHP_FALIAS(pg_loreadall, pg_lo_read_all, arginfo_pg_lo_read_all)

PHP_FALIAS(pg_locreate, pg_lo_create, arginfo_pg_lo_create)

PHP_FALIAS(pg_lounlink, pg_lo_unlink, arginfo_pg_lo_unlink)

PHP_FALIAS(pg_loopen, pg_lo_open, arginfo_pg_lo_open)

PHP_FALIAS(pg_loclose, pg_lo_close, arginfo_pg_lo_close)

PHP_FALIAS(pg_loread, pg_lo_read, arginfo_pg_lo_read)

PHP_FALIAS(pg_lowrite, pg_lo_write, arginfo_pg_lo_write)

PHP_FALIAS(pg_loimport, pg_lo_import, arginfo_pg_lo_import)

PHP_FALIAS(pg_loexport, pg_lo_export, arginfo_pg_lo_export)

#if HAVE_PQCLIENTENCODING

PHP_FALIAS(pg_clientencoding, pg_client_encoding, arginfo_pg_client_encoding)

PHP_FALIAS(pg_setclientencoding, pg_set_client_encoding, arginfo_pg_set_client_encoding)

#endif

PHP_FE_END

};

/* }}} */

/* {{{ pgsql_module_entry

*/

zend_module_entry pgsql_module_entry = {

STANDARD_MODULE_HEADER,

"pgsql",

pgsql_functions,

PHP_MINIT(pgsql),

PHP_MSHUTDOWN(pgsql),

PHP_RINIT(pgsql),

PHP_RSHUTDOWN(pgsql),

PHP_MINFO(pgsql),

PHP_PGSQL_VERSION,

PHP_MODULE_GLOBALS(pgsql),

PHP_GINIT(pgsql),

NULL,

NULL,

STANDARD_MODULE_PROPERTIES_EX

};

/* }}} */

#ifdef COMPILE_DL_PGSQL

#ifdef ZTS

ZEND_TSRMLS_CACHE_DEFINE()

#endif

ZEND_GET_MODULE(pgsql)

#endif

static int le_link, le_plink, le_result, le_lofp, le_string;

/* Compatibility definitions */

#ifndef HAVE_PGSQL_WITH_MULTIBYTE_SUPPORT

#define pg_encoding_to_char(x) "SQL_ASCII"

#endif

#if !HAVE_PQESCAPE_CONN

#define PQescapeStringConn(conn, to, from, len, error) PQescapeString(to, from, len)

#endif

#if HAVE_PQESCAPELITERAL

#define PGSQLescapeLiteral(conn, str, len) PQescapeLiteral(conn, str, len)

#define PGSQLescapeIdentifier(conn, str, len) PQescapeIdentifier(conn, str, len)

#define PGSQLfree(a) PQfreemem(a)

#else

#define PGSQLescapeLiteral(conn, str, len) php_pgsql_PQescapeInternal(conn, str, len, 1, 0)

#define PGSQLescapeLiteral2(conn, str, len) php_pgsql_PQescapeInternal(conn, str, len, 1, 1)

#define PGSQLescapeIdentifier(conn, str, len) php_pgsql_PQescapeInternal(conn, str, len, 0, 0)

#define PGSQLfree(a) efree(a)

/* emulate libpq's PQescapeInternal() 9.0 or later */

static char *php_pgsql_PQescapeInternal(PGconn *conn, const char *str, size_t len, int escape_literal, int safe) /* {{{ */

{

char *result, *rp, *s;

if (!conn) {

return NULL;

}

/* allocate enough memory */

rp = result = (char *)safe_emalloc(len, 2, 5); /* leading " E" needs extra 2 bytes + quote_chars on both end for 2 bytes + NULL */

if (escape_literal) {

if (safe) {

size_t new_len;

char *tmp = (char *)safe_emalloc(len, 2, 1);

*rp++ = '\'';

/* PQescapeString does not escape \, but it handles multibyte chars safely.

This escape is incompatible with PQescapeLiteral. */

new_len = PQescapeStringConn(conn, tmp, str, len, NULL);

strncpy(rp, tmp, new_len);

efree(tmp);

rp += new_len;

} else {

char *encoding;

size_t tmp_len;

/* This is compatible with PQescapeLiteral, but it cannot handle multbyte chars

such as SJIS, BIG5. Raise warning and return NULL by checking

client_encoding. */

encoding = (char *) pg_encoding_to_char(PQclientEncoding(conn));

if (!strncmp(encoding, "SJIS", sizeof("SJIS")-1) ||

!strncmp(encoding, "SHIFT_JIS_2004", sizeof("SHIFT_JIS_2004")-1) ||

!strncmp(encoding, "BIG5", sizeof("BIG5")-1) ||

!strncmp(encoding, "GB18030", sizeof("GB18030")-1) ||

!strncmp(encoding, "GBK", sizeof("GBK")-1) ||

!strncmp(encoding, "JOHAB", sizeof("JOHAB")-1) ||

!strncmp(encoding, "UHC", sizeof("UHC")-1) ) {

php_error_docref(NULL, E_WARNING, "Unsafe encoding is used. Do not use '%s' encoding or use PostgreSQL 9.0 or later libpq.", encoding);

}

/* check backslashes */

tmp_len = strspn(str, "\\");

if (tmp_len != len) {

/* add " E" for escaping slashes */

*rp++ = ' ';

*rp++ = 'E';

}

*rp++ = '\'';

for (s = (char *)str; s - str < len; ++s) {

if (*s == '\'' || *s == '\\') {

*rp++ = *s;

*rp++ = *s;

} else {

*rp++ = *s;

}

}

}

*rp++ = '\'';

} else {

/* Identifier escape. */

*rp++ = '"';

for (s = (char *)str; s - str < len; ++s) {

if (*s == '"') {

*rp++ = '"';

*rp++ = '"';

} else {

*rp++ = *s;

}

}

*rp++ = '"';

}

*rp = '\0';

return result;

}

/* }}} */

#endif

/* {{{ _php_pgsql_trim_message */

static char * _php_pgsql_trim_message(const char *message, size_t *len)

{

register size_t i = strlen(message);

if (i>2 && (message[i-2] == '\r' || message[i-2] == '\n') && message[i-1] == '.') {

--i;

}

while (i>1 && (message[i-1] == '\r' || message[i-1] == '\n')) {

--i;

}

if (len) {

*len = i;

}

return estrndup(message, i);

}

/* }}} */

/* {{{ _php_pgsql_trim_result */

static inline char * _php_pgsql_trim_result(PGconn * pgsql, char **buf)

{

return *buf = _php_pgsql_trim_message(PQerrorMessage(pgsql), NULL);

}

/* }}} */

#define PQErrorMessageTrim(pgsql, buf) _php_pgsql_trim_result(pgsql, buf)

#define PHP_PQ_ERROR(text, pgsql) { \

char *msgbuf = _php_pgsql_trim_message(PQerrorMessage(pgsql), NULL); \

php_error_docref(NULL, E_WARNING, text, msgbuf); \

efree(msgbuf); \

} \

/* {{{ php_pgsql_set_default_link

*/

static void php_pgsql_set_default_link(zend_resource *res)

{

GC_ADDREF(res);

if (PGG(default_link) != NULL) {

zend_list_delete(PGG(default_link));

}

PGG(default_link) = res;

}

/* }}} */

/* {{{ _close_pgsql_link

*/

static void _close_pgsql_link(zend_resource *rsrc)

{

PGconn *link = (PGconn *)rsrc->ptr;

PGresult *res;

while ((res = PQgetResult(link))) {

PQclear(res);

}

PQfinish(link);

PGG(num_links)--;

}

/* }}} */

/* {{{ _close_pgsql_plink

*/

static void _close_pgsql_plink(zend_resource *rsrc)

{

PGconn *link = (PGconn *)rsrc->ptr;

PGresult *res;

while ((res = PQgetResult(link))) {

PQclear(res);

}

PQfinish(link);

PGG(num_persistent)--;

PGG(num_links)--;

}

/* }}} */

/* {{{ _php_pgsql_notice_handler

*/

static void _php_pgsql_notice_handler(void *resource_id, const char *message)

{

zval *notices;

zval tmp;

char *trimed_message;

size_t trimed_message_len;

if (! PGG(ignore_notices)) {

notices = zend_hash_index_find(&PGG(notices), (zend_ulong)resource_id);

if (!notices) {

array_init(&tmp);

notices = &tmp;

zend_hash_index_update(&PGG(notices), (zend_ulong)resource_id, notices);

}

trimed_message = _php_pgsql_trim_message(message, &trimed_message_len);

if (PGG(log_notices)) {

php_error_docref(NULL, E_NOTICE, "%s", trimed_message);

}

add_next_index_stringl(notices, trimed_message, trimed_message_len);

efree(trimed_message);

}

}

/* }}} */

/* {{{ _rollback_transactions

*/

static int _rollback_transactions(zval *el)

{

PGconn *link;

PGresult *res;

zend_resource *rsrc = Z_RES_P(el);

if (rsrc->type != le_plink)