Lines Matching refs:result
42 enum_func_status mysqlnd_stmt_fetch_row_buffered(MYSQLND_RES *result, void *param,
46 enum_func_status mysqlnd_fetch_stmt_row_cursor(MYSQLND_RES *result, void *param,
62 MYSQLND_RES * result; in MYSQLND_METHOD() local
65 if (!stmt || !stmt->conn || !stmt->result) { in MYSQLND_METHOD()
97 result = stmt->result; in MYSQLND_METHOD()
98 result->type = MYSQLND_RES_PS_BUF; in MYSQLND_METHOD()
99 result->m.fetch_row = mysqlnd_stmt_fetch_row_buffered; in MYSQLND_METHOD()
100 result->m.fetch_lengths = NULL;/* makes no sense */ in MYSQLND_METHOD()
101 result->m.row_decoder = php_mysqlnd_rowp_read_binary_protocol; in MYSQLND_METHOD()
103 result->result_set_memory_pool = mysqlnd_mempool_create(MYSQLND_G(mempool_default_size) TSRMLS_CC); in MYSQLND_METHOD()
105 ret = result->m.store_result_fetch_data(conn, result, result->meta, TRUE TSRMLS_CC); in MYSQLND_METHOD()
109 stmt->upsert_status->affected_rows = stmt->result->stored_data->row_count; in MYSQLND_METHOD()
113 COPY_CLIENT_ERROR(*conn->error_info, result->stored_data->error_info); in MYSQLND_METHOD()
114 stmt->result->m.free_result_contents(stmt->result TSRMLS_CC); in MYSQLND_METHOD()
115 mnd_efree(stmt->result); in MYSQLND_METHOD()
116 stmt->result = NULL; in MYSQLND_METHOD()
120 DBG_RETURN(result); in MYSQLND_METHOD()
131 MYSQLND_RES *result; in MYSQLND_METHOD() local
134 if (!stmt || !stmt->conn || !stmt->result) { in MYSQLND_METHOD()
163 result = conn->m->result_init(stmt->result->field_count, stmt->persistent TSRMLS_CC); in MYSQLND_METHOD()
164 if (!result) { in MYSQLND_METHOD()
169 result->meta = stmt->result->meta->m->clone_metadata(stmt->result->meta, FALSE TSRMLS_CC); in MYSQLND_METHOD()
170 if (!result->meta) { in MYSQLND_METHOD()
175 if ((result = result->m.store_result(result, conn, TRUE TSRMLS_CC))) { in MYSQLND_METHOD()
176 stmt->upsert_status->affected_rows = result->stored_data->row_count; in MYSQLND_METHOD()
178 result->type = MYSQLND_RES_PS_BUF; in MYSQLND_METHOD()
184 DBG_RETURN(result); in MYSQLND_METHOD()
187 if (result) { in MYSQLND_METHOD()
188 result->m.free_result(result, TRUE TSRMLS_CC); in MYSQLND_METHOD()
217 if (!stmt || !stmt->conn || !stmt->result) { in MYSQLND_METHOD()
340 if (stmt->result) { in mysqlnd_stmt_prepare_read_eof()
341 stmt->result->m.free_result_contents(stmt->result TSRMLS_CC); in mysqlnd_stmt_prepare_read_eof()
342 mnd_efree(stmt->result); in mysqlnd_stmt_prepare_read_eof()
388 if (stmt->state > MYSQLND_STMT_WAITING_USE_OR_STORE && stmt->result) { in MYSQLND_METHOD()
389 stmt->result->m.skip_result(stmt->result TSRMLS_CC); in MYSQLND_METHOD()
422 …MYSQLND_RES * result = stmt->conn->m->result_init(stmt_to_prepare->field_count, stmt_to_prepare->p… in MYSQLND_METHOD() local
423 if (!result) { in MYSQLND_METHOD()
428 stmt_to_prepare->result = result; in MYSQLND_METHOD()
430 result->conn = stmt_to_prepare->conn->m->get_reference(stmt_to_prepare->conn TSRMLS_CC); in MYSQLND_METHOD()
432 result->type = MYSQLND_RES_PS_BUF; in MYSQLND_METHOD()
434 if (FAIL == result->m.read_result_metadata(result, stmt_to_prepare->conn TSRMLS_CC) || in MYSQLND_METHOD()
514 stmt->result->type = MYSQLND_RES_PS_BUF; in mysqlnd_stmt_execute_parse_response()
515 if (!stmt->result->conn) { in mysqlnd_stmt_execute_parse_response()
520 stmt->result->conn = stmt->conn->m->get_reference(stmt->conn TSRMLS_CC); in mysqlnd_stmt_execute_parse_response()
524 stmt->field_count = stmt->result->field_count = conn->field_count; in mysqlnd_stmt_execute_parse_response()
525 stmt->result->lengths = NULL; in mysqlnd_stmt_execute_parse_response()
602 if (stmt->result && stmt->state >= MYSQLND_STMT_PREPARED && stmt->field_count) { in MYSQLND_METHOD()
641 stmt->result->m.free_result_buffers(stmt->result TSRMLS_CC); in MYSQLND_METHOD()
713 mysqlnd_stmt_fetch_row_buffered(MYSQLND_RES *result, void *param, unsigned int flags, zend_bool *fe… in mysqlnd_stmt_fetch_row_buffered() argument
717 MYSQLND_RES_BUFFERED *set = result->stored_data; in mysqlnd_stmt_fetch_row_buffered()
718 unsigned int field_count = result->meta->field_count; in mysqlnd_stmt_fetch_row_buffered()
731 MYSQLND_RES_METADATA * meta = result->meta; in mysqlnd_stmt_fetch_row_buffered()
736 enum_func_status rc = result->m.row_decoder(set->row_buffers[row_num], in mysqlnd_stmt_fetch_row_buffered()
740 result->conn->options->int_and_float_native, in mysqlnd_stmt_fetch_row_buffered()
741 result->conn->stats TSRMLS_CC); in mysqlnd_stmt_fetch_row_buffered()
747 for (i = 0; i < result->field_count; i++) { in mysqlnd_stmt_fetch_row_buffered()
763 for (i = 0; i < result->field_count; i++) { in mysqlnd_stmt_fetch_row_buffered()
810 mysqlnd_stmt_fetch_row_unbuffered(MYSQLND_RES *result, void *param, unsigned int flags, zend_bool *… in mysqlnd_stmt_fetch_row_unbuffered() argument
821 if (result->unbuf->eof_reached) { in mysqlnd_stmt_fetch_row_unbuffered()
826 if (CONN_GET_STATE(result->conn) != CONN_FETCHING_DATA) { in mysqlnd_stmt_fetch_row_unbuffered()
827 SET_CLIENT_ERROR(*result->conn->error_info, CR_COMMANDS_OUT_OF_SYNC, in mysqlnd_stmt_fetch_row_unbuffered()
832 if (!(row_packet = result->row_packet)) { in mysqlnd_stmt_fetch_row_unbuffered()
843 if (PASS == (ret = PACKET_READ(row_packet, result->conn)) && !row_packet->eof) { in mysqlnd_stmt_fetch_row_unbuffered()
844 unsigned int i, field_count = result->field_count; in mysqlnd_stmt_fetch_row_unbuffered()
847 result->m.unbuffered_free_last_data(result TSRMLS_CC); in mysqlnd_stmt_fetch_row_unbuffered()
849 result->unbuf->last_row_data = row_packet->fields; in mysqlnd_stmt_fetch_row_unbuffered()
850 result->unbuf->last_row_buffer = row_packet->row_buffer; in mysqlnd_stmt_fetch_row_unbuffered()
854 if (PASS != result->m.row_decoder(result->unbuf->last_row_buffer, in mysqlnd_stmt_fetch_row_unbuffered()
855 result->unbuf->last_row_data, in mysqlnd_stmt_fetch_row_unbuffered()
858 result->conn->options->int_and_float_native, in mysqlnd_stmt_fetch_row_unbuffered()
859 result->conn->stats TSRMLS_CC)) in mysqlnd_stmt_fetch_row_unbuffered()
866 zval *data = result->unbuf->last_row_data[i]; in mysqlnd_stmt_fetch_row_unbuffered()
875 …if ((Z_TYPE_P(data) == IS_STRING) && (result->meta->fields[i].max_length < (unsigned long) Z_STRLE… in mysqlnd_stmt_fetch_row_unbuffered()
876 result->meta->fields[i].max_length = Z_STRLEN_P(data); in mysqlnd_stmt_fetch_row_unbuffered()
897 result->unbuf->row_count++; in mysqlnd_stmt_fetch_row_unbuffered()
904 CONN_SET_STATE(result->conn, CONN_READY); in mysqlnd_stmt_fetch_row_unbuffered()
905 result->unbuf->eof_reached = TRUE; /* so next time we won't get an error */ in mysqlnd_stmt_fetch_row_unbuffered()
909 result->unbuf->eof_reached = TRUE; in mysqlnd_stmt_fetch_row_unbuffered()
910 memset(result->conn->upsert_status, 0, sizeof(*result->conn->upsert_status)); in mysqlnd_stmt_fetch_row_unbuffered()
911 result->conn->upsert_status->warning_count = row_packet->warning_count; in mysqlnd_stmt_fetch_row_unbuffered()
912 result->conn->upsert_status->server_status = row_packet->server_status; in mysqlnd_stmt_fetch_row_unbuffered()
917 if (result->conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS) { in mysqlnd_stmt_fetch_row_unbuffered()
918 CONN_SET_STATE(result->conn, CONN_NEXT_RESULT_PENDING); in mysqlnd_stmt_fetch_row_unbuffered()
920 CONN_SET_STATE(result->conn, CONN_READY); in mysqlnd_stmt_fetch_row_unbuffered()
935 MYSQLND_RES * result; in MYSQLND_METHOD() local
939 if (!stmt || !stmt->conn || !stmt->result) { in MYSQLND_METHOD()
960 result = stmt->result; in MYSQLND_METHOD()
962 result->m.use_result(stmt->result, TRUE TSRMLS_CC); in MYSQLND_METHOD()
963 result->m.fetch_row = stmt->cursor_exists? mysqlnd_fetch_stmt_row_cursor: in MYSQLND_METHOD()
967 DBG_INF_FMT("%p", result); in MYSQLND_METHOD()
968 DBG_RETURN(result); in MYSQLND_METHOD()
977 mysqlnd_fetch_stmt_row_cursor(MYSQLND_RES *result, void *param, unsigned int flags, zend_bool *fetc… in mysqlnd_fetch_stmt_row_cursor() argument
987 if (!stmt || !stmt->conn || !result || !result->conn || !result->unbuf) { in mysqlnd_fetch_stmt_row_cursor()
1001 if (!(row_packet = result->row_packet)) { in mysqlnd_fetch_stmt_row_cursor()
1021 if (PASS == (ret = PACKET_READ(row_packet, result->conn)) && !row_packet->eof) { in mysqlnd_fetch_stmt_row_cursor()
1022 unsigned int i, field_count = result->field_count; in mysqlnd_fetch_stmt_row_cursor()
1025 result->m.unbuffered_free_last_data(result TSRMLS_CC); in mysqlnd_fetch_stmt_row_cursor()
1027 result->unbuf->last_row_data = row_packet->fields; in mysqlnd_fetch_stmt_row_cursor()
1028 result->unbuf->last_row_buffer = row_packet->row_buffer; in mysqlnd_fetch_stmt_row_cursor()
1032 if (PASS != result->m.row_decoder(result->unbuf->last_row_buffer, in mysqlnd_fetch_stmt_row_cursor()
1033 result->unbuf->last_row_data, in mysqlnd_fetch_stmt_row_cursor()
1036 result->conn->options->int_and_float_native, in mysqlnd_fetch_stmt_row_cursor()
1037 result->conn->stats TSRMLS_CC)) in mysqlnd_fetch_stmt_row_cursor()
1045 zval *data = result->unbuf->last_row_data[i]; in mysqlnd_fetch_stmt_row_cursor()
1056 …if ((Z_TYPE_P(data) == IS_STRING) && (result->meta->fields[i].max_length < (unsigned long) Z_STRLE… in mysqlnd_fetch_stmt_row_cursor()
1057 result->meta->fields[i].max_length = Z_STRLEN_P(data); in mysqlnd_fetch_stmt_row_cursor()
1077 ret = PACKET_READ(row_packet, result->conn); in mysqlnd_fetch_stmt_row_cursor()
1084 result->unbuf->row_count++; in mysqlnd_fetch_stmt_row_cursor()
1097 result->unbuf->eof_reached = row_packet->eof; in mysqlnd_fetch_stmt_row_cursor()
1109 result->unbuf->eof_reached); in mysqlnd_fetch_stmt_row_cursor()
1127 if (!stmt->result || in MYSQLND_METHOD()
1154 for (i = 0; i < stmt->result->field_count; i++) { in MYSQLND_METHOD()
1163 ret = stmt->result->m.fetch_row(stmt->result, (void*)s, 0, fetched_anything TSRMLS_CC); in MYSQLND_METHOD()
1248 if (stmt->result) { in MYSQLND_METHOD()
1250 stmt->result->m.skip_result(stmt->result TSRMLS_CC); in MYSQLND_METHOD()
1658 return stmt && stmt->result? mysqlnd_num_rows(stmt->result):0; in MYSQLND_METHOD()
1738 return stmt && stmt->result? stmt->result->m.seek_data(stmt->result, row TSRMLS_CC) : FAIL; in MYSQLND_METHOD()
1761 MYSQLND_RES *result; in MYSQLND_METHOD() local
1769 if (!stmt->field_count || !stmt->conn || !stmt->result || !stmt->result->meta) { in MYSQLND_METHOD()
1774 if (stmt->update_max_length && stmt->result->stored_data) { in MYSQLND_METHOD()
1776 stmt->result->m.initialize_result_set_rest(stmt->result TSRMLS_CC); in MYSQLND_METHOD()
1788 result = stmt->conn->m->result_init(stmt->field_count, stmt->persistent TSRMLS_CC); in MYSQLND_METHOD()
1789 if (!result) { in MYSQLND_METHOD()
1792 result->type = MYSQLND_RES_NORMAL; in MYSQLND_METHOD()
1793 result->m.fetch_row = result->m.fetch_row_normal_unbuffered; in MYSQLND_METHOD()
1794 result->unbuf = mnd_ecalloc(1, sizeof(MYSQLND_RES_UNBUFFERED)); in MYSQLND_METHOD()
1795 if (!result->unbuf) { in MYSQLND_METHOD()
1798 result->unbuf->eof_reached = TRUE; in MYSQLND_METHOD()
1799 result->meta = stmt->result->meta->m->clone_metadata(stmt->result->meta, FALSE TSRMLS_CC); in MYSQLND_METHOD()
1800 if (!result->meta) { in MYSQLND_METHOD()
1804 DBG_INF_FMT("result=%p", result); in MYSQLND_METHOD()
1805 DBG_RETURN(result); in MYSQLND_METHOD()
1809 if (result) { in MYSQLND_METHOD()
1810 result->m.free_result(result, TRUE TSRMLS_CC); in MYSQLND_METHOD()
1916 if (!stmt->result) { in MYSQLND_METHOD()
1935 stmt->result->m.skip_result(stmt->result TSRMLS_CC); in MYSQLND_METHOD()
1943 stmt->result->m.free_result_buffers(stmt->result TSRMLS_CC); in MYSQLND_METHOD()
2081 if (stmt->result) { in MYSQLND_METHOD()
2082 stmt->result->m.free_result_internal(stmt->result TSRMLS_CC); in MYSQLND_METHOD()
2083 stmt->result = NULL; in MYSQLND_METHOD()
2167 if (stmt->result) { in MYSQLND_METHOD_PRIVATE()
2169 stmt->result->m.skip_result(stmt->result TSRMLS_CC); in MYSQLND_METHOD_PRIVATE()
