[Sync] Add support for loading, updating and querying delete journals in

sync/syncable/directory_backing_store.h

 // Copyright 2012 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.
 
 #ifndef SYNC_SYNCABLE_DIRECTORY_BACKING_STORE_H_
 #define SYNC_SYNCABLE_DIRECTORY_BACKING_STORE_H_
 
 #include <string>
 
 #include "base/memory/scoped_ptr.h"
@@ skipping 41 matching lines @@
   // Loads and drops all currently persisted meta entries into |entry_bucket|
   // and loads appropriate persisted kernel info into |info_bucket|.
   //
   // This function can perform some cleanup tasks behind the scenes.  It will
   // clean up unused entries from the database and migrate to the latest
   // database version.  The caller can safely ignore these details.
   //
   // NOTE: On success (return value of OPENED), the buckets are populated with
   // newly allocated items, meaning ownership is bestowed upon the caller.
   virtual DirOpenResult Load(MetahandlesIndex* entry_bucket,
+                             JournalIndex* delete_journals,
                              Directory::KernelLoadInfo* kernel_load_info) = 0;
 
   // Updates the on-disk store with the input |snapshot| as a database
   // transaction.  Does NOT open any syncable transactions as this would cause
   // opening transactions elsewhere to block on synchronous I/O.
   // DO NOT CALL THIS FROM MORE THAN ONE THREAD EVER.  Also, whichever thread
   // calls SaveChanges *must* be the thread that owns/destroys |this|.
   virtual bool SaveChanges(const Directory::SaveChangesSnapshot& snapshot);
 
  protected:
@@ skipping 18 matching lines @@
   bool CreateV75ModelsTable();
 
   // We don't need to load any synced and applied deleted entries, we can
   // in fact just purge them forever on startup.
   bool DropDeletedEntries();
   // Drops a table if it exists, harmless if the table did not already exist.
   bool SafeDropTable(const char* table_name);
 
   // Load helpers for entries and attributes.
   bool LoadEntries(MetahandlesIndex* entry_bucket);
+  bool LoadDeleteJournals(JournalIndex* delete_journals);
   bool LoadInfo(Directory::KernelLoadInfo* info);
 
   // Save/update helpers for entries.  Return false if sqlite commit fails.
-  bool SaveEntryToDB(const EntryKernel& entry);
+  static bool SaveEntryToDB(sql::Statement* save_statement,
+                            const EntryKernel& entry);
   bool SaveNewEntryToDB(const EntryKernel& entry);
   bool UpdateEntryToDB(const EntryKernel& entry);
 
   DirOpenResult DoLoad(MetahandlesIndex* entry_bucket,
       Directory::KernelLoadInfo* kernel_load_info);
 
   // Close save_dbhandle_.  Broken out for testing.
   void EndSave();
 
-  // Removes each entry whose metahandle is in |handles| from the database.
-  // Does synchronous I/O.  Returns false on error.
-  bool DeleteEntries(const MetahandleSet& handles);
+  enum EntryTable {
+    METAS_TABLE,
+    DELETE_JOURNAL_TABLE,
+  };
+  // Removes each entry whose metahandle is in |handles| from the table
+  // specified by |from| table. Does synchronous I/O.  Returns false on error.
+  bool DeleteEntries(EntryTable from, const MetahandleSet& handles);
 
   // Drop all tables in preparation for reinitialization.
   void DropAllTables();
 
   // Serialization helpers for ModelType.  These convert between
   // the ModelType enum and the values we persist in the database to identify
   // a model.  We persist a default instance of the specifics protobuf as the
   // ID, rather than the enum value.
   static ModelType ModelIdToModelTypeEnum(const void* data, int length);
   static std::string ModelTypeEnumToModelId(ModelType model_type);
@@ skipping 34 matching lines @@
   bool MigrateVersion77To78();
   bool MigrateVersion78To79();
   bool MigrateVersion79To80();
   bool MigrateVersion80To81();
   bool MigrateVersion81To82();
   bool MigrateVersion82To83();
   bool MigrateVersion83To84();
   bool MigrateVersion84To85();
 
   scoped_ptr<sql::Connection> db_;
-  sql::Statement save_entry_statement_;
+  sql::Statement save_meta_statment_;
+  sql::Statement save_delete_journal_statment_;
   std::string dir_name_;
 
   // Set to true if migration left some old columns around that need to be
   // discarded.
   bool needs_column_refresh_;
 
+ private:
+  // Helper function for loading entries from specified table.
+  template<class T>
+  bool LoadEntriesInternal(const std::string& table, T* bucket);
+
+  // Prepares |save_statement| for saving entries in |table|.
+  void PrepareSaveEntryStatement(EntryTable table,
+                                 sql::Statement* save_statement);
+
   DISALLOW_COPY_AND_ASSIGN(DirectoryBackingStore);
 };
 
 }  // namespace syncable
 }  // namespace syncer
 
 #endif  // SYNC_SYNCABLE_DIRECTORY_BACKING_STORE_H_