WIP: The Bookmark Position Megapatch

sync/syncable/directory_backing_store_unittest.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 "testing/gtest/include/gtest/gtest.h"
 
 #include <string>
 
 #include "base/file_path.h"
 #include "base/file_util.h"
@@ skipping 52 matching lines @@
   void SetUpVersion76Database(sql::Connection* connection);
   void SetUpVersion77Database(sql::Connection* connection);
   void SetUpVersion78Database(sql::Connection* connection);
   void SetUpVersion79Database(sql::Connection* connection);
   void SetUpVersion80Database(sql::Connection* connection);
   void SetUpVersion81Database(sql::Connection* connection);
   void SetUpVersion82Database(sql::Connection* connection);
   void SetUpVersion83Database(sql::Connection* connection);
   void SetUpVersion84Database(sql::Connection* connection);
   void SetUpVersion85Database(sql::Connection* connection);
+  void SetUpVersion86Database(sql::Connection* connection);
 
   void SetUpCurrentDatabaseAndCheckVersion(sql::Connection* connection) {
-    SetUpVersion85Database(connection);  // Prepopulates data.
+    SetUpVersion86Database(connection);  // Prepopulates data.
     scoped_ptr<TestDirectoryBackingStore> dbs(
         new TestDirectoryBackingStore(GetUsername(), connection));
+    ASSERT_EQ(kCurrentDBVersion, dbs->GetVersion());
 
     ASSERT_TRUE(LoadAndIgnoreReturnedData(dbs.get()));
     ASSERT_FALSE(dbs->needs_column_refresh_);
-    ASSERT_EQ(kCurrentDBVersion, dbs->GetVersion());
   }
 
  private:
   base::ScopedTempDir temp_dir_;
 };
 
 class DirectoryBackingStoreTest : public MigrationTest {};
 
 #if defined(OS_WIN)
 
@@ skipping 2325 matching lines @@
   for (int i = 0; i < V80_ROW_COUNT; i++) {
     sql::Statement s(connection->GetUniqueStatement(insert_stmts[i]));
     std::string ord = V81_Ordinal(i);
     s.BindBlob(0, ord.data(), ord.length());
     ASSERT_TRUE(s.Run());
     s.Reset(true);
   }
   ASSERT_TRUE(connection->CommitTransaction());
 }
 
