阿里开发者

开源新发布|PolarDB-X v2.4.2开源生态适配升级

Image

2025年09月开源PolarDB-X正式发布v2.4.2版本,重点完善周边生态能力,包含:新增客户端驱动(PolarDB-X Connector)、新开源polardbx-proxy组件,同时面向数据库运维和稳定性优化,提供在千亿大表场景下的实践验证,包含DDL在线变更、数据库扩缩容、数据TTL等的多项问题修复。详细请查阅ChangeLog[1]。

PolarDB分布式版简介

PolarDB分布式版(简称“PolarDB-X”)是阿里云自主研发的云原生集中式和分布式一体化数据库产品,整体采用了基于存储计算分离的Shared-Nothing系统架构,支持水平扩展、分布式事务、混合负载等能力,具备金融级高可用、高吞吐、大存储、低延时、易扩展、高度兼容MySQL系统及生态等特点。更多产品能力与特性介绍可参考产品文档[2]。

Image

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.sh
quick_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集群信息)

Image

2. show rw / show ro (查询proxy的链接池情况)

Image

3. show properties(查询proxy配置参数)

Image

性能测试

购买一组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不中断、不报错的无感体验,极大的改善业务使用数据库的体验。

无感切换,工作原理示意:

Image

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的指令。

Image

开源用户遇到比较多的一个问题,就是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了解更多详情~