diff --git a/src/connector/python/linux/python2/taos/cinterface.py b/src/connector/python/linux/python2/taos/cinterface.py index e25dad5a73..10df10b31f 100644 --- a/src/connector/python/linux/python2/taos/cinterface.py +++ b/src/connector/python/linux/python2/taos/cinterface.py @@ -413,5 +413,5 @@ if __name__ == '__main__': print(data) - cinter.freeresult(result) + cinter.freeResult(result) cinter.close(conn) \ No newline at end of file diff --git a/src/connector/python/linux/python2/taos/cursor.py b/src/connector/python/linux/python2/taos/cursor.py index 75aa7f69d8..f7c840442e 100644 --- a/src/connector/python/linux/python2/taos/cursor.py +++ b/src/connector/python/linux/python2/taos/cursor.py @@ -93,7 +93,6 @@ class TDengineCursor(object): if self._connection is None: return False - self._connection.clear_result_set() self._reset_result() self._connection = None @@ -109,7 +108,6 @@ class TDengineCursor(object): # TODO : change the exception raised here raise ProgrammingError("Cursor is not connected") - self._connection.clear_result_set() self._reset_result() stmt = operation @@ -202,7 +200,6 @@ class TDengineCursor(object): for i in range(len(self._fields)): buffer[i].extend(block[i]) - self._connection.clear_result_set() return list(map(tuple, zip(*buffer))) @@ -222,6 +219,8 @@ class TDengineCursor(object): """ self._description = None self._rowcount = -1 + if self._result is not None: + CTaosInterface.freeResult(self._result) self._result = None self._fields = None self._block = None diff --git a/src/connector/python/linux/python3/taos/cinterface.py b/src/connector/python/linux/python3/taos/cinterface.py index be0226447d..c3c8a4603a 100644 --- a/src/connector/python/linux/python3/taos/cinterface.py +++ b/src/connector/python/linux/python3/taos/cinterface.py @@ -413,5 +413,5 @@ if __name__ == '__main__': print(data) - cinter.freeresult(result) + cinter.freeResult(result) cinter.close(conn) \ No newline at end of file diff --git a/src/connector/python/linux/python3/taos/cursor.py b/src/connector/python/linux/python3/taos/cursor.py index 3baca89462..5db5365eb3 100644 --- a/src/connector/python/linux/python3/taos/cursor.py +++ b/src/connector/python/linux/python3/taos/cursor.py @@ -95,7 +95,6 @@ class TDengineCursor(object): if self._connection is None: return False - self._connection.clear_result_set() self._reset_result() self._connection = None @@ -111,7 +110,6 @@ class TDengineCursor(object): # TODO : change the exception raised here raise ProgrammingError("Cursor is not connected") - self._connection.clear_result_set() self._reset_result() stmt = operation @@ -204,8 +202,6 @@ class TDengineCursor(object): for i in range(len(self._fields)): buffer[i].extend(block[i]) - self._connection.clear_result_set() - return list(map(tuple, zip(*buffer))) def nextset(self): @@ -224,6 +220,8 @@ class TDengineCursor(object): """ self._description = None self._rowcount = -1 + if self._result is not None: + CTaosInterface.freeResult(self._result) self._result = None self._fields = None self._block = None @@ -240,3 +238,4 @@ class TDengineCursor(object): (ele['name'], ele['type'], None, None, None, None, False)) return self._result + diff --git a/src/connector/python/windows/python2/taos/cinterface.py b/src/connector/python/windows/python2/taos/cinterface.py index 0b446253b7..06ade4fc35 100644 --- a/src/connector/python/windows/python2/taos/cinterface.py +++ b/src/connector/python/windows/python2/taos/cinterface.py @@ -413,5 +413,5 @@ if __name__ == '__main__': print(data) - cinter.freeresult(result) + cinter.freeResult(result) cinter.close(conn) \ No newline at end of file diff --git a/src/connector/python/windows/python2/taos/cursor.py b/src/connector/python/windows/python2/taos/cursor.py index 6af82e72de..1da726638a 100644 --- a/src/connector/python/windows/python2/taos/cursor.py +++ b/src/connector/python/windows/python2/taos/cursor.py @@ -86,7 +86,6 @@ class TDengineCursor(object): if self._connection is None: return False - self._connection.clear_result_set() self._reset_result() self._connection = None @@ -102,7 +101,6 @@ class TDengineCursor(object): # TODO : change the exception raised here raise ProgrammingError("Cursor is not connected") - self._connection.clear_result_set() self._reset_result() stmt = operation @@ -149,7 +147,6 @@ class TDengineCursor(object): for i in range(len(self._fields)): buffer[i].extend(block[i]) - self._connection.clear_result_set() return list(map(tuple, zip(*buffer))) @@ -171,6 +168,8 @@ class TDengineCursor(object): """ self._description = None self._rowcount = -1 + if self._result is not None: + CTaosInterface.freeResult(self._result) self._result = None self._fields = None self._block = None diff --git a/src/connector/python/windows/python3/taos/cinterface.py b/src/connector/python/windows/python3/taos/cinterface.py index 864a2f5ecb..c6218fe9d4 100644 --- a/src/connector/python/windows/python3/taos/cinterface.py +++ b/src/connector/python/windows/python3/taos/cinterface.py @@ -413,5 +413,5 @@ if __name__ == '__main__': print(data) - cinter.freeresult(result) + cinter.freeResult(result) cinter.close(conn) \ No newline at end of file diff --git a/src/connector/python/windows/python3/taos/cursor.py b/src/connector/python/windows/python3/taos/cursor.py index 0ee8af4ed0..2dcd0aaccb 100644 --- a/src/connector/python/windows/python3/taos/cursor.py +++ b/src/connector/python/windows/python3/taos/cursor.py @@ -86,7 +86,6 @@ class TDengineCursor(object): if self._connection is None: return False - self._connection.clear_result_set() self._reset_result() self._connection = None @@ -102,7 +101,6 @@ class TDengineCursor(object): # TODO : change the exception raised here raise ProgrammingError("Cursor is not connected") - self._connection.clear_result_set() self._reset_result() stmt = operation @@ -149,7 +147,6 @@ class TDengineCursor(object): for i in range(len(self._fields)): buffer[i].extend(block[i]) - self._connection.clear_result_set() return list(map(tuple, zip(*buffer))) @@ -171,6 +168,8 @@ class TDengineCursor(object): """ self._description = None self._rowcount = -1 + if self._result is not None: + CTaosInterface.freeResult(self._result) self._result = None self._fields = None self._block = None