提交 1d533875 编写于 作者: S Shuduo Sang

add log sql command to file for python2.

上级 cf4c4e98
...@@ -34,6 +34,7 @@ class TDengineCursor(object): ...@@ -34,6 +34,7 @@ class TDengineCursor(object):
self._block_rows = -1 self._block_rows = -1
self._block_iter = 0 self._block_iter = 0
self._affected_rows = 0 self._affected_rows = 0
self._logfile = ""
if connection is not None: if connection is not None:
self._connection = connection self._connection = connection
...@@ -83,6 +84,9 @@ class TDengineCursor(object): ...@@ -83,6 +84,9 @@ class TDengineCursor(object):
""" """
pass pass
def log(self, logfile):
self._logfile = logfile
def close(self): def close(self):
"""Close the cursor. """Close the cursor.
""" """
...@@ -113,6 +117,11 @@ class TDengineCursor(object): ...@@ -113,6 +117,11 @@ class TDengineCursor(object):
pass pass
res = CTaosInterface.query(self._connection._conn, stmt) res = CTaosInterface.query(self._connection._conn, stmt)
if (self._logfile):
with open(self._logfile, "a") as logfile:
logfile.write("%s;\n" % operation)
if res == 0: if res == 0:
if CTaosInterface.fieldsCount(self._connection._conn) == 0: if CTaosInterface.fieldsCount(self._connection._conn) == 0:
self._affected_rows += CTaosInterface.affectedRows( self._affected_rows += CTaosInterface.affectedRows(
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册