3.00.5

3.00.5.2

新增功能

  • ExclusiveDBConnectionPool 新增弹性连接池能力。可通过新增构造方法或 ExclusiveDBConnectionPoolConfig 设置 minimumPoolSize、maximumPoolSize 和 idleTimeout，支持按任务压力动态扩容，并在空闲后回收到最小连接数。

  • 新增 ExclusiveDBConnectionPoolConfig 配置类，用于统一配置连接参数和弹性连接池参数。

  • ExclusiveDBConnectionPool 新增运行时状态和配置查询方法： getCurrentConnectionCount()、 getMinimumPoolSize()、 getMaximumPoolSize()、 getIdleTimeout()、 getActiveConnectionsCount() 和 getIdleConnectionsCount()。

兼容性说明

  • 从 Java API 3.00.5.2 版本开始，ExclusiveDBConnectionPool 已有构造方法保持不变。已有 count 参数在内部同时映射为 minimumPoolSize 和 maximumPoolSize，因此通过已有构造方法创建的连接池仍保持固定连接数行为，不会触发动态扩容或 idleTimeout 空闲回收。

  • getConnectionCount() 返回当前实际存在的 worker/连接数。固定连接数模式下，该值始终等于 count；弹性连接池模式下，该值会在 minimumPoolSize 和 maximumPoolSize 之间变化。如需获取配置的最大并发能力，请使用 getMaximumPoolSize()。

  • 新增查询方法定义在 ExclusiveDBConnectionPool 具体类上，未新增到 DBConnectionPool 接口中。若需要调用这些方法，请使用 ExclusiveDBConnectionPool 类型声明连接池对象。

3.00.5.1

新增功能

  • BasicTable 新增支持 Java 原生类型的构造方法。

  • BasicTable 新增支持 Java 原生类型的 addColumn 方法，用于向表中添加列：

    • public void addColumn(String colName, List<?> col)

    • public void addColumn(String colName, Object[] col)

兼容性说明

从 Java API 3.00.5.1 版本开始，BasicTable 新增了多个 addColumn 重载方法。如果需要将第二个参数 col 指定为 null，必须显式声明类型，例如：(List<?>) null、(Vector) null 或 (Object[]) null。

3.00.5.0

新增功能

  • 新增异步写入工具用于 DolphinDB 多活部署架构。

  • StreamingSQLClient 提供 UpdateListener 接口，用于实时监听和并允许用户自行处理 Streaming SQL 订阅的数据变化。

  • StreamingSQLClient 新增 getStreamingSQLSubscriptionInfo 方法，用于根据 queryId 获取订阅信息。

  • BasicAnyVector 新增支持 Append 方法，用于追加 matrix、set、table、dict 等形式的数据。

  • CEP 提供同步等待某个事件的 appendEventWithResponse 方法。

功能优化

  • 优化取消订阅时的 EOFException 报错信息。

故障修复

  • 修复 StreamingSQLClient 在写入 any 数据时，更新表报错问题。

  • 修复 Java API 依赖的 lz4-java 漏洞问题，从 org.lz4 改为 at.yawk.lz4。