Delete and recreate the sync database if it is corrupt.

chrome/browser/sync/syncable/directory_backing_store_unittest.cc

 // Copyright (c) 2010 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 "app/sql/connection.h"
 #include "app/sql/statement.h"
 #include "app/sql/transaction.h"
 #include "base/file_path.h"
+#include "base/file_util.h"
 #include "base/scoped_ptr.h"
 #include "base/scoped_temp_dir.h"
 #include "base/stl_util-inl.h"
 #include "chrome/browser/sync/protocol/bookmark_specifics.pb.h"
 #include "chrome/browser/sync/protocol/sync.pb.h"
 #include "chrome/browser/sync/syncable/directory_backing_store.h"
 #include "chrome/browser/sync/syncable/directory_manager.h"
 #include "chrome/browser/sync/syncable/syncable-inl.h"
 #include "chrome/browser/sync/syncable/syncable.h"
 #include "chrome/common/sqlite_utils.h"
@@ skipping 840 matching lines @@
 
 TEST_F(DirectoryBackingStoreTest, ModelTypeIds) {
   for (int i = FIRST_REAL_MODEL_TYPE; i < MODEL_TYPE_COUNT; ++i) {
     std::string model_id =
         DirectoryBackingStore::ModelTypeEnumToModelId(ModelTypeFromInt(i));
     EXPECT_EQ(i,
         DirectoryBackingStore::ModelIdToModelTypeEnum(model_id));
   }
 }
 
+TEST_F(DirectoryBackingStoreTest, Corruption) {
+  {
+    scoped_ptr<DirectoryBackingStore> dbs(
+        new DirectoryBackingStore(GetUsername(), GetDatabasePath()));
+    EXPECT_TRUE(dbs->BeginLoad());
+  }
+  std::string bad_data("BAD DATA");
+  EXPECT_TRUE(file_util::WriteFile(GetDatabasePath(), bad_data.data(),
+                                   bad_data.size()));
+  {
+    scoped_ptr<DirectoryBackingStore> dbs(
+        new DirectoryBackingStore(GetUsername(), GetDatabasePath()));
+
+    // In release mode, we expect the sync database to nuke itself and start
+    // over if it detects invalid/corrupted data.
+#if defined(NDEBUG)
+    EXPECT_TRUE(dbs->BeginLoad());
+#else
+    EXPECT_DEATH(dbs->BeginLoad(), "sqlite error");
+#endif
+  }
+}
+
 }  // namespace syncable