MySQL 8.0.29
Source Code Documentation
table_replication_applier_configuration.h
Go to the documentation of this file.
1/*
2 Copyright (c) 2013, 2022, Oracle and/or its affiliates.
3
4 This program is free software; you can redistribute it and/or modify
5 it under the terms of the GNU General Public License, version 2.0,
6 as published by the Free Software Foundation.
7
8 This program is also distributed with certain software (including
9 but not limited to OpenSSL) that is licensed under separate terms,
10 as designated in a particular file or component or in included license
11 documentation. The authors of MySQL hereby grant you an additional
12 permission to link the program and your derivative works with the
13 separately licensed software that they have included with MySQL.
14
15 This program is distributed in the hope that it will be useful,
16 but WITHOUT ANY WARRANTY; without even the implied warranty of
17 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18 GNU General Public License, version 2.0, for more details.
19
20 You should have received a copy of the GNU General Public License
21 along with this program; if not, write to the Free Software
22 Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */
23
24#ifndef TABLE_REPLICATION_APPLIER_CONFIGURATION_H
25#define TABLE_REPLICATION_APPLIER_CONFIGURATION_H
26
27/**
28 @file storage/perfschema/table_replication_applier_configuration.h
29 Table replication_applier_configuration (declarations).
30*/
31
32#include <sys/types.h>
33#include <time.h>
34
35#include "my_base.h"
36#include "sql/rpl_info.h" /*CHANNEL_NAME_LENGTH*/
37#include "sql/rpl_rli.h" /*enum_require_table_primary_key*/
40
41class Field;
42class Master_info;
43class Plugin_table;
44struct TABLE;
45struct THR_LOCK;
46
47#ifndef ENUM_RPL_YES_NO
48#define ENUM_RPL_YES_NO
50#endif
51
52/**
53 @addtogroup performance_schema_tables
54 @{
55*/
56
57/** A row in the table*/
63 std::string privilege_checks_user{""};
70};
71
73 public:
75 : PFS_engine_index(&m_key), m_key("CHANNEL_NAME") {}
76
77 ~PFS_index_rpl_applier_config() override = default;
78
79 virtual bool match(Master_info *mi);
80
81 private:
83};
84
85/** Table PERFORMANCE_SCHEMA.replication_applier_configuration */
88
89 private:
90 int make_row(Master_info *mi);
91
92 /** Table share lock. */
94 /** Table definition. */
96
97 /** Current row */
99 /** Current position. */
101 /** Next position. */
103
104 protected:
105 /**
106 Read the current row values.
107 @param table Table handle
108 @param buf row buffer
109 @param fields Table fields
110 @param read_all true if all columns are read.
111 */
112
113 int read_row_values(TABLE *table, unsigned char *buf, Field **fields,
114 bool read_all) override;
115
117
118 public:
120
121 /** Table share. */
124 static ha_rows get_row_count();
125
126 void reset_position(void) override;
127
128 int rnd_next() override;
129 int rnd_pos(const void *pos) override;
130
131 int index_init(uint idx, bool sorted) override;
132 int index_next() override;
133
134 private:
136};
137
138/** @} */
139#endif
enum_type
This accepted value of the type of the Assign_gtids_to_anonymous_transactions info OFF : Anonymous gt...
Definition: rpl_rli.h:104
Definition: field.h:573
Definition: rpl_mi.h:86
Definition: pfs_engine_table.h:299
An abstract PERFORMANCE_SCHEMA table.
Definition: pfs_engine_table.h:69
Definition: table_replication_applier_configuration.h:72
PFS_key_name m_key
Definition: table_replication_applier_configuration.h:82
~PFS_index_rpl_applier_config() override=default
virtual bool match(Master_info *mi)
Definition: table_replication_applier_configuration.cc:98
PFS_index_rpl_applier_config()
Definition: table_replication_applier_configuration.h:74
Definition: table_helper.h:1508
Class to hold information regarding a table to be created on behalf of a plugin.
Definition: plugin_table.h:39
enum_require_table_primary_key
Identifies what is the slave policy on primary keys in tables.
Definition: rpl_rli.h:268
Table PERFORMANCE_SCHEMA.replication_applier_configuration.
Definition: table_replication_applier_configuration.h:86
PFS_simple_index pos_t
Definition: table_replication_applier_configuration.h:87
int index_init(uint idx, bool sorted) override
Definition: table_replication_applier_configuration.cc:173
void reset_position(void) override
Reset the cursor position to the beginning of the table.
Definition: table_replication_applier_configuration.cc:127
table_replication_applier_configuration()
Definition: table_replication_applier_configuration.cc:121
static Plugin_table m_table_def
Table definition.
Definition: table_replication_applier_configuration.h:95
pos_t m_pos
Current position.
Definition: table_replication_applier_configuration.h:100
int read_row_values(TABLE *table, unsigned char *buf, Field **fields, bool read_all) override
Read the current row values.
Definition: table_replication_applier_configuration.cc:259
static ha_rows get_row_count()
Definition: table_replication_applier_configuration.cc:132
int make_row(Master_info *mi)
Definition: table_replication_applier_configuration.cc:209
int rnd_next() override
Fetch the next row in this cursor.
Definition: table_replication_applier_configuration.cc:136
PFS_index_rpl_applier_config * m_opened_index
Definition: table_replication_applier_configuration.h:135
static THR_LOCK m_table_lock
Table share lock.
Definition: table_replication_applier_configuration.h:93
pos_t m_next_pos
Next position.
Definition: table_replication_applier_configuration.h:102
int rnd_pos(const void *pos) override
Fetch a row by position.
Definition: table_replication_applier_configuration.cc:155
int index_next() override
Find key in index, read record.
Definition: table_replication_applier_configuration.cc:184
static PFS_engine_table_share m_share
Table share.
Definition: table_replication_applier_configuration.h:122
static PFS_engine_table * create(PFS_engine_table_share *)
Definition: table_replication_applier_configuration.cc:115
st_row_applier_config m_row
Current row.
Definition: table_replication_applier_configuration.h:98
char * pos
Definition: do_ctype.cc:76
@ PS_RPL_NO
Definition: table_replication_applier_configuration.h:49
@ PS_RPL_YES
Definition: table_replication_applier_configuration.h:49
This file includes constants used by all storage engines.
my_off_t ha_rows
Definition: my_base.h:1139
Definition: buf0block_hint.cc:29
Performance schema tables (declarations).
#define CHANNEL_NAME_LENGTH
Definition: rpl_info.h:40
A PERFORMANCE_SCHEMA table share.
Definition: pfs_engine_table.h:357
Position of a cursor, for simple iterations.
Definition: pfs_engine_table.h:558
Definition: table.h:1394
Definition: thr_lock.h:138
A row in the table.
Definition: table_replication_applier_configuration.h:58
enum_rpl_yes_no requires_row_format
Definition: table_replication_applier_configuration.h:64
time_t desired_delay
Definition: table_replication_applier_configuration.h:61
std::string assign_gtids_to_anonymous_transactions_value
Definition: table_replication_applier_configuration.h:69
bool desired_delay_is_set
Definition: table_replication_applier_configuration.h:62
Relay_log_info::enum_require_table_primary_key require_table_primary_key_check
Definition: table_replication_applier_configuration.h:66
char channel_name[CHANNEL_NAME_LENGTH]
Definition: table_replication_applier_configuration.h:59
std::string privilege_checks_user
Definition: table_replication_applier_configuration.h:63
uint channel_name_length
Definition: table_replication_applier_configuration.h:60
Assign_gtids_to_anonymous_transactions_info::enum_type assign_gtids_to_anonymous_transactions_type
Definition: table_replication_applier_configuration.h:68
Helpers to implement a performance schema table.
enum_rpl_yes_no
Definition: table_replication_applier_configuration.h:49
Include file for Sun RPC to compile out of the box.
unsigned int uint
Definition: uca-dump.cc:29