1/* Copyright (c) 2010, 2012, Oracle and/or its affiliates. All rights reserved.
2
3 This program is free software; you can redistribute it and/or modify
4 it under the terms of the GNU General Public License as published by
5 the Free Software Foundation; version 2 of the License.
6
7 This program is distributed in the hope that it will be useful,
8 but WITHOUT ANY WARRANTY; without even the implied warranty of
9 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
10 GNU General Public License for more details.
11
12 You should have received a copy of the GNU General Public License
13 along with this program; if not, write to the Free Software
14 Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA */
15
16#ifndef TABLE_ESGS_BY_USER_BY_EVENT_NAME_H
17#define TABLE_ESGS_BY_USER_BY_EVENT_NAME_H
18
19/**
20 @file storage/perfschema/table_esgs_by_user_by_event_name.h
21 Table EVENTS_STAGES_SUMMARY_BY_USER_BY_EVENT_NAME (declarations).
22*/
23
24#include "pfs_column_types.h"
25#include "pfs_engine_table.h"
26#include "pfs_instr_class.h"
27#include "pfs_instr.h"
28#include "pfs_user.h"
29#include "table_helper.h"
30
31/**
32 @addtogroup Performance_schema_tables
33 @{
34*/
35
36/**
37 A row of table
38 PERFORMANCE_SCHEMA.EVENTS_STAGES_SUMMARY_BY_USER_BY_EVENT_NAME.
39*/
40struct row_esgs_by_user_by_event_name
41{
42 /** Column USER. */
43 PFS_user_row m_user;
44 /** Column EVENT_NAME. */
45 PFS_event_name_row m_event_name;
46 /** Columns COUNT_STAR, SUM/MIN/AVG/MAX TIMER_WAIT. */
47 PFS_stage_stat_row m_stat;
48};
49
50/**
51 Position of a cursor on
52 PERFORMANCE_SCHEMA.EVENTS_STAGES_SUMMARY_BY_USER_BY_EVENT_NAME.
53 Index 1 on user (0 based)
54 Index 2 on stage class (1 based)
55*/
56struct pos_esgs_by_user_by_event_name
57: public PFS_double_index
58{
59 pos_esgs_by_user_by_event_name()
60 : PFS_double_index(0, 1)
61 {}
62
63 inline void reset(void)
64 {
65 m_index_1= 0;
66 m_index_2= 1;
67 }
68
69 inline bool has_more_user(void)
70 { return (m_index_1 < user_max); }
71
72 inline void next_user(void)
73 {
74 m_index_1++;
75 m_index_2= 1;
76 }
77
78 inline void next_stage(void)
79 {
80 m_index_2++;
81 }
82};
83
84/** Table PERFORMANCE_SCHEMA.EVENTS_STAGES_SUMMARY_BY_USER_BY_EVENT_NAME. */
85class table_esgs_by_user_by_event_name : public PFS_engine_table
86{
87public:
88 /** Table share */
89 static PFS_engine_table_share m_share;
90 static PFS_engine_table* create();
91 static int delete_all_rows();
92
93 virtual int rnd_init(bool scan);
94 virtual int rnd_next();
95 virtual int rnd_pos(const void *pos);
96 virtual void reset_position(void);
97
98protected:
99 virtual int read_row_values(TABLE *table,
100 unsigned char *buf,
101 Field **fields,
102 bool read_all);
103
104 table_esgs_by_user_by_event_name();
105
106public:
107 ~table_esgs_by_user_by_event_name()
108 {}
109
110protected:
111 void make_row(PFS_user *user, PFS_stage_class *klass);
112
113private:
114 /** Table share lock. */
115 static THR_LOCK m_table_lock;
116
117 /** Current row. */
118 row_esgs_by_user_by_event_name m_row;
119 /** True is the current row exists. */
120 bool m_row_exists;
121 /** Current position. */
122 pos_esgs_by_user_by_event_name m_pos;
123 /** Next position. */
124 pos_esgs_by_user_by_event_name m_next_pos;
125};
126
127/** @} */
128#endif
129