开发指南—Replication

简介: 特性 兼容MySQL Binlog文件格式和Dump协议。PolarDB-X的全局Binlog是在DN节点的物理Binlog基础之上生成的,剔除了分布式事务的细节,只保留了单机事务的特性。同时,全局Binlog兼容MySQL Binlog文件格式,在数据订阅方式上也完全兼容MySQL Dump协议,您可以像使用单机MySQL一样来订阅PolarDB-X的事务日志。

特性

  • 兼容MySQL Binlog文件格式和Dump协议。PolarDB-X的全局Binlog是在DN节点的物理Binlog基础之上生成的,剔除了分布式事务的细节,只保留了单机事务的特性。同时,全局Binlog兼容MySQL Binlog文件格式,在数据订阅方式上也完全兼容MySQL Dump协议,您可以像使用单机MySQL一样来订阅PolarDB-X的事务日志。
  • 保证分布式事务的完整性和有序性。全局Binlog不是将物理Binlog简单地汇总到一起,而是通过合并模块和归并模块保证了分布式事务的完整性和有序性,从而实现高数据一致性。例如,在转账场景下,基于全局Binlog能力,接入PolarDB-X的下游MySQL,可以在任何时刻查询到一致的余额。
  • 提供7x24小时服务能力,运维简单。全局Binlog剔除了PolarDB-X的内部细节(此时您可以将PolarDB-X看作一个单机MySQL), 来避免实例内部发生的变化对数据订阅链路的影响。PolarDB-X通过一系列的协议和算法来保证全局Binlog的服务能力,确保实例内部发生的各种变更(如HA切换、增删节点、执行Scale Out或分布式DDL等操作)不会影响数据订阅链路的正常工作。

使用限制

  • 暂不支持Gtid(Global Transaction Identifier)模式下的数据订阅方式。
  • 仅当事务策略指定为TSO时(即更高强度的一致性保证),才支持对分布式事务的合并。

数据订阅源端支持的SQL语句

  • 查看PolarDB-X全局Binlog文件列表。
SHOW BINARY LOGS

  • 说明 执行上述SQL语句需要有SUPER或REPLICATION CLIENT权限。权限操作请参见账号和权限系统
  • 查看PolarDB-X作为主Master角色的Binlog信息。
SHOW MASTER STATUS

  • 说明 执行上述SQL语句需要有SUPER或REPLICATION CLIENT权限。权限操作请参见账号和权限系统
  • 查看全局Binlog文件中的具体事件信息。
SHOW BINLOG EVENTS

[IN 'log_name']
[FROM pos]
[LIMIT [offset,] row_count]

  • 说明 执行上述SQL语句需要有SUPER或REPLICATION CLIENT权限。权限操作请参见账号和权限系统

数据订阅目标端支持的SQL语句

如果数据订阅目标端是标准MySQL,目前支持MySQL的Replicate指令。

  • 在数据订阅目标端设置需要同步的源端数据源信息。
CHANGE MASTER TO option [, option] ... [ channel_option ]
option: {
MASTER_BIND = 'interface_name'
| MASTER_HOST = 'host_name'
| MASTER_USER = 'user_name'
| MASTER_PASSWORD = 'password'
| MASTER_PORT = port_num
| PRIVILEGE_CHECKS_USER = {'account' | NULL}
| REQUIRE_ROW_FORMAT = {0|1}
| REQUIRE_TABLE_PRIMARY_KEY_CHECK = {STREAM | ON | OFF}
| ASSIGN_GTIDS_TO_ANONYMOUS_TRANSACTIONS = {OFF | LOCAL | uuid}
| MASTER_LOG_FILE = 'source_log_name'
| MASTER_LOG_POS = source_log_pos
| MASTER_AUTO_POSITION = {0|1}
| RELAY_LOG_FILE = 'relay_log_name'
| RELAY_LOG_POS = relay_log_pos
| MASTER_HEARTBEAT_PERIOD = interval
| MASTER_CONNECT_RETRY = interval
| MASTER_RETRY_COUNT = count
| SOURCE_CONNECTION_AUTO_FAILOVER = {0|1}
| MASTER_DELAY = interval
| MASTER_COMPRESSION_ALGORITHMS = 'value'
| MASTER_ZSTD_COMPRESSION_LEVEL = level
| MASTER_SSL = {0|1}
| MASTER_SSL_CA = 'ca_file_name'
| MASTER_SSL_CAPATH = 'ca_directory_name'
| MASTER_SSL_CERT = 'cert_file_name'
| MASTER_SSL_CRL = 'crl_file_name'
| MASTER_SSL_CRLPATH = 'crl_directory_name'
| MASTER_SSL_KEY = 'key_file_name'
| MASTER_SSL_CIPHER = 'cipher_list'
| MASTER_SSL_VERIFY_SERVER_CERT = {0|1}
| MASTER_TLS_VERSION = 'protocol_list'
| MASTER_TLS_CIPHERSUITES = 'ciphersuite_list'
| MASTER_PUBLIC_KEY_PATH = 'key_file_name'
| GET_MASTER_PUBLIC_KEY = {0|1}
| NETWORK_NAMESPACE = 'namespace'
| IGNORE_SERVER_IDS = (server_id_list)
}
channel_option:
FOR CHANNEL channel
server_id_list:
[server_id [, server_id] ... ]
  • 开启主备同步
