Remove expired logs while creating Store objects

Change-Id: I334abe0155bcbf6a8bc91c046c9639606b9753a2
Signed-off-by: Mu-Woong Lee <muwoong.lee@samsung.com>

diff --git a/src/server/Store.cpp b/src/server/Store.cpp
index d05d3c8..80f529b 100644 (file)
--- a/src/server/Store.cpp
+++ b/src/server/Store.cpp
@@ -45,7 +45,6 @@ const std::string& Store::getColumns()
 int Store::insert(ContextStoreClient& client, const std::string& columns, std::vector<std::shared_ptr<Tuple>>& tuples)
 {
        //TODO: handling owner's ID
-       //TODO: delete expired data
        if (!__writable(client))
                return E_ACCESS;
 
@@ -105,3 +104,30 @@ int Store::remove(ContextStoreClient& client, const std::string selection)
 
        return E_NONE;
 }
+
+void Store::removeExpired()
+{
+       std::string timePruningQuery;
+       std::string countPruningQuery;
+
+       // DELETE FROM <table> WHERE __timestamp < datetime('now', '-<retention> hours');
+       if (metadata.retention != 0) {
+               timePruningQuery =
+                       "DELETE FROM [" + metadata.uri + "] WHERE " + COL_TIMESTAMP +
+                       " < datetime('now', '-" + std::to_string(metadata.retention) + " hours');";
+       }
+
+       // DELETE FROM <table> WHERE rowid < (
+       //     SELECT MIN(rowid) FROM (
+       //         SELECT rowid FROM <table> ORDER BY rowid DESC LIMIT <limit>
+       //     )
+       // );
+       if (metadata.limit != 0) {
+               countPruningQuery =
+                       "DELETE FROM [" + metadata.uri + "] WHERE rowid <" \
+                       " (SELECT MIN(rowid) FROM (SELECT rowid FROM [" + metadata.uri + "]" \
+                       " ORDER BY rowid DESC LIMIT " + std::to_string(metadata.limit) + "));";
+       }
+
+       __getDatabase().execute(timePruningQuery + countPruningQuery, NULL);
+}

diff --git a/src/server/Store.h b/src/server/Store.h
index 42304f4..543d66c 100644 (file)
--- a/src/server/Store.h
+++ b/src/server/Store.h
@@ -58,6 +58,8 @@ namespace ctx {
 
                int remove(ContextStoreClient& client, const std::string selection);
 
+               void removeExpired();
+
        protected:
                Store();
 

diff --git a/src/server/StoreManager.cpp b/src/server/StoreManager.cpp
index 3ee0012..1ff2b4c 100644 (file)
--- a/src/server/StoreManager.cpp
+++ b/src/server/StoreManager.cpp
@@ -95,6 +95,8 @@ Store* StoreManager::__createStore(Database& database, std::list<Store*>& stores
                stores.pop_back();
        }
 
+       store->removeExpired();
+
        return store;
 }