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 "webkit/database/databases_table.h" | 5 #include "webkit/database/databases_table.h" |
6 | 6 |
7 #include "base/logging.h" | 7 #include "base/logging.h" |
8 #include "base/utf_string_conversions.h" | 8 #include "base/utf_string_conversions.h" |
9 #include "sql/statement.h" | 9 #include "sql/statement.h" |
10 | 10 |
(...skipping 19 matching lines...) Expand all Loading... |
30 "origin TEXT NOT NULL, " | 30 "origin TEXT NOT NULL, " |
31 "name TEXT NOT NULL, " | 31 "name TEXT NOT NULL, " |
32 "description TEXT NOT NULL, " | 32 "description TEXT NOT NULL, " |
33 "estimated_size INTEGER NOT NULL)") && | 33 "estimated_size INTEGER NOT NULL)") && |
34 db_->Execute( | 34 db_->Execute( |
35 "CREATE INDEX origin_index ON Databases (origin)") && | 35 "CREATE INDEX origin_index ON Databases (origin)") && |
36 db_->Execute( | 36 db_->Execute( |
37 "CREATE UNIQUE INDEX unique_index ON Databases (origin, name)")); | 37 "CREATE UNIQUE INDEX unique_index ON Databases (origin, name)")); |
38 } | 38 } |
39 | 39 |
40 int64 DatabasesTable::GetDatabaseID(const string16& origin_identifier, | 40 int64 DatabasesTable::GetDatabaseID(const base::string16& origin_identifier, |
41 const string16& database_name) { | 41 const base::string16& database_name) { |
42 sql::Statement select_statement(db_->GetCachedStatement( | 42 sql::Statement select_statement(db_->GetCachedStatement( |
43 SQL_FROM_HERE, "SELECT id FROM Databases WHERE origin = ? AND name = ?")); | 43 SQL_FROM_HERE, "SELECT id FROM Databases WHERE origin = ? AND name = ?")); |
44 select_statement.BindString16(0, origin_identifier); | 44 select_statement.BindString16(0, origin_identifier); |
45 select_statement.BindString16(1, database_name); | 45 select_statement.BindString16(1, database_name); |
46 | 46 |
47 if (select_statement.Step()) { | 47 if (select_statement.Step()) { |
48 return select_statement.ColumnInt64(0); | 48 return select_statement.ColumnInt64(0); |
49 } | 49 } |
50 | 50 |
51 return -1; | 51 return -1; |
52 } | 52 } |
53 | 53 |
54 bool DatabasesTable::GetDatabaseDetails(const string16& origin_identifier, | 54 bool DatabasesTable::GetDatabaseDetails(const base::string16& origin_identifier, |
55 const string16& database_name, | 55 const base::string16& database_name, |
56 DatabaseDetails* details) { | 56 DatabaseDetails* details) { |
57 DCHECK(details); | 57 DCHECK(details); |
58 sql::Statement select_statement(db_->GetCachedStatement( | 58 sql::Statement select_statement(db_->GetCachedStatement( |
59 SQL_FROM_HERE, "SELECT description, estimated_size FROM Databases " | 59 SQL_FROM_HERE, "SELECT description, estimated_size FROM Databases " |
60 "WHERE origin = ? AND name = ?")); | 60 "WHERE origin = ? AND name = ?")); |
61 select_statement.BindString16(0, origin_identifier); | 61 select_statement.BindString16(0, origin_identifier); |
62 select_statement.BindString16(1, database_name); | 62 select_statement.BindString16(1, database_name); |
63 | 63 |
64 if (select_statement.Step()) { | 64 if (select_statement.Step()) { |
65 details->origin_identifier = origin_identifier; | 65 details->origin_identifier = origin_identifier; |
(...skipping 23 matching lines...) Expand all Loading... |
89 SQL_FROM_HERE, "UPDATE Databases SET description = ?, " | 89 SQL_FROM_HERE, "UPDATE Databases SET description = ?, " |
90 "estimated_size = ? WHERE origin = ? AND name = ?")); | 90 "estimated_size = ? WHERE origin = ? AND name = ?")); |
91 update_statement.BindString16(0, details.description); | 91 update_statement.BindString16(0, details.description); |
92 update_statement.BindInt64(1, details.estimated_size); | 92 update_statement.BindInt64(1, details.estimated_size); |
93 update_statement.BindString16(2, details.origin_identifier); | 93 update_statement.BindString16(2, details.origin_identifier); |
94 update_statement.BindString16(3, details.database_name); | 94 update_statement.BindString16(3, details.database_name); |
95 | 95 |
96 return (update_statement.Run() && db_->GetLastChangeCount()); | 96 return (update_statement.Run() && db_->GetLastChangeCount()); |
97 } | 97 } |
98 | 98 |
99 bool DatabasesTable::DeleteDatabaseDetails(const string16& origin_identifier, | 99 bool DatabasesTable::DeleteDatabaseDetails( |
100 const string16& database_name) { | 100 const base::string16& origin_identifier, |
| 101 const base::string16& database_name) { |
101 sql::Statement delete_statement(db_->GetCachedStatement( | 102 sql::Statement delete_statement(db_->GetCachedStatement( |
102 SQL_FROM_HERE, "DELETE FROM Databases WHERE origin = ? AND name = ?")); | 103 SQL_FROM_HERE, "DELETE FROM Databases WHERE origin = ? AND name = ?")); |
103 delete_statement.BindString16(0, origin_identifier); | 104 delete_statement.BindString16(0, origin_identifier); |
104 delete_statement.BindString16(1, database_name); | 105 delete_statement.BindString16(1, database_name); |
105 | 106 |
106 return (delete_statement.Run() && db_->GetLastChangeCount()); | 107 return (delete_statement.Run() && db_->GetLastChangeCount()); |
107 } | 108 } |
108 | 109 |
109 bool DatabasesTable::GetAllOrigins(std::vector<string16>* origins) { | 110 bool DatabasesTable::GetAllOrigins(std::vector<base::string16>* origins) { |
110 sql::Statement statement(db_->GetCachedStatement( | 111 sql::Statement statement(db_->GetCachedStatement( |
111 SQL_FROM_HERE, "SELECT DISTINCT origin FROM Databases ORDER BY origin")); | 112 SQL_FROM_HERE, "SELECT DISTINCT origin FROM Databases ORDER BY origin")); |
112 | 113 |
113 while (statement.Step()) | 114 while (statement.Step()) |
114 origins->push_back(statement.ColumnString16(0)); | 115 origins->push_back(statement.ColumnString16(0)); |
115 | 116 |
116 return statement.Succeeded(); | 117 return statement.Succeeded(); |
117 } | 118 } |
118 | 119 |
119 bool DatabasesTable::GetAllDatabaseDetailsForOrigin( | 120 bool DatabasesTable::GetAllDatabaseDetailsForOrigin( |
120 const string16& origin_identifier, | 121 const base::string16& origin_identifier, |
121 std::vector<DatabaseDetails>* details_vector) { | 122 std::vector<DatabaseDetails>* details_vector) { |
122 sql::Statement statement(db_->GetCachedStatement( | 123 sql::Statement statement(db_->GetCachedStatement( |
123 SQL_FROM_HERE, "SELECT name, description, estimated_size " | 124 SQL_FROM_HERE, "SELECT name, description, estimated_size " |
124 "FROM Databases WHERE origin = ? ORDER BY name")); | 125 "FROM Databases WHERE origin = ? ORDER BY name")); |
125 statement.BindString16(0, origin_identifier); | 126 statement.BindString16(0, origin_identifier); |
126 | 127 |
127 while (statement.Step()) { | 128 while (statement.Step()) { |
128 DatabaseDetails details; | 129 DatabaseDetails details; |
129 details.origin_identifier = origin_identifier; | 130 details.origin_identifier = origin_identifier; |
130 details.database_name = statement.ColumnString16(0); | 131 details.database_name = statement.ColumnString16(0); |
131 details.description = statement.ColumnString16(1); | 132 details.description = statement.ColumnString16(1); |
132 details.estimated_size = statement.ColumnInt64(2); | 133 details.estimated_size = statement.ColumnInt64(2); |
133 details_vector->push_back(details); | 134 details_vector->push_back(details); |
134 } | 135 } |
135 | 136 |
136 return statement.Succeeded(); | 137 return statement.Succeeded(); |
137 } | 138 } |
138 | 139 |
139 bool DatabasesTable::DeleteOrigin(const string16& origin_identifier) { | 140 bool DatabasesTable::DeleteOrigin(const base::string16& origin_identifier) { |
140 sql::Statement delete_statement(db_->GetCachedStatement( | 141 sql::Statement delete_statement(db_->GetCachedStatement( |
141 SQL_FROM_HERE, "DELETE FROM Databases WHERE origin = ?")); | 142 SQL_FROM_HERE, "DELETE FROM Databases WHERE origin = ?")); |
142 delete_statement.BindString16(0, origin_identifier); | 143 delete_statement.BindString16(0, origin_identifier); |
143 | 144 |
144 return (delete_statement.Run() && db_->GetLastChangeCount()); | 145 return (delete_statement.Run() && db_->GetLastChangeCount()); |
145 } | 146 } |
146 | 147 |
147 } // namespace webkit_database | 148 } // namespace webkit_database |
OLD | NEW |