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
|
/* Copyright (c) 2010, 2015, Oracle and/or its affiliates. All rights reserved.
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 St, Fifth Floor, Boston, MA 02110-1335 USA */
#ifndef PFS_EVENTS_STATEMENTS_H
#define PFS_EVENTS_STATEMENTS_H
/**
@file storage/perfschema/pfs_events_statements.h
Events statements data structures (declarations).
*/
#include "pfs_column_types.h"
#include "pfs_events.h"
#include "pfs_digest.h"
struct PFS_thread;
struct PFS_account;
struct PFS_user;
struct PFS_host;
/** A statement record. */
struct PFS_events_statements : public PFS_events
{
/** Database name. */
char m_current_schema_name[NAME_LEN];
/** Length of @c m_current_schema_name. */
uint m_current_schema_name_length;
/** SQL_TEXT */
char m_sqltext[COL_INFO_SIZE];
/** Length of @ m_info. */
uint m_sqltext_length;
/** Locked time. */
ulonglong m_lock_time;
/** Diagnostics area, message text. */
char m_message_text[MYSQL_ERRMSG_SIZE+1];
/** Diagnostics area, error number. */
uint m_sql_errno;
/** Diagnostics area, SQLSTATE. */
char m_sqlstate[SQLSTATE_LENGTH];
/** Diagnostics area, error count. */
uint m_error_count;
/** Diagnostics area, warning count. */
uint m_warning_count;
/** Diagnostics area, rows affected. */
ulonglong m_rows_affected;
/** Optimizer metric, number of rows sent. */
ulonglong m_rows_sent;
/** Optimizer metric, number of rows examined. */
ulonglong m_rows_examined;
/** Optimizer metric, number of temporary tables created on disk. */
ulonglong m_created_tmp_disk_tables;
/** Optimizer metric, number of temporary tables created. */
ulonglong m_created_tmp_tables;
/** Optimizer metric, number of full join. */
ulonglong m_select_full_join;
/** Optimizer metric, number of full range join. */
ulonglong m_select_full_range_join;
/** Optimizer metric, number of select range. */
ulonglong m_select_range;
/** Optimizer metric, number of select range checks. */
ulonglong m_select_range_check;
/** Optimizer metric, number of select scans. */
ulonglong m_select_scan;
/** Optimizer metric, number of sort merge passes. */
ulonglong m_sort_merge_passes;
/** Optimizer metric, number of sort ranges. */
ulonglong m_sort_range;
/** Optimizer metric, number of sort rows. */
ulonglong m_sort_rows;
/** Optimizer metric, number of sort scans. */
ulonglong m_sort_scan;
/** Optimizer metric, number of 'no index used'. */
ulonglong m_no_index_used;
/** Optimizer metric, number of 'no good index used'. */
ulonglong m_no_good_index_used;
/** True if sqltext was truncated. */
bool m_sqltext_truncated;
/** Statement character set number. */
uint m_sqltext_cs_number;
/**
Statement digest.
This underlying token array storage pointer is immutable,
and always point to pre allocated memory.
*/
sql_digest_storage m_digest_storage;
};
void insert_events_statements_history(PFS_thread *thread, PFS_events_statements *statement);
void insert_events_statements_history_long(PFS_events_statements *statement);
extern bool flag_events_statements_current;
extern bool flag_events_statements_history;
extern bool flag_events_statements_history_long;
extern bool events_statements_history_long_full;
extern volatile uint32 events_statements_history_long_index;
extern PFS_events_statements *events_statements_history_long_array;
extern size_t events_statements_history_long_size;
int init_events_statements_history_long(size_t events_statements_history_long_sizing);
void cleanup_events_statements_history_long();
void reset_events_statements_current();
void reset_events_statements_history();
void reset_events_statements_history_long();
void reset_events_statements_by_thread();
void reset_events_statements_by_account();
void reset_events_statements_by_user();
void reset_events_statements_by_host();
void reset_events_statements_global();
void aggregate_account_statements(PFS_account *account);
void aggregate_user_statements(PFS_user *user);
void aggregate_host_statements(PFS_host *host);
#endif
|
