|
|
|
|
@ -1637,14 +1637,10 @@ bool MySQL_Session::handler___status_WAITING_CLIENT_DATA___STATE_SLEEP___MYSQL_C
|
|
|
|
|
delete qpo->new_query;
|
|
|
|
|
}
|
|
|
|
|
if (qpo->cache_ttl>0) {
|
|
|
|
|
// client_myds->query_SQL=(unsigned char *)l_alloc(pkt->size-sizeof(mysql_hdr));
|
|
|
|
|
// memcpy(client_myds->query_SQL,(unsigned char *)pkt->ptr+sizeof(mysql_hdr)+1,pkt->size-sizeof(mysql_hdr)-1);
|
|
|
|
|
// client_myds->query_SQL[pkt->size-sizeof(mysql_hdr)-1]=0;
|
|
|
|
|
uint32_t resbuf=0;
|
|
|
|
|
unsigned char *aa=GloQC->get( client_myds->myconn->userinfo->hash, (const unsigned char *)client_myds->mysql_real_query.QueryPtr , client_myds->mysql_real_query.QuerySize , &resbuf);
|
|
|
|
|
if (aa) {
|
|
|
|
|
l_free(pkt->size,pkt->ptr);
|
|
|
|
|
// l_free(strlen((char *)client_myds->query_SQL)+1,client_myds->query_SQL);
|
|
|
|
|
client_myds->buffer2resultset(aa,resbuf);
|
|
|
|
|
free(aa);
|
|
|
|
|
client_myds->PSarrayOUT->copy_add(client_myds->resultset,0,client_myds->resultset->len);
|
|
|
|
|
@ -1801,7 +1797,6 @@ void MySQL_Session::MySQL_Result_to_MySQL_wire(MYSQL *mysql, MySQL_ResultSet *My
|
|
|
|
|
GloQC->set( client_myds->myconn->userinfo->hash , (const unsigned char *)client_myds->mysql_real_query.QueryPtr , client_myds->mysql_real_query.QuerySize , aa,client_myds->resultset_length,qpo->cache_ttl);
|
|
|
|
|
l_free(client_myds->resultset_length,aa);
|
|
|
|
|
client_myds->resultset_length=0;
|
|
|
|
|
// l_free(strlen((char *)client_myds->query_SQL)+1,client_myds->query_SQL);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|