Lines Matching refs:S
63 pdo_pgsql_stmt *S = (pdo_pgsql_stmt*)stmt->driver_data; in pgsql_stmt_dtor() local
68 if (S->result) { in pgsql_stmt_dtor()
70 PQclear(S->result); in pgsql_stmt_dtor()
71 S->result = NULL; in pgsql_stmt_dtor()
74 if (S->stmt_name) { in pgsql_stmt_dtor()
75 if (S->is_prepared && server_obj_usable) { in pgsql_stmt_dtor()
76 pdo_pgsql_db_handle *H = S->H; in pgsql_stmt_dtor()
80 spprintf(&q, 0, "DEALLOCATE %s", S->stmt_name); in pgsql_stmt_dtor()
87 efree(S->stmt_name); in pgsql_stmt_dtor()
88 S->stmt_name = NULL; in pgsql_stmt_dtor()
90 if (S->param_lengths) { in pgsql_stmt_dtor()
91 efree(S->param_lengths); in pgsql_stmt_dtor()
92 S->param_lengths = NULL; in pgsql_stmt_dtor()
94 if (S->param_values) { in pgsql_stmt_dtor()
95 efree(S->param_values); in pgsql_stmt_dtor()
96 S->param_values = NULL; in pgsql_stmt_dtor()
98 if (S->param_formats) { in pgsql_stmt_dtor()
99 efree(S->param_formats); in pgsql_stmt_dtor()
100 S->param_formats = NULL; in pgsql_stmt_dtor()
102 if (S->param_types) { in pgsql_stmt_dtor()
103 efree(S->param_types); in pgsql_stmt_dtor()
104 S->param_types = NULL; in pgsql_stmt_dtor()
106 if (S->query) { in pgsql_stmt_dtor()
107 efree(S->query); in pgsql_stmt_dtor()
108 S->query = NULL; in pgsql_stmt_dtor()
111 if (S->cursor_name) { in pgsql_stmt_dtor()
113 pdo_pgsql_db_handle *H = S->H; in pgsql_stmt_dtor()
117 spprintf(&q, 0, "CLOSE %s", S->cursor_name); in pgsql_stmt_dtor()
122 efree(S->cursor_name); in pgsql_stmt_dtor()
123 S->cursor_name = NULL; in pgsql_stmt_dtor()
126 if(S->cols) { in pgsql_stmt_dtor()
127 efree(S->cols); in pgsql_stmt_dtor()
128 S->cols = NULL; in pgsql_stmt_dtor()
130 efree(S); in pgsql_stmt_dtor()
137 pdo_pgsql_stmt *S = (pdo_pgsql_stmt*)stmt->driver_data; in pgsql_stmt_execute() local
138 pdo_pgsql_db_handle *H = S->H; in pgsql_stmt_execute()
142 if(S->result) { in pgsql_stmt_execute()
143 PQclear(S->result); in pgsql_stmt_execute()
144 S->result = NULL; in pgsql_stmt_execute()
147 S->current_row = 0; in pgsql_stmt_execute()
149 if (S->cursor_name) { in pgsql_stmt_execute()
152 if (S->is_prepared) { in pgsql_stmt_execute()
153 spprintf(&q, 0, "CLOSE %s", S->cursor_name); in pgsql_stmt_execute()
154 S->result = PQexec(H->server, q); in pgsql_stmt_execute()
158 …spprintf(&q, 0, "DECLARE %s SCROLL CURSOR WITH HOLD FOR %s", S->cursor_name, stmt->active_query_st… in pgsql_stmt_execute()
159 S->result = PQexec(H->server, q); in pgsql_stmt_execute()
163 status = PQresultStatus(S->result); in pgsql_stmt_execute()
165 pdo_pgsql_error_stmt(stmt, status, pdo_pgsql_sqlstate(S->result)); in pgsql_stmt_execute()
168 PQclear(S->result); in pgsql_stmt_execute()
171 S->is_prepared = 1; in pgsql_stmt_execute()
174 spprintf(&q, 0, "FETCH FORWARD 0 FROM %s", S->cursor_name); in pgsql_stmt_execute()
175 S->result = PQexec(H->server, q); in pgsql_stmt_execute()
177 } else if (S->stmt_name) { in pgsql_stmt_execute()
180 if (!S->is_prepared) { in pgsql_stmt_execute()
184 S->result = PQprepare(H->server, S->stmt_name, S->query, in pgsql_stmt_execute()
186 S->param_types); in pgsql_stmt_execute()
187 status = PQresultStatus(S->result); in pgsql_stmt_execute()
192 S->is_prepared = 1; in pgsql_stmt_execute()
193 PQclear(S->result); in pgsql_stmt_execute()
196 char *sqlstate = pdo_pgsql_sqlstate(S->result); in pgsql_stmt_execute()
206 snprintf(buf, sizeof(buf), "DEALLOCATE %s", S->stmt_name); in pgsql_stmt_execute()
219 S->result = PQexecPrepared(H->server, S->stmt_name, in pgsql_stmt_execute()
223 (const char**)S->param_values, in pgsql_stmt_execute()
224 S->param_lengths, in pgsql_stmt_execute()
225 S->param_formats, in pgsql_stmt_execute()
229 S->result = PQexecParams(H->server, S->query, in pgsql_stmt_execute()
231 S->param_types, in pgsql_stmt_execute()
232 (const char**)S->param_values, in pgsql_stmt_execute()
233 S->param_lengths, in pgsql_stmt_execute()
234 S->param_formats, in pgsql_stmt_execute()
238 S->result = PQexec(H->server, stmt->active_query_string); in pgsql_stmt_execute()
240 status = PQresultStatus(S->result); in pgsql_stmt_execute()
243 pdo_pgsql_error_stmt(stmt, status, pdo_pgsql_sqlstate(S->result)); in pgsql_stmt_execute()
247 if (!stmt->executed && (!stmt->column_count || S->cols == NULL)) { in pgsql_stmt_execute()
248 stmt->column_count = (int) PQnfields(S->result); in pgsql_stmt_execute()
249 S->cols = ecalloc(stmt->column_count, sizeof(pdo_pgsql_column)); in pgsql_stmt_execute()
253 ZEND_ATOL(stmt->row_count, PQcmdTuples(S->result)); in pgsql_stmt_execute()
254 H->pgoid = PQoidValue(S->result); in pgsql_stmt_execute()
256 stmt->row_count = (zend_long)PQntuples(S->result); in pgsql_stmt_execute()
265 pdo_pgsql_stmt *S = (pdo_pgsql_stmt*)stmt->driver_data; in pgsql_stmt_param_hook() local
314 if (!S->param_values) { in pgsql_stmt_param_hook()
315 S->param_values = ecalloc( in pgsql_stmt_param_hook()
318 S->param_lengths = ecalloc( in pgsql_stmt_param_hook()
321 S->param_formats = ecalloc( in pgsql_stmt_param_hook()
324 S->param_types = ecalloc( in pgsql_stmt_param_hook()
358 S->param_values[param->paramno] = (char*)&P->oid; in pgsql_stmt_param_hook()
359 S->param_lengths[param->paramno] = sizeof(P->oid); in pgsql_stmt_param_hook()
360 S->param_formats[param->paramno] = 1; in pgsql_stmt_param_hook()
361 S->param_types[param->paramno] = OIDOID; in pgsql_stmt_param_hook()
381 S->param_values[param->paramno] = NULL; in pgsql_stmt_param_hook()
382 S->param_lengths[param->paramno] = 0; in pgsql_stmt_param_hook()
384 S->param_values[param->paramno] = Z_TYPE_P(parameter) == IS_TRUE ? "t" : "f"; in pgsql_stmt_param_hook()
385 S->param_lengths[param->paramno] = 1; in pgsql_stmt_param_hook()
386 S->param_formats[param->paramno] = 0; in pgsql_stmt_param_hook()
390 S->param_values[param->paramno] = Z_STRVAL_P(parameter); in pgsql_stmt_param_hook()
391 S->param_lengths[param->paramno] = Z_STRLEN_P(parameter); in pgsql_stmt_param_hook()
392 S->param_formats[param->paramno] = 0; in pgsql_stmt_param_hook()
396 S->param_types[param->paramno] = 0; in pgsql_stmt_param_hook()
397 S->param_formats[param->paramno] = 1; in pgsql_stmt_param_hook()
399 S->param_types[param->paramno] = 0; in pgsql_stmt_param_hook()
420 pdo_pgsql_stmt *S = (pdo_pgsql_stmt*)stmt->driver_data; in pgsql_stmt_fetch() local
422 if (S->cursor_name) { in pgsql_stmt_fetch()
438 if(S->result) { in pgsql_stmt_fetch()
439 PQclear(S->result); in pgsql_stmt_fetch()
440 S->result = NULL; in pgsql_stmt_fetch()
443 spprintf(&q, 0, "FETCH %s FROM %s", ori_str, S->cursor_name); in pgsql_stmt_fetch()
445 S->result = PQexec(S->H->server, q); in pgsql_stmt_fetch()
447 status = PQresultStatus(S->result); in pgsql_stmt_fetch()
450 pdo_pgsql_error_stmt(stmt, status, pdo_pgsql_sqlstate(S->result)); in pgsql_stmt_fetch()
454 if (PQntuples(S->result)) { in pgsql_stmt_fetch()
455 S->current_row = 1; in pgsql_stmt_fetch()
461 if (S->current_row < stmt->row_count) { in pgsql_stmt_fetch()
462 S->current_row++; in pgsql_stmt_fetch()
472 pdo_pgsql_stmt *S = (pdo_pgsql_stmt*)stmt->driver_data; in pgsql_stmt_describe() local
477 if (!S->result) { in pgsql_stmt_describe()
481 str = PQfname(S->result, colno); in pgsql_stmt_describe()
483 cols[colno].maxlen = PQfsize(S->result, colno); in pgsql_stmt_describe()
484 cols[colno].precision = PQfmod(S->result, colno); in pgsql_stmt_describe()
485 S->cols[colno].pgsql_type = PQftype(S->result, colno); in pgsql_stmt_describe()
487 switch (S->cols[colno].pgsql_type) { in pgsql_stmt_describe()
533 pdo_pgsql_stmt *S = (pdo_pgsql_stmt*)stmt->driver_data; in pgsql_stmt_get_col() local
537 if (!S->result) { in pgsql_stmt_get_col()
542 if (PQgetisnull(S->result, S->current_row - 1, colno)) { /* Check if we got NULL */ in pgsql_stmt_get_col()
546 *ptr = PQgetvalue(S->result, S->current_row - 1, colno); in pgsql_stmt_get_col()
547 *len = PQgetlength(S->result, S->current_row - 1, colno); in pgsql_stmt_get_col()
552 ZEND_ATOL(S->cols[colno].intval, *ptr); in pgsql_stmt_get_col()
553 *ptr = (char *) &(S->cols[colno].intval); in pgsql_stmt_get_col()
558 S->cols[colno].boolval = **ptr == 't' ? 1: 0; in pgsql_stmt_get_col()
559 *ptr = (char *) &(S->cols[colno].boolval); in pgsql_stmt_get_col()
564 if (S->cols[colno].pgsql_type == OIDOID) { in pgsql_stmt_get_col()
568 int loid = lo_open(S->H->server, oid, INV_READ); in pgsql_stmt_get_col()
640 pdo_pgsql_stmt *S = (pdo_pgsql_stmt*)stmt->driver_data; in pgsql_stmt_get_column_meta() local
647 if (!S->result) { in pgsql_stmt_get_column_meta()
656 add_assoc_long(return_value, "pgsql:oid", S->cols[colno].pgsql_type); in pgsql_stmt_get_column_meta()
658 table_oid = PQftable(S->result, colno); in pgsql_stmt_get_column_meta()
660 table_name = pdo_pgsql_translate_oid_to_table(table_oid, S->H->server); in pgsql_stmt_get_column_meta()
666 switch (S->cols[colno].pgsql_type) { in pgsql_stmt_get_column_meta()
696 spprintf(&q, 0, "SELECT TYPNAME FROM PG_TYPE WHERE OID=%u", S->cols[colno].pgsql_type); in pgsql_stmt_get_column_meta()
697 res = PQexec(S->H->server, q); in pgsql_stmt_get_column_meta()
710 pdo_pgsql_stmt *S = (pdo_pgsql_stmt*)stmt->driver_data; in pdo_pgsql_stmt_cursor_closer() local
712 if (S->cols != NULL){ in pdo_pgsql_stmt_cursor_closer()
713 efree(S->cols); in pdo_pgsql_stmt_cursor_closer()
714 S->cols = NULL; in pdo_pgsql_stmt_cursor_closer()
