From 1f90800be4b77664c1c1ec7416f1f0040d165a16 Mon Sep 17 00:00:00 2001 From: dingbo Date: Thu, 14 Jul 2022 17:51:17 +0800 Subject: [PATCH] docs: sql_writer.py --- docs/examples/python/sql_writer.py | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/docs/examples/python/sql_writer.py b/docs/examples/python/sql_writer.py index 3daaa7d201..886f257001 100644 --- a/docs/examples/python/sql_writer.py +++ b/docs/examples/python/sql_writer.py @@ -38,7 +38,7 @@ class SQLWriter: group_id = ps[-1] tag_value = f"('{location}',{group_id})" self._tb_tags[table_name] = tag_value - self.flush2() + self.flush() def flush(self): """ @@ -63,12 +63,6 @@ class SQLWriter: self.execute_sql(sql) self._tb_values.clear() - def flush2(self): - for tb_name, values in self._tb_values.items(): - q = "INSERT INTO " + tb_name + " VALUES " + values - self.execute_sql(q) - self._tb_values.clear() - def execute_sql(self, sql): try: self._conn.execute(sql) -- GitLab