From a165043d13ef7b6b4f827d2ff5a69635eca29c4d Mon Sep 17 00:00:00 2001 From: menshibin Date: Tue, 11 Feb 2025 10:44:49 +0800 Subject: [PATCH 1/3] docs(node):fix node.js wsconfig case --- docs/zh/14-reference/05-connector/35-node.mdx | 24 +++++++++++-------- 1 file changed, 14 insertions(+), 10 deletions(-) diff --git a/docs/zh/14-reference/05-connector/35-node.mdx b/docs/zh/14-reference/05-connector/35-node.mdx index cb5d69d137..d15a7a5a63 100644 --- a/docs/zh/14-reference/05-connector/35-node.mdx +++ b/docs/zh/14-reference/05-connector/35-node.mdx @@ -130,16 +130,20 @@ Node.js 连接器（`@tdengine/websocket`）, 其通过 taosAdapter 提供的 We 除了通过指定的 URL 获取连接，还可以使用 WSConfig 指定建立连接时的参数。 ```js -try { - let url = 'ws://127.0.0.1:6041' - let conf = WsSql.NewConfig(url) - conf.setUser('root') - conf.setPwd('taosdata') - conf.setDb('db') - conf.setTimeOut(500) - let wsSql = await WsSql.open(conf); -} catch (e) { - console.error(e); +const taos = require("@tdengine/websocket"); + +async function createConnect() { + try { + let url = 'ws://127.0.0.1:6041' + let conf = WsSql.NewConfig(url) + conf.setUser('root') + conf.setPwd('taosdata') + conf.setDb('db') + conf.setTimeOut(500) + let wsSql = await taos.sqlConnect(conf) + } catch (e) { + console.error(e); + } } ``` From bb6d0ee8b2b2047d8515825ca1a76f20d7d84f27 Mon Sep 17 00:00:00 2001 From: menshibin Date: Tue, 11 Feb 2025 14:58:09 +0800 Subject: [PATCH 2/3] docs: add node version explanation --- docs/en/14-reference/05-connector/35-node.md | 26 ++++++++++++------- docs/zh/14-reference/05-connector/35-node.mdx | 2 ++ 2 files changed, 18 insertions(+), 10 deletions(-) diff --git a/docs/en/14-reference/05-connector/35-node.md b/docs/en/14-reference/05-connector/35-node.md index 49b1d200cf..e1d06d1db6 100644 --- a/docs/en/14-reference/05-connector/35-node.md +++ b/docs/en/14-reference/05-connector/35-node.md @@ -25,6 +25,8 @@ Support all platforms that can run Node.js. | Node.js Connector Version | Major Changes | TDengine Version | | ------------------------- | ------------------------------------------------------------------------ | --------------------------- | +| 3.1.4 | Modified the readme.| - | +| 3.1.3 | Upgraded the es5-ext version to address vulnerabilities in the lower version. | - | | 3.1.2 | Optimized data protocol and parsing, significantly improved performance. | - | | 3.1.1 | Optimized data transmission performance. | 3.3.2.0 and higher versions | | 3.1.0 | New release, supports WebSocket connection. | 3.2.0.0 and higher versions | @@ -132,16 +134,20 @@ Node.js connector (`@tdengine/websocket`), which connects to a TDengine instance In addition to obtaining a connection through a specified URL, you can also use WSConfig to specify parameters when establishing a connection. ```js -try { - let url = 'ws://127.0.0.1:6041' - let conf = WsSql.NewConfig(url) - conf.setUser('root') - conf.setPwd('taosdata') - conf.setDb('db') - conf.setTimeOut(500) - let wsSql = await WsSql.open(conf); -} catch (e) { - console.error(e); +const taos = require("@tdengine/websocket"); + +async function createConnect() { + try { + let url = 'ws://127.0.0.1:6041' + let conf = WsSql.NewConfig(url) + conf.setUser('root') + conf.setPwd('taosdata') + conf.setDb('db') + conf.setTimeOut(500) + let wsSql = await taos.sqlConnect(conf) + } catch (e) { + console.error(e); + } } ``` diff --git a/docs/zh/14-reference/05-connector/35-node.mdx b/docs/zh/14-reference/05-connector/35-node.mdx index d15a7a5a63..42eff0d650 100644 --- a/docs/zh/14-reference/05-connector/35-node.mdx +++ b/docs/zh/14-reference/05-connector/35-node.mdx @@ -24,6 +24,8 @@ Node.js 连接器源码托管在 [GitHub](https://github.com/taosdata/taos-conne | Node.js 连接器 版本 | 主要变化 | TDengine 版本 | | ------------------| ----------------------| ----------------| +| 3.1.4 | 修改 readme | - | +| 3.1.3 | 升级了 es5-ext 版本，解决低版本的漏洞 | - | | 3.1.2 | 对数据协议和解析进行了优化，性能得到大幅提升| - | | 3.1.1 | 优化了数据传输性能 | 3.3.2.0 及更高版本 | | 3.1.0 | 新版本发布，支持 WebSocket 连接 | 3.2.0.0 及更高版本 | From 6620350ebce7a88e5a8e99f1cd6507db244235de Mon Sep 17 00:00:00 2001 From: menshibin Date: Tue, 11 Feb 2025 15:49:16 +0800 Subject: [PATCH 3/3] docs: add flink version explanation --- docs/en/10-third-party/01-collection/flink.md | 3 ++- docs/zh/10-third-party/01-collection/12-flink.md | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/docs/en/10-third-party/01-collection/flink.md b/docs/en/10-third-party/01-collection/flink.md index 19a767f1f6..b225a2d610 100644 --- a/docs/en/10-third-party/01-collection/flink.md +++ b/docs/en/10-third-party/01-collection/flink.md @@ -26,6 +26,7 @@ Flink Connector supports all platforms that can run Flink 1.19 and above version | Flink Connector Version | Major Changes | TDengine Version| |-------------------------| ------------------------------------ | ---------------- | +| 2.0.2 | The Table Sink supports types such as RowKind.UPDATE_BEFORE, RowKind.UPDATE_AFTER, and RowKind.DELETE.| - | | 2.0.1 | Sink supports writing types from Rowdata implementations.| - | | 2.0.0 | 1.Support SQL queries on data in TDengine database.
2. Support CDC subscription to data in TDengine database.
3. Supports reading and writing to TDengine database using Table SQL. | 3.3.5.1 and higher| | 1.0.0 | Support Sink function to write data from other sources to TDengine in the future.| 3.3.2.0 and higher| @@ -115,7 +116,7 @@ If using Maven to manage a project, simply add the following dependencies in pom com.taosdata.flink flink-connector-tdengine - 2.0.1 + 2.0.2 ``` diff --git a/docs/zh/10-third-party/01-collection/12-flink.md b/docs/zh/10-third-party/01-collection/12-flink.md index 0f8bde5260..d74f6cad6d 100644 --- a/docs/zh/10-third-party/01-collection/12-flink.md +++ b/docs/zh/10-third-party/01-collection/12-flink.md @@ -24,6 +24,7 @@ Flink Connector 支持所有能运行 Flink 1.19 及以上版本的平台。 ## 版本历史 | Flink Connector 版本 | 主要变化 | TDengine 版本 | | ------------------| ------------------------------------ | ---------------- | +| 2.0.2 | Table Sink 支持 RowKind.UPDATE_BEFORE、RowKind.UPDATE_AFTER 和 RowKind.DELETE 类型| - | | 2.0.1 | Sink 支持对所有继承自 RowData 并已实现的类型进行数据写入| - | | 2.0.0 | 1. 支持 SQL 查询 TDengine 数据库中的数据
2. 支持 CDC 订阅 TDengine 数据库中的数据
3. 支持 Table SQL 方式读取和写入 TDengine 数据库| 3.3.5.1 及以上版本 | | 1.0.0 | 支持 Sink 功能，将来着其他数据源的数据写入到 TDengine| 3.3.2.0 及以上版本| @@ -112,7 +113,7 @@ env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.AT_LEAST_ONCE); com.taosdata.flink flink-connector-tdengine - 2.0.1 + 2.0.2 ```