[chronojump/chronojump-importer] Imports PersonSession77.
- From: Carles Pina i Estany <carlespina src gnome org>
- To: commits-list gnome org
- Cc:
- Subject: [chronojump/chronojump-importer] Imports PersonSession77.
- Date: Thu, 1 Sep 2016 15:15:21 +0000 (UTC)
commit d9c8281d8493f5b8ec3fd3025b6742e5b12ac40f
Author: Carles Pina i Estany <carles pina cat>
Date: Thu Sep 1 16:14:57 2016 +0100
Imports PersonSession77.
src/chronojump-importer/chronojump-importer.py | 40 ++++++++++++++++++++++++
1 files changed, 40 insertions(+), 0 deletions(-)
---
diff --git a/src/chronojump-importer/chronojump-importer.py b/src/chronojump-importer/chronojump-importer.py
index 0218deb..89f2c95 100755
--- a/src/chronojump-importer/chronojump-importer.py
+++ b/src/chronojump-importer/chronojump-importer.py
@@ -236,6 +236,43 @@ def import_jump_rj(source_db, destination_db, source_session, new_session_id):
return new_ids
+
+def import_person_session_77(source_db, destination_db, source_session, destination_session):
+ source_cursor = source_db.cursor()
+
+ person_session_77_columns = get_column_names(source_db, "PersonSession77")
+
+ person_session_77_columns = person_session_77_columns[1:]
+
+ source_cursor.execute("SELECT " + ",".join(person_session_77_columns) + " FROM PersonSession77 WHERE
sessionID={}".format(source_session))
+ results = source_cursor.fetchall()
+
+ for row in results:
+ new_row = list(row)
+ new_person_id = get_person_id(source_db, destination_db, row[0])
+
+ new_row[0] = new_person_id
+ new_row[1] = destination_session
+
+ insert_person_session_77(destination_db, row)
+
+
+def insert_person_session_77(destination_db, row):
+ """ Inserts row into PersonSession77 and returns the uniqueID"""
+ destination_cursor = destination_db.cursor()
+
+ column_names = get_column_names(destination_db, "PersonSession77")
+ column_names = column_names[1:]
+
+ sql = create_insert("PersonSession77", column_names, row)
+
+ destination_cursor.execute(sql)
+
+ new_id = destination_cursor.lastrowid
+
+ return new_id
+
+
def import_database(source_db, destination_db, source_session):
jump_types = find_jump_types(source_session, source_db, "JumpType")
ids_from_data(destination_db, "JumpType", jump_types)
@@ -245,6 +282,9 @@ def import_database(source_db, destination_db, source_session):
new_session_id = import_session(source_db, destination_db, source_session)
print("Imported sessionId:", new_session_id)
+
+ import_person_session_77(source_db, destination_db, source_session, new_session_id)
+
new_jump_rj_ids = import_jump_rj(source_db, destination_db, source_session, new_session_id)
print("new_jump_rj_ids:", new_jump_rj_ids)
[
Date Prev][
Date Next] [
Thread Prev][
Thread Next]
[
Thread Index]
[
Date Index]
[
Author Index]