+void MigrationTest::SetUpVersion86Database(sql::Connection* connection) {
+  ASSERT_TRUE(connection->is_open());
+  ASSERT_TRUE(connection->BeginTransaction());
+  ASSERT_TRUE(connection->Execute(
+      "CREATE TABLE share_version (id VARCHAR(128) primary key, data INT);"
+      "INSERT INTO 'share_version' VALUES('nick@chromium.org',86);"
+      "CREATE TABLE models (model_id BLOB primary key, progress_marker BLOB,"
+         " transaction_version BIGINT default 0);"
+      "INSERT INTO 'models' VALUES(X'C2881000',X'0888810218B605',1);"
+      "CREATE TABLE 'metas'(metahandle bigint primary key ON CONFLICT FAIL,b"
+         "ase_version bigint default -1,server_version bigint default 0,local_e"
+         "xternal_id bigint default 0,transaction_version bigint default 0,mtim"
+         "e bigint default 0,server_mtime bigint default 0,ctime bigint default"
+         " 0,server_ctime bigint default 0,id varchar(255) default 'r',parent_i"
+         "d varchar(255) default 'r',server_parent_id varchar(255) default 'r',"
+         "is_unsynced bit default 0,is_unapplied_update bit default 0,is_del bi"
+         "t default 0,is_dir bit default 0,server_is_dir bit default 0,server_i"
+         "s_del bit default 0,non_unique_name varchar,server_non_unique_name va"
+         "rchar(255),unique_server_tag varchar,unique_client_tag varchar,specif"
+         "ics blob,server_specifics blob,base_server_specifics blob,server_uniq"
+          "ue_position blob,unique_position blob,unique_bookmark_tag blob);"
+      "INSERT INTO 'metas' VALUES(1,-1,0,0,0,1263522064000,1263522064000,126"
+         "3522064000,1263522064000,'r','r','r',0,0,0,1,0,0,NULL,NULL,NULL,NULL,"
+          "X'',X'',NULL,X'',X'',X'');"
+      "INSERT INTO 'metas' VALUES(6,694,694,6,0,1260924017000,1260924017000,"
+         "1260924017000,1260924017000,'s_ID_6','s_ID_9','s_ID_9',0,0,0,1,1,0,'T"
+         "he Internet','The Internet',NULL,NULL,X'C2881000',X'C2881000',NULL,X'"
+          "',X'',X'');"
+      "INSERT INTO 'metas' VALUES(7,663,663,0,0,1253212875000,1253212875000,"
+         "1253212875000,1253212875000,'s_ID_7','r','r',0,0,0,1,1,0,'Google Chro"
+         "me','Google Chrome','google_chrome',NULL,NULL,NULL,NULL,X'',X'',X'');"
+      "INSERT INTO 'metas' VALUES(8,664,664,0,0,1253212875000,1253212875000,"
+         "1253212875000,1253212875000,'s_ID_8','s_ID_7','s_ID_7',0,0,0,1,1,0,'B"
+         "ookmarks','Bookmarks','google_chrome_bookmarks',NULL,X'C2881000',X'C2"
+         "881000',NULL,X'',X'',X'');"
+      "INSERT INTO 'metas' VALUES(9,665,665,1,0,1253212875000,1253212875000,"
+         "1253212875000,1253212875000,'s_ID_9','s_ID_8','s_ID_8',0,0,0,1,1,0,'B"
+         "ookmark Bar','Bookmark Bar','bookmark_bar',NULL,X'C2881000',X'C288100"
+         "0',NULL,X'',X'',X'');"
+      "INSERT INTO 'metas' VALUES(10,666,666,2,0,1253212875000,1253212875000"
+         ",1253212875000,1253212875000,'s_ID_10','s_ID_8','s_ID_8',0,0,0,1,1,0,"
+         "'Other Bookmarks','Other Bookmarks','other_bookmarks',NULL,X'C2881000"
+         "',X'C2881000',NULL,X'',X'',X'');"
+      "INSERT INTO 'metas' VALUES(11,683,683,8,0,1263522094000,1263522094000"
+         ",1263522094000,1263522094000,'s_ID_11','s_ID_6','s_ID_6',0,0,0,0,0,0,"
+         "'Home (The Chromium Projects)','Home (The Chromium Projects)',NULL,NU"
+         "LL,X'C28810220A18687474703A2F2F6465762E6368726F6D69756D2E6F72672F1206"
+         "414741545741',X'C28810290A1D687474703A2F2F6465762E6368726F6D69756D2E6"
+         "F72672F6F7468657212084146414756415346',NULL,X'',X'',X'');"
+      "INSERT INTO 'metas' VALUES(12,685,685,9,0,1263522151000,1263522151000"
+         ",1263522151000,1263522151000,'s_ID_12','s_ID_6','s_ID_6',0,0,0,1,1,0,"
+         "'Extra Bookmarks','Extra Bookmarks',NULL,NULL,X'C2881000',X'C2881000'"
+         ",NULL,X'',X'',X'');"
+      "INSERT INTO 'metas' VALUES(13,687,687,10,0,1263522198000,126352219800"
+         "0,1263522198000,1263522198000,'s_ID_13','s_ID_6','s_ID_6',0,0,0,0,0,0"
+         ",'ICANN | Internet Corporation for Assigned Names and Numbers','ICANN"
+         " | Internet Corporation for Assigned Names and Numbers',NULL,NULL,X'C"
+         "28810240A15687474703A2F2F7777772E6963616E6E2E636F6D2F120B504E47415846"
+         "3041414646',X'C28810200A15687474703A2F2F7777772E6963616E6E2E636F6D2F1"
+         "20744414146415346',NULL,X'',X'',X'');"
+      "INSERT INTO 'metas' VALUES(14,692,692,11,0,1263522238000,126352223800"
+         "0,1263522238000,1263522238000,'s_ID_14','s_ID_6','s_ID_6',0,0,0,0,0,0"
+         ",'The WebKit Open Source Project','The WebKit Open Source Project',NU"
+         "LL,NULL,X'C288101A0A12687474703A2F2F7765626B69742E6F72672F1204504E475"
+         "8',X'C288101C0A13687474703A2F2F7765626B69742E6F72672F781205504E473259"
+         "',NULL,X'',X'',X'');"
+      "CREATE TABLE deleted_metas (metahandle bigint primary key ON CONFLICT"
+         " FAIL,base_version bigint default -1,server_version bigint default 0,"
+         "local_external_id bigint default 0,transaction_version bigint default"
+         " 0,mtime bigint default 0,server_mtime bigint default 0,ctime bigint "
+         "default 0,server_ctime bigint default 0,id varchar(255) default 'r',p"
+         "arent_id varchar(255) default 'r',server_parent_id varchar(255) defau"
+         "lt 'r',is_unsynced bit default 0,is_unapplied_update bit default 0,is"
+         "_del bit default 0,is_dir bit default 0,server_is_dir bit default 0,s"
+         "erver_is_del bit default 0,non_unique_name varchar,server_non_unique_"
+         "name varchar(255),unique_server_tag varchar,unique_client_tag varchar"
+         ",specifics blob,server_specifics blob,base_server_specifics blob,serv"
+         "er_unique_position blob,unique_position blob,unique_bookmark_tag blob"
+         ");"
+      "CREATE TABLE 'share_info' (id TEXT primary key, name TEXT, store_birt"
+         "hday TEXT, db_create_version TEXT, db_create_time INT, next_id INT de"
+         "fault -2, cache_guid TEXT, notification_state BLOB, bag_of_chips BLOB"
+         ");"
+      "INSERT INTO 'share_info' VALUES('nick@chromium.org','nick@chromium.or"
+         "g','c27e9f59-08ca-46f8-b0cc-f16a2ed778bb','Unknown',1263522064,-13107"
+          "8,'9010788312004066376x-6609234393368420856x',NULL,NULL);"));
+  ASSERT_TRUE(connection->CommitTransaction());
+}
+
 TEST_F(DirectoryBackingStoreTest, MigrateVersion67To68) {
   sql::Connection connection;
   ASSERT_TRUE(connection.OpenInMemory());
 
   SetUpVersion67Database(&connection);
 
   // Columns existing before version 67.
   ASSERT_TRUE(connection.DoesColumnExist("metas", "name"));
   ASSERT_TRUE(connection.DoesColumnExist("metas", "unsanitized_name"));
   ASSERT_TRUE(connection.DoesColumnExist("metas", "server_name"));
@@ skipping 364 matching lines @@
       "FROM metas WHERE unique_server_tag = 'google_chrome'"));
   ASSERT_TRUE(new_s.Step());
   ASSERT_EQ(sql::COLUMN_TYPE_BLOB, new_s.ColumnType(1));
 
   std::string expected_ordinal = Int64ToNodeOrdinal(1048576).ToInternalValue();
   std::string actual_ordinal;
   new_s.ColumnBlobAsString(1, &actual_ordinal);
   ASSERT_EQ(expected_ordinal, actual_ordinal);
 }
 
