blob: 1a60d20367e03ac6cfb9668074b228a1fc354f9a (
plain) (
blame)
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
|
#pragma once
#include "clickhouse_config.h"
#if USE_MYSQL
#include <base/types.h>
#include <Core/MySQL/MySQLReplication.h>
#error #include <mysqlxx/Connection.h>
#error #include <mysqlxx/PoolWithFailover.h>
#include <Interpreters/Context.h>
namespace DB
{
/** Materialize database engine metadata
*
* Record data version and current snapshot of MySQL, including:
* binlog_file - currently executing binlog_file
* binlog_position - position of the currently executing binlog file
* executed_gtid_set - currently executing gtid
* need_dumping_tables - Table structure snapshot at the current moment(Only when database first created or executed binlog file is deleted)
*/
struct MaterializeMetadata
{
const String persistent_path;
const Settings settings;
String binlog_file;
UInt64 binlog_position;
String binlog_do_db;
String binlog_ignore_db;
String executed_gtid_set;
size_t data_version = 1;
size_t meta_version = 2;
String binlog_checksum = "CRC32";
void fetchMasterStatus(mysqlxx::PoolWithFailover::Entry & connection);
void fetchMasterVariablesValue(const mysqlxx::PoolWithFailover::Entry & connection);
bool checkBinlogFileExists(const mysqlxx::PoolWithFailover::Entry & connection) const;
void transaction(const MySQLReplication::Position & position, const std::function<void()> & fun);
void startReplication(
mysqlxx::PoolWithFailover::Entry & connection,
const String & database,
bool & opened_transaction,
std::unordered_map<String, String> & need_dumping_tables,
std::unordered_set<String> & materialized_tables_list);
MaterializeMetadata(const String & path_, const Settings & settings_);
};
}
#endif
|
