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

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

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

PolarDB分布式版产品架构

2021年10月，阿里云宣布对外开源云原生分布式数据库PolarDB-X，采用全内核开源的模式，开源内容包含计算引擎、存储引擎、日志引擎、列存引擎等，开源历程详见：云原生数据库PolarDB开源社区^[3]。

PolarDB-X Proxy是使用Java开发的高性能PolarDB-X标准版的代理，具备自动识别集群主节点、无感高可用切换、读写分离、实例级连接池等功能。可以部署于PolarDB-X标准版之前，提供更加简易便捷的使用体验。（开源地址^[4]）

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

mysql -Ac -h127.1 -P3307 -uappuser -pappuser

以JDBC驱动为例，参考JDBC使用文档^[5]。

<dependency>
    <groupId>com.alibaba.polardbx</groupId>
    <artifactId>polardbx-connector-java</artifactId>
    <version>2.2.10</version>
</dependency>

jdbc:polardbx://11.167.60.147:6991/test

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();
        }
    }
}

<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
        <property name="driverClassName" value="com.alibaba.polardbx.Driver" />
        <!-- 基本属性 URL、user、password -->
        <property name="url" value="jdbc:polardbx://ip:port/db?autoReconnect=true&rewriteBatchedStatements=true&socketTimeout=30000&connectTimeout=3000" />
        <property name="username" value="root" />
        <property name="password" value="123456" />
        <!-- 配置初始化大小、最小、最大 -->
        <property name="maxActive" value="20" />
        <property name="initialSize" value="3" />
        <property name="minIdle" value="3" />
        <!-- maxWait 获取连接等待超时的时间 -->
        <property name="maxWait" value="60000" />
        <!-- timeBetweenEvictionRunsMillis 间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 -->
        <property name="timeBetweenEvictionRunsMillis" value="60000" />
        <!-- minEvictableIdleTimeMillis 一个连接在池中最小空闲的时间，单位是毫秒-->
        <property name="minEvictableIdleTimeMillis" value="300000" />
        <!-- 检测连接是否可用的 SQL -->
        <property name="validationQuery" value="select 'z' from dual" />
        <!-- 是否开启空闲连接检查 -->
        <property name="testWhileIdle" value="true" />
        <!-- 是否在获取连接前检查连接状态 -->
        <property name="testOnBorrow" value="false" />
        <!-- 是否在归还连接时检查连接状态 -->
        <property name="testOnReturn" value="false" />
        <!-- 是否在固定时间关闭连接。增加此参数可以均衡后端服务节点参数 -->
        <property name="phyTimeoutMillis" value="600000" />
        <!-- 是否在固定SQL使用次数之后关闭连接，增加此参数可以均衡后端服务节点参数-->
        <property name="phyMaxUseCount" value="10000" />
    </bean>

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的无感切换能力，推荐链接池：Druid^[6]>= 1.2.24版本。

自建MySQL迁移PolarDB-X，PolarDB-X提供了非常好的兼容性，目前用户最大的诉求是支持数据迁移、以及回流的标准方案。PolarDB-X在商业化版本，提供了专业的数据迁移和同步工具，比如阿里自研的DTS工具，官网完整说明见《解决方案：自建MySQL迁移至PolarDB-X》^[7]。

#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)

#3.过滤掉不需要同步的系统库表，比如原有的心跳表等， 
#  将下面参数配置到从库的cnf文件中重启生效
replicate_ignore_db=aaa:mysql
replicate_ignore_db=aaa:sys
replicate_ignore_db=aaa:__recycle_bin__
replicate_ignore_db=aaa:information_schema
replicate_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都是No
show slave status for channel 'aaa'\G

#7. 在从库leader节点上启动aaa主从复制链路
start slave for channel 'aaa';

#8. 查看该链路 Slave_IO_Running、Slave_SQL_Running都是Yes
show slave status for channel 'aaa'\G

#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)

#1. 查看最新binlog
mysql> 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_pos
mysql> 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)

#3.过滤掉不需要同步的系统库表，比如原有的心跳表等， 
#  将下面参数配置到从库的cnf文件中重启生效
replicate_ignore_db=mysql
replicate_ignore_db=sys
replicate_ignore_db=__recycle_bin__
replicate_ignore_db=information_schema
replicate_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都是No
show slave status for channel 'bbb'\G

#7. 在从库leader节点上启动bbb主从复制链路
start slave for channel 'bbb';

#8. 查看该链路 Slave_IO_Running、Slave_SQL_Running都是Yes
show slave status for channel 'bbb'\G

#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)

[mysqld]
expire_logs_days = 7

# Install globally
npm install -g polardbx-mcp

# Or install in current project only
npm install polardbx-mcp

{
  "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^[8]。