Lines Matching refs:upsert_status
126 stmt->upsert_status->affected_rows = stmt->result->stored_data->row_count; in MYSQLND_METHOD()
193 stmt->upsert_status->affected_rows = result->stored_data->row_count; in MYSQLND_METHOD()
240 …if (CONN_GET_STATE(conn) != CONN_NEXT_RESULT_PENDING || !(conn->upsert_status->server_status & SER… in MYSQLND_METHOD()
244 …DBG_INF_FMT("server_status=%u cursor=%u", stmt->upsert_status->server_status, stmt->upsert_status-… in MYSQLND_METHOD()
325 stmt->warning_count = stmt->conn->upsert_status->warning_count = prepare_resp->warning_count; in mysqlnd_stmt_read_prepare_response()
328 stmt->upsert_status->affected_rows = 0; /* be like libmysql */ in mysqlnd_stmt_read_prepare_response()
364 stmt->upsert_status->server_status = fields_eof->server_status; in mysqlnd_stmt_prepare_read_eof()
365 stmt->upsert_status->warning_count = fields_eof->warning_count; in mysqlnd_stmt_prepare_read_eof()
507 memset(stmt->upsert_status, 0, sizeof(*stmt->upsert_status)); in mysqlnd_stmt_execute_parse_response()
508 stmt->upsert_status->affected_rows = conn->upsert_status->affected_rows; in mysqlnd_stmt_execute_parse_response()
524 *stmt->upsert_status = *conn->upsert_status; /* copy status */ in mysqlnd_stmt_execute_parse_response()
554 DBG_INF_FMT("server_status=%u cursor=%u", stmt->upsert_status->server_status, in mysqlnd_stmt_execute_parse_response()
555 stmt->upsert_status->server_status & SERVER_STATUS_CURSOR_EXISTS); in mysqlnd_stmt_execute_parse_response()
557 if (stmt->upsert_status->server_status & SERVER_STATUS_CURSOR_EXISTS) { in mysqlnd_stmt_execute_parse_response()
588 if (stmt->upsert_status->server_status & SERVER_PS_OUT_PARAMS) { in mysqlnd_stmt_execute_parse_response()
596 …DBG_INF_FMT("server_status=%u cursor=%u", stmt->upsert_status->server_status, stmt->upsert_status-… in mysqlnd_stmt_execute_parse_response()
598 if (ret == PASS && conn->last_query_type == QUERY_UPSERT && stmt->upsert_status->affected_rows) { in mysqlnd_stmt_execute_parse_response()
599 …MYSQLND_INC_CONN_STATISTIC_W_VALUE(conn->stats, STAT_ROWS_AFFECTED_PS, stmt->upsert_status->affect… in mysqlnd_stmt_execute_parse_response()
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()
1068 memset(stmt->upsert_status, 0, sizeof(*stmt->upsert_status)); in mysqlnd_fetch_stmt_row_cursor()
1146 stmt->upsert_status->warning_count = in mysqlnd_fetch_stmt_row_cursor()
1147 stmt->conn->upsert_status->warning_count = in mysqlnd_fetch_stmt_row_cursor()
1150 stmt->upsert_status->server_status = in mysqlnd_fetch_stmt_row_cursor()
1151 stmt->conn->upsert_status->server_status = in mysqlnd_fetch_stmt_row_cursor()
1156 stmt->upsert_status->warning_count = in mysqlnd_fetch_stmt_row_cursor()
1157 stmt->conn->upsert_status->warning_count = in mysqlnd_fetch_stmt_row_cursor()
1159 stmt->upsert_status->server_status = in mysqlnd_fetch_stmt_row_cursor()
1160 stmt->conn->upsert_status->server_status = in mysqlnd_fetch_stmt_row_cursor()
1273 *stmt->upsert_status = *conn->upsert_status; in MYSQLND_METHOD()
1695 return stmt? stmt->upsert_status->last_insert_id : 0; in MYSQLND_METHOD()
1705 return stmt? stmt->upsert_status->affected_rows : 0; in MYSQLND_METHOD()
1725 return stmt? stmt->upsert_status->warning_count : 0; in MYSQLND_METHOD()
1735 return stmt? stmt->upsert_status->server_status : 0; in MYSQLND_METHOD()