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          2314 ext/pgsql/pgsql.c 	PGconn *pg_link;
pg_link          2322 ext/pgsql/pgsql.c 	if ((pg_link = (PGconn *)zend_fetch_resource2(Z_RES_P(pgsql_link), "PostgreSQL link", le_link, le_plink)) == NULL) {
pg_link          5488 ext/pgsql/pgsql.c PHP_PGSQL_API int php_pgsql_meta_data(PGconn *pg_link, const char *table_name, zval *meta, zend_bool extended)
pg_link          5536 ext/pgsql/pgsql.c 	new_len = PQescapeStringConn(pg_link, escaped, tmp_name2, strlen(tmp_name2), NULL);
pg_link          5544 ext/pgsql/pgsql.c 	new_len = PQescapeStringConn(pg_link, escaped, tmp_name, strlen(tmp_name), NULL);
pg_link          5554 ext/pgsql/pgsql.c 	pg_result = PQexec(pg_link, ZSTR_VAL(querystr.s));
pg_link          5801 ext/pgsql/pgsql.c PHP_PGSQL_API int php_pgsql_convert(PGconn *pg_link, const char *table_name, const zval *values, zval *result, zend_ulong opt)
pg_link          5808 ext/pgsql/pgsql.c 	assert(pg_link != NULL);
pg_link          5819 ext/pgsql/pgsql.c 	if (php_pgsql_meta_data(pg_link, table_name, &meta, 0) == FAILURE) {
pg_link          6050 ext/pgsql/pgsql.c 							ZSTR_LEN(str) = PQescapeStringConn(pg_link, ZSTR_VAL(str), Z_STRVAL_P(val), Z_STRLEN_P(val), NULL);
pg_link          6339 ext/pgsql/pgsql.c 							tmp = PQescapeByteaConn(pg_link, (unsigned char *)Z_STRVAL_P(val), Z_STRLEN_P(val), &to_len);
pg_link          6425 ext/pgsql/pgsql.c 				escaped = PGSQLescapeIdentifier(pg_link, ZSTR_VAL(field), ZSTR_LEN(field));
pg_link          6450 ext/pgsql/pgsql.c 	PGconn *pg_link;
pg_link          6465 ext/pgsql/pgsql.c 	if ((pg_link = (PGconn *)zend_fetch_resource2(Z_RES_P(pgsql_link), "PostgreSQL link", le_link, le_plink)) == NULL) {
pg_link          6469 ext/pgsql/pgsql.c 	if (php_pgsql_flush_query(pg_link)) {
pg_link          6473 ext/pgsql/pgsql.c 	if (php_pgsql_convert(pg_link, table_name, values, return_value, option) == FAILURE) {
pg_link          6480 ext/pgsql/pgsql.c static int do_exec(smart_str *querystr, int expect, PGconn *pg_link, zend_ulong opt) /* {{{ */
pg_link          6483 ext/pgsql/pgsql.c 		if (PQsendQuery(pg_link, ZSTR_VAL(querystr->s))) {
pg_link          6490 ext/pgsql/pgsql.c 		pg_result = PQexec(pg_link, ZSTR_VAL(querystr->s));
pg_link          6504 ext/pgsql/pgsql.c static inline void build_tablename(smart_str *querystr, PGconn *pg_link, const char *table) /* {{{ */
pg_link          6520 ext/pgsql/pgsql.c 		escaped = PGSQLescapeIdentifier(pg_link, token, len);
pg_link          6531 ext/pgsql/pgsql.c 			escaped = PGSQLescapeIdentifier(pg_link, tmp, len);
pg_link          6543 ext/pgsql/pgsql.c PHP_PGSQL_API int php_pgsql_insert(PGconn *pg_link, const char *table, zval *var_array, zend_ulong opt, zend_string **sql)
pg_link          6552 ext/pgsql/pgsql.c 	assert(pg_link != NULL);
pg_link          6559 ext/pgsql/pgsql.c 		build_tablename(&querystr, pg_link, table);
pg_link          6568 ext/pgsql/pgsql.c 		if (php_pgsql_convert(pg_link, table, var_array, &converted, (opt & PGSQL_CONV_OPTS)) == FAILURE) {
pg_link          6575 ext/pgsql/pgsql.c 	build_tablename(&querystr, pg_link, table);
pg_link          6584 ext/pgsql/pgsql.c 			tmp = PGSQLescapeIdentifier(pg_link, ZSTR_VAL(fld), ZSTR_LEN(fld) + 1);
pg_link          6604 ext/pgsql/pgsql.c 					new_len = PQescapeStringConn(pg_link, tmp, Z_STRVAL_P(val), Z_STRLEN_P(val), NULL);
pg_link          6638 ext/pgsql/pgsql.c 		do_exec(&querystr, PGRES_COMMAND_OK, pg_link, (opt & PGSQL_CONV_OPTS)) == 0) {
pg_link          6665 ext/pgsql/pgsql.c 	PGconn *pg_link;
pg_link          6681 ext/pgsql/pgsql.c 	if ((pg_link = (PGconn *)zend_fetch_resource2(Z_RES_P(pgsql_link), "PostgreSQL link", le_link, le_plink)) == NULL) {
pg_link          6685 ext/pgsql/pgsql.c 	if (php_pgsql_flush_query(pg_link)) {
pg_link          6692 ext/pgsql/pgsql.c 		if (php_pgsql_insert(pg_link, table, values, option|PGSQL_DML_STRING, &sql) == FAILURE) {
pg_link          6695 ext/pgsql/pgsql.c 		pg_result = PQexec(pg_link, ZSTR_VAL(sql));
pg_link          6696 ext/pgsql/pgsql.c 		if ((PGG(auto_reset_persistent) & 2) && PQstatus(pg_link) != CONNECTION_OK) {
pg_link          6698 ext/pgsql/pgsql.c 			PQreset(pg_link);
pg_link          6699 ext/pgsql/pgsql.c 			pg_result = PQexec(pg_link, ZSTR_VAL(sql));
pg_link          6706 ext/pgsql/pgsql.c 			status = (ExecStatusType) PQstatus(pg_link);
pg_link          6714 ext/pgsql/pgsql.c 				PHP_PQ_ERROR("Query failed: %s", pg_link);
pg_link          6722 ext/pgsql/pgsql.c 					pgsql_handle->conn = pg_link;
pg_link          6732 ext/pgsql/pgsql.c 	} else if (php_pgsql_insert(pg_link, table, values, option, &sql) == FAILURE) {
pg_link          6743 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, zend_ulong opt) /* {{{ */
pg_link          6756 ext/pgsql/pgsql.c 			tmp = PGSQLescapeIdentifier(pg_link, ZSTR_VAL(fld), ZSTR_LEN(fld) + 1);
pg_link          6773 ext/pgsql/pgsql.c 					new_len = PQescapeStringConn(pg_link, tmp, Z_STRVAL_P(val), Z_STRLEN_P(val), NULL);
pg_link          6807 ext/pgsql/pgsql.c PHP_PGSQL_API int php_pgsql_update(PGconn *pg_link, const char *table, zval *var_array, zval *ids_array, zend_ulong opt, zend_string **sql)
pg_link          6813 ext/pgsql/pgsql.c 	assert(pg_link != NULL);
pg_link          6828 ext/pgsql/pgsql.c 		if (php_pgsql_convert(pg_link, table, var_array, &var_converted, (opt & PGSQL_CONV_OPTS)) == FAILURE) {
pg_link          6833 ext/pgsql/pgsql.c 		if (php_pgsql_convert(pg_link, table, ids_array, &ids_converted, (opt & PGSQL_CONV_OPTS)) == FAILURE) {
pg_link          6840 ext/pgsql/pgsql.c 	build_tablename(&querystr, pg_link, table);
pg_link          6843 ext/pgsql/pgsql.c 	if (build_assignment_string(pg_link, &querystr, Z_ARRVAL_P(var_array), 0, ",", 1, opt))
pg_link          6848 ext/pgsql/pgsql.c 	if (build_assignment_string(pg_link, &querystr, Z_ARRVAL_P(ids_array), 1, " AND ", sizeof(" AND ")-1, opt))
pg_link          6854 ext/pgsql/pgsql.c 	if ((opt & PGSQL_DML_EXEC) && do_exec(&querystr, PGRES_COMMAND_OK, pg_link, opt) == 0) {
pg_link          6881 ext/pgsql/pgsql.c 	PGconn *pg_link;
pg_link          6894 ext/pgsql/pgsql.c 	if ((pg_link = (PGconn *)zend_fetch_resource2(Z_RES_P(pgsql_link), "PostgreSQL link", le_link, le_plink)) == NULL) {
pg_link          6898 ext/pgsql/pgsql.c 	if (php_pgsql_flush_query(pg_link)) {
pg_link          6901 ext/pgsql/pgsql.c 	if (php_pgsql_update(pg_link, table, values, ids, option, &sql) == FAILURE) {
pg_link          6913 ext/pgsql/pgsql.c PHP_PGSQL_API int php_pgsql_delete(PGconn *pg_link, const char *table, zval *ids_array, zend_ulong opt, zend_string **sql)
pg_link          6919 ext/pgsql/pgsql.c 	assert(pg_link != NULL);
pg_link          6931 ext/pgsql/pgsql.c 		if (php_pgsql_convert(pg_link, table, ids_array, &ids_converted, (opt & PGSQL_CONV_OPTS)) == FAILURE) {
pg_link          6938 ext/pgsql/pgsql.c 	build_tablename(&querystr, pg_link, table);
pg_link          6941 ext/pgsql/pgsql.c 	if (build_assignment_string(pg_link, &querystr, Z_ARRVAL_P(ids_array), 1, " AND ", sizeof(" AND ")-1, opt))
pg_link          6947 ext/pgsql/pgsql.c 	if ((opt & PGSQL_DML_EXEC) && do_exec(&querystr, PGRES_COMMAND_OK, pg_link, opt) == 0) {
pg_link          6973 ext/pgsql/pgsql.c 	PGconn *pg_link;
pg_link          6986 ext/pgsql/pgsql.c 	if ((pg_link = (PGconn *)zend_fetch_resource2(Z_RES_P(pgsql_link), "PostgreSQL link", le_link, le_plink)) == NULL) {
pg_link          6990 ext/pgsql/pgsql.c 	if (php_pgsql_flush_query(pg_link)) {
pg_link          6993 ext/pgsql/pgsql.c 	if (php_pgsql_delete(pg_link, table, ids, option, &sql) == FAILURE) {
pg_link          7041 ext/pgsql/pgsql.c PHP_PGSQL_API int php_pgsql_select(PGconn *pg_link, const char *table, zval *ids_array, zval *ret_array, zend_ulong opt, zend_string **sql)
pg_link          7048 ext/pgsql/pgsql.c 	assert(pg_link != NULL);
pg_link          7061 ext/pgsql/pgsql.c 		if (php_pgsql_convert(pg_link, table, ids_array, &ids_converted, (opt & PGSQL_CONV_OPTS)) == FAILURE) {
pg_link          7068 ext/pgsql/pgsql.c 	build_tablename(&querystr, pg_link, table);
pg_link          7071 ext/pgsql/pgsql.c 	if (build_assignment_string(pg_link, &querystr, Z_ARRVAL_P(ids_array), 1, " AND ", sizeof(" AND ")-1, opt))
pg_link          7077 ext/pgsql/pgsql.c 	pg_result = PQexec(pg_link, ZSTR_VAL(querystr.s));
pg_link          7105 ext/pgsql/pgsql.c 	PGconn *pg_link;
pg_link          7118 ext/pgsql/pgsql.c 	if ((pg_link = (PGconn *)zend_fetch_resource2(Z_RES_P(pgsql_link), "PostgreSQL link", le_link, le_plink)) == NULL) {
pg_link          7122 ext/pgsql/pgsql.c 	if (php_pgsql_flush_query(pg_link)) {
pg_link          7126 ext/pgsql/pgsql.c 	if (php_pgsql_select(pg_link, table, ids, return_value, option, &sql) == FAILURE) {
pg_link           216 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);
pg_link           217 ext/pgsql/php_pgsql.h PHP_PGSQL_API int php_pgsql_convert(PGconn *pg_link, const char *table_name, const zval *values, zval *result, zend_ulong opt);
pg_link           218 ext/pgsql/php_pgsql.h PHP_PGSQL_API int php_pgsql_insert(PGconn *pg_link, const char *table, zval *values, zend_ulong opt, zend_string **sql);
pg_link           219 ext/pgsql/php_pgsql.h PHP_PGSQL_API int php_pgsql_update(PGconn *pg_link, const char *table, zval *values, zval *ids, zend_ulong opt , zend_string **sql);
pg_link           220 ext/pgsql/php_pgsql.h PHP_PGSQL_API int php_pgsql_delete(PGconn *pg_link, const char *table, zval *ids, zend_ulong opt, zend_string **sql);
pg_link           221 ext/pgsql/php_pgsql.h PHP_PGSQL_API int php_pgsql_select(PGconn *pg_link, const char *table, zval *ids, zval *ret_array, zend_ulong opt, zend_string **sql );