diff options
author | unknown <venu@myvenu.com> | 2003-07-08 02:27:21 -0700 |
---|---|---|
committer | unknown <venu@myvenu.com> | 2003-07-08 02:27:21 -0700 |
commit | 6a2e71229042ce17c922ff796763743653606e89 (patch) | |
tree | d30194a84c520bf0e621463153cea359044f89e1 /sql | |
parent | e25c83e0c6b6db5c5aec223b8f4d18210017181d (diff) | |
download | mariadb-git-6a2e71229042ce17c922ff796763743653606e89.tar.gz |
implementation of mysql_stmt_reset client end
include/mysql.h:
add mysql_stmt_reset prototype
include/mysql_com.h:
add COM_STMT_RESET
libmysql/libmysql.def:
Add mysql_stmt_reset def
sql/sql_prepare.cc:
Fix selects hang after windows slowdown issue fix (send_fields)
sql/sql_parse.cc:
Add COM_STMT_RESET
sql/mysql_priv.h:
add defination of mysql_stmt_reset
Diffstat (limited to 'sql')
-rw-r--r-- | sql/mysql_priv.h | 1 | ||||
-rw-r--r-- | sql/sql_parse.cc | 5 | ||||
-rw-r--r-- | sql/sql_prepare.cc | 2 |
3 files changed, 7 insertions, 1 deletions
diff --git a/sql/mysql_priv.h b/sql/mysql_priv.h index 5ad2cc56b8c..6633912967e 100644 --- a/sql/mysql_priv.h +++ b/sql/mysql_priv.h @@ -557,6 +557,7 @@ void free_prep_stmt(PREP_STMT *stmt, TREE_FREE mode, void *not_used); bool mysql_stmt_prepare(THD *thd, char *packet, uint packet_length); void mysql_stmt_execute(THD *thd, char *packet); void mysql_stmt_free(THD *thd, char *packet); +void mysql_stmt_reset(THD *thd, char *packet); void mysql_stmt_get_longdata(THD *thd, char *pos, ulong packet_length); int check_insert_fields(THD *thd,TABLE *table,List<Item> &fields, List<Item> &values, ulong counter); diff --git a/sql/sql_parse.cc b/sql/sql_parse.cc index 0db6ce8a642..00917e296ca 100644 --- a/sql/sql_parse.cc +++ b/sql/sql_parse.cc @@ -1290,6 +1290,11 @@ restore_user: mysql_stmt_free(thd, packet); break; } + case COM_RESET_STMT: + { + mysql_stmt_reset(thd, packet); + break; + } case COM_QUERY: { if (alloc_query(thd, packet, packet_length)) diff --git a/sql/sql_prepare.cc b/sql/sql_prepare.cc index c38fb44db1c..550e4bbe086 100644 --- a/sql/sql_prepare.cc +++ b/sql/sql_prepare.cc @@ -965,7 +965,7 @@ void mysql_stmt_reset(THD *thd, char *packet) PREP_STMT *stmt; DBUG_ENTER("mysql_stmt_reset"); - if (!(stmt=find_prepared_statement(thd, stmt_id, "close"))) + if (!(stmt= find_prepared_statement(thd, stmt_id, "reset"))) { send_error(thd); DBUG_VOID_RETURN; |