-TEST_F(DirectoryBackingStoreTest, DetectInvalidOrdinal) {
+TEST_F(DirectoryBackingStoreTest, DetectInvalidPosition) {
   sql::Connection connection;
   ASSERT_TRUE(connection.OpenInMemory());
-  SetUpVersion81Database(&connection);
+  SetUpVersion86Database(&connection);
 
   scoped_ptr<TestDirectoryBackingStore> dbs(
       new TestDirectoryBackingStore(GetUsername(), &connection));
-  ASSERT_EQ(81, dbs->GetVersion());
+  ASSERT_EQ(86, dbs->GetVersion());
 
-  // Insert row with bad ordinal.
-  const int64 now = TimeToProtoTime(base::Time::Now());
+  // Insert row with bad position.
   sql::Statement s(connection.GetUniqueStatement(
       "INSERT INTO metas "
-      "( id, metahandle, is_dir, ctime, mtime, server_ordinal_in_parent) "
-      "VALUES( \"c-invalid\", 9999, 1, ?, ?, \" \")"));
-  s.BindInt64(0, now);
-  s.BindInt64(1, now);
+      "( id, metahandle, is_dir, ctime, mtime,"
+      "  unique_position, server_unique_position) "
+      "VALUES('c-invalid', 9999, 1, 0, 0, 'BAD_POS', 'BAD_POS')"));
   ASSERT_TRUE(s.Run());
 
   // Trying to unpack this entry should signal that the DB is corrupted.
   MetahandlesIndex entry_bucket;
   STLElementDeleter<MetahandlesIndex> deleter(&entry_bucket);
   Directory::KernelLoadInfo kernel_load_info;
   ASSERT_EQ(FAILED_DATABASE_CORRUPT,
             dbs->Load(&entry_bucket, &kernel_load_info));
 }
 
@@ skipping 47 matching lines @@
   SetUpVersion84Database(&connection);
   ASSERT_TRUE(connection.DoesColumnExist("models", "initial_sync_ended"));
 
   scoped_ptr<TestDirectoryBackingStore> dbs(
       new TestDirectoryBackingStore(GetUsername(), &connection));
   ASSERT_TRUE(dbs->MigrateVersion84To85());
   ASSERT_EQ(85, dbs->GetVersion());
   ASSERT_FALSE(connection.DoesColumnExist("models", "initial_sync_ended"));
 }
 
