pg_link            84 ext/pgsql/pgsql.c #define PQ_SETNONBLOCKING(pg_link, flag) PQsetnonblocking(pg_link, flag)
pg_link            86 ext/pgsql/pgsql.c #define PQ_SETNONBLOCKING(pg_link, flag) 0
pg_link          2321 ext/pgsql/pgsql.c 	PGconn *pg_link;
pg_link          2329 ext/pgsql/pgsql.c 	ZEND_FETCH_RESOURCE2(pg_link, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
pg_link          5465 ext/pgsql/pgsql.c PHP_PGSQL_API int php_pgsql_meta_data(PGconn *pg_link, const char *table_name, zval *meta, zend_bool extended TSRMLS_DC)
pg_link          5513 ext/pgsql/pgsql.c 	new_len = PQescapeStringConn(pg_link, escaped, tmp_name2, strlen(tmp_name2), NULL);
pg_link          5521 ext/pgsql/pgsql.c 	new_len = PQescapeStringConn(pg_link, escaped, tmp_name, strlen(tmp_name), NULL);
pg_link          5531 ext/pgsql/pgsql.c 	pg_result = PQexec(pg_link, querystr.c);
pg_link          5786 ext/pgsql/pgsql.c PHP_PGSQL_API int php_pgsql_convert(PGconn *pg_link, const char *table_name, const zval *values, zval *result, ulong opt TSRMLS_DC) 
pg_link          5796 ext/pgsql/pgsql.c 	assert(pg_link != NULL);
pg_link          5808 ext/pgsql/pgsql.c 	if (php_pgsql_meta_data(pg_link, table_name, meta, 0 TSRMLS_CC) == FAILURE) {
pg_link          6043 ext/pgsql/pgsql.c 							Z_STRLEN_P(new_val) = (int)PQescapeStringConn(pg_link, tmp, Z_STRVAL_PP(val), Z_STRLEN_PP(val), NULL);
pg_link          6331 ext/pgsql/pgsql.c 							tmp = PQescapeByteaConn(pg_link, (unsigned char *)Z_STRVAL_PP(val), Z_STRLEN_PP(val), &to_len);
pg_link          6423 ext/pgsql/pgsql.c 				escaped = PGSQLescapeIdentifier(pg_link, field, field_len);
pg_link          6449 ext/pgsql/pgsql.c 	PGconn *pg_link;
pg_link          6465 ext/pgsql/pgsql.c 	ZEND_FETCH_RESOURCE2(pg_link, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
pg_link          6467 ext/pgsql/pgsql.c 	if (php_pgsql_flush_query(pg_link TSRMLS_CC)) {
pg_link          6471 ext/pgsql/pgsql.c 	if (php_pgsql_convert(pg_link, table_name, values, return_value, option TSRMLS_CC) == FAILURE) {
pg_link          6478 ext/pgsql/pgsql.c static int do_exec(smart_str *querystr, int expect, PGconn *pg_link, ulong opt TSRMLS_DC)
pg_link          6481 ext/pgsql/pgsql.c 		if (PQsendQuery(pg_link, querystr->c)) {
pg_link          6488 ext/pgsql/pgsql.c 		pg_result = PQexec(pg_link, querystr->c);
pg_link          6501 ext/pgsql/pgsql.c static inline void build_tablename(smart_str *querystr, PGconn *pg_link, const char *table)
pg_link          6517 ext/pgsql/pgsql.c 		escaped = PGSQLescapeIdentifier(pg_link, token, len);
pg_link          6528 ext/pgsql/pgsql.c 			escaped = PGSQLescapeIdentifier(pg_link, tmp, len);
pg_link          6539 ext/pgsql/pgsql.c PHP_PGSQL_API int php_pgsql_insert(PGconn *pg_link, const char *table, zval *var_array, ulong opt, char **sql TSRMLS_DC)
pg_link          6550 ext/pgsql/pgsql.c 	assert(pg_link != NULL);
pg_link          6556 ext/pgsql/pgsql.c 		build_tablename(&querystr, pg_link, table);
pg_link          6566 ext/pgsql/pgsql.c 		if (php_pgsql_convert(pg_link, table, var_array, converted, (opt & PGSQL_CONV_OPTS) TSRMLS_CC) == FAILURE) {
pg_link          6573 ext/pgsql/pgsql.c 	build_tablename(&querystr, pg_link, table);
pg_link          6584 ext/pgsql/pgsql.c 			tmp = PGSQLescapeIdentifier(pg_link, fld, fld_len);
pg_link          6608 ext/pgsql/pgsql.c 					new_len = PQescapeStringConn(pg_link, tmp, Z_STRVAL_PP(val), Z_STRLEN_PP(val), NULL);
pg_link          6642 ext/pgsql/pgsql.c 		do_exec(&querystr, PGRES_COMMAND_OK, pg_link, (opt & PGSQL_CONV_OPTS) TSRMLS_CC) == 0) {
pg_link          6672 ext/pgsql/pgsql.c 	PGconn *pg_link;
pg_link          6687 ext/pgsql/pgsql.c 	ZEND_FETCH_RESOURCE2(pg_link, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
pg_link          6689 ext/pgsql/pgsql.c 	if (php_pgsql_flush_query(pg_link TSRMLS_CC)) {
pg_link          6696 ext/pgsql/pgsql.c 		if (php_pgsql_insert(pg_link, table, values, option|PGSQL_DML_STRING, &sql TSRMLS_CC) == FAILURE) {
pg_link          6699 ext/pgsql/pgsql.c 		pg_result = PQexec(pg_link, sql);
pg_link          6700 ext/pgsql/pgsql.c 		if ((PGG(auto_reset_persistent) & 2) && PQstatus(pg_link) != CONNECTION_OK) {
pg_link          6702 ext/pgsql/pgsql.c 			PQreset(pg_link);
pg_link          6703 ext/pgsql/pgsql.c 			pg_result = PQexec(pg_link, sql);
pg_link          6710 ext/pgsql/pgsql.c 			status = (ExecStatusType) PQstatus(pg_link);
pg_link          6718 ext/pgsql/pgsql.c 				PHP_PQ_ERROR("Query failed: %s", pg_link);
pg_link          6726 ext/pgsql/pgsql.c 					pgsql_handle->conn = pg_link;
pg_link          6737 ext/pgsql/pgsql.c 	} else if (php_pgsql_insert(pg_link, table, values, option, &sql TSRMLS_CC) == FAILURE) {
pg_link          6747 ext/pgsql/pgsql.c static inline int build_assignment_string(PGconn *pg_link, smart_str *querystr, HashTable *ht, int where_cond, const char *pad, int pad_len, ulong opt TSRMLS_DC)
pg_link          6766 ext/pgsql/pgsql.c 			tmp = PGSQLescapeIdentifier(pg_link, fld, fld_len);
pg_link          6783 ext/pgsql/pgsql.c 					new_len = PQescapeStringConn(pg_link, tmp, Z_STRVAL_PP(val), Z_STRLEN_PP(val), NULL);
pg_link          6814 ext/pgsql/pgsql.c PHP_PGSQL_API int php_pgsql_update(PGconn *pg_link, const char *table, zval *var_array, zval *ids_array, ulong opt, char **sql TSRMLS_DC) 
pg_link          6820 ext/pgsql/pgsql.c 	assert(pg_link != NULL);
pg_link          6834 ext/pgsql/pgsql.c 		if (php_pgsql_convert(pg_link, table, var_array, var_converted, (opt & PGSQL_CONV_OPTS) TSRMLS_CC) == FAILURE) {
pg_link          6840 ext/pgsql/pgsql.c 		if (php_pgsql_convert(pg_link, table, ids_array, ids_converted, (opt & PGSQL_CONV_OPTS) TSRMLS_CC) == FAILURE) {
pg_link          6847 ext/pgsql/pgsql.c 	build_tablename(&querystr, pg_link, table);
pg_link          6850 ext/pgsql/pgsql.c 	if (build_assignment_string(pg_link, &querystr, Z_ARRVAL_P(var_array), 0, ",", 1, opt TSRMLS_CC))
pg_link          6855 ext/pgsql/pgsql.c 	if (build_assignment_string(pg_link, &querystr, Z_ARRVAL_P(ids_array), 1, " AND ", sizeof(" AND ")-1, opt TSRMLS_CC))
pg_link          6861 ext/pgsql/pgsql.c 	if ((opt & PGSQL_DML_EXEC) && do_exec(&querystr, PGRES_COMMAND_OK, pg_link, opt TSRMLS_CC) == 0) {
pg_link          6894 ext/pgsql/pgsql.c 	PGconn *pg_link;
pg_link          6906 ext/pgsql/pgsql.c 	ZEND_FETCH_RESOURCE2(pg_link, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
pg_link          6908 ext/pgsql/pgsql.c 	if (php_pgsql_flush_query(pg_link TSRMLS_CC)) {
pg_link          6911 ext/pgsql/pgsql.c 	if (php_pgsql_update(pg_link, table, values, ids, option, &sql TSRMLS_CC) == FAILURE) {
pg_link          6923 ext/pgsql/pgsql.c PHP_PGSQL_API int php_pgsql_delete(PGconn *pg_link, const char *table, zval *ids_array, ulong opt, char **sql TSRMLS_DC) 
pg_link          6929 ext/pgsql/pgsql.c 	assert(pg_link != NULL);
pg_link          6941 ext/pgsql/pgsql.c 		if (php_pgsql_convert(pg_link, table, ids_array, ids_converted, (opt & PGSQL_CONV_OPTS) TSRMLS_CC) == FAILURE) {
pg_link          6948 ext/pgsql/pgsql.c 	build_tablename(&querystr, pg_link, table);
pg_link          6951 ext/pgsql/pgsql.c 	if (build_assignment_string(pg_link, &querystr, Z_ARRVAL_P(ids_array), 1, " AND ", sizeof(" AND ")-1, opt TSRMLS_CC))
pg_link          6957 ext/pgsql/pgsql.c 	if ((opt & PGSQL_DML_EXEC) && do_exec(&querystr, PGRES_COMMAND_OK, pg_link, opt TSRMLS_CC) == 0) {
pg_link          6986 ext/pgsql/pgsql.c 	PGconn *pg_link;
pg_link          6998 ext/pgsql/pgsql.c 	ZEND_FETCH_RESOURCE2(pg_link, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
pg_link          7000 ext/pgsql/pgsql.c 	if (php_pgsql_flush_query(pg_link TSRMLS_CC)) {
pg_link          7003 ext/pgsql/pgsql.c 	if (php_pgsql_delete(pg_link, table, ids, option, &sql TSRMLS_CC) == FAILURE) {
pg_link          7057 ext/pgsql/pgsql.c PHP_PGSQL_API int php_pgsql_select(PGconn *pg_link, const char *table, zval *ids_array, zval *ret_array, ulong opt, char **sql TSRMLS_DC)
pg_link          7064 ext/pgsql/pgsql.c 	assert(pg_link != NULL);
pg_link          7077 ext/pgsql/pgsql.c 		if (php_pgsql_convert(pg_link, table, ids_array, ids_converted, (opt & PGSQL_CONV_OPTS) TSRMLS_CC) == FAILURE) {
pg_link          7084 ext/pgsql/pgsql.c 	build_tablename(&querystr, pg_link, table);
pg_link          7087 ext/pgsql/pgsql.c 	if (build_assignment_string(pg_link, &querystr, Z_ARRVAL_P(ids_array), 1, " AND ", sizeof(" AND ")-1, opt TSRMLS_CC))
pg_link          7093 ext/pgsql/pgsql.c 	pg_result = PQexec(pg_link, querystr.c);
pg_link          7124 ext/pgsql/pgsql.c 	PGconn *pg_link;
pg_link          7136 ext/pgsql/pgsql.c 	ZEND_FETCH_RESOURCE2(pg_link, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
pg_link          7138 ext/pgsql/pgsql.c 	if (php_pgsql_flush_query(pg_link TSRMLS_CC)) {
pg_link          7142 ext/pgsql/pgsql.c 	if (php_pgsql_select(pg_link, table, ids, return_value, option, &sql TSRMLS_CC) == FAILURE) {
pg_link           213 ext/pgsql/php_pgsql.h PHP_PGSQL_API int php_pgsql_meta_data(PGconn *pg_link, const char *table_name, zval *meta, zend_bool extended TSRMLS_DC);
pg_link           214 ext/pgsql/php_pgsql.h PHP_PGSQL_API int php_pgsql_convert(PGconn *pg_link, const char *table_name, const zval *values, zval *result, ulong opt TSRMLS_DC);
pg_link           215 ext/pgsql/php_pgsql.h PHP_PGSQL_API int php_pgsql_insert(PGconn *pg_link, const char *table, zval *values, ulong opt, char **sql TSRMLS_DC);
pg_link           216 ext/pgsql/php_pgsql.h PHP_PGSQL_API int php_pgsql_update(PGconn *pg_link, const char *table, zval *values, zval *ids, ulong opt , char **sql TSRMLS_DC);
pg_link           217 ext/pgsql/php_pgsql.h PHP_PGSQL_API int php_pgsql_delete(PGconn *pg_link, const char *table, zval *ids, ulong opt, char **sql TSRMLS_DC);
pg_link           218 ext/pgsql/php_pgsql.h PHP_PGSQL_API int php_pgsql_select(PGconn *pg_link, const char *table, zval *ids, zval *ret_array, ulong opt, char **sql  TSRMLS_DC);