[chronojump/chronojump-importer] Improves logging for the Person77: actually it inserts them in one call to the insert operation inst



commit 13be25ffc42d856cf2f9ad5a49f4ae9d4f843c3d
Author: Carles Pina i Estany <carles pina cat>
Date:   Wed Sep 7 10:56:01 2016 +0100

    Improves logging for the Person77: actually it inserts them in one call to the insert operation instead 
of 2.

 src/chronojump-importer/chronojump_importer.py |   21 ++++++++++++++-------
 1 files changed, 14 insertions(+), 7 deletions(-)
---
diff --git a/src/chronojump-importer/chronojump_importer.py b/src/chronojump-importer/chronojump_importer.py
index 82a2b15..273fdd8 100755
--- a/src/chronojump-importer/chronojump_importer.py
+++ b/src/chronojump-importer/chronojump_importer.py
@@ -232,6 +232,17 @@ def print_summary(table_name, table_data):
     print("{table_name} - inserted: {inserted}, reused: {reused}".format(table_name=table_name, 
inserted=inserted, reused=reused))
 
 
+def remove_duplicates_list(l):
+    """ Returns a new list without duplicate elements. """
+    result = []
+
+    for index, element in enumerate(l):
+        if element not in l[index+1:]:
+            result.append(element)
+
+    return result
+
+
 def import_database(source_path, destination_path, source_session):
     """ Imports the session source_session from source_db into destination_db """
 
@@ -288,20 +299,16 @@ def import_database(source_path, destination_path, source_session):
                                             join_clause="LEFT JOIN JumpRj ON 
Person77.uniqueID=JumpRj.personID",
                                             group_by_clause="Person77.uniqueID")
 
-    persons77_jump_rj = insert_data_into_table(cursor=destination_cursor, table_name="Person77", 
data=persons77_jump_rj,
-                                               matches_columns=["name"])
-
     # Imports Person77 used by Jump table
     persons77_jump = get_data_from_table(cursor=source_cursor, table_name="Person77",
                                          where_condition="Jump.sessionID={}".format(source_session),
                                          join_clause="LEFT JOIN Jump ON Person77.uniqueID=Jump.personID",
                                          group_by_clause="Person77.uniqueID")
 
-    persons77_jump = insert_data_into_table(cursor=destination_cursor, table_name="Person77", 
data=persons77_jump,
-                                            matches_columns=["name"])
+    persons77 = remove_duplicates_list(persons77_jump + persons77_jump_rj)
 
-    persons77 = persons77_jump_rj + persons77_jump
-    print_summary("Person77", persons77)
+    persons77 = insert_data_into_table(cursor=destination_cursor, table_name="Person77", data=persons77,
+                                            matches_columns=["name"])
 
     # Imports JumpRj table (with the new Person77's uniqueIDs)
     jump_rj = get_data_from_table(cursor=source_cursor, table_name="JumpRj",


[Date Prev][Date Next]   [Thread Prev][Thread Next]   [Thread Index] [Date Index] [Author Index]