OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "components/history/core/browser/history_database.h" | 5 #include "components/history/core/browser/history_database.h" |
6 | 6 |
7 #include <stdint.h> | 7 #include <stdint.h> |
8 | 8 |
9 #include <algorithm> | 9 #include <algorithm> |
10 #include <set> | 10 #include <set> |
(...skipping 18 matching lines...) Expand all Loading... |
29 #include "base/mac/mac_util.h" | 29 #include "base/mac/mac_util.h" |
30 #endif | 30 #endif |
31 | 31 |
32 namespace history { | 32 namespace history { |
33 | 33 |
34 namespace { | 34 namespace { |
35 | 35 |
36 // Current version number. We write databases at the "current" version number, | 36 // Current version number. We write databases at the "current" version number, |
37 // but any previous version that can read the "compatible" one can make do with | 37 // but any previous version that can read the "compatible" one can make do with |
38 // our database without *too* many bad effects. | 38 // our database without *too* many bad effects. |
39 const int kCurrentVersionNumber = 33; | 39 const int kCurrentVersionNumber = 34; |
40 const int kCompatibleVersionNumber = 16; | 40 const int kCompatibleVersionNumber = 16; |
41 const char kEarlyExpirationThresholdKey[] = "early_expiration_threshold"; | 41 const char kEarlyExpirationThresholdKey[] = "early_expiration_threshold"; |
42 const int kMaxHostsInMemory = 10000; | 42 const int kMaxHostsInMemory = 10000; |
43 | 43 |
44 } // namespace | 44 } // namespace |
45 | 45 |
46 HistoryDatabase::HistoryDatabase( | 46 HistoryDatabase::HistoryDatabase( |
47 DownloadInterruptReason download_interrupt_reason_none, | 47 DownloadInterruptReason download_interrupt_reason_none, |
48 DownloadInterruptReason download_interrupt_reason_crash) | 48 DownloadInterruptReason download_interrupt_reason_crash) |
49 : DownloadDatabase(download_interrupt_reason_none, | 49 : DownloadDatabase(download_interrupt_reason_none, |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
89 // Prime the cache. | 89 // Prime the cache. |
90 db_.Preload(); | 90 db_.Preload(); |
91 | 91 |
92 // Create the tables and indices. | 92 // Create the tables and indices. |
93 // NOTE: If you add something here, also add it to | 93 // NOTE: If you add something here, also add it to |
94 // RecreateAllButStarAndURLTables. | 94 // RecreateAllButStarAndURLTables. |
95 if (!meta_table_.Init(&db_, GetCurrentVersion(), kCompatibleVersionNumber)) | 95 if (!meta_table_.Init(&db_, GetCurrentVersion(), kCompatibleVersionNumber)) |
96 return sql::INIT_FAILURE; | 96 return sql::INIT_FAILURE; |
97 if (!CreateURLTable(false) || !InitVisitTable() || | 97 if (!CreateURLTable(false) || !InitVisitTable() || |
98 !InitKeywordSearchTermsTable() || !InitDownloadTable() || | 98 !InitKeywordSearchTermsTable() || !InitDownloadTable() || |
99 !InitSegmentTables()) | 99 !InitSegmentTables() || !InitSyncTable()) |
100 return sql::INIT_FAILURE; | 100 return sql::INIT_FAILURE; |
101 CreateMainURLIndex(); | 101 CreateMainURLIndex(); |
102 CreateKeywordSearchTermsIndices(); | 102 CreateKeywordSearchTermsIndices(); |
103 | 103 |
104 // TODO(benjhayden) Remove at some point. | 104 // TODO(benjhayden) Remove at some point. |
105 meta_table_.DeleteKey("next_download_id"); | 105 meta_table_.DeleteKey("next_download_id"); |
106 | 106 |
107 // Version check. | 107 // Version check. |
108 sql::InitStatus version_status = EnsureCurrentVersion(); | 108 sql::InitStatus version_status = EnsureCurrentVersion(); |
109 if (version_status != sql::INIT_OK) | 109 if (version_status != sql::INIT_OK) |
(...skipping 425 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
535 cur_version++; | 535 cur_version++; |
536 meta_table_.SetVersionNumber(cur_version); | 536 meta_table_.SetVersionNumber(cur_version); |
537 } | 537 } |
538 | 538 |
539 if (cur_version == 32) { | 539 if (cur_version == 32) { |
540 // New download slices table is introduced, no migration needed. | 540 // New download slices table is introduced, no migration needed. |
541 cur_version++; | 541 cur_version++; |
542 meta_table_.SetVersionNumber(cur_version); | 542 meta_table_.SetVersionNumber(cur_version); |
543 } | 543 } |
544 | 544 |
| 545 if (cur_version == 33) { |
| 546 // AUTOINCREMENT is added to urls table PRIMARY KEY(id), need to recreate a |
| 547 // new table and copy all contents over. Also typed_url_sync_metadata and |
| 548 // autofill_model_type_state tables are introduced, no migration needed for |
| 549 // those two tables. |
| 550 if (!RecreateURLTableWithAllContents()) { |
| 551 LOG(WARNING) << "Unable to update history database to version 34."; |
| 552 return sql::INIT_FAILURE; |
| 553 } |
| 554 cur_version++; |
| 555 meta_table_.SetVersionNumber(cur_version); |
| 556 } |
| 557 |
545 // When the version is too old, we just try to continue anyway, there should | 558 // When the version is too old, we just try to continue anyway, there should |
546 // not be a released product that makes a database too old for us to handle. | 559 // not be a released product that makes a database too old for us to handle. |
547 LOG_IF(WARNING, cur_version < GetCurrentVersion()) << | 560 LOG_IF(WARNING, cur_version < GetCurrentVersion()) << |
548 "History database version " << cur_version << " is too old to handle."; | 561 "History database version " << cur_version << " is too old to handle."; |
549 | 562 |
550 return sql::INIT_OK; | 563 return sql::INIT_OK; |
551 } | 564 } |
552 | 565 |
553 #if !defined(OS_WIN) | 566 #if !defined(OS_WIN) |
554 void HistoryDatabase::MigrateTimeEpoch() { | 567 void HistoryDatabase::MigrateTimeEpoch() { |
555 // Update all the times in the URLs and visits table in the main database. | 568 // Update all the times in the URLs and visits table in the main database. |
556 ignore_result(db_.Execute( | 569 ignore_result(db_.Execute( |
557 "UPDATE urls " | 570 "UPDATE urls " |
558 "SET last_visit_time = last_visit_time + 11644473600000000 " | 571 "SET last_visit_time = last_visit_time + 11644473600000000 " |
559 "WHERE id IN (SELECT id FROM urls WHERE last_visit_time > 0);")); | 572 "WHERE id IN (SELECT id FROM urls WHERE last_visit_time > 0);")); |
560 ignore_result(db_.Execute( | 573 ignore_result(db_.Execute( |
561 "UPDATE visits " | 574 "UPDATE visits " |
562 "SET visit_time = visit_time + 11644473600000000 " | 575 "SET visit_time = visit_time + 11644473600000000 " |
563 "WHERE id IN (SELECT id FROM visits WHERE visit_time > 0);")); | 576 "WHERE id IN (SELECT id FROM visits WHERE visit_time > 0);")); |
564 ignore_result(db_.Execute( | 577 ignore_result(db_.Execute( |
565 "UPDATE segment_usage " | 578 "UPDATE segment_usage " |
566 "SET time_slot = time_slot + 11644473600000000 " | 579 "SET time_slot = time_slot + 11644473600000000 " |
567 "WHERE id IN (SELECT id FROM segment_usage WHERE time_slot > 0);")); | 580 "WHERE id IN (SELECT id FROM segment_usage WHERE time_slot > 0);")); |
568 } | 581 } |
569 #endif | 582 #endif |
570 | 583 |
571 } // namespace history | 584 } // namespace history |
OLD | NEW |