@@ -359,8 +359,13 @@ def run_clients(options, db_table_set):
         if error_queue.empty() and not interrupt_event.is_set():
             print_progress(1.0)
 
-        # Continue past the progress output line
+        # Continue past the progress output line and print total rows processed
+        def plural(num, text):
+            return "%d %s%s" % (num, text, "" if num == 1 else "s")
+
         print ""
+        print "%s exported from %s" % (plural(sum([info[0].value for info in progress_info]), "row"),
+                                       plural(len(db_table_set), "table"))
     finally:
         signal.signal(signal.SIGINT, signal.SIG_DFL)
 
 
@@ -329,6 +329,7 @@ def read_json_array(json_data, file_in, callback, progress_info):
 
             (obj, offset) = decoder.raw_decode(json_data, idx=offset)
             callback(obj)
+            progress_info[2].value += 1
 
             # Read past whitespace to the next record
             file_offset += offset
@@ -373,6 +374,7 @@ def json_reader(task_queue, filename, db, table, primary_key, fields, progress_i
             json_data = read_json_array(json_data[offset + 1:], file_in, callback, progress_info)
         elif json_data[offset] == "{":
             json_data = read_json_single_object(json_data[offset:], file_in, callback)
+            progress_info[2].value = 1
         else:
             raise RuntimeError("Error: JSON format not recognized - file does not begin with an object or array")
 
@@ -426,6 +428,7 @@ def csv_reader(task_queue, filename, db, table, primary_key, options, progress_i
                 if len(obj[key]) == 0:
                     del obj[key]
             object_callback(obj, db, table, task_queue, object_buffers, buffer_sizes, options["fields"], exit_event)
+            progress_info[2].value += 1
 
     if len(object_buffers) > 0:
         task_queue.put((db, table, object_buffers))
@@ -487,7 +490,7 @@ def print_progress(ratio):
 
 def update_progress(progress_info):
     lowest_completion = 1.0
-    for (current, max_count) in progress_info:
+    for (current, max_count, rows) in progress_info:
         curr_val = current.value
         max_val = max_count.value
         if curr_val < 0:
@@ -526,8 +529,9 @@ def spawn_import_clients(options, files_info):
             client_procs[-1].start()
 
         for file_info in files_info:
-            progress_info.append((multiprocessing.Value(ctypes.c_longlong, -1),
-                                  multiprocessing.Value(ctypes.c_longlong, 0)))
+            progress_info.append((multiprocessing.Value(ctypes.c_longlong, -1), # Current lines/bytes processed
+                                  multiprocessing.Value(ctypes.c_longlong, 0), # Total lines/bytes to process
+                                  multiprocessing.Value(ctypes.c_longlong, 0))) # Total rows processed
             reader_procs.append(multiprocessing.Process(target=table_reader,
                                                         args=(options,
                                                               file_info,
@@ -560,7 +564,12 @@ def spawn_import_clients(options, files_info):
             print_progress(1.0)
 
         # Continue past the progress output line
+        def plural(num, text):
+            return "%d %s%s" % (num, text, "" if num == 1 else "s")
+
         print ""
+        print "%s imported in %s" % (plural(sum([info[2].value for info in progress_info]), "row"),
+                                       plural(len(files_info), "table"))
     finally:
         signal.signal(signal.SIGINT, signal.SIG_DFL)