Skip to content
Permalink
master
Switch branches/tags

Name already in use

A tag already exists with the provided branch name. Many Git commands accept both tag and branch names, so creating this branch may cause unexpected behavior. Are you sure you want to create this branch?

patches/mysql/5.0/connection_status.patch

Go to file
 
 
Cannot retrieve contributors at this time
246 lines (233 sloc) 7.46 KB
Raw Blame
Open in GitHub Desktop
diff -Nur -x bdb mysql-5.0.26/sql/item_create.cc set_session/sql/item_create.cc
--- mysql-5.0.26/sql/item_create.cc 2006-10-04 04:24:09.000000000 -0700
+++ set_session/sql/item_create.cc 2006-10-17 20:22:26.000000000 -0700
@@ -75,6 +75,11 @@
return new Item_func_connection_id();
}
+Item *create_func_connection_status(void)
+{
+ return new Item_func_connection_status();
+}
+
Item *create_func_conv(Item* a, Item *b, Item *c)
{
return new Item_func_conv(a,b,c);
diff -Nur -x bdb mysql-5.0.26/sql/item_create.h set_session/sql/item_create.h
--- mysql-5.0.26/sql/item_create.h 2006-10-04 04:24:01.000000000 -0700
+++ set_session/sql/item_create.h 2006-10-17 19:58:25.000000000 -0700
@@ -31,6 +31,7 @@
Item *create_func_cast(Item *a, Cast_target cast_type, int len, int dec,
CHARSET_INFO *cs);
Item *create_func_connection_id(void);
+Item *create_func_connection_status(void);
Item *create_func_conv(Item* a, Item *b, Item *c);
Item *create_func_cos(Item* a);
Item *create_func_cot(Item* a);
diff -Nur -x bdb mysql-5.0.26/sql/item_strfunc.cc set_session/sql/item_strfunc.cc
--- mysql-5.0.26/sql/item_strfunc.cc 2006-10-04 04:24:23.000000000 -0700
+++ set_session/sql/item_strfunc.cc 2006-10-17 20:40:35.000000000 -0700
@@ -3175,3 +3175,15 @@
return str;
}
+String *Item_func_connection_status::val_str(String *str)
+{
+ if(!current_thd->connection_status)
+ {
+ null_value= 1;
+ return 0;
+ }
+
+ str->copy(current_thd->connection_status, strlen(current_thd->connection_status), system_charset_info);
+ return str;
+}
+
diff -Nur -x bdb mysql-5.0.26/sql/item_strfunc.h set_session/sql/item_strfunc.h
--- mysql-5.0.26/sql/item_strfunc.h 2006-10-04 04:24:10.000000000 -0700
+++ set_session/sql/item_strfunc.h 2006-10-17 20:16:26.000000000 -0700
@@ -842,3 +842,13 @@
String *val_str(String *);
};
+class Item_func_connection_status: public Item_str_func
+{
+public:
+ Item_func_connection_status(): Item_str_func() {}
+ void fix_length_and_dec() {
+ max_length= MAX_BLOB_WIDTH;
+ }
+ const char *func_name() const{ return "connection_status"; }
+ String *val_str(String *);
+};
diff -Nur -x bdb mysql-5.0.26/sql/lex.h set_session/sql/lex.h
--- mysql-5.0.26/sql/lex.h 2006-10-04 04:24:43.000000000 -0700
+++ set_session/sql/lex.h 2006-10-17 20:13:15.000000000 -0700
@@ -577,6 +577,7 @@
{ "CONCAT", SYM(CONCAT)},
{ "CONCAT_WS", SYM(CONCAT_WS)},
{ "CONNECTION_ID", F_SYM(FUNC_ARG0),0,CREATE_FUNC(create_func_connection_id)},
+ { "CONNECTION_STATUS",F_SYM(FUNC_ARG0),0,CREATE_FUNC(create_func_connection_status)},
{ "CONV", F_SYM(FUNC_ARG3),0,CREATE_FUNC(create_func_conv)},
{ "CONVERT_TZ", SYM(CONVERT_TZ_SYM)},
{ "COUNT", SYM(COUNT_SYM)},
diff -Nur -x bdb mysql-5.0.26/sql/set_var.cc set_session/sql/set_var.cc
--- mysql-5.0.26/sql/set_var.cc 2006-10-04 04:24:23.000000000 -0700
+++ set_session/sql/set_var.cc 2006-10-17 19:52:21.000000000 -0700
@@ -3299,6 +3299,51 @@
return 0;
}
+/*****************************************************************************
+ Functions to handle SET CONNECTION STATUS [=] expr
+*****************************************************************************/
+
+/*
+ Set the connection status for a thread
+
+ SYNOPSIS
+ status_arg current status string
+
+ RETURN
+ 0
+*/
+set_var_connection_status::set_var_connection_status(String *status_arg)
+{
+ if(status_arg)
+ {
+ status.copy(*status_arg);
+ is_null= 0;
+ } else {
+ is_null= 1;
+ }
+}
+
+int set_var_connection_status::check(THD *thd)
+{
+ return 0;
+}
+
+int set_var_connection_status::update(THD *thd)
+{
+ if(thd->connection_status)
+ {
+ my_free((gptr)thd->connection_status, MYF(0));
+ thd->connection_status= 0;
+ }
+ if(!is_null)
+ {
+ thd->connection_status= my_strdup(status.c_ptr(), MYF(0));
+ } else {
+ thd->connection_status= 0;
+ }
+ return 0;
+}
+
/*****************************************************************************
Functions to handle SET PASSWORD
diff -Nur -x bdb mysql-5.0.26/sql/set_var.h set_session/sql/set_var.h
--- mysql-5.0.26/sql/set_var.h 2006-10-04 04:24:22.000000000 -0700
+++ set_session/sql/set_var.h 2006-10-17 18:46:34.000000000 -0700
@@ -923,6 +923,19 @@
int update(THD *thd);
};
+/* For SET CONNECTION STATUS */
+
+class set_var_connection_status: public set_var_base
+{
+ String status;
+ bool is_null;
+public:
+ set_var_connection_status(String *status_arg);
+ int check(THD *thd);
+ int update(THD *thd);
+};
+
+
/* For SET NAMES and SET CHARACTER SET */
diff -Nur -x bdb mysql-5.0.26/sql/sql_class.cc set_session/sql/sql_class.cc
--- mysql-5.0.26/sql/sql_class.cc 2006-10-04 04:24:43.000000000 -0700
+++ set_session/sql/sql_class.cc 2006-10-17 19:58:01.000000000 -0700
@@ -238,6 +238,7 @@
/* Variables with default values */
proc_info="login";
+ connection_status= 0;
where= THD::DEFAULT_WHERE;
server_id = ::server_id;
slave_net = 0;
diff -Nur -x bdb mysql-5.0.26/sql/sql_class.h set_session/sql/sql_class.h
--- mysql-5.0.26/sql/sql_class.h 2006-10-04 04:24:43.000000000 -0700
+++ set_session/sql/sql_class.h 2006-10-17 14:48:26.000000000 -0700
@@ -1147,6 +1147,9 @@
*/
const char *proc_info;
+ /* for connection status*/
+ const char *connection_status;
+
ulong client_capabilities; /* What the client supports */
ulong max_client_packet_length;
diff -Nur -x bdb mysql-5.0.26/sql/sql_show.cc set_session/sql/sql_show.cc
--- mysql-5.0.26/sql/sql_show.cc 2006-10-04 04:24:21.000000000 -0700
+++ set_session/sql/sql_show.cc 2006-10-17 16:47:30.000000000 -0700
@@ -1266,6 +1266,7 @@
uint command;
const char *user,*host,*db,*proc_info,*state_info;
char *query;
+ char *connection_status;
};
#ifdef HAVE_EXPLICIT_TEMPLATE_INSTANTIATION
@@ -1293,6 +1294,11 @@
field->maybe_null=1;
field_list.push_back(field=new Item_empty_string("Info",max_query_length));
field->maybe_null=1;
+ if(verbose)
+ {
+ field_list.push_back(field=new Item_empty_string("Status",max_query_length));
+ field->maybe_null=1;
+ }
if (protocol->send_fields(&field_list,
Protocol::SEND_NUM_ROWS | Protocol::SEND_EOF))
DBUG_VOID_RETURN;
@@ -1367,6 +1373,15 @@
uint length= min(max_query_length, tmp->query_length);
thd_info->query=(char*) thd->strmake(tmp->query,length);
}
+
+ if( verbose )
+ {
+ if(tmp->connection_status)
+ thd_info->connection_status= thd->strdup(tmp->connection_status);
+ else
+ thd_info->connection_status= 0;
+ }
+
thread_infos.append(thd_info);
}
}
@@ -1392,6 +1407,13 @@
protocol->store_null();
protocol->store(thd_info->state_info, system_charset_info);
protocol->store(thd_info->query, system_charset_info);
+ if(verbose)
+ {
+ if(thd_info->connection_status)
+ protocol->store(thd_info->connection_status, system_charset_info);
+ else
+ protocol->store_null();
+ }
if (protocol->write())
break; /* purecov: inspected */
}
diff -Nur -x bdb mysql-5.0.26/sql/sql_yacc.yy set_session/sql/sql_yacc.yy
--- mysql-5.0.26/sql/sql_yacc.yy 2006-10-04 04:24:23.000000000 -0700
+++ set_session/sql/sql_yacc.yy 2006-10-17 18:51:34.000000000 -0700
@@ -8111,6 +8111,14 @@
{
Lex->var_list.push_back(new set_var_password($3,$5));
}
+ | CONNECTION_SYM STATUS_SYM opt_equal expr
+ {
+ THD *thd= YYTHD;
+ Item *e= $4;
+ e->fix_fields(thd, &e);
+ String str, *res= e->val_str(&str);
+ Lex->var_list.push_back(new set_var_connection_status(res));
+ }
;
internal_variable_name: