开源新发布|PolarDB-X v2.4.2开源生态适配升级
2025年09月开源PolarDB-X正式发布v2.4.2版本,重点完善周边生态能力,包含:新增客户端驱动(PolarDB-X Connector)、新开源polardbx-proxy组件,同时面向数据库运维和稳定性优化,提供在千亿大表场景下的实践验证,包含DDL在线变更、数据库扩缩容、数据TTL等的多项问题修复。详细请查阅ChangeLog[1]。
PolarDB分布式版简介
PolarDB分布式版(简称“PolarDB-X”)是阿里云自主研发的云原生集中式和分布式一体化数据库产品,整体采用了基于存储计算分离的Shared-Nothing系统架构,支持水平扩展、分布式事务、混合负载等能力,具备金融级高可用、高吞吐、大存储、低延时、易扩展、高度兼容MySQL系统及生态等特点。更多产品能力与特性介绍可参考产品文档[2]。
PolarDB分布式版产品架构
PolarDB具备多种产品输出形态:公共云、专有云、DBStack、轻量版(纯软输出)。不同产品输出形态采用同一套内核版本,充分发挥公有云产品管理和迭代优势,保障客户云上云下业务兼容,降低数据库管理成本。
2021年10月,阿里云宣布对外开源云原生分布式数据库PolarDB-X,采用全内核开源的模式,开源内容包含计算引擎、存储引擎、日志引擎、列存引擎等,开源历程详见:云原生数据库PolarDB开源社区[3]。
开源PolarDB-X v2.4.2特性
新增开源polardbx-proxy组件
PolarDB-X Proxy是使用Java开发的高性能PolarDB-X标准版的代理,具备自动识别集群主节点、无感高可用切换、读写分离、实例级连接池等功能。可以部署于PolarDB-X标准版之前,提供更加简易便捷的使用体验。(开源地址[4])
支持的功能:
读写分离 & 基于活跃请求数的负载均衡;
备库一致性读;
事务级连接池;
支持快速HA检测 & 幂等重试连接保持;
支持Prepared Statement性能提升 & 透传;
功能体验
通过docker镜像,可以一键拉起 polardbx-proxy。
wget https://raw.githubusercontent.com/polardb/polardbx-proxy/refs/heads/main/polardbx-proxy/quick_start.shquick_start.sh -e backend_address=127.0.0.1:3306 -e backend_username=appuser -e backend_password=appuser -e memory=4294967296
backend_address: 数据库地址(格式:ip:port,leader或者follower的地址);
backend_username: 数据库用户名;
backend_password: 数据库密码(必须有密码,必须使用 mysql_native_password);
memory: Proxy使用内存(单位B,请正确配置,否则可能会导致OOM,推荐 16GB,最少 4GB);
无需过多配置,可以直接访问,默认为3307端口。
mysql -Ac -h127.1 -P3307 -uappuser -pappuser整体的效果和直连PolarDB-X标准版体验基本一致,可以无缝适配数据库的用户名和schema等,polardbx-proxy仅支持对接一个polardbx 实例(多个副本),不支持挂载不同的polardbx实例。
比较实用的管理指令:
1. show cluster (查询PolarDB-X后端Paxos集群信息)
2. show rw / show ro (查询proxy的链接池情况)
3. show properties(查询proxy配置参数)
性能测试
购买一组ECS测试机,三个实例(单实例规格32C128G)部署PolarDB-X标准版,一个实例(规格:32C64G)部署proxy。然后压测Proxy的性能,主要看重其SQL转发的性能,特意选择最简单的SQL转发场景(sysbench的 oltp_point_select)。
测试场景 | sysbench oltp_point_select,1000并发 |
无proxy,直连polardb-x标准版 | QPS:1100089.10,DB CPU:98% |
有proxy,开箱参数(默认开启读写分离 + 默认打开全量SQL审计) | QPS:769210.60,Proxy CPU:80% |
有proxy,开箱参数 + 开启读写分离 + 关闭SQL审计 | QPS:1094244.83,Proxy CPU:90% |
有proxy,开箱参数 + 开启读写分离 + 开启备库延迟读 + 关闭SQL审计 | QPS:1284683.56,Proxy CPU:98% |
有proxy,开箱参数 + 关闭读写分离 + 关闭SQL审计 | QPS:1081086.38,Proxy CPU:90% |
测试结论:
1. polardbx-proxy的整体的性能,可以转到单core 4万QPS;
2. 全量SQL审计,可以按需打开,部分影响性能;
JDBC/GO/C++客户端驱动
PolarDB-X Connector,提供多语言的驱动实现,可以方便集成到应用中,提供自动识别集群主节点、无感高可用切换、读写分离、负载均衡等功能。相比于 PolarDB-X Proxy,可以减少额外的 Proxy 资源部署。
支持的功能:
支持多语言驱动,包含JDBC、GO、C++;
直连PolarDB-X 2.0标准版,并提供在HA后自动连接新主节点的能力、以及提供无感切换能力;
直连PolarDB-X 2.0企业版,并实现多节点的负载均衡;
客户端驱动 | 软件地址 |
Java | https://repo1.maven.org/maven2/com/alibaba/polardbx/polardbx-connector-java |
GO | https://github.com/polardb/polardbx-connector-go |
C++ | https://github.com/polardb/polardbx-connector-cpp |
使用样例
以JDBC驱动为例,参考JDBC使用文档[5]。
简单maven使用例子:
<dependency><groupId>com.alibaba.polardbx</groupId><artifactId>polardbx-connector-java</artifactId><version>2.2.10</version></dependency>
JDBC URL样例:
jdbc:polardbx://11.167.60.147:6991/test驱动包名:com.alibaba.polardbx.Driver
协议标志头:polardbx
ip端口指定:
标准版三节点其中一个IP:port或者VIP:port,或者多个IP0:port0,IP1:port1(必须为同一集群中的节点,以英文逗号分隔),建连时会被路由到 leader 节点。
企业版其中一个IP:port或者VIP:port,或者多个IP0:port0,IP1:port1(必须为同一集群中的节点,以英文逗号分隔),建连时会负载均衡到集群中随机一个读写节点。
1. 直接使用驱动连接PolarDB-X
Class.forName("com.alibaba.polardbx.Driver");try (final Connection conn = DriverManager.getConnection("jdbc:polardbx://127.0.0.1:3306/", "root", "*****");final Statement stmt = conn.createStatement()) {try (final ResultSet rs = stmt.executeQuery("select 1")) {for (int i = 0; i < rs.getMetaData().getColumnCount(); ++i) {System.out.print(rs.getMetaData().getColumnName(i + 1) + "\t");}System.out.println();while (rs.next()) {for (int i = 0; i < rs.getMetaData().getColumnCount(); ++i) {System.out.print(rs.getObject(i + 1) + "\t");}System.out.println();}}}
2. 使用Druid连接池
<beanid="dataSource"class="com.alibaba.druid.pool.DruidDataSource"init-method="init"destroy-method="close"><propertyname="driverClassName"value="com.alibaba.polardbx.Driver" /><!-- 基本属性 URL、user、password --><propertyname="url"value="jdbc:polardbx://ip:port/db?autoReconnect=true&rewriteBatchedStatements=true&socketTimeout=30000&connectTimeout=3000" /><propertyname="username"value="root" /><propertyname="password"value="123456" /><!-- 配置初始化大小、最小、最大 --><propertyname="maxActive"value="20" /><propertyname="initialSize"value="3" /><propertyname="minIdle"value="3" /><!-- maxWait 获取连接等待超时的时间 --><propertyname="maxWait"value="60000" /><!-- timeBetweenEvictionRunsMillis 间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒 --><propertyname="timeBetweenEvictionRunsMillis"value="60000" /><!-- minEvictableIdleTimeMillis 一个连接在池中最小空闲的时间,单位是毫秒--><propertyname="minEvictableIdleTimeMillis"value="300000" /><!-- 检测连接是否可用的 SQL --><propertyname="validationQuery"value="select 'z' from dual" /><!-- 是否开启空闲连接检查 --><propertyname="testWhileIdle"value="true" /><!-- 是否在获取连接前检查连接状态 --><propertyname="testOnBorrow"value="false" /><!-- 是否在归还连接时检查连接状态 --><propertyname="testOnReturn"value="false" /><!-- 是否在固定时间关闭连接。增加此参数可以均衡后端服务节点参数 --><propertyname="phyTimeoutMillis"value="600000" /><!-- 是否在固定SQL使用次数之后关闭连接,增加此参数可以均衡后端服务节点参数--><propertyname="phyMaxUseCount"value="10000" /></bean>
Go驱动
polardbx-connector-go安装
go get github.com/polardb/polardbx-connector-go使用例子:
import (_ "github.com/polardb/polardbx-connector-go")db, err := sql.Open("polardbx", "user:password@tcp(ip:port)/dbname")if err != nil {panic(err)}db.SetConnMaxLifetime(time.Minute * 3)db.SetMaxOpenConns(10)db.SetMaxIdleConns(10)
功能体验:高可用无感切换
PolarDB-X结合polardbx-connector-java驱动,提供了面向数据库的无感切换能力。
比如:DBA进行数据库主动主机下线的运维,此时数据库需要发生预期内的HA切换操作,基于PolarDB-X数据库+驱动的无感切换能力,可以提供业务SQL不中断、不报错的无感体验,极大的改善业务使用数据库的体验。
无感切换,工作原理示意:
PolarDB-X提供的无感切换,通过驱动实时感知PolarDB-X标准版三节点集群状态,在数据库HA切换动作完成之前:
客户端驱动,阻塞分配连接返回,直到切换完成;
针对业务已经获取连接尽快完成请求,并标记其不可复用;
注意事项:
客户端驱动,新增两个无感切换的检查点(获取链接、归还链接),通过实时感知PolarDB-X标准版三节点集群状态,实现HA切换后链接的动态重建能力,仅增加了获取新连接时间,但不会导致已有连接上请求报错,实现计划切换时应用无感。
业务获取了数据库Connection链接,推荐使用标准try-with-resources实现的数据库操作,只要try块中的业务执行时间小于对应PolarDB-X设置的HA窗口(
consensus_wait_millisecond_before_change_leader时间阈值,默认为1秒),就不会因为计划切换报错。而对于持有连接时长超出时间阈值的长事务,因为横跨切换流程,切换后会因为不能写入而报错。目前PolarDB-X的无感切换能力,推荐链接池:Druid[6]>= 1.2.24版本。
适配开源MySQL的主备集群复制
自建MySQL迁移PolarDB-X,PolarDB-X提供了非常好的兼容性,目前用户最大的诉求是支持数据迁移、以及回流的标准方案。PolarDB-X在商业化版本,提供了专业的数据迁移和同步工具,比如阿里自研的DTS工具,官网完整说明见《解决方案:自建MySQL迁移至PolarDB-X》[7]。
PolarDB-X提供了兼容开源MySQL生态的手动迁移方案,比较适合熟悉MySQL的DBA操作。数据全量同步可以采用mysqldump工具,最主要的难点是在数据增量同步和回流方案。
在V2.4.2版本,PolarDB-X提供了兼容MySQL开源的主备集群复制,基于MySQL Binlog主从复制的方式进行增量同步,主库是MySQL为源库,从库是PolarDB-X DN的Leader节点为目标库。
MySQL增量同步到PolarDB-X
1. 在主库MySQL上。
#1. 主库上创建主从复制使用的账户create user rep identified with mysql_native_password by '123456';grant replication slave on *.* to rep;#2. 显示Master主机上已注册的复制主机列表mysql> show slave hosts;Empty set, 1 warning (0.00 sec)
2. PolarDB-X作为从库,在Leader节点上。#3.过滤掉不需要同步的系统库表,比如原有的心跳表等,# 将下面参数配置到从库的cnf文件中重启生效replicate_ignore_db=aaa:mysqlreplicate_ignore_db=aaa:sysreplicate_ignore_db=aaa:__recycle_bin__replicate_ignore_db=aaa:information_schemareplicate_ignore_db=aaa:performance_schema#4. 在从库上停掉之前创建aaa链路stop slave for channel 'aaa';reset slave all for channel 'aaa';#5. 配置主从复制链路aaa, master_host、master_port为主库的host和port,#master_user为刚才创建的复制账户change master to master_host = '127.0.0.1', master_port = 13050, \master_user = 'rep', master_password = '123456', \master_auto_position=1 \for channel 'aaa';#6. 查看该链路 Slave_IO_Running、Slave_SQL_Running都是Noshow slave status for channel 'aaa'\G#7. 在从库leader节点上启动aaa主从复制链路start slave for channel 'aaa';#8. 查看该链路 Slave_IO_Running、Slave_SQL_Running都是Yesshow slave status for channel 'aaa'\G
3. 继续在主库MySQL上。
#9. 登陆主库显示Master主机上已注册的复制主机列表mysql> show slave hosts;+-----------+------+-------+-----------+--------------------------------------+| Server_id | Host | Port | Master_id | Slave_UUID |+-----------+------+-------+-----------+--------------------------------------+| 10 | | 13060 | 2 | 26663b57-91e6-11f0-8700-b8599f3009a8 |+-----------+------+-------+-----------+--------------------------------------+1row in set(0.00 sec)
PolarDB-X反向增量回流到MySQL
1. PolarDB-X作为主库,在Leader节点上。
#1. 查看最新binlogmysql> show consensus logs;+---------------+-----------+-----------------+| Log_name | File_size | Start_log_index |+---------------+-----------+-----------------+| binlog.000001 | 15777 | 1 || binlog.000002 | 7611 | 44 |+---------------+-----------+-----------------+2rows in set(0.00 sec)#2. 查看最新binlog的最后一行的End_log_posmysql> show binlog events in 'binlog.000002';+---------------+------+--------------------------+-----------+-------------+--------------------------------------------------------------+| Log_name | Pos | Event_type | Server_id | End_log_pos | Info |+---------------+------+--------------------------+-----------+-------------+--------------------------------------------------------------+| binlog.000002 | 4 | Format_desc | 10 | 190 | Server ver: 8.0.32-X-Cluster-8.4.20-20241014, Binlog ver: 4 || binlog.000002 | 190 | Previous_consensus_index | 10 | 221 | ##PREV_CONSENSUS_INDEX: 44' || binlog.000002 | 221 | Previous_gtids | 10 | 332 | 37a1bb4b-91f9-11f0-b12d-b8599f3009a8:1-30,902b4fe0-92a4-11f0-92ea-b8599f3009a8:1-11 |.......| binlog.000002 | 7580 | Xid | 3 | 7611 | COMMIT /* xid=237 */ |+---------------+------+--------------------------+-----------+-------------+--------------------------------------------------------------+78rows in set(0.00 sec)
2. 在从库MySQL上。#3.过滤掉不需要同步的系统库表,比如原有的心跳表等,# 将下面参数配置到从库的cnf文件中重启生效replicate_ignore_db=mysqlreplicate_ignore_db=sysreplicate_ignore_db=__recycle_bin__replicate_ignore_db=information_schemareplicate_ignore_db=performance_schema#4. 在从库上停掉之前创建bbb链路stop slave for channel 'bbb';reset slave all for channel 'bbb';#5. 配置主从复制链路bbb, master_host、master_port为主库的host和port,#master_log_file、master_log_pos来自上面在主库上获取的值change master to master_host = '127.0.0.1', master_port = 13050, \master_user = 'rep', master_password = '123456', \master_log_file='binlog.000002' \master_log_pos=7611 \for channel 'bbb';#6. 查看该链路 Slave_IO_Running、Slave_SQL_Running都是Noshow slave status for channel 'bbb'\G#7. 在从库leader节点上启动bbb主从复制链路start slave for channel 'bbb';#8. 查看该链路 Slave_IO_Running、Slave_SQL_Running都是Yesshow slave status for channel 'bbb'\G
3. PolarDB-X作为主库,在Leader节点上。#9. 登陆主库显示Master主机上已注册的复制主机列表mysql> show slave hosts;+-----------+------+-------+-----------+--------------------------------------+| Server_id | Host | Port | Master_id | Slave_UUID |+-----------+------+-------+-----------+--------------------------------------+| 1 | | 13010 | 2 | 902b4fe0-92a4-11f0-92ea-b8599f3009a8 |+-----------+------+-------+-----------+--------------------------------------+1row in set(0.00 sec)
其他MySQL开源兼容
PolarDB-X基于X-Paxos协议,替换了传统MySQL基于binlog的主备复制协议,引入了自有的日志管理机制,基于binlog的载体合并了binlog和relay log,同时提供show consensus log的指令。
开源用户遇到比较多的一个问题,就是PolarDB-X的增量日志管理,之前习惯了开源MySQL的binlog自动清理机制,在PolarDB-X早期版本无法生效,导致遇到多例的磁盘满的问题。
在PolarDB-X V2.4.2版本,提供了兼容开源MySQL的 expire_logs_days 。
[mysqld]expire_logs_days = 7
适配 MCP 开源生态
PolarDB-X V2.4.2版本进一步扩展了其开源生态能力,推出了PolarDB-X Model Context Protocol (MCP) Server,专为AI Agent与PolarDB-X数据库的交互而设计。PolarDB-X MCP Server提供了一套标准化的工具(tools)和资源(resources),帮助开发者高效构建智能数据库应用。
开源地址[8]
目前,PolarDB-X MCP Server提供了如下的工具和资源:
工具(tools):
SQL 查询执行:AI代理可通过query接口直接运行SQL查询。
数据库状态监控:实时获取PolarDB-X集群状态(如QPS、慢 SQL 数、节点负载),辅助动态调优。
命令管理:提供PolarDB-X支持的运维和语法规范,供大模型使用。
资源(resoures):
Schema 信息查询:提供JSON格式的表结构信息,包括列名、数据类型及索引定义。
示例:polardbx://<database_name>/<table_name>支持AI Agent快速解析复杂表结构,生成上下文感知的查询建议。
基于,PolarDB-X MCP Server提供的能力,开发者可以围绕PolarDB-X打造强大的AI Agent,如以下几个场景:
智能数据库运维:AI Agent通过MCP Server获取数据库状态和Schema信息,自动诊断性能瓶颈(如数据分布不均、死锁)并生成修复建议。
Data Agent/Chat BI:通过SQL接口,连接PolarDB-X的只读实例,提供数据分析和报表服务
Vibe Coding/低代码开发:AI工具通过MCP Server的Schema查询接口,自动解析数据库结构、生成符合实际版本的代码片段;提供SQL执行接口,使AI工具自动校验SQL正确性。
功能体验
目前,PolarDB-X MCP Server已发布到npm包仓库,可使用npm一键安装部署:
1. 使用npm安装:
# Install globallynpm install -g polardbx-mcp# Or install in current project onlynpm install polardbx-mcp
2. 在MCP client中使用,配置如下:
{"mcpServers": {"polardbx-mcp": {"command": "npx","args": ["polardbx-mcp"],"env": {"POLARDB_X_HOST": "your_database_host","POLARDB_X_PORT": "your_database_port","POLARDB_X_USER": "your_database_user","POLARDB_X_PASSWORD": "your_database_password","POLARDB_X_DATABASE": "your_database_name"},}}}
总结
PolarDB坚持自主研发创新,100%兼容原生社区生态和主流数据库管理工具,支持同城灾备、异地灾备等多种容灾架构,兼容国产主流操作系统和芯片,获得信安中心权威认可,更多详情可以访问安全可靠的国产自研分布式数据库PolarDB[9]。
欢迎点击阅读原文了解云原生数据库PolarDB了解更多详情~