diff --git a/.gitmodules b/.gitmodules
index 7c84eac8a4ee7529005855bc836387561c49ae2d..049b39abfb2cf5f31abe10f194e7a09c4dc932f0 100644
--- a/.gitmodules
+++ b/.gitmodules
@@ -4,3 +4,6 @@
[submodule "src/connector/grafanaplugin"]
path = src/connector/grafanaplugin
url = https://github.com/taosdata/grafanaplugin
+[submodule "src/connector/hivemq-tdengine-extension"]
+ path = src/connector/hivemq-tdengine-extension
+ url = https://github.com/huskar-t/hivemq-tdengine-extension.git
diff --git a/.travis.yml b/.travis.yml
index 5ce9873d1534f8aec1b8e44640cce145c1254330..eb69370418a9c83c7b8bfe5daa1d6ead19150243 100644
--- a/.travis.yml
+++ b/.travis.yml
@@ -32,6 +32,8 @@ matrix:
- python3-setuptools
- valgrind
- psmisc
+ - unixodbc
+ - unixodbc-dev
before_script:
- export TZ=Asia/Harbin
diff --git a/Jenkinsfile b/Jenkinsfile
index 4410d81be6974fc246f50044cbc142076212677b..8bf7e435fd5e96aa49e7f2e07af0c4b2decc365e 100644
--- a/Jenkinsfile
+++ b/Jenkinsfile
@@ -4,11 +4,12 @@ pipeline {
WK = '/var/lib/jenkins/workspace/TDinternal'
WKC= '/var/lib/jenkins/workspace/TDinternal/community'
}
+
stages {
stage('Parallel test stage') {
parallel {
stage('pytest') {
- agent{label 'master'}
+ agent{label '184'}
steps {
sh '''
date
@@ -33,13 +34,13 @@ pipeline {
}
}
stage('test_b1') {
- agent{label '184'}
+ agent{label 'master'}
steps {
sh '''
- date
cd ${WKC}
git checkout develop
git pull
+
git submodule update
cd ${WK}
git checkout develop
@@ -62,10 +63,10 @@ pipeline {
agent{label "185"}
steps {
sh '''
-
cd ${WKC}
git checkout develop
git pull
+
git submodule update
cd ${WK}
git checkout develop
@@ -78,7 +79,21 @@ pipeline {
cmake .. > /dev/null
make > /dev/null
cd ${WKC}/tests/pytest
- ./crash_gen.sh -a -p -t 4 -s 2000
+ '''
+ catchError(buildResult: 'SUCCESS', stageResult: 'FAILURE') {
+ sh '''
+ cd ${WKC}/tests/pytest
+ ./crash_gen.sh -a -p -t 4 -s 2000
+ '''
+ }
+ catchError(buildResult: 'SUCCESS', stageResult: 'FAILURE') {
+ sh '''
+ cd ${WKC}/tests/pytest
+ ./crash_gen.sh --valgrind -p -t 10 -s 100 -b 4
+ ./handle_crash_gen_val_log.sh
+ '''
+ }
+ sh '''
date
cd ${WKC}/tests
./test-all.sh b2
@@ -89,12 +104,13 @@ pipeline {
stage('test_valgrind') {
agent{label "186"}
+
steps {
sh '''
- date
cd ${WKC}
git checkout develop
git pull
+
git submodule update
cd ${WK}
git checkout develop
@@ -116,10 +132,122 @@ pipeline {
date'''
}
}
+ stage('connector'){
+ agent{label "release"}
+ steps{
+ sh'''
+ cd ${WORKSPACE}
+ git checkout develop
+ '''
+ catchError(buildResult: 'SUCCESS', stageResult: 'FAILURE') {
+ sh '''
+ cd ${WORKSPACE}/tests/gotest
+ bash batchtest.sh
+ '''
+ }
+ catchError(buildResult: 'SUCCESS', stageResult: 'FAILURE') {
+ sh '''
+ cd ${WORKSPACE}/tests/examples/python/PYTHONConnectorChecker
+ python3 PythonChecker.py
+ '''
+ }
+ catchError(buildResult: 'SUCCESS', stageResult: 'FAILURE') {
+ sh '''
+ cd ${WORKSPACE}/tests/examples/JDBC/JDBCDemo/
+ mvn clean package assembly:single >/dev/null
+ java -jar target/jdbcChecker-SNAPSHOT-jar-with-dependencies.jar -host 127.0.0.1
+ '''
+ }
+ catchError(buildResult: 'SUCCESS', stageResult: 'FAILURE') {
+ sh '''
+ cd ${JENKINS_HOME}/workspace/C#NET/src/CheckC#
+ dotnet run
+ '''
+ }
+
+ }
+ }
}
}
}
-
+ post {
+ success {
+ emailext (
+ subject: "SUCCESSFUL: Job '${env.JOB_NAME} [${env.BUILD_NUMBER}]'",
+ body: '''
+
+
+
+
+
+
+
+
+ 构建信息
+
|
+
+
+
+
+
+ - 构建名称>>分支：${PROJECT_NAME}
+ - 构建结果： Successful
+ - 构建编号：${BUILD_NUMBER}
+ - 触发用户：${CAUSE}
+ - 变更概要：${CHANGES}
+ - 构建地址：${BUILD_URL}
+ - 构建日志：${BUILD_URL}console
+ - 变更集：${JELLY_SCRIPT}
+
+ |
+
+
+
+ ''',
+ to: "yqliu@taosdata.com,pxiao@taosdata.com",
+ from: "support@taosdata.com"
+ )
+ }
+ failure {
+ emailext (
+ subject: "FAILED: Job '${env.JOB_NAME} [${env.BUILD_NUMBER}]'",
+ body: '''
+
+
+
+
+
+
+
+
+ 构建信息
+
|
+
+
+
+
+
+ - 构建名称>>分支：${PROJECT_NAME}
+ - 构建结果： Successful
+ - 构建编号：${BUILD_NUMBER}
+ - 触发用户：${CAUSE}
+ - 变更概要：${CHANGES}
+ - 构建地址：${BUILD_URL}
+ - 构建日志：${BUILD_URL}console
+ - 变更集：${JELLY_SCRIPT}
+
+ |
+
+
+
+ ''',
+ to: "yqliu@taosdata.com,pxiao@taosdata.com",
+ from: "support@taosdata.com"
+ )
+ }
+ }
}
\ No newline at end of file
diff --git a/alert/README.md b/alert/README.md
index 23179669349ebf94f3774c6101c06c2e375ef059..547f3a0381a74714b1f6c8c74b861678b3805619 100644
--- a/alert/README.md
+++ b/alert/README.md
@@ -61,7 +61,7 @@ The use of each configuration item is:
* **port**: This is the `http` service port which enables other application to manage rules by `restful API`.
* **database**: rules are stored in a `sqlite` database, this is the path of the database file (if the file does not exist, the alert application creates it automatically).
-* **tdengine**: connection string of `TDEngine` server, note in most cases the database information should be put in a rule, thus it should NOT be included here.
+* **tdengine**: connection string of `TDEngine` server, note the database name should be put in the `sql` field of a rule in most cases, thus it should NOT be included in the string.
* **log > level**: log level, could be `production` or `debug`.
* **log > path**: log output file path.
* **receivers > alertManager**: the alert application pushes alerts to `AlertManager` at this URL.
diff --git a/alert/README_cn.md b/alert/README_cn.md
index ec6e4566c8eb9fa2142c37b2b3e1b1a04f783a9a..938b23a58406f5d6f279191a47dc957c446911ce 100644
--- a/alert/README_cn.md
+++ b/alert/README_cn.md
@@ -58,7 +58,7 @@ $ go build
* **port**：报警监测程序支持使用 `restful API` 对规则进行管理，这个参数用于配置 `http` 服务的侦听端口。
* **database**：报警监测程序将规则保存到了一个 `sqlite` 数据库中，这个参数用于指定数据库文件的路径（不需要提前创建这个文件，如果它不存在，程序会自动创建它）。
-* **tdengine**：`TDEngine` 的连接信息，一般来说，数据库信息应该在报警规则中指定，所以这里 **不** 应包含这一部分信息。
+* **tdengine**：`TDEngine` 的连接字符串，一般来说，数据库名应该在报警规则的 `sql` 语句中指定，所以这个字符串中 **不** 应包含数据库名。
* **log > level**：日志的记录级别，可选 `production` 或 `debug`。
* **log > path**：日志文件的路径。
* **receivers > alertManager**：报警监测程序会将报警推送到 `AlertManager`，在这里指定 `AlertManager` 的接收地址。
diff --git a/cmake/install.inc b/cmake/install.inc
index c7fbd6df794f4a414b7b28e31b0c73ba3a4da906..dfca758b9362c96bec0ce45aa385d54a4e75a9e5 100755
--- a/cmake/install.inc
+++ b/cmake/install.inc
@@ -31,7 +31,7 @@ ELSEIF (TD_WINDOWS)
#INSTALL(TARGETS taos RUNTIME DESTINATION driver)
#INSTALL(TARGETS shell RUNTIME DESTINATION .)
IF (TD_MVN_INSTALLED)
- INSTALL(FILES ${LIBRARY_OUTPUT_PATH}/taos-jdbcdriver-2.0.0-dist.jar DESTINATION connector/jdbc)
+ INSTALL(FILES ${LIBRARY_OUTPUT_PATH}/taos-jdbcdriver-2.0.8-dist.jar DESTINATION connector/jdbc)
ENDIF ()
ELSEIF (TD_DARWIN)
SET(TD_MAKE_INSTALL_SH "${TD_COMMUNITY_DIR}/packaging/tools/make_install.sh")
diff --git a/cmake/version.inc b/cmake/version.inc
index ce2b960eeabc2de65d9abb14dd41d25f95c5d26b..a248f76f48ede5f1f483943c08fce6604756b6d4 100644
--- a/cmake/version.inc
+++ b/cmake/version.inc
@@ -4,7 +4,7 @@ PROJECT(TDengine)
IF (DEFINED VERNUMBER)
SET(TD_VER_NUMBER ${VERNUMBER})
ELSE ()
- SET(TD_VER_NUMBER "2.0.5.1")
+ SET(TD_VER_NUMBER "2.0.6.0")
ENDIF ()
IF (DEFINED VERCOMPATIBLE)
diff --git a/documentation/tdenginedocs-cn/advanced-features/index.html b/documentation/tdenginedocs-cn/advanced-features/index.html
index 9a1b908cd5bae690f747c27e46416e12e110480e..b4953b4dd482341ce937f56b806b682ff7145409 100644
--- a/documentation/tdenginedocs-cn/advanced-features/index.html
+++ b/documentation/tdenginedocs-cn/advanced-features/index.html
@@ -51,8 +51,8 @@ INTERVAL(1M)
mseconds：查询数据库更新的时间间隔，单位为毫秒。一般设置为1000毫秒。返回值为指向TDengine_SUB 结构的指针，如果返回为空，表示失败。
TAOS_ROW taos_consume(TAOS_SUB *tsub)
该函数用来获取订阅的结果，用户应用程序将其置于一个无限循环语句。如果数据库有新记录到达，该API将返回该最新的记录。如果没有新的记录，该API将阻塞。如果返回值为空，说明系统出错。参数说明：
void taos_unsubscribe(TAOS_SUB *tsub)
取消订阅。应用程序退出时，务必调用该函数以避免资源泄露。
-int taos_num_subfields(TAOS_SUB *tsub)
获取返回的一行记录中数据包含多少列。
-TAOS_FIELD *taos_fetch_subfields(TAOS_SUB *tsub)
获取每列数据的属性（数据类型、名字、长度），与taos_num_subfileds配合使用，可解析返回的每行数据。
+int taos_num_fields(TAOS_SUB *tsub)
获取返回的一行记录中数据包含多少列。
+TAOS_FIELD *taos_fetch_fields(TAOS_SUB *tsub)
获取每列数据的属性（数据类型、名字、长度），与taos_num_subfileds配合使用，可解析返回的每行数据。
示例代码：请看安装包中的的示范程序
缓存 (Cache)
TDengine采用时间驱动缓存管理策略（First-In-First-Out，FIFO），又称为写驱动的缓存管理机制。这种策略有别于读驱动的数据缓存模式（Least-Recent-Use，LRU），直接将最近写入的数据保存在系统的缓存中。当缓存达到临界值的时候，将最早的数据批量写入磁盘。一般意义上来说，对于物联网数据的使用，用户最为关心最近产生的数据，即当前状态。TDengine充分利用了这一特性，将最近到达的（当前状态）数据保存在缓存中。
diff --git a/documentation/tdenginedocs-cn/connector/index.html b/documentation/tdenginedocs-cn/connector/index.html
index 3167c1521f099f8acd7ae237cc37bd5867ee209a..34ea19813fbd7a9f70074ff109308b37ba7b647a 100644
--- a/documentation/tdenginedocs-cn/connector/index.html
+++ b/documentation/tdenginedocs-cn/connector/index.html
@@ -64,9 +64,9 @@
该API用来获取最新消息，应用程序一般会将其置于一个无限循环语句中。其中参数tsub是taos_subscribe的返回值。如果数据库有新的记录，该API将返回，返回参数是一行记录。如果没有新的记录，该API将阻塞。如果返回值为空，说明系统出错，需要检查系统是否还在正常运行。
void taos_unsubscribe(TAOS_SUB *tsub)
该API用于取消订阅，参数tsub是taos_subscribe的返回值。应用程序退出时，需要调用该API，否则有资源泄露。
-int taos_num_subfields(TAOS_SUB *tsub)
+int taos_num_fields(TAOS_SUB *tsub)
该API用来获取返回的一排数据中数据的列数
-TAOS_FIELD *taos_fetch_subfields(TAOS_RES *res)
+TAOS_FIELD *taos_fetch_fields(TAOS_RES *res)
该API用来获取每列数据的属性（数据类型、名字、字节数），与taos_num_subfileds配合使用，可用来解析返回的一排数据。
Java Connector
@@ -259,4 +259,4 @@ conn.close()
_ "taosSql"
)
taosSql驱动包内采用cgo模式，调用了TDengine的C/C++同步接口，与TDengine进行交互，因此，在数据库操作执行完成之前，客户端应用将处于阻塞状态。单个数据库连接，在同一时刻只能有一个线程调用API。客户应用可以建立多个连接，进行多线程的数据写入或查询处理。
-更多使用的细节，请参考下载目录中的示例源码。
回去