1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
|
// Copyright (c) 2009 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 <algorithm>
#include <string>
#include "app/sql/statement.h"
#include "app/sql/transaction.h"
#include "base/string_util.h"
#include "chrome/browser/history/archived_database.h"
namespace history {
namespace {
static const int kCurrentVersionNumber = 2;
static const int kCompatibleVersionNumber = 2;
} // namespace
ArchivedDatabase::ArchivedDatabase() {
}
ArchivedDatabase::~ArchivedDatabase() {
}
bool ArchivedDatabase::Init(const FilePath& file_name) {
// Set the database page size to something a little larger to give us
// better performance (we're typically seek rather than bandwidth limited).
// This only has an effect before any tables have been created, otherwise
// this is a NOP. Must be a power of 2 and a max of 8192.
db_.set_page_size(4096);
// Don't use very much memory caching this database. We seldom use it for
// anything important.
db_.set_cache_size(64);
// Run the database in exclusive mode. Nobody else should be accessing the
// database while we're running, and this will give somewhat improved perf.
db_.set_exclusive_locking();
if (!db_.Open(file_name))
return false;
sql::Transaction transaction(&db_);
if (!transaction.Begin()) {
db_.Close();
return false;
}
// Version check.
if (!meta_table_.Init(&db_, kCurrentVersionNumber,
kCompatibleVersionNumber)) {
db_.Close();
return false;
}
// Create the tables.
if (!CreateURLTable(false) || !InitVisitTable() ||
!InitKeywordSearchTermsTable()) {
db_.Close();
return false;
}
CreateMainURLIndex();
if (EnsureCurrentVersion() != INIT_OK) {
db_.Close();
return false;
}
return transaction.Commit();
}
void ArchivedDatabase::BeginTransaction() {
db_.BeginTransaction();
}
void ArchivedDatabase::CommitTransaction() {
db_.CommitTransaction();
}
sql::Connection& ArchivedDatabase::GetDB() {
return db_;
}
// Migration -------------------------------------------------------------------
InitStatus ArchivedDatabase::EnsureCurrentVersion() {
// We can't read databases newer than we were designed for.
if (meta_table_.GetCompatibleVersionNumber() > kCurrentVersionNumber) {
LOG(WARNING) << "Archived database is too new.";
return INIT_TOO_NEW;
}
// NOTICE: If you are changing structures for things shared with the archived
// history file like URLs, visits, or downloads, that will need migration as
// well. Instead of putting such migration code in this class, it should be
// in the corresponding file (url_database.cc, etc.) and called from here and
// from the archived_database.cc.
int cur_version = meta_table_.GetVersionNumber();
if (cur_version == 1) {
if (!DropStarredIDFromURLs()) {
LOG(WARNING) << "Unable to update archived database to version 2.";
return INIT_FAILURE;
}
++cur_version;
meta_table_.SetVersionNumber(cur_version);
meta_table_.SetCompatibleVersionNumber(
std::min(cur_version, kCompatibleVersionNumber));
}
// Put future migration cases here.
// When the version is too old, we just try to continue anyway, there should
// not be a released product that makes a database too old for us to handle.
LOG_IF(WARNING, cur_version < kCurrentVersionNumber) <<
"Archived database version " << cur_version << " is too old to handle.";
return INIT_OK;
}
} // namespace history
|
