|
|
|
|
@ -2989,8 +2989,12 @@ handler_again:
|
|
|
|
|
case PROCESSING_STMT_PREPARE:
|
|
|
|
|
{
|
|
|
|
|
char sqlstate[10];
|
|
|
|
|
sprintf(sqlstate,"%s",mysql_sqlstate(myconn->mysql));
|
|
|
|
|
client_myds->myprot.generate_pkt_ERR(true,NULL,NULL,client_myds->pkt_sid+1,mysql_errno(myconn->mysql),sqlstate,(char *)mysql_stmt_error(myconn->query.stmt));
|
|
|
|
|
if (myconn->mysql) {
|
|
|
|
|
sprintf(sqlstate,"%s",mysql_sqlstate(myconn->mysql));
|
|
|
|
|
client_myds->myprot.generate_pkt_ERR(true,NULL,NULL,client_myds->pkt_sid+1,mysql_errno(myconn->mysql),sqlstate,(char *)mysql_stmt_error(myconn->query.stmt));
|
|
|
|
|
} else {
|
|
|
|
|
client_myds->myprot.generate_pkt_ERR(true,NULL,NULL,client_myds->pkt_sid+1, 2013, (char *)"" ,(char *)"Lost connection to MySQL server during query");
|
|
|
|
|
}
|
|
|
|
|
client_myds->pkt_sid++;
|
|
|
|
|
if (previous_status.size()) {
|
|
|
|
|
// an STMT_PREPARE failed
|
|
|
|
|
@ -3004,8 +3008,12 @@ handler_again:
|
|
|
|
|
case PROCESSING_STMT_EXECUTE:
|
|
|
|
|
{
|
|
|
|
|
char sqlstate[10];
|
|
|
|
|
sprintf(sqlstate,"%s",mysql_sqlstate(myconn->mysql));
|
|
|
|
|
client_myds->myprot.generate_pkt_ERR(true,NULL,NULL,client_myds->pkt_sid+1,mysql_errno(myconn->mysql),sqlstate,(char *)mysql_stmt_error(myconn->query.stmt));
|
|
|
|
|
if (myconn->mysql) {
|
|
|
|
|
sprintf(sqlstate,"%s",mysql_sqlstate(myconn->mysql));
|
|
|
|
|
client_myds->myprot.generate_pkt_ERR(true,NULL,NULL,client_myds->pkt_sid+1,mysql_errno(myconn->mysql),sqlstate,(char *)mysql_stmt_error(myconn->query.stmt));
|
|
|
|
|
} else {
|
|
|
|
|
client_myds->myprot.generate_pkt_ERR(true,NULL,NULL,client_myds->pkt_sid+1, 2013, (char *)"" ,(char *)"Lost connection to MySQL server during query");
|
|
|
|
|
}
|
|
|
|
|
client_myds->pkt_sid++;
|
|
|
|
|
}
|
|
|
|
|
break;
|
|
|
|
|
|