diff --git a/docs/examples/python/sql_writer.py b/docs/examples/python/sql_writer.py index 3daaa7d201fd46d6d24ff7f6ba724a823813bdb1..886f257001e0ca16fd52224fe2fb6c76c54b4a8b 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)