CI: Add merge workflow that runs SonarCloud scan

[ric-app/ad.git] / src / insert.py

diff --git a/src/insert.py b/src/insert.py
index 815d42f..a5c3a5b 100644 (file)
--- a/src/insert.py
+++ b/src/insert.py
@@ -31,7 +31,7 @@ class INSERTDATA(DATABASE):
         super().__init__()
         self.config()
         self.connect()
-        self.dropdb('RIC-Test')
+#        self.dropdb('RIC-Test')
         self.createdb('RIC-Test')
 
     def config(self):
@@ -49,13 +49,15 @@ class INSERTDATA(DATABASE):
                 self.meas = cfg.get(section, "measurement")
 
     def createdb(self, dbname):
-        print("Create database: " + dbname)
-        self.client.create_database(dbname)
-        self.client.switch_database(dbname)
+        if dbname not in self.client.get_list_database():
+            print("Create database: " + dbname)
+            self.client.create_database(dbname)
+            self.client.switch_database(dbname)
 
     def dropdb(self, dbname):
-        print("DROP database: " + dbname)
-        self.client.drop_database(dbname)
+        if next((item for item in self.client.get_list_database() if item.get("name") == dbname), None) is not None:
+            print("DROP database: " + dbname)
+            self.client.drop_database(dbname)
 
     def dropmeas(self, measname):
         print("DROP MEASUREMENT: " + measname)
@@ -67,7 +69,7 @@ class INSERTDATA(DATABASE):
             d = df[df['measTimeStampRf'] == timestamp]
             d.index = pd.date_range(start=datetime.datetime.now(), freq='1ms', periods=len(d))
             self.client.write_points(d, self.meas)
-            time.sleep(0.4)
+            time.sleep(0.7)
 
 
 def populatedb():