summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorBinh Le <lebinh.it@gmail.com>2014-04-09 10:07:32 +0700
committerBinh Le <lebinh.it@gmail.com>2014-04-09 10:07:32 +0700
commite409482be582eedc08ed4a97687305e422b1aa2b (patch)
treeb48e3de60a9f8f5167f4813f6aa9ec5f82e77a32
parent7b154b1af413d07a06b473de296fa91af6cdf37c (diff)
parenta546be9e6d92137bf3484038b9408738ab7bcd74 (diff)
Merge pull request #29 from jreese/groupby
Support multiple fields in --group-by
-rwxr-xr-xngxtop/ngxtop.py8
1 files changed, 7 insertions, 1 deletions
diff --git a/ngxtop/ngxtop.py b/ngxtop/ngxtop.py
index 428af12..afb5bc3 100755
--- a/ngxtop/ngxtop.py
+++ b/ngxtop/ngxtop.py
@@ -210,6 +210,7 @@ class SQLProcessor(object):
def process(self, records):
self.begin = time.time()
insert = 'insert into log (%s) values (%s)' % (self.column_list, self.holder_list)
+ logging.info('sqlite insert: %s', insert)
with closing(self.conn.cursor()) as cursor:
for r in records:
cursor.execute(insert, r)
@@ -300,7 +301,12 @@ def build_processor(arguments):
for label, query in report_queries:
logging.info('query for "%s":\n %s', label, query)
- processor = SQLProcessor(report_queries, fields)
+
+ processor_fields = []
+ for field in fields:
+ processor_fields.extend(field.split(','))
+
+ processor = SQLProcessor(report_queries, processor_fields)
return processor