This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch query_v2_py in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 945b5a43efcdf93958a38c58ade206c84da5585d Author: HTHou <[email protected]> AuthorDate: Thu Mar 20 12:11:21 2025 +0800 Try CI --- .github/workflows/multi-language-client.yml | 1 + iotdb-client/client-py/iotdb/Session.py | 24 ++++++++++++------------ 2 files changed, 13 insertions(+), 12 deletions(-) diff --git a/.github/workflows/multi-language-client.yml b/.github/workflows/multi-language-client.yml index 095f22557d6..675e6a46b77 100644 --- a/.github/workflows/multi-language-client.yml +++ b/.github/workflows/multi-language-client.yml @@ -4,6 +4,7 @@ on: branches: - master - "rc/*" + - query_v2_py paths: - 'pom.xml' - 'iotdb-client/pom.xml' diff --git a/iotdb-client/client-py/iotdb/Session.py b/iotdb-client/client-py/iotdb/Session.py index 2ab2428a213..2796c417d47 100644 --- a/iotdb-client/client-py/iotdb/Session.py +++ b/iotdb-client/client-py/iotdb/Session.py @@ -1516,13 +1516,13 @@ class Session(object): """ request = TSExecuteStatementReq(self.__session_id, sql, self.__statement_id) try: - resp = self.__client.executeUpdateStatement(request) + resp = self.__client.executeUpdateStatementV2(request) except TTransport.TException as e: if self.reconnect(): try: request.sessionId = self.__session_id request.statementId = self.__statement_id - resp = self.__client.executeUpdateStatement(request) + resp = self.__client.executeUpdateStatementV2(request) except TTransport.TException as e1: raise IoTDBConnectionException(e1) from None else: @@ -1547,13 +1547,13 @@ class Session(object): self.__session_id, sql, self.__statement_id, timeout ) try: - resp = self.__client.executeStatement(request) + resp = self.__client.executeStatementV2(request) except TTransport.TException as e: if self.reconnect(): try: request.sessionId = self.__session_id request.statementId = self.__statement_id - resp = self.__client.executeStatement(request) + resp = self.__client.executeStatementV2(request) except TTransport.TException as e1: raise IoTDBConnectionException(e1) from None else: @@ -1570,7 +1570,7 @@ class Session(object): self.__client, self.__statement_id, self.__session_id, - resp.queryDataSet, + resp.queryResult, resp.ignoreTimeStamp, ) else: @@ -1761,13 +1761,13 @@ class Session(object): enableRedirectQuery=False, ) try: - resp = self.__client.executeRawDataQuery(request) + resp = self.__client.executeRawDataQueryV2(request) except TTransport.TException as e: if self.reconnect(): try: request.sessionId = self.__session_id request.statementId = self.__statement_id - resp = self.__client.executeRawDataQuery(request) + resp = self.__client.executeRawDataQueryV2(request) except TTransport.TException as e1: raise IoTDBConnectionException(e1) from None else: @@ -1782,7 +1782,7 @@ class Session(object): self.__client, self.__statement_id, self.__session_id, - resp.queryDataSet, + resp.queryResult, resp.ignoreTimeStamp, ) @@ -1802,13 +1802,13 @@ class Session(object): enableRedirectQuery=False, ) try: - resp = self.__client.executeLastDataQuery(request) + resp = self.__client.executeLastDataQueryV2(request) except TTransport.TException as e: if self.reconnect(): try: request.sessionId = self.__session_id request.statementId = self.__statement_id - resp = self.__client.executeLastDataQuery(request) + resp = self.__client.executeLastDataQueryV2(request) except TTransport.TException as e1: raise IoTDBConnectionException(e1) from None else: @@ -1823,7 +1823,7 @@ class Session(object): self.__client, self.__statement_id, self.__session_id, - resp.queryDataSet, + resp.queryResult, resp.ignoreTimeStamp, ) @@ -2474,7 +2474,7 @@ class SessionConnection(object): def change_database(self, sql): try: - self.client.executeUpdateStatement( + self.client.executeUpdateStatementV2( TSExecuteStatementReq(self.session_id, sql, self.statement_id) ) except TTransport.TException as e:
