[chronojump/import-runs] chronojump-importer: imports PulseType and Pulse (and related Person77, PersonSession77)

[Carles Pina i Estany <carlespina src gnome org>]

commit 9a9bc4f4f8b57c2316aaeaa77c8bdcbd9cc68c82
Author: Carles Pina i Estany <carles pina cat>
Date:   Fri Sep 30 15:13:22 2016 +0200

    chronojump-importer: imports PulseType and Pulse (and related Person77, PersonSession77)

 src/chronojump-importer/chronojump_importer.py |   18 ++++++++++++++++++
 1 files changed, 18 insertions(+), 0 deletions(-)
---
diff --git a/src/chronojump-importer/chronojump_importer.py b/src/chronojump-importer/chronojump_importer.py
index 2596bf3..802c89c 100755
--- a/src/chronojump-importer/chronojump_importer.py
+++ b/src/chronojump-importer/chronojump_importer.py
@@ -437,6 +437,16 @@ def import_database(source_path, destination_path, source_session):
                          matches_columns=destination_db.column_names("RunIntervalType", ["uniqueID"]),
                          avoids_duplicate_column="name")
 
+    # Imports PulseTypes table
+    pulse_types = source_db.read(table_name="PulseType",
+                                 where_condition="Session.uniqueID={}".format(source_session),
+                                 join_clause="LEFT JOIN Pulse ON PulseType.name=Pulse.type LEFT JOIN Session 
on Pulse.sessionID=Session.uniqueID",
+                                 group_by_clause="PulseType.uniqueID")
+
+    destination_db.write(table=pulse_types,
+                         matches_columns=destination_db.column_names("PulseType", ["uniqueID"]),
+                         avoids_duplicate_column="name")
+
     # Imports Persons77 used by JumpRj table
     persons77_jump_rj = source_db.read(table_name="Person77",
                                        where_condition="JumpRj.sessionID={}".format(source_session),
@@ -455,16 +465,24 @@ def import_database(source_path, destination_path, source_session):
                                     join_clause="LEFT JOIN Run ON Person77.uniqueID=Run.personID",
                                     group_by_clause="Person77.uniqueID")
 
+    # Imports Person77 used by RunInterval table
     persons77_run_interval = source_db.read(table_name="Person77",
                                             
where_condition="RunInterval.sessionID={}".format(source_session),
                                             join_clause="LEFT JOIN RunInterval ON 
Person77.uniqueID=RunInterval.personID",
                                             group_by_clause="Person77.uniqueID")
 
+    # Imports Person77 used by Pulse table
+    persons77_pulse = source_db.read(table_name="Person77",
+                                     where_condition="Pulse.sessionID={}".format(source_session),
+                                     join_clause="LEFT JOIN Pulse ON Person77.uniqueID=Pulse.personID",
+                                     group_by_clause="Pulse.uniqueID")
+
     persons77 = Table("person77")
     persons77.concatenate_table(persons77_jump)
     persons77.concatenate_table(persons77_jump_rj)
     persons77.concatenate_table(persons77_run)
     persons77.concatenate_table(persons77_run_interval)
+    persons77.concatenate_table(persons77_pulse)
     persons77.remove_duplicates()
 
     destination_db.write(table=persons77,