feat: add connect property setting function to native connector

.github/workflows/mac.yml

@@ -97,7 +97,7 @@ jobs:
           || github.event_name == 'schedule'
         uses: actions/setup-go@v3
         with:
-          go-version: 1.18
+          go-version: stable
 
       - name: Set up Rust
         if: |
@@ -138,23 +138,24 @@ jobs:
           cp ./TDengine/debug/build/bin/taos ./release/
           cp ./TDengine/debug/build/bin/taosd ./release/
           cp ./TDengine/debug/build/bin/taosadapter ./release/
-          cp ./TDengine/debug/build/lib/libtaos.3.9.9.9.dylib ./release/
-          cp ./TDengine/debug/build/lib/libtaosnative.3.9.9.9.dylib ./release/
+          cp ./TDengine/debug/build/lib/libtaos.dylib ./release/
+          cp ./TDengine/debug/build/lib/libtaosnative.dylib ./release/
           cp ./TDengine/include/client/taos.h ./release/
           cat >./release/install.sh<<EOF 
+          echo "-------------"
+          ls -l /usr/local/lib/
           chmod +x ./taos
           chmod +x ./taosd
           chmod +x ./taosadapter
           cp ./taos /usr/local/bin
           cp ./taosd /usr/local/bin
           cp ./taosadapter /usr/local/bin
-          cp ./libtaos.3.9.9.9.dylib /usr/local/lib
-          ln -sfv /usr/local/lib/libtaos.3.9.9.9.dylib /usr/local/lib/libtaos.1.dylib
-          ln -sfv /usr/local/lib/libtaos.1.dylib /usr/local/lib/libtaos.dylib
-          cp ./libtaosnative.3.9.9.9.dylib /usr/local/lib
-          ln -sfv /usr/local/lib/libtaosnative.3.9.9.9.dylib /usr/local/lib/libtaosnative.1.dylib
-          ln -sfv /usr/local/lib/libtaosnative.1.dylib /usr/local/lib/libtaosnative.dylib
+          sudo rm -rf /usr/local/lib/libtaos*
+          cp ./libtaos.dylib /usr/local/lib
+          cp ./libtaosnative.dylib /usr/local/lib
           cp ./taos.h /usr/local/include
+          ls -l /usr/local/lib/
+          echo "!-------------!"
           EOF
           tar -zcvf server.tar.gz ./release
 
@@ -358,8 +359,8 @@ jobs:
         run: |
           pwd
           mkdir -p TDengine/debug/build/lib
-          ln -sfv /usr/local/lib/libtaos.1.dylib TDengine/debug/build/lib/libtaos.1.dylib
-          ln -sfv /usr/local/lib/libtaosnative.1.dylib TDengine/debug/build/lib/libtaosnative.1.dylib
+          ln -sfv /usr/local/lib/libtaos.dylib TDengine/debug/build/lib/libtaos.dylib
+          ln -sfv /usr/local/lib/libtaosnative.dylib TDengine/debug/build/lib/libtaosnative.dylib
           ls -l TDengine/debug/build/lib/
           sudo taosadapter &
 
@@ -372,7 +373,10 @@ jobs:
         run: |
           source $VENV
           export TDENGINE_URL=localhost:6041
+          echo "DYLD_LIBRARY_PATH=$DYLD_LIBRARY_PATH"
+          ls -l /usr/local/lib
           ps aux | grep taos
+          python -c "import ctypes; print(ctypes.CDLL('/usr/local/lib/libtaos.dylib'))"
           poetry run pip install psutil pandas "numpy<2.0.0" shapely
           poetry run pytest tests
 

CHANGELOG.md

@@ -7,6 +7,30 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+## v2.8.1 - 2025-05-22
+
+### Features:
+
+- add connect property setting function to native connector
+
+### Bug Fixes:
+
+- all workflows cmake config
+- delete token auth
+- modify version to 2.8.0
+- optimize null value checks (#317)
+- password supports special characters
+- remove superset driver TDengine.py
+- test auth base64
+- uniform python name
+- workflows cmake config
+- **(ws)**: update Cargo.lock
+
+### Documents:
+
+- add changelog for v2.7.22/v2.7.23
+- python to Python
+
 ## v2.7.23 - 2025-03-24
 - support DECIMAL data type
 

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "taospy"
-version = "2.8.0"
+version = "2.8.1"
 description = "The official TDengine Python connector"
 authors = ["Taosdata Inc. <support@taosdata.com>"]
 license = "MIT"

taos/_version.py

@@ -1 +1 @@
-__version__ = '2.8.0'
+__version__ = '2.8.1'

taos/cinterface.py

@@ -156,6 +156,16 @@ def taos_options(option, value):
     _value = c_char_p(value.encode("utf-8"))
     _libtaos.taos_options(option, _value)
 
+def taos_options_connection(connection, option, value):
+    _value = c_char_p(value.encode("utf-8"))
+    res = _libtaos.taos_options_connection(connection, option, _value)
+    if res != 0:
+        raise DatabaseError("taos_options_connection error", res)
+
+def taos_set_conn_mode(connection, mode, value):
+    res = _libtaos.taos_set_conn_mode(connection, mode, value)
+    if res != 0:
+        raise DatabaseError("taos_set_conn_mode error", res)
 
 def taos_init():
     # type: () -> None

taos/connection.py

@@ -74,6 +74,12 @@ def server_info(self):
         # type: () -> str
         return taos_get_server_info(self._conn)
 
+    def options_connection(self, option, value):
+        taos_options_connection(self._conn, option, value)
+
+    def set_conn_mode(self, mode, value):
+        taos_set_conn_mode(self._conn, mode, value)
+
     def select_db(self, database):
         # type: (str) -> None
         taos_select_db(self._conn, database)

tests/test_connect_args.py

@@ -1,5 +1,5 @@
 from taos import *
-
+import time
 
 def test_connect_args():
     """
@@ -8,7 +8,34 @@ def test_connect_args():
     Useless args, prevent mistakenly deleted args in connect init.
     Because some case in CI of earlier version may use it.
     """
+
     host = "localhost:6030"
     conn = connect(host)
+    conn.options_connection(0, "utf8")
+    conn.options_connection(1, "UTC")
+    conn.options_connection(2, "127.0.0.2")
+    conn.options_connection(3, "python client")
+    conn.set_conn_mode(0, 1)
+
+    time.sleep(30)
+    bClient = False
+    bHost = False
+    result = conn.query("show connections")
+    assert result is not None
+    for row in result:
+        print(row)
+        if row[7] == "python client":
+            bClient = True
+        if row[8] == "127.0.0.2":
+            bHost = True
+
+    assert bClient and bHost
+
+    result = conn.query("select timezone()")
+    assert result is not None
+    for row in result:
+        print(row)
+        assert row[0] == "UTC (UTC, +0000)"
+
     assert conn is not None
     conn.close()