From 395c2b023ca827bb4fa9faa48790d47729251a71 Mon Sep 17 00:00:00 2001
From: AD <alexander.dunkel@tu-dresden.de>
Date: Tue, 5 Jun 2018 10:15:51 +0200
Subject: [PATCH] Added Author, Version, License; added submitData class

---
 classes/submitData.py | 12 ++++++++++++
 transferData.py       |  9 ++++++++-
 2 files changed, 20 insertions(+), 1 deletion(-)
 create mode 100644 classes/submitData.py

diff --git a/classes/submitData.py b/classes/submitData.py
new file mode 100644
index 0000000..cb25475
--- /dev/null
+++ b/classes/submitData.py
@@ -0,0 +1,12 @@
+# -*- coding: utf-8 -*-
+
+import psycopg2
+from decimal import Decimal
+from classes.helperFunctions import helperFunctions
+from classes.helperFunctions import lbsnRecordDicts as lbsnRecordDicts
+from lbsnstructure.Structure_pb2 import *
+from lbsnstructure.external.timestamp_pb2 import Timestamp
+import logging 
+
+class lbsnDB():  
+    def submitLBSNRecord(record):      
\ No newline at end of file
diff --git a/transferData.py b/transferData.py
index 928c7ce..3e0e3c2 100644
--- a/transferData.py
+++ b/transferData.py
@@ -1,5 +1,9 @@
 # -*- coding: utf-8 -*-
 
+__author__      = "Alexander Dunkel"
+__license__   = "GNU GPLv3"
+__version__ = "0.1.0"
+
 import getpass
 import argparse
 import logging 
@@ -7,6 +11,7 @@
 from classes.helperFunctions import helperFunctions
 from classes.helperFunctions import lbsnRecordDicts as lbsnRecordDicts
 from classes.fieldMapping import fieldMappingTwitter as fieldMappingTwitter
+from classes.submitData import lbsnDB as lbsnDB
 #LBSN Structure Import from ProtoBuf
 from lbsnstructure.Structure_pb2 import *
 from lbsnstructure.external.timestamp_pb2 import Timestamp
@@ -67,7 +72,6 @@ def main():
                                    args.passwordOutput
                                    )
     conn_output, cursor_output = outputConnection.connect()
-    cursor_output.close()
     inputConnection = dbConnection(args.serveradressInput,
                                    args.dbnameInput,
                                    args.usernameInput,
@@ -92,7 +96,10 @@ def main():
             print(f'{processedRecords} Processed. Count per type: {lbsnRecords.getTypeCounts()}records.', end='\r')
             # update console
             sys.stdout.flush()
+            
+    # Close connections to DBs        
     cursor_input.close()
+    cursor_output.close()
     log.info(f'\n\nProcessed {processedRecords} records. From DBRowNumber {firstDBRowNumber} to {lastDBRowNumber}.')
     #print('10 Random samples for each type:\n')
     #for key,keyHash in lbsnRecords.KeyHashes.items():