Lines Matching refs:stmt
59 static int pgsql_stmt_dtor(pdo_stmt_t *stmt) in pgsql_stmt_dtor() argument
61 pdo_pgsql_stmt *S = (pdo_pgsql_stmt*)stmt->driver_data; in pgsql_stmt_dtor()
62 zend_bool server_obj_usable = !Z_ISUNDEF(stmt->database_object_handle) in pgsql_stmt_dtor()
63 && IS_OBJ_VALID(EG(objects_store).object_buckets[Z_OBJ_HANDLE(stmt->database_object_handle)]) in pgsql_stmt_dtor()
64 && !(OBJ_FLAGS(Z_OBJ(stmt->database_object_handle)) & IS_OBJ_FREE_CALLED); in pgsql_stmt_dtor()
129 stmt->driver_data = NULL; in pgsql_stmt_dtor()
133 static int pgsql_stmt_execute(pdo_stmt_t *stmt) in pgsql_stmt_execute() argument
135 pdo_pgsql_stmt *S = (pdo_pgsql_stmt*)stmt->driver_data; in pgsql_stmt_execute()
156 …spprintf(&q, 0, "DECLARE %s SCROLL CURSOR WITH HOLD FOR %s", S->cursor_name, stmt->active_query_st… in pgsql_stmt_execute()
163 pdo_pgsql_error_stmt(stmt, status, pdo_pgsql_sqlstate(S->result)); in pgsql_stmt_execute()
183 stmt->bound_params ? zend_hash_num_elements(stmt->bound_params) : 0, in pgsql_stmt_execute()
211 pdo_pgsql_error_stmt(stmt, status, sqlstate); in pgsql_stmt_execute()
218 stmt->bound_params ? in pgsql_stmt_execute()
219 zend_hash_num_elements(stmt->bound_params) : in pgsql_stmt_execute()
225 } else if (stmt->supports_placeholders == PDO_PLACEHOLDER_NAMED) { in pgsql_stmt_execute()
228 stmt->bound_params ? zend_hash_num_elements(stmt->bound_params) : 0, in pgsql_stmt_execute()
236 S->result = PQexec(H->server, stmt->active_query_string); in pgsql_stmt_execute()
241 pdo_pgsql_error_stmt(stmt, status, pdo_pgsql_sqlstate(S->result)); in pgsql_stmt_execute()
245 if (!stmt->executed && (!stmt->column_count || S->cols == NULL)) { in pgsql_stmt_execute()
246 stmt->column_count = (int) PQnfields(S->result); in pgsql_stmt_execute()
247 S->cols = ecalloc(stmt->column_count, sizeof(pdo_pgsql_column)); in pgsql_stmt_execute()
251 ZEND_ATOL(stmt->row_count, PQcmdTuples(S->result)); in pgsql_stmt_execute()
254 stmt->row_count = (zend_long)PQntuples(S->result); in pgsql_stmt_execute()
260 static int pgsql_stmt_param_hook(pdo_stmt_t *stmt, struct pdo_bound_param_data *param, in pgsql_stmt_param_hook() argument
263 pdo_pgsql_stmt *S = (pdo_pgsql_stmt*)stmt->driver_data; in pgsql_stmt_param_hook()
265 if (stmt->supports_placeholders == PDO_PLACEHOLDER_NAMED && param->is_param) { in pgsql_stmt_param_hook()
282 if (stmt->bound_param_map && (namevar = zend_hash_find_ptr(stmt->bound_param_map, in pgsql_stmt_param_hook()
287 pdo_raise_impl_error(stmt->dbh, stmt, "HY093", ZSTR_VAL(param->name)); in pgsql_stmt_param_hook()
295 if (!stmt->bound_param_map) { in pgsql_stmt_param_hook()
298 if (!zend_hash_index_exists(stmt->bound_param_map, param->paramno)) { in pgsql_stmt_param_hook()
299 pdo_raise_impl_error(stmt->dbh, stmt, "HY093", "parameter was not defined"); in pgsql_stmt_param_hook()
309 if (!stmt->bound_param_map) { in pgsql_stmt_param_hook()
314 zend_hash_num_elements(stmt->bound_param_map), in pgsql_stmt_param_hook()
317 zend_hash_num_elements(stmt->bound_param_map), in pgsql_stmt_param_hook()
320 zend_hash_num_elements(stmt->bound_param_map), in pgsql_stmt_param_hook()
323 zend_hash_num_elements(stmt->bound_param_map), in pgsql_stmt_param_hook()
372 pdo_pgsql_error_stmt(stmt, PGRES_FATAL_ERROR, "HY105"); in pgsql_stmt_param_hook()
415 static int pgsql_stmt_fetch(pdo_stmt_t *stmt, in pgsql_stmt_fetch() argument
418 pdo_pgsql_stmt *S = (pdo_pgsql_stmt*)stmt->driver_data; in pgsql_stmt_fetch()
448 pdo_pgsql_error_stmt(stmt, status, pdo_pgsql_sqlstate(S->result)); in pgsql_stmt_fetch()
459 if (S->current_row < stmt->row_count) { in pgsql_stmt_fetch()
468 static int pgsql_stmt_describe(pdo_stmt_t *stmt, int colno) in pgsql_stmt_describe() argument
470 pdo_pgsql_stmt *S = (pdo_pgsql_stmt*)stmt->driver_data; in pgsql_stmt_describe()
471 struct pdo_column_data *cols = stmt->columns; in pgsql_stmt_describe()
493 if (stmt->bound_columns && ( in pgsql_stmt_describe()
494 (param = zend_hash_index_find_ptr(stmt->bound_columns, colno)) != NULL || in pgsql_stmt_describe()
495 (param = zend_hash_find_ptr(stmt->bound_columns, cols[colno].name)) != NULL)) { in pgsql_stmt_describe()
529 static int pgsql_stmt_get_col(pdo_stmt_t *stmt, int colno, char **ptr, size_t *len, int *caller_fre… in pgsql_stmt_get_col() argument
531 pdo_pgsql_stmt *S = (pdo_pgsql_stmt*)stmt->driver_data; in pgsql_stmt_get_col()
532 struct pdo_column_data *cols = stmt->columns; in pgsql_stmt_get_col()
568 *ptr = (char*)pdo_pgsql_create_lob_stream(&stmt->database_object_handle, loid, oid); in pgsql_stmt_get_col()
636 static int pgsql_stmt_get_column_meta(pdo_stmt_t *stmt, zend_long colno, zval *return_value) in pgsql_stmt_get_column_meta() argument
638 pdo_pgsql_stmt *S = (pdo_pgsql_stmt*)stmt->driver_data; in pgsql_stmt_get_column_meta()
649 if (colno >= stmt->column_count) { in pgsql_stmt_get_column_meta()
706 static int pdo_pgsql_stmt_cursor_closer(pdo_stmt_t *stmt) in pdo_pgsql_stmt_cursor_closer() argument
708 pdo_pgsql_stmt *S = (pdo_pgsql_stmt*)stmt->driver_data; in pdo_pgsql_stmt_cursor_closer()