START {SLAVE | REPLICA}
  • 停止主备同步
STOP {SLAVE | REPLICA}
  • 重置主备同步,需要先停止主备同步
RESET {SLAVE | REPLICA} [ALL] [channel_option]
channel_option:
FOR CHANNEL channel

  • 说明 如果目标端是PolarDB-X,目前暂时不支持相关Replicate指令。
相关文章
|
SQL Java 数据库连接
JDBC DriverManager 详解
JDBC(Java Database Connectivity)是 Java 标准库中用于与数据库进行交互的 API。它允许 Java 应用程序连接到各种不同的数据库管理系统(DBMS),执行 SQL 查询和更新操作,以及处理数据库事务。在 JDBC 中,DriverManager 是一个关键的类,用于管理数据库驱动程序和建立数据库连接。本文将详细介绍 JDBC DriverManager 的用法,面向基础小白,帮助您快速入门 JDBC 数据库连接。
395 1
|
存储 监控 数据可视化
无需重新学习,使用 Kibana 查询/可视化 SLS 数据
本文演示了使用 Kibana 连接 SLS ES 兼容接口进行查询和分析的方法。
67462 103
|
搜索推荐 API 数据处理
Python魔法:打造个性化天气查询工具
【8月更文挑战第31天】 在这篇文章中,我们将一起探索如何用Python构建一个个性化的天气查询工具。不同于传统的技术文章,我们将通过一个简单的故事引入主题,让读者感受到编程的乐趣和实用性。文章将介绍如何使用API获取数据,处理这些数据,并以用户友好的方式展示信息。无论你是编程新手还是想扩展你的项目库,这篇文章都会给你提供有价值的见解和代码示例。
|
机器学习/深度学习 人工智能 算法
探索机器学习中的算法优化之路
【4月更文挑战第28天】 在机器学习的广阔天地中,算法是构建智能系统的核心。本文将深入探讨算法优化的策略与实践,从理论到应用,揭示提升模型性能的关键因素。我们将穿梭于参数调整、特征工程、模型选择和超参数优化等关键环节,剖析如何通过迭代改进,达到提高准确率、减少误差的目的。此文不仅为初学者提供启示,也为经验丰富的开发者提供深度思考,共同探索算法的极致潜能。
|
搜索推荐 Shell
idea如何Ctrl + F查找内容,当前文件内容,Ctrl+R全局替换C t r l + S h i f t + R
idea如何Ctrl + F查找内容,当前文件内容,Ctrl+R全局替换C t r l + S h i f t + R
|
域名解析 JSON 监控
Mqtt学习笔记--接入阿里云(2)
Mqtt学习笔记--接入阿里云(2)
471 1
|
XML JSON API
淘宝商品详情数据接口(taobao.item_get)
淘宝商品详情数据接口(taobao.item_get)
|
PyTorch 算法框架/工具 C++
导入pytorch报错:Redistributable is not installed...安装vc_redist.x64.exe报错:Error 1402:Could not open key..
导入pytorch报错:Redistributable is not installed...安装vc_redist.x64.exe报错:Error 1402:Could not open key..
导入pytorch报错:Redistributable is not installed...安装vc_redist.x64.exe报错:Error 1402:Could not open key..
|
前端开发 新制造 UED
SpringBoot-23-全局异常机制+RESTful统一规范
SpringBoot-23-全局异常机制+RESTful统一规范
277 0
|
Java 应用服务中间件 Apache
Tomcat 的安装与环境配置教程(超详细)
Tomcat 的安装与环境配置教程
1005 0
Tomcat 的安装与环境配置教程(超详细)