Lines Matching refs:result
52 MYSQLND_RES * result; in MYSQLND_METHOD() local
55 if (!stmt || !stmt->conn || !stmt->result) { in MYSQLND_METHOD()
87 result = stmt->result; in MYSQLND_METHOD()
88 result->type = MYSQLND_RES_PS_BUF; in MYSQLND_METHOD()
91 …result->stored_data = (MYSQLND_RES_BUFFERED *) mysqlnd_result_buffered_zval_init(result->field_cou… in MYSQLND_METHOD()
92 if (!result->stored_data) { in MYSQLND_METHOD()
97 …ret = result->m.store_result_fetch_data(conn, result, result->meta, &result->stored_data->row_buff… in MYSQLND_METHOD()
99 result->stored_data->m.fetch_row = mysqlnd_stmt_fetch_row_buffered; in MYSQLND_METHOD()
103 if (result->stored_data->type == MYSQLND_BUFFERED_TYPE_ZVAL) { in MYSQLND_METHOD()
104 MYSQLND_RES_BUFFERED_ZVAL * set = (MYSQLND_RES_BUFFERED_ZVAL *) result->stored_data; in MYSQLND_METHOD()
105 if (result->stored_data->row_count) { in MYSQLND_METHOD()
107 if (result->stored_data->row_count * result->meta->field_count * sizeof(zval *) > SIZE_MAX) { in MYSQLND_METHOD()
112 …set->data = mnd_emalloc((size_t)(result->stored_data->row_count * result->meta->field_count * size… in MYSQLND_METHOD()
117 …memset(set->data, 0, (size_t)(result->stored_data->row_count * result->meta->field_count * sizeof(… in MYSQLND_METHOD()
121 } else if (result->stored_data->type == MYSQLND_BUFFERED_TYPE_ZVAL) { in MYSQLND_METHOD()
126 stmt->upsert_status->affected_rows = stmt->result->stored_data->row_count; in MYSQLND_METHOD()
130 COPY_CLIENT_ERROR(*conn->error_info, result->stored_data->error_info); in MYSQLND_METHOD()
131 stmt->result->m.free_result_contents(stmt->result); in MYSQLND_METHOD()
132 mnd_pefree(stmt->result, stmt->result->persistent); in MYSQLND_METHOD()
133 stmt->result = NULL; in MYSQLND_METHOD()
137 DBG_RETURN(result); in MYSQLND_METHOD()
148 MYSQLND_RES *result; in MYSQLND_METHOD() local
151 if (!stmt || !stmt->conn || !stmt->result) { in MYSQLND_METHOD()
180 result = conn->m->result_init(stmt->result->field_count, stmt->persistent); in MYSQLND_METHOD()
181 if (!result) { in MYSQLND_METHOD()
186 result->meta = stmt->result->meta->m->clone_metadata(stmt->result->meta, FALSE); in MYSQLND_METHOD()
187 if (!result->meta) { in MYSQLND_METHOD()
192 if ((result = result->m.store_result(result, conn, MYSQLND_STORE_PS | MYSQLND_STORE_NO_COPY))) { in MYSQLND_METHOD()
193 stmt->upsert_status->affected_rows = result->stored_data->row_count; in MYSQLND_METHOD()
195 result->type = MYSQLND_RES_PS_BUF; in MYSQLND_METHOD()
201 DBG_RETURN(result); in MYSQLND_METHOD()
204 if (result) { in MYSQLND_METHOD()
205 result->m.free_result(result, TRUE); in MYSQLND_METHOD()
234 if (!stmt || !stmt->conn || !stmt->result) { in MYSQLND_METHOD()
357 if (stmt->result) { in mysqlnd_stmt_prepare_read_eof()
358 stmt->result->m.free_result_contents(stmt->result); in mysqlnd_stmt_prepare_read_eof()
359 mnd_pefree(stmt->result, stmt->result->persistent); in mysqlnd_stmt_prepare_read_eof()
405 if (stmt->state > MYSQLND_STMT_WAITING_USE_OR_STORE && stmt->result) { in MYSQLND_METHOD()
406 stmt->result->m.skip_result(stmt->result); in MYSQLND_METHOD()
439 …MYSQLND_RES * result = stmt->conn->m->result_init(stmt_to_prepare->field_count, stmt_to_prepare->p… in MYSQLND_METHOD() local
440 if (!result) { in MYSQLND_METHOD()
445 stmt_to_prepare->result = result; in MYSQLND_METHOD()
447 result->conn = stmt_to_prepare->conn->m->get_reference(stmt_to_prepare->conn); in MYSQLND_METHOD()
449 result->type = MYSQLND_RES_PS_BUF; in MYSQLND_METHOD()
451 if (FAIL == result->m.read_result_metadata(result, stmt_to_prepare->conn) || in MYSQLND_METHOD()
531 stmt->result->type = MYSQLND_RES_PS_BUF; in mysqlnd_stmt_execute_parse_response()
532 if (!stmt->result->conn) { in mysqlnd_stmt_execute_parse_response()
537 stmt->result->conn = stmt->conn->m->get_reference(stmt->conn); in mysqlnd_stmt_execute_parse_response()
541 stmt->field_count = stmt->result->field_count = conn->field_count; in mysqlnd_stmt_execute_parse_response()
542 if (stmt->result->stored_data) { in mysqlnd_stmt_execute_parse_response()
543 stmt->result->stored_data->lengths = NULL; in mysqlnd_stmt_execute_parse_response()
544 } else if (stmt->result->unbuf) { in mysqlnd_stmt_execute_parse_response()
545 stmt->result->unbuf->lengths = NULL; in mysqlnd_stmt_execute_parse_response()
644 if (stmt->result && stmt->state >= MYSQLND_STMT_PREPARED && stmt->field_count) { in MYSQLND_METHOD()
670 zval *result = &stmt->result_bind[i].zv; in MYSQLND_METHOD() local
671 ZVAL_DEREF(result); in MYSQLND_METHOD()
672 Z_TRY_ADDREF_P(result); in MYSQLND_METHOD()
685 stmt->result->m.free_result_buffers(stmt->result); in MYSQLND_METHOD()
750 mysqlnd_stmt_fetch_row_buffered(MYSQLND_RES * result, void * param, unsigned int flags, zend_bool *… in mysqlnd_stmt_fetch_row_buffered() argument
754 const MYSQLND_RES_METADATA * const meta = result->meta; in mysqlnd_stmt_fetch_row_buffered()
762 if (result->stored_data->type == MYSQLND_BUFFERED_TYPE_ZVAL) { in mysqlnd_stmt_fetch_row_buffered()
763 MYSQLND_RES_BUFFERED_ZVAL * set = (MYSQLND_RES_BUFFERED_ZVAL *) result->stored_data; in mysqlnd_stmt_fetch_row_buffered()
765 (set->data_cursor - set->data) < (result->stored_data->row_count * field_count)) in mysqlnd_stmt_fetch_row_buffered()
774 …enum_func_status rc = result->stored_data->m.row_decoder(result->stored_data->row_buffers[row_num], in mysqlnd_stmt_fetch_row_buffered()
778 result->conn->options->int_and_float_native, in mysqlnd_stmt_fetch_row_buffered()
779 result->conn->stats); in mysqlnd_stmt_fetch_row_buffered()
783 result->stored_data->initialized_rows++; in mysqlnd_stmt_fetch_row_buffered()
785 for (i = 0; i < result->field_count; i++) { in mysqlnd_stmt_fetch_row_buffered()
801 for (i = 0; i < result->field_count; i++) { in mysqlnd_stmt_fetch_row_buffered()
802 zval *result = &stmt->result_bind[i].zv; in mysqlnd_stmt_fetch_row_buffered() local
804 ZVAL_DEREF(result); in mysqlnd_stmt_fetch_row_buffered()
807 zval_dtor(result); in mysqlnd_stmt_fetch_row_buffered()
821 ZVAL_COPY_VALUE(result, ¤t_row[i]); in mysqlnd_stmt_fetch_row_buffered()
823 Z_TRY_ADDREF_P(result); in mysqlnd_stmt_fetch_row_buffered()
826 ZVAL_NULL(result); in mysqlnd_stmt_fetch_row_buffered()
840 } else if (result->stored_data->type == MYSQLND_BUFFERED_TYPE_C) { in mysqlnd_stmt_fetch_row_buffered()
851 mysqlnd_stmt_fetch_row_unbuffered(MYSQLND_RES * result, void * param, unsigned int flags, zend_bool… in mysqlnd_stmt_fetch_row_unbuffered() argument
857 const MYSQLND_RES_METADATA * const meta = result->meta; in mysqlnd_stmt_fetch_row_unbuffered()
863 if (result->unbuf->eof_reached) { in mysqlnd_stmt_fetch_row_unbuffered()
868 if (CONN_GET_STATE(result->conn) != CONN_FETCHING_DATA) { in mysqlnd_stmt_fetch_row_unbuffered()
869 SET_CLIENT_ERROR(*result->conn->error_info, CR_COMMANDS_OUT_OF_SYNC, in mysqlnd_stmt_fetch_row_unbuffered()
874 if (!(row_packet = result->unbuf->row_packet)) { in mysqlnd_stmt_fetch_row_unbuffered()
885 if (PASS == (ret = PACKET_READ(row_packet, result->conn)) && !row_packet->eof) { in mysqlnd_stmt_fetch_row_unbuffered()
886 unsigned int i, field_count = result->field_count; in mysqlnd_stmt_fetch_row_unbuffered()
889 result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL); in mysqlnd_stmt_fetch_row_unbuffered()
891 result->unbuf->last_row_data = row_packet->fields; in mysqlnd_stmt_fetch_row_unbuffered()
892 result->unbuf->last_row_buffer = row_packet->row_buffer; in mysqlnd_stmt_fetch_row_unbuffered()
896 if (PASS != result->unbuf->m.row_decoder(result->unbuf->last_row_buffer, in mysqlnd_stmt_fetch_row_unbuffered()
897 result->unbuf->last_row_data, in mysqlnd_stmt_fetch_row_unbuffered()
900 result->conn->options->int_and_float_native, in mysqlnd_stmt_fetch_row_unbuffered()
901 result->conn->stats)) in mysqlnd_stmt_fetch_row_unbuffered()
908 zval *data = &result->unbuf->last_row_data[i]; in mysqlnd_stmt_fetch_row_unbuffered()
909 zval *result = &stmt->result_bind[i].zv; in mysqlnd_stmt_fetch_row_unbuffered() local
911 ZVAL_DEREF(result); in mysqlnd_stmt_fetch_row_unbuffered()
917 zval_dtor(result); in mysqlnd_stmt_fetch_row_unbuffered()
924 ZVAL_COPY_VALUE(result, data); in mysqlnd_stmt_fetch_row_unbuffered()
928 ZVAL_NULL(result); in mysqlnd_stmt_fetch_row_unbuffered()
945 result->unbuf->row_count++; in mysqlnd_stmt_fetch_row_unbuffered()
952 CONN_SET_STATE(result->conn, CONN_READY); in mysqlnd_stmt_fetch_row_unbuffered()
953 result->unbuf->eof_reached = TRUE; /* so next time we won't get an error */ in mysqlnd_stmt_fetch_row_unbuffered()
957 result->unbuf->eof_reached = TRUE; in mysqlnd_stmt_fetch_row_unbuffered()
958 memset(result->conn->upsert_status, 0, sizeof(*result->conn->upsert_status)); in mysqlnd_stmt_fetch_row_unbuffered()
959 result->conn->upsert_status->warning_count = row_packet->warning_count; in mysqlnd_stmt_fetch_row_unbuffered()
960 result->conn->upsert_status->server_status = row_packet->server_status; in mysqlnd_stmt_fetch_row_unbuffered()
965 if (result->conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS) { in mysqlnd_stmt_fetch_row_unbuffered()
966 CONN_SET_STATE(result->conn, CONN_NEXT_RESULT_PENDING); in mysqlnd_stmt_fetch_row_unbuffered()
968 CONN_SET_STATE(result->conn, CONN_READY); in mysqlnd_stmt_fetch_row_unbuffered()
983 MYSQLND_RES * result; in MYSQLND_METHOD() local
987 if (!stmt || !stmt->conn || !stmt->result) { in MYSQLND_METHOD()
1008 result = stmt->result; in MYSQLND_METHOD()
1010 result->m.use_result(stmt->result, TRUE); in MYSQLND_METHOD()
1011 result->unbuf->m.fetch_row = stmt->cursor_exists? mysqlnd_fetch_stmt_row_cursor: in MYSQLND_METHOD()
1015 DBG_INF_FMT("%p", result); in MYSQLND_METHOD()
1016 DBG_RETURN(result); in MYSQLND_METHOD()
1025 mysqlnd_fetch_stmt_row_cursor(MYSQLND_RES * result, void * param, unsigned int flags, zend_bool * f… in mysqlnd_fetch_stmt_row_cursor() argument
1035 if (!stmt || !stmt->conn || !result || !result->conn || !result->unbuf) { in mysqlnd_fetch_stmt_row_cursor()
1049 if (!(row_packet = result->unbuf->row_packet)) { in mysqlnd_fetch_stmt_row_cursor()
1069 if (PASS == (ret = PACKET_READ(row_packet, result->conn)) && !row_packet->eof) { in mysqlnd_fetch_stmt_row_cursor()
1070 const MYSQLND_RES_METADATA * const meta = result->meta; in mysqlnd_fetch_stmt_row_cursor()
1071 unsigned int i, field_count = result->field_count; in mysqlnd_fetch_stmt_row_cursor()
1074 result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL); in mysqlnd_fetch_stmt_row_cursor()
1076 result->unbuf->last_row_data = row_packet->fields; in mysqlnd_fetch_stmt_row_cursor()
1077 result->unbuf->last_row_buffer = row_packet->row_buffer; in mysqlnd_fetch_stmt_row_cursor()
1081 if (PASS != result->unbuf->m.row_decoder(result->unbuf->last_row_buffer, in mysqlnd_fetch_stmt_row_cursor()
1082 result->unbuf->last_row_data, in mysqlnd_fetch_stmt_row_cursor()
1085 result->conn->options->int_and_float_native, in mysqlnd_fetch_stmt_row_cursor()
1086 result->conn->stats)) in mysqlnd_fetch_stmt_row_cursor()
1094 zval *data = &result->unbuf->last_row_data[i]; in mysqlnd_fetch_stmt_row_cursor()
1095 zval *result = &stmt->result_bind[i].zv; in mysqlnd_fetch_stmt_row_cursor() local
1097 ZVAL_DEREF(result); in mysqlnd_fetch_stmt_row_cursor()
1103 zval_dtor(result); in mysqlnd_fetch_stmt_row_cursor()
1114 ZVAL_COPY_VALUE(result, data); in mysqlnd_fetch_stmt_row_cursor()
1118 ZVAL_NULL(result); in mysqlnd_fetch_stmt_row_cursor()
1134 ret = PACKET_READ(row_packet, result->conn); in mysqlnd_fetch_stmt_row_cursor()
1141 result->unbuf->row_count++; in mysqlnd_fetch_stmt_row_cursor()
1154 result->unbuf->eof_reached = row_packet->eof; in mysqlnd_fetch_stmt_row_cursor()
1166 result->unbuf->eof_reached); in mysqlnd_fetch_stmt_row_cursor()
1184 if (!stmt->result || in MYSQLND_METHOD()
1211 for (i = 0; i < stmt->result->field_count; i++) { in MYSQLND_METHOD()
1213 zval *result = &stmt->result_bind[i].zv; in MYSQLND_METHOD() local
1214 ZVAL_DEREF(result); in MYSQLND_METHOD()
1215 zval_dtor(result); in MYSQLND_METHOD()
1216 ZVAL_NULL(result); in MYSQLND_METHOD()
1222 ret = stmt->result->m.fetch_row(stmt->result, (void*)s, 0, fetched_anything); in MYSQLND_METHOD()
1307 if (stmt->result) { in MYSQLND_METHOD()
1309 stmt->result->m.skip_result(stmt->result); in MYSQLND_METHOD()
1715 return stmt && stmt->result? mysqlnd_num_rows(stmt->result):0; in MYSQLND_METHOD()
1795 return stmt && stmt->result? stmt->result->m.seek_data(stmt->result, row) : FAIL; in MYSQLND_METHOD()
1818 MYSQLND_RES *result; in MYSQLND_METHOD() local
1826 if (!stmt->field_count || !stmt->conn || !stmt->result || !stmt->result->meta) { in MYSQLND_METHOD()
1831 if (stmt->update_max_length && stmt->result->stored_data) { in MYSQLND_METHOD()
1833 …stmt->result->stored_data->m.initialize_result_set_rest(stmt->result->stored_data, stmt->result->m… in MYSQLND_METHOD()
1846 result = stmt->conn->m->result_init(stmt->field_count, stmt->persistent); in MYSQLND_METHOD()
1847 if (!result) { in MYSQLND_METHOD()
1850 result->type = MYSQLND_RES_NORMAL; in MYSQLND_METHOD()
1851 result->unbuf = mysqlnd_result_unbuffered_init(stmt->field_count, TRUE, result->persistent); in MYSQLND_METHOD()
1852 if (!result->unbuf) { in MYSQLND_METHOD()
1855 result->unbuf->eof_reached = TRUE; in MYSQLND_METHOD()
1856 result->meta = stmt->result->meta->m->clone_metadata(stmt->result->meta, FALSE); in MYSQLND_METHOD()
1857 if (!result->meta) { in MYSQLND_METHOD()
1861 DBG_INF_FMT("result=%p", result); in MYSQLND_METHOD()
1862 DBG_RETURN(result); in MYSQLND_METHOD()
1866 if (result) { in MYSQLND_METHOD()
1867 result->m.free_result(result, TRUE); in MYSQLND_METHOD()
1973 if (!stmt->result) { in MYSQLND_METHOD()
1992 stmt->result->m.skip_result(stmt->result); in MYSQLND_METHOD()
2000 stmt->result->m.free_result_buffers(stmt->result); in MYSQLND_METHOD()
2105 if (stmt->result) { in MYSQLND_METHOD()
2106 stmt->result->m.free_result_internal(stmt->result); in MYSQLND_METHOD()
2107 stmt->result = NULL; in MYSQLND_METHOD()
2189 if (stmt->result) { in MYSQLND_METHOD_PRIVATE()
2191 stmt->result->m.skip_result(stmt->result); in MYSQLND_METHOD_PRIVATE()
