1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
|
/* Copyright (C) 2013 Percona and Sergey Vojtovich
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; version 2 of the License.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1335 USA */
#define MYSQL_SERVER
#include <my_global.h>
#include <sql_class.h>
#include <sql_i_s.h>
#include <sql_show.h>
#include <mysql/plugin_audit.h>
#include "query_response_time.h"
ulong opt_query_response_time_range_base= QRT_DEFAULT_BASE;
my_bool opt_query_response_time_stats= 0;
static my_bool opt_query_response_time_flush= 0;
static void query_response_time_flush_update(
MYSQL_THD thd __attribute__((unused)),
struct st_mysql_sys_var *var __attribute__((unused)),
void *tgt __attribute__((unused)),
const void *save __attribute__((unused)))
{
query_response_time_flush();
}
static MYSQL_SYSVAR_ULONG(range_base, opt_query_response_time_range_base,
PLUGIN_VAR_RQCMDARG,
"Select base of log for query_response_time ranges. WARNING: variable "
"change affect only after flush",
NULL, NULL, QRT_DEFAULT_BASE, 2, QRT_MAXIMUM_BASE, 1);
static MYSQL_SYSVAR_BOOL(stats, opt_query_response_time_stats,
PLUGIN_VAR_OPCMDARG,
"Enable or disable query response time statisics collecting",
NULL, NULL, FALSE);
static MYSQL_SYSVAR_BOOL(flush, opt_query_response_time_flush,
PLUGIN_VAR_NOCMDOPT,
"Update of this variable flushes statistics and re-reads "
"query_response_time_range_base",
NULL, query_response_time_flush_update, FALSE);
#ifndef DBUG_OFF
static MYSQL_THDVAR_ULONGLONG(exec_time_debug, PLUGIN_VAR_NOCMDOPT,
"Pretend queries take this many microseconds. When 0 (the default) use "
"the actual execution time. Used only for debugging.",
NULL, NULL, 0, 0, LONG_TIMEOUT, 1);
#endif
static struct st_mysql_sys_var *query_response_time_info_vars[]=
{
MYSQL_SYSVAR(range_base),
MYSQL_SYSVAR(stats),
MYSQL_SYSVAR(flush),
#ifndef DBUG_OFF
MYSQL_SYSVAR(exec_time_debug),
#endif
NULL
};
namespace Show {
ST_FIELD_INFO query_response_time_fields_info[] =
{
Column("TIME", Varchar(QRT_TIME_STRING_LENGTH), NOT_NULL, "Time"),
Column("COUNT", ULong(), NOT_NULL, "Count"),
Column("TOTAL", Varchar(QRT_TIME_STRING_LENGTH), NOT_NULL, "Total"),
CEnd()
};
} // namespace Show
static int query_response_time_info_init(void *p)
{
ST_SCHEMA_TABLE *i_s_query_response_time= (ST_SCHEMA_TABLE *) p;
i_s_query_response_time->fields_info= Show::query_response_time_fields_info;
i_s_query_response_time->fill_table= query_response_time_fill;
i_s_query_response_time->reset_table= query_response_time_flush;
query_response_time_init();
return 0;
}
static int query_response_time_info_deinit(void *arg __attribute__((unused)))
{
opt_query_response_time_stats= 0;
query_response_time_free();
return 0;
}
static struct st_mysql_information_schema query_response_time_info_descriptor=
{ MYSQL_INFORMATION_SCHEMA_INTERFACE_VERSION };
static void query_response_time_audit_notify(MYSQL_THD thd,
unsigned int event_class,
const void *event)
{
const struct mysql_event_general *event_general=
(const struct mysql_event_general *) event;
DBUG_ASSERT(event_class == MYSQL_AUDIT_GENERAL_CLASS);
if (event_general->event_subclass == MYSQL_AUDIT_GENERAL_STATUS &&
opt_query_response_time_stats)
{
#ifndef DBUG_OFF
if (THDVAR(thd, exec_time_debug))
query_response_time_collect(thd->lex->sql_command != SQLCOM_SET_OPTION ?
THDVAR(thd, exec_time_debug) : 0);
else
#endif
query_response_time_collect(thd->utime_after_query - thd->utime_after_lock);
}
}
static struct st_mysql_audit query_response_time_audit_descriptor=
{
MYSQL_AUDIT_INTERFACE_VERSION, NULL, query_response_time_audit_notify,
{ (unsigned long) MYSQL_AUDIT_GENERAL_CLASSMASK }
};
maria_declare_plugin(query_response_time)
{
MYSQL_INFORMATION_SCHEMA_PLUGIN,
&query_response_time_info_descriptor,
"QUERY_RESPONSE_TIME",
"Percona and Sergey Vojtovich",
"Query Response Time Distribution INFORMATION_SCHEMA Plugin",
PLUGIN_LICENSE_GPL,
query_response_time_info_init,
query_response_time_info_deinit,
0x0100,
NULL,
query_response_time_info_vars,
"1.0",
MariaDB_PLUGIN_MATURITY_STABLE
},
{
MYSQL_AUDIT_PLUGIN,
&query_response_time_audit_descriptor,
"QUERY_RESPONSE_TIME_AUDIT",
"Percona and Sergey Vojtovich",
"Query Response Time Distribution Audit Plugin",
PLUGIN_LICENSE_GPL,
NULL,
NULL,
0x0100,
NULL,
NULL,
"1.0",
MariaDB_PLUGIN_MATURITY_STABLE
}
maria_declare_plugin_end;
|