+TEST_F(DirectoryBackingStoreTest, MigrateVersion85To86) {
+  sql::Connection connection;
+  ASSERT_TRUE(connection.OpenInMemory());
+  SetUpVersion85Database(&connection);
+  EXPECT_TRUE(connection.DoesColumnExist("metas", "next_id"));
+  EXPECT_TRUE(connection.DoesColumnExist("metas", "prev_id"));
+  EXPECT_TRUE(connection.DoesColumnExist("metas", "server_ordinal_in_parent"));
+  EXPECT_FALSE(connection.DoesColumnExist("metas", "unique_position"));
+  EXPECT_FALSE(connection.DoesColumnExist("metas", "server_unique_position"));
+  EXPECT_FALSE(connection.DoesColumnExist("metas", "unique_bookmark_tag"));
+
+  scoped_ptr<TestDirectoryBackingStore> dbs(
+      new TestDirectoryBackingStore(GetUsername(), &connection));
+  ASSERT_TRUE(dbs->MigrateVersion85To86());
+  EXPECT_EQ(86, dbs->GetVersion());
+  EXPECT_TRUE(connection.DoesColumnExist("metas", "unique_position"));
+  EXPECT_TRUE(connection.DoesColumnExist("metas", "server_unique_position"));
+  EXPECT_TRUE(connection.DoesColumnExist("metas", "unique_bookmark_tag"));
+  ASSERT_TRUE(dbs->needs_column_refresh_);
+  ASSERT_TRUE(dbs->RefreshColumns());
+  EXPECT_FALSE(connection.DoesColumnExist("metas", "next_id"));
+  EXPECT_FALSE(connection.DoesColumnExist("metas", "prev_id"));
+  EXPECT_FALSE(connection.DoesColumnExist("metas", "server_ordinal_in_parent"));
+}
+
 TEST_P(MigrationTest, ToCurrentVersion) {
   sql::Connection connection;
   ASSERT_TRUE(connection.OpenInMemory());
   switch (GetParam()) {
     case 67:
       SetUpVersion67Database(&connection);
       break;
     case 68:
       SetUpVersion68Database(&connection);
       break;
@@ skipping 38 matching lines @@
       break;
     case 82:
       SetUpVersion82Database(&connection);
       break;
     case 83:
       SetUpVersion83Database(&connection);
       break;
     case 84:
       SetUpVersion84Database(&connection);
       break;
+    case 85:
+      SetUpVersion85Database(&connection);
+      break;
+    case 86:
+      SetUpVersion86Database(&connection);
+      break;
     default:
       // If you see this error, it may mean that you've increased the
       // database version number but you haven't finished adding unit tests
       // for the database migration code.  You need to need to supply a
       // SetUpVersionXXDatabase function with a dump of the test database
       // at the old schema.  Here's one way to do that:
       //   1. Start on a clean tree (with none of your pending schema changes).
       //   2. Set a breakpoint in this function and run the unit test.
       //   3. Allow this test to run to completion (step out of the call),
       //      without allowing ~MigrationTest to execute.
@@ skipping 193 matching lines @@
   ASSERT_TRUE(++it != index.end());
   ASSERT_EQ(13, (*it)->ref(META_HANDLE));
 
   ASSERT_TRUE(++it != index.end());
   ASSERT_EQ(14, (*it)->ref(META_HANDLE));
 
   ASSERT_TRUE(++it == index.end());
 }
 
 INSTANTIATE_TEST_CASE_P(DirectoryBackingStore, MigrationTest,
-                        testing::Range(67, kCurrentDBVersion));
+                        testing::Range(67, kCurrentDBVersion+1));
 
 TEST_F(DirectoryBackingStoreTest, ModelTypeIds) {
   for (int i = FIRST_REAL_MODEL_TYPE; i < MODEL_TYPE_COUNT; ++i) {
     std::string model_id =
         TestDirectoryBackingStore::ModelTypeEnumToModelId(ModelTypeFromInt(i));
     EXPECT_EQ(i,
         TestDirectoryBackingStore::ModelIdToModelTypeEnum(model_id.data(),
                                                           model_id.size()));
   }
 }
@@ skipping 115 matching lines @@
   const std::string& guid2 = TestDirectoryBackingStore::GenerateCacheGUID();
   EXPECT_EQ(24U, guid1.size());
   EXPECT_EQ(24U, guid2.size());
   // In theory this test can fail, but it won't before the universe
   // dies of heat death.
   EXPECT_NE(guid1, guid2);
 }
 
 }  // namespace syncable
 }  // namespace syncer