summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlexey Botchkov <holyfoot@askmonty.org>2016-01-27 13:42:53 +0400
committerAlexey Botchkov <holyfoot@askmonty.org>2016-01-28 11:12:03 +0400
commitefb36ac5d5a5e2b7937545e2d3fddb1b7c8b7f9a (patch)
treeec8e821ca35531d4f828e3627de271cd90530283
parent75a1d866dd4c00b91ca9b29593ad41543f084544 (diff)
downloadmariadb-git-efb36ac5d5a5e2b7937545e2d3fddb1b7c8b7f9a.tar.gz
MDEV-5273 Prepared statement doesn't return metadata after prepare.
SHOW MASTER STATUS fixed.
-rw-r--r--sql/slave.h1
-rw-r--r--sql/sql_prepare.cc30
-rw-r--r--sql/sql_repl.cc34
-rw-r--r--tests/mysql_client_test.c7
4 files changed, 58 insertions, 14 deletions
diff --git a/sql/slave.h b/sql/slave.h
index d88d08b2b0d..ca89064d773 100644
--- a/sql/slave.h
+++ b/sql/slave.h
@@ -211,6 +211,7 @@ void show_master_info_get_fields(THD *thd, List<Item> *field_list,
bool full, size_t gtid_pos_length);
bool show_master_info(THD* thd, Master_info* mi, bool full);
bool show_all_master_info(THD* thd);
+void show_binlog_info_get_fields(THD *thd, List<Item> *field_list);
bool show_binlog_info(THD* thd);
bool rpl_master_has_bug(const Relay_log_info *rli, uint bug_id, bool report,
bool (*pred)(const void *), const void *param);
diff --git a/sql/sql_prepare.cc b/sql/sql_prepare.cc
index fee364912c0..7ba269ed131 100644
--- a/sql/sql_prepare.cc
+++ b/sql/sql_prepare.cc
@@ -1917,6 +1917,29 @@ static bool mysql_test_show_slave_status(Prepared_statement *stmt)
/**
+ Validate and prepare for execution SHOW MASTER STATUS statement.
+
+ @param stmt prepared statement
+
+ @retval
+ FALSE success
+ @retval
+ TRUE error, error message is set in THD
+*/
+
+static bool mysql_test_show_master_status(Prepared_statement *stmt)
+{
+ DBUG_ENTER("mysql_test_show_master_status");
+ THD *thd= stmt->thd;
+ List<Item> fields;
+
+ show_binlog_info_get_fields(thd, &fields);
+
+ DBUG_RETURN(send_stmt_metadata(thd, stmt, &fields));
+}
+
+
+/**
@brief Validate and prepare for execution CREATE VIEW statement
@param stmt prepared statement
@@ -2277,6 +2300,13 @@ static bool check_prepared_statement(Prepared_statement *stmt)
DBUG_RETURN(FALSE);
}
break;
+ case SQLCOM_SHOW_MASTER_STAT:
+ if (!(res= mysql_test_show_master_status(stmt)))
+ {
+ /* Statement and field info has already been sent */
+ DBUG_RETURN(FALSE);
+ }
+ break;
case SQLCOM_CREATE_VIEW:
if (lex->create_view_mode == VIEW_ALTER)
{
diff --git a/sql/sql_repl.cc b/sql/sql_repl.cc
index e524153ad15..3a73237ad4f 100644
--- a/sql/sql_repl.cc
+++ b/sql/sql_repl.cc
@@ -4088,6 +4088,25 @@ err:
}
+void show_binlog_info_get_fields(THD *thd, List<Item> *field_list)
+{
+ MEM_ROOT *mem_root= thd->mem_root;
+ field_list->push_back(new (mem_root)
+ Item_empty_string(thd, "File", FN_REFLEN),
+ mem_root);
+ field_list->push_back(new (mem_root)
+ Item_return_int(thd, "Position", 20,
+ MYSQL_TYPE_LONGLONG),
+ mem_root);
+ field_list->push_back(new (mem_root)
+ Item_empty_string(thd, "Binlog_Do_DB", 255),
+ mem_root);
+ field_list->push_back(new (mem_root)
+ Item_empty_string(thd, "Binlog_Ignore_DB", 255),
+ mem_root);
+}
+
+
/**
Execute a SHOW MASTER STATUS statement.
@@ -4100,23 +4119,10 @@ err:
bool show_binlog_info(THD* thd)
{
Protocol *protocol= thd->protocol;
- MEM_ROOT *mem_root= thd->mem_root;
DBUG_ENTER("show_binlog_info");
List<Item> field_list;
- field_list.push_back(new (mem_root)
- Item_empty_string(thd, "File", FN_REFLEN),
- mem_root);
- field_list.push_back(new (mem_root)
- Item_return_int(thd, "Position", 20,
- MYSQL_TYPE_LONGLONG),
- mem_root);
- field_list.push_back(new (mem_root)
- Item_empty_string(thd, "Binlog_Do_DB", 255),
- mem_root);
- field_list.push_back(new (mem_root)
- Item_empty_string(thd, "Binlog_Ignore_DB", 255),
- mem_root);
+ show_binlog_info_get_fields(thd, &field_list);
if (protocol->send_result_set_metadata(&field_list,
Protocol::SEND_NUM_ROWS | Protocol::SEND_EOF))
diff --git a/tests/mysql_client_test.c b/tests/mysql_client_test.c
index d871ea178ea..ccc39d5f9ce 100644
--- a/tests/mysql_client_test.c
+++ b/tests/mysql_client_test.c
@@ -450,6 +450,13 @@ static void test_prepare_simple()
DIE_UNLESS(mysql_stmt_field_count(stmt) == 47);
mysql_stmt_close(stmt);
+ /* show master status */
+ strmov(query, "SHOW MASTER STATUS");
+ stmt= mysql_simple_prepare(mysql, query);
+ check_stmt(stmt);
+ DIE_UNLESS(mysql_stmt_field_count(stmt) == 4);
+ mysql_stmt_close(stmt);
+
/* now fetch the results ..*/
rc= mysql_commit(mysql);
myquery(rc);