From 2014cbcecf17660f5bad89e8d1c146a183a8a5f3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Ren=C3=A9=20Canna=C3=B2?= Date: Sun, 16 Aug 2015 08:39:01 +0000 Subject: [PATCH] EOF packets returns the correct status --- lib/MySQL_Session.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/MySQL_Session.cpp b/lib/MySQL_Session.cpp index 60bcce5a3..2076001ec 100644 --- a/lib/MySQL_Session.cpp +++ b/lib/MySQL_Session.cpp @@ -2176,7 +2176,7 @@ void MySQL_Session::MySQL_Result_to_MySQL_wire(MYSQL *mysql, MYSQL_RES *result, } myds->DSS=STATE_COLUMN_DEFINITION; num_rows=mysql_num_rows(result); - myprot->generate_pkt_EOF(true,NULL,&pkt_length,sid,0,0); sid++; + myprot->generate_pkt_EOF(true,NULL,&pkt_length,sid,0,mysql->status); sid++; client_myds->resultset_length+=pkt_length; //char **p=(char **)malloc(sizeof(char*)*num_fields); //int *l=(int *)malloc(sizeof(int*)*num_fields); @@ -2193,7 +2193,7 @@ void MySQL_Session::MySQL_Result_to_MySQL_wire(MYSQL *mysql, MYSQL_RES *result, client_myds->resultset_length+=pkt_length; } myds->DSS=STATE_ROW; - myprot->generate_pkt_EOF(true,NULL,&pkt_length,sid,0,2); sid++; + myprot->generate_pkt_EOF(true,NULL,&pkt_length,sid,0,mysql->status); sid++; client_myds->resultset_length+=pkt_length; if (qpo && qpo->cache_ttl>0 && mysql_errno(mysql)==0) { client_myds->resultset->copy_add(client_myds->PSarrayOUT,0,client_myds->PSarrayOUT->len);