Populate versions on individual nodes in sync model and native bookmark model.

sync/syncable/directory_backing_store.cc

 // Copyright (c) 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.
 
 #include "sync/syncable/directory_backing_store.h"
 
 #include "build/build_config.h"
 
 #include <limits>
 
@@ skipping 22 matching lines @@
 
 namespace syncer {
 namespace syncable {
 
 // This just has to be big enough to hold an UPDATE or INSERT statement that
 // modifies all the columns in the entry table.
 static const string::size_type kUpdateStatementBufferSize = 2048;
 
 // Increment this version whenever updating DB tables.
 extern const int32 kCurrentDBVersion;  // Global visibility for our unittest.
-const int32 kCurrentDBVersion = 82;
+const int32 kCurrentDBVersion = 83;
 
 // Iterate over the fields of |entry| and bind each to |statement| for
 // updating.  Returns the number of args bound.
 void BindFields(const EntryKernel& entry,
                 sql::Statement* statement) {
   int index = 0;
   int i = 0;
   for (i = BEGIN_FIELDS; i < INT64_FIELDS_END; ++i) {
     statement->BindInt64(index++, entry.ref(static_cast<Int64Field>(i)));
   }
@@ skipping 297 matching lines @@
     if (MigrateVersion80To81())
       version_on_disk = 81;
   }
 
   // Version 82 migration added transaction_version column per data type.
   if (version_on_disk == 81) {
     if (MigrateVersion81To82())
       version_on_disk = 82;
   }
 
+  // Version 83 migration added transaction_version column per sync entry.
+  if (version_on_disk == 82) {
+    if (MigrateVersion82To83())
+      version_on_disk = 83;
+  }
+
   // If one of the migrations requested it, drop columns that aren't current.
   // It's only safe to do this after migrating all the way to the current
   // version.
   if (version_on_disk == kCurrentDBVersion && needs_column_refresh_) {
     if (!RefreshColumns())
       version_on_disk = 0;
   }
 
   // A final, alternative catch-all migration to simply re-sync everything.
   //
@@ skipping 694 matching lines @@
       "ALTER TABLE models ADD COLUMN transaction_version BIGINT default 0"))
     return false;
   sql::Statement update(db_->GetUniqueStatement(
       "UPDATE models SET transaction_version = 0"));
   if (!update.Run())
     return false;
   SetVersion(82);
   return true;
 }
 
+bool DirectoryBackingStore::MigrateVersion82To83() {
+  // Version 83 added transaction_version on sync node.
+  if (!db_->Execute(
+      "ALTER TABLE metas ADD COLUMN transaction_version BIGINT default 0"))
+    return false;
+  sql::Statement update(db_->GetUniqueStatement(
+      "UPDATE metas SET transaction_version = 0"));
+  if (!update.Run())
+    return false;
+  SetVersion(83);
+  return true;
+}
+
 bool DirectoryBackingStore::CreateTables() {
   DVLOG(1) << "First run, creating tables";
   // Create two little tables share_version and share_info
   if (!db_->Execute(
           "CREATE TABLE share_version ("
           "id VARCHAR(128) primary key, data INT)")) {
     return false;
   }
 
   {
@@ skipping 162 matching lines @@
     bool prev_exists = (ids_set.find(entry->ref(PREV_ID).value()) != end);
     bool parent_exists = (ids_set.find(entry->ref(PARENT_ID).value()) != end);
     bool next_exists = (ids_set.find(entry->ref(NEXT_ID).value()) != end);
     is_ok = is_ok && prev_exists && parent_exists && next_exists;
   }
   return is_ok;
 }
 
 }  // namespace syncable
 }  // namespace syncer