Compressed activity log database storage

chrome/browser/extensions/activity_log/fullstream_ui_policy.cc

 // Copyright 2013 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/extensions/activity_log/fullstream_ui_policy.h"
 
 #include "base/callback.h"
 #include "base/command_line.h"
 #include "base/files/file_path.h"
 #include "base/json/json_reader.h"
@@ skipping 50 matching lines @@
 
 const char* FullStreamUIPolicy::kTableName = "activitylog_full";
 const char* FullStreamUIPolicy::kTableContentFields[] = {
   "extension_id", "time", "action_type", "api_name", "args", "page_url",
   "page_title", "arg_url", "other"
 };
 const char* FullStreamUIPolicy::kTableFieldTypes[] = {
   "LONGVARCHAR NOT NULL", "INTEGER", "INTEGER", "LONGVARCHAR", "LONGVARCHAR",
   "LONGVARCHAR", "LONGVARCHAR", "LONGVARCHAR", "LONGVARCHAR"
 };
-const int FullStreamUIPolicy::kTableFieldCount = arraysize(kTableContentFields);
+const int FullStreamUIPolicy::kTableFieldCount =
+    arraysize(FullStreamUIPolicy::kTableContentFields);
 
 FullStreamUIPolicy::FullStreamUIPolicy(Profile* profile)
     : ActivityLogDatabasePolicy(
           profile,
-          FilePath(chrome::kExtensionActivityLogFilename)) {}
+          FilePath(chrome::kExtensionActivityLogFilename)),
+      string_table_("string_ids"),
+      url_table_("url_ids") {}
 
 FullStreamUIPolicy::~FullStreamUIPolicy() {}
 
 bool FullStreamUIPolicy::InitDatabase(sql::Connection* db) {
   // Drop old database tables.
   for (size_t i = 0; i < arraysize(kObsoleteTables); i++) {
     const char* table_name = kObsoleteTables[i];
     if (db->DoesTableExist(table_name)) {
       std::string drop_statement =
           base::StringPrintf("DROP TABLE %s", table_name);
       if (!db->Execute(drop_statement.c_str())) {
         return false;
       }
     }
   }
 
+  if (!string_table_.Initialize(db))
+    return false;
+  if (!url_table_.Initialize(db))
+    return false;
+
   // Create the unified activity log entry table.
   return ActivityDatabase::InitializeTable(db,
                                            kTableName,
                                            kTableContentFields,
                                            kTableFieldTypes,
                                            arraysize(kTableContentFields));
 }
 
 bool FullStreamUIPolicy::FlushDatabase(sql::Connection* db) {
   if (queued_actions_.empty())
     return true;
 
   sql::Transaction transaction(db);
   if (!transaction.Begin())
     return false;
 
   std::string sql_str =
       "INSERT INTO " + std::string(FullStreamUIPolicy::kTableName) +
       " (extension_id, time, action_type, api_name, args, "
       "page_url, page_title, arg_url, other) VALUES (?,?,?,?,?,?,?,?,?)";
   sql::Statement statement(db->GetCachedStatement(
       sql::StatementID(SQL_FROM_HERE), sql_str.c_str()));
 
+  // TODO(mvrable): Should be moved to a utility function, perhaps.
   url_canon::Replacements<char> url_sanitizer;
   if (!CommandLine::ForCurrentProcess()->HasSwitch(
           switches::kEnableExtensionActivityLogTesting)) {
     url_sanitizer.ClearQuery();
     url_sanitizer.ClearRef();
   }
 
   Action::ActionVector::size_type i;
   for (i = 0; i != queued_actions_.size(); ++i) {
     const Action& action = *queued_actions_[i];
@@ skipping 182 matching lines @@
 }
 
 void FullStreamUIPolicy::QueueAction(scoped_refptr<Action> action) {
   if (activity_database()->is_db_valid()) {
     queued_actions_.push_back(action);
     activity_database()->NotifyAction();
   }
 }
 
 }  // namespace extensions