Lines Matching refs:conn
58 result->conn->options->int_and_float_native, in MYSQLND_METHOD()
59 result->conn->stats TSRMLS_CC); in MYSQLND_METHOD()
145 MYSQLND_STATS *global_stats = result->conn? result->conn->stats:NULL; in MYSQLND_METHOD()
294 if (result->conn) { in mysqlnd_internal_free_result()
295 result->conn->m->free_reference(result->conn TSRMLS_CC); in mysqlnd_internal_free_result()
296 result->conn = NULL; in mysqlnd_internal_free_result()
308 MYSQLND_METHOD(mysqlnd_res, read_result_metadata)(MYSQLND_RES * result, MYSQLND_CONN_DATA * conn TS… in MYSQLND_METHOD()
325 SET_OOM_ERROR(*conn->error_info); in MYSQLND_METHOD()
332 if (FAIL == result->meta->m->read_metadata(result->meta, conn TSRMLS_CC)) { in MYSQLND_METHOD()
353 mysqlnd_query_read_result_set_header(MYSQLND_CONN_DATA * conn, MYSQLND_STMT * s TSRMLS_DC) in mysqlnd_query_read_result_set_header() argument
365 rset_header = conn->protocol->m.get_rset_header_packet(conn->protocol, FALSE TSRMLS_CC); in mysqlnd_query_read_result_set_header()
367 SET_OOM_ERROR(*conn->error_info); in mysqlnd_query_read_result_set_header()
372 SET_ERROR_AFF_ROWS(conn); in mysqlnd_query_read_result_set_header()
374 if (FAIL == (ret = PACKET_READ(rset_header, conn))) { in mysqlnd_query_read_result_set_header()
389 conn->upsert_status->server_status &= ~SERVER_MORE_RESULTS_EXISTS; in mysqlnd_query_read_result_set_header()
394 COPY_CLIENT_ERROR(*conn->error_info, rset_header->error_info); in mysqlnd_query_read_result_set_header()
398 CONN_SET_STATE(conn, CONN_READY); in mysqlnd_query_read_result_set_header()
401 conn->error_info->error_no = 0; in mysqlnd_query_read_result_set_header()
407 conn->last_query_type = QUERY_LOAD_LOCAL; in mysqlnd_query_read_result_set_header()
408 …conn->field_count = 0; /* overwrite previous value, or the last value could be used and lead to bu… in mysqlnd_query_read_result_set_header()
409 CONN_SET_STATE(conn, CONN_SENDING_LOAD_DATA); in mysqlnd_query_read_result_set_header()
410 ret = mysqlnd_handle_local_infile(conn, rset_header->info_or_local_file, &is_warning TSRMLS_CC); in mysqlnd_query_read_result_set_header()
411 CONN_SET_STATE(conn, (ret == PASS || is_warning == TRUE)? CONN_READY:CONN_QUIT_SENT); in mysqlnd_query_read_result_set_header()
412 MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_NON_RSET_QUERY); in mysqlnd_query_read_result_set_header()
417 conn->last_query_type = QUERY_UPSERT; in mysqlnd_query_read_result_set_header()
418 conn->field_count = rset_header->field_count; in mysqlnd_query_read_result_set_header()
419 memset(conn->upsert_status, 0, sizeof(*conn->upsert_status)); in mysqlnd_query_read_result_set_header()
420 conn->upsert_status->warning_count = rset_header->warning_count; in mysqlnd_query_read_result_set_header()
421 conn->upsert_status->server_status = rset_header->server_status; in mysqlnd_query_read_result_set_header()
422 conn->upsert_status->affected_rows = rset_header->affected_rows; in mysqlnd_query_read_result_set_header()
423 conn->upsert_status->last_insert_id = rset_header->last_insert_id; in mysqlnd_query_read_result_set_header()
424 SET_NEW_MESSAGE(conn->last_message, conn->last_message_len, in mysqlnd_query_read_result_set_header()
426 conn->persistent); in mysqlnd_query_read_result_set_header()
428 if (conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS) { in mysqlnd_query_read_result_set_header()
429 CONN_SET_STATE(conn, CONN_NEXT_RESULT_PENDING); in mysqlnd_query_read_result_set_header()
431 CONN_SET_STATE(conn, CONN_READY); in mysqlnd_query_read_result_set_header()
434 MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_NON_RSET_QUERY); in mysqlnd_query_read_result_set_header()
441 SET_EMPTY_MESSAGE(conn->last_message, conn->last_message_len, conn->persistent); in mysqlnd_query_read_result_set_header()
443 MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_RSET_QUERY); in mysqlnd_query_read_result_set_header()
444 memset(conn->upsert_status, 0, sizeof(*conn->upsert_status)); in mysqlnd_query_read_result_set_header()
446 SET_ERROR_AFF_ROWS(conn); in mysqlnd_query_read_result_set_header()
448 conn->last_query_type = QUERY_SELECT; in mysqlnd_query_read_result_set_header()
449 CONN_SET_STATE(conn, CONN_FETCHING_DATA); in mysqlnd_query_read_result_set_header()
451 conn->field_count = rset_header->field_count; in mysqlnd_query_read_result_set_header()
453 …result = conn->current_result = conn->m->result_init(rset_header->field_count, conn->persistent TS… in mysqlnd_query_read_result_set_header()
462 …result = stmt->result = conn->m->result_init(rset_header->field_count, stmt->persistent TSRMLS_CC); in mysqlnd_query_read_result_set_header()
480 SET_OOM_ERROR(*conn->error_info); in mysqlnd_query_read_result_set_header()
485 if (FAIL == (ret = result->m.read_result_metadata(result, conn TSRMLS_CC))) { in mysqlnd_query_read_result_set_header()
487 if (!stmt && conn->current_result) { in mysqlnd_query_read_result_set_header()
488 mnd_efree(conn->current_result); in mysqlnd_query_read_result_set_header()
489 conn->current_result = NULL; in mysqlnd_query_read_result_set_header()
496 fields_eof = conn->protocol->m.get_eof_packet(conn->protocol, FALSE TSRMLS_CC); in mysqlnd_query_read_result_set_header()
498 SET_OOM_ERROR(*conn->error_info); in mysqlnd_query_read_result_set_header()
502 if (FAIL == (ret = PACKET_READ(fields_eof, conn))) { in mysqlnd_query_read_result_set_header()
507 conn->current_result = NULL; in mysqlnd_query_read_result_set_header()
517 conn->upsert_status->warning_count = fields_eof->warning_count; in mysqlnd_query_read_result_set_header()
525 conn->upsert_status->server_status = fields_eof->server_status; in mysqlnd_query_read_result_set_header()
540 MYSQLND_INC_CONN_STATISTIC(conn->stats, statistic); in mysqlnd_query_read_result_set_header()
627 if (CONN_GET_STATE(result->conn) != CONN_FETCHING_DATA) { in mysqlnd_fetch_row_unbuffered_c()
628 SET_CLIENT_ERROR(*result->conn->error_info, CR_COMMANDS_OUT_OF_SYNC, in mysqlnd_fetch_row_unbuffered_c()
643 if (PASS == (ret = PACKET_READ(row_packet, result->conn)) && !row_packet->eof) { in mysqlnd_fetch_row_unbuffered_c()
653 MYSQLND_INC_CONN_STATISTIC(result->conn->stats, STAT_ROWS_FETCHED_FROM_CLIENT_NORMAL_UNBUF); in mysqlnd_fetch_row_unbuffered_c()
663 result->conn->options->int_and_float_native, in mysqlnd_fetch_row_unbuffered_c()
664 result->conn->stats TSRMLS_CC); in mysqlnd_fetch_row_unbuffered_c()
693 SET_OOM_ERROR(*result->conn->error_info); in mysqlnd_fetch_row_unbuffered_c()
698 COPY_CLIENT_ERROR(*result->conn->error_info, row_packet->error_info); in mysqlnd_fetch_row_unbuffered_c()
701 CONN_SET_STATE(result->conn, CONN_READY); in mysqlnd_fetch_row_unbuffered_c()
707 memset(result->conn->upsert_status, 0, sizeof(*result->conn->upsert_status)); in mysqlnd_fetch_row_unbuffered_c()
708 result->conn->upsert_status->warning_count = row_packet->warning_count; in mysqlnd_fetch_row_unbuffered_c()
709 result->conn->upsert_status->server_status = row_packet->server_status; in mysqlnd_fetch_row_unbuffered_c()
714 if (result->conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS) { in mysqlnd_fetch_row_unbuffered_c()
715 CONN_SET_STATE(result->conn, CONN_NEXT_RESULT_PENDING); in mysqlnd_fetch_row_unbuffered_c()
717 CONN_SET_STATE(result->conn, CONN_READY); in mysqlnd_fetch_row_unbuffered_c()
742 if (CONN_GET_STATE(result->conn) != CONN_FETCHING_DATA) { in mysqlnd_fetch_row_unbuffered()
743 …SET_CLIENT_ERROR(*result->conn->error_info, CR_COMMANDS_OUT_OF_SYNC, UNKNOWN_SQLSTATE, mysqlnd_out… in mysqlnd_fetch_row_unbuffered()
757 if (PASS == (ret = PACKET_READ(row_packet, result->conn)) && !row_packet->eof) { in mysqlnd_fetch_row_unbuffered()
765 MYSQLND_INC_CONN_STATISTIC(result->conn->stats, STAT_ROWS_FETCHED_FROM_CLIENT_NORMAL_UNBUF); in mysqlnd_fetch_row_unbuffered()
778 result->conn->options->int_and_float_native, in mysqlnd_fetch_row_unbuffered()
779 result->conn->stats TSRMLS_CC); in mysqlnd_fetch_row_unbuffered()
825 COPY_CLIENT_ERROR(*result->conn->error_info, row_packet->error_info); in mysqlnd_fetch_row_unbuffered()
828 CONN_SET_STATE(result->conn, CONN_READY); in mysqlnd_fetch_row_unbuffered()
834 memset(result->conn->upsert_status, 0, sizeof(*result->conn->upsert_status)); in mysqlnd_fetch_row_unbuffered()
835 result->conn->upsert_status->warning_count = row_packet->warning_count; in mysqlnd_fetch_row_unbuffered()
836 result->conn->upsert_status->server_status = row_packet->server_status; in mysqlnd_fetch_row_unbuffered()
841 if (result->conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS) { in mysqlnd_fetch_row_unbuffered()
842 CONN_SET_STATE(result->conn, CONN_NEXT_RESULT_PENDING); in mysqlnd_fetch_row_unbuffered()
844 CONN_SET_STATE(result->conn, CONN_READY); in mysqlnd_fetch_row_unbuffered()
861 SET_EMPTY_ERROR(*result->conn->error_info); in MYSQLND_METHOD()
893 …result->row_packet = result->conn->protocol->m.get_row_packet(result->conn->protocol, FALSE TSRMLS… in MYSQLND_METHOD()
906 SET_OOM_ERROR(*result->conn->error_info); in MYSQLND_METHOD()
936 result->conn->options->int_and_float_native, in mysqlnd_fetch_row_buffered_c()
937 result->conn->stats TSRMLS_CC); in mysqlnd_fetch_row_buffered_c()
1008 result->conn->options->int_and_float_native, in mysqlnd_fetch_row_buffered()
1009 result->conn->stats TSRMLS_CC); in mysqlnd_fetch_row_buffered()
1078 MYSQLND_METHOD(mysqlnd_res, store_result_fetch_data)(MYSQLND_CONN_DATA * const conn, MYSQLND_RES * … in MYSQLND_METHOD()
1091 SET_OOM_ERROR(*conn->error_info); in MYSQLND_METHOD()
1098 SET_OOM_ERROR(*conn->error_info); in MYSQLND_METHOD()
1106 row_packet = conn->protocol->m.get_row_packet(conn->protocol, FALSE TSRMLS_CC); in MYSQLND_METHOD()
1108 SET_OOM_ERROR(*conn->error_info); in MYSQLND_METHOD()
1121 while (FAIL != (ret = PACKET_READ(row_packet, conn)) && !row_packet->eof) { in MYSQLND_METHOD()
1129 SET_OOM_ERROR(*conn->error_info); in MYSQLND_METHOD()
1135 SET_OOM_ERROR(*conn->error_info); in MYSQLND_METHOD()
1161 SET_OOM_ERROR(*conn->error_info); in MYSQLND_METHOD()
1168 SET_OOM_ERROR(*conn->error_info); in MYSQLND_METHOD()
1175 MYSQLND_INC_CONN_STATISTIC_W_VALUE(conn->stats, in MYSQLND_METHOD()
1182 memset(conn->upsert_status, 0, sizeof(*conn->upsert_status)); in MYSQLND_METHOD()
1183 conn->upsert_status->warning_count = row_packet->warning_count; in MYSQLND_METHOD()
1184 conn->upsert_status->server_status = row_packet->server_status; in MYSQLND_METHOD()
1190 SET_OOM_ERROR(*conn->error_info); in MYSQLND_METHOD()
1197 if (conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS) { in MYSQLND_METHOD()
1198 CONN_SET_STATE(conn, CONN_NEXT_RESULT_PENDING); in MYSQLND_METHOD()
1200 CONN_SET_STATE(conn, CONN_READY); in MYSQLND_METHOD()
1210 conn->upsert_status->affected_rows = set->row_count; in MYSQLND_METHOD()
1213 …ret == PASS? "PASS":"FAIL", (uint) set->row_count, conn->upsert_status->warning_count, conn->upser… in MYSQLND_METHOD()
1225 MYSQLND_CONN_DATA * const conn, in MYSQLND_METHOD()
1233 result->conn = conn->m->get_reference(conn TSRMLS_CC); in MYSQLND_METHOD()
1244 SET_OOM_ERROR(*conn->error_info); in MYSQLND_METHOD()
1248 CONN_SET_STATE(conn, CONN_FETCHING_DATA); in MYSQLND_METHOD()
1250 ret = result->m.store_result_fetch_data(conn, result, result->meta, ps_protocol TSRMLS_CC); in MYSQLND_METHOD()
1253 COPY_CLIENT_ERROR(*conn->error_info, result->stored_data->error_info); in MYSQLND_METHOD()
1255 SET_OOM_ERROR(*conn->error_info); in MYSQLND_METHOD()
1260 conn->upsert_status->affected_rows = result->stored_data->row_count; in MYSQLND_METHOD()
1284 MYSQLND_INC_CONN_STATISTIC(result->conn->stats, in MYSQLND_METHOD()
1304 MYSQLND_INC_CONN_STATISTIC(result->conn? result->conn->stats : NULL, in MYSQLND_METHOD()
1543 if (result->conn) { in MYSQLND_METHOD()
1544 …SET_CLIENT_ERROR(*result->conn->error_info, CR_NOT_IMPLEMENTED, UNKNOWN_SQLSTATE, "fetch_all can b… in MYSQLND_METHOD()
