flush left over data in database

diff --git a/plugins/database/databasesink.cpp b/plugins/database/databasesink.cpp
index 833ced6..67f06a3 100644 (file)
--- a/plugins/database/databasesink.cpp
+++ b/plugins/database/databasesink.cpp
@@ -58,6 +58,16 @@ void * cbFunc(gpointer data)
                delete obj;
        }
 
+       /// final flush of whatever is still in the queue:
+
+       shared->db->exec("BEGIN IMMEDIATE TRANSACTION");
+       for(int i=0; i< insertList.size(); i++)
+       {
+               DictionaryList<string> d = insertList[i];
+               shared->db->insert(d);
+       }
+       shared->db->exec("END TRANSACTION");
+
        return NULL;
 }