GCC Code Coverage Report

Directory: cvmfs/
File: cvmfs/sql_impl.h
Date: 2025-10-19 02:35:28
Exec Total Coverage
Lines: 209 240 87.1%
Branches: 211 448 47.1%
Line Branch Exec Source
1 /**
2 * This file is part of the CernVM file system.
3 */
4
5 #ifndef CVMFS_SQL_IMPL_H_
6 #define CVMFS_SQL_IMPL_H_
7
8 #include <fcntl.h>
9
10 #include <cassert>
11 #include <cerrno>
12 #include <string>
13
14 #include "sqlitemem.h"
15 #include "util/logging.h"
16 #include "util/platform.h"
17
18 namespace sqlite {
19
20 template<class DerivedT>
21 15756 Database<DerivedT>::Database(const std::string &filename,
22 const OpenMode open_mode)
23 15756 : database_(filename, this)
24 15756 , read_write_(kOpenReadWrite == open_mode)
25 15756 , schema_version_(0.0f)
26
5/10
✓ Branch 2 taken 15756 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 15756 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 15756 times.
✗ Branch 9 not taken.
✓ Branch 11 taken 15756 times.
✗ Branch 12 not taken.
✓ Branch 14 taken 15756 times.
✗ Branch 15 not taken.
 31512 , schema_revision_(0) { }
27
28
29 template<class DerivedT>
30 8280 DerivedT *Database<DerivedT>::Create(const std::string &filename) {
31
3/6
✓ Branch 1 taken 8280 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 8280 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 4097 times.
✗ Branch 8 not taken.
 8280 UniquePtr<DerivedT> database(new DerivedT(filename, kOpenReadWrite));
32
33
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 8280 times.
 8280 if (!database.IsValid()) {
34 ✗ LogCvmfs(kLogSql, kLogDebug, "Failed to create new database object");
35 ✗ return NULL;
36 }
37
38 8280 database->set_schema_version(DerivedT::kLatestSchema);
39 8280 database->set_schema_revision(DerivedT::kLatestSchemaRevision);
40
41 8280 const int open_flags = SQLITE_OPEN_NOMUTEX | SQLITE_OPEN_READWRITE
42 | SQLITE_OPEN_CREATE;
43
2/4
✓ Branch 2 taken 8280 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 8280 times.
 8280 if (!database->OpenDatabase(open_flags)) {
44 ✗ LogCvmfs(kLogSql, kLogDebug, "Failed to create new database file");
45 ✗ return NULL;
46 }
47
48
2/4
✓ Branch 2 taken 8280 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 8280 times.
 8280 if (!database->CreatePropertiesTable()) {
49 ✗ database->PrintSqlError("Failed to create common properties table");
50 ✗ return NULL;
51 }
52
53
2/4
✓ Branch 2 taken 8280 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 8280 times.
 8280 if (!database->CreateEmptyDatabase()) {
54 ✗ database->PrintSqlError("Failed to create empty database");
55 ✗ return NULL;
56 }
57
58
2/4
✓ Branch 2 taken 8280 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 8280 times.
 8280 if (!database->PrepareCommonQueries()) {
59 ✗ database->PrintSqlError("Failed to initialize properties queries");
60 ✗ return NULL;
61 }
62
63
2/4
✓ Branch 2 taken 8280 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 8280 times.
 8280 if (!database->StoreSchemaRevision()) {
64 ✗ database->PrintSqlError("Failed to store initial schema revision");
65 ✗ return NULL;
66 }
67
68 8280 return database.Release();
69 8280 }
70
71
72 template<class DerivedT>
73 7476 DerivedT *Database<DerivedT>::Open(const std::string &filename,
74 const OpenMode open_mode) {
75
3/6
✓ Branch 1 taken 7476 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 7476 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 5985 times.
✗ Branch 8 not taken.
 7476 UniquePtr<DerivedT> database(new DerivedT(filename, open_mode));
76
77
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 7476 times.
 7476 if (!database.IsValid()) {
78 ✗ LogCvmfs(kLogSql, kLogDebug,
79 "Failed to open database file '%s' - errno: %d", filename.c_str(),
80 ✗ errno);
81 ✗ return NULL;
82 }
83
84
3/4
✓ Branch 2 taken 7476 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 144 times.
✓ Branch 5 taken 7332 times.
 7476 if (!database->Initialize()) {
85 144 return NULL;
86 }
87
88 7332 return database.Release();
89 7476 }
90
91
92 template<class DerivedT>
93 7476 bool Database<DerivedT>::Initialize() {
94
2/2
✓ Branch 0 taken 4344 times.
✓ Branch 1 taken 3132 times.
 7476 const int flags = (read_write_) ? SQLITE_OPEN_NOMUTEX | SQLITE_OPEN_READWRITE
95 : SQLITE_OPEN_NOMUTEX | SQLITE_OPEN_READONLY;
96
97
2/4
✓ Branch 2 taken 7400 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 7400 times.
✗ Branch 6 not taken.
 14876 bool successful = OpenDatabase(flags) && Configure() && FileReadAhead()
98
3/4
✓ Branch 0 taken 7400 times.
✓ Branch 1 taken 76 times.
✓ Branch 3 taken 7400 times.
✗ Branch 4 not taken.
 14876 && PrepareCommonQueries();
99
2/2
✓ Branch 0 taken 76 times.
✓ Branch 1 taken 7400 times.
 7476 if (!successful) {
100 76 LogCvmfs(kLogSql, kLogDebug, "failed to open database file '%s'",
101 76 filename().c_str());
102 76 return false;
103 }
104
105 7400 ReadSchemaRevision();
106 7400 LogCvmfs(kLogSql, kLogDebug,
107 "opened database with schema version %f "
108 "and revision %u",
109 7400 schema_version_, schema_revision_);
110
111
2/2
✓ Branch 1 taken 34 times.
✓ Branch 2 taken 7366 times.
 7400 if (!static_cast<DerivedT *>(this)->CheckSchemaCompatibility()) {
112 68 LogCvmfs(kLogSql, kLogDebug, "schema version %f not supported (%s)",
113 34 schema_version_, filename().c_str());
114 34 return false;
115 }
116
117 14732 if (read_write_
118
6/6
✓ Branch 0 taken 4310 times.
✓ Branch 1 taken 3056 times.
✓ Branch 3 taken 34 times.
✓ Branch 4 taken 4276 times.
✓ Branch 5 taken 34 times.
✓ Branch 6 taken 7332 times.
 7366 && !static_cast<DerivedT *>(this)->LiveSchemaUpgradeIfNecessary()) {
119 34 LogCvmfs(kLogSql, kLogDebug, "failed tp upgrade schema revision");
120 34 return false;
121 }
122
123 7332 return true;
124 }
125
126
127 template<class DerivedT>
128 15756 bool Database<DerivedT>::OpenDatabase(const int flags) {
129 // Open database file (depending on the flags read-only or read-write)
130 15756 LogCvmfs(kLogSql, kLogDebug, "opening database file %s", filename().c_str());
131 15756 int retval = sqlite3_open_v2(filename().c_str(),
132 &database_.sqlite_db,
133 flags | SQLITE_OPEN_EXRESCODE,
134 NULL);
135
2/2
✓ Branch 0 taken 76 times.
✓ Branch 1 taken 15680 times.
 15756 if (retval != SQLITE_OK) {
136 76 LogCvmfs(kLogSql, kLogDebug, "cannot open database file %s (%d - %d)",
137 76 filename().c_str(), retval, errno);
138 76 return false;
139 }
140
141 15680 return true;
142 }
143
144
145 template<class DerivedT>
146 17014 Database<DerivedT>::DatabaseRaiiWrapper::~DatabaseRaiiWrapper() {
147
1/2
✓ Branch 0 taken 15634 times.
✗ Branch 1 not taken.
 17014 if (NULL != sqlite_db) {
148 17014 const bool close_successful = Close();
149
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 15634 times.
 17014 assert(close_successful);
150 }
151 17014 }
152
153
154 template<class DerivedT>
155 17014 bool Database<DerivedT>::DatabaseRaiiWrapper::Close() {
156
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 15634 times.
 17014 assert(NULL != sqlite_db);
157
158
2/2
✓ Branch 0 taken 3370 times.
✓ Branch 1 taken 12264 times.
 34028 LogCvmfs(kLogSql, kLogDebug, "closing SQLite database '%s' (unlink: %s)",
159 34028 filename().c_str(), (db_file_guard.IsEnabled() ? "yes" : "no"));
160 17014 const int result = sqlite3_close(sqlite_db);
161
162
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 15634 times.
 17014 if (result != SQLITE_OK) {
163 ✗ LogCvmfs(kLogSql, kLogDebug,
164 "failed to close SQLite database '%s' (%d - %s)",
165 ✗ filename().c_str(), result, delegate_->GetLastErrorMsg().c_str());
166 ✗ return false;
167 }
168
169 17014 sqlite_db = NULL;
170
2/2
✓ Branch 0 taken 1219 times.
✓ Branch 1 taken 14415 times.
 17014 if (lookaside_buffer != NULL) {
171 1219 SqliteMemoryManager::GetInstance()->ReleaseLookasideBuffer(
172 lookaside_buffer);
173 1219 lookaside_buffer = NULL;
174 }
175 17014 return true;
176 }
177
178
179 template<class DerivedT>
180 7400 bool Database<DerivedT>::Configure() {
181 // Read-only databases should store temporary files in memory. This avoids
182 // unexpected open read-write file descriptors in the cache directory like
183 // etilqs_<number>. They also use the optimized memory manager, if it is
184 // available.
185
2/2
✓ Branch 0 taken 3056 times.
✓ Branch 1 taken 4344 times.
 7400 if (!read_write_) {
186
2/2
✓ Branch 1 taken 1219 times.
✓ Branch 2 taken 1837 times.
 3056 if (SqliteMemoryManager::HasInstance()) {
187 1219 database_.lookaside_buffer = SqliteMemoryManager::GetInstance()
188 1219 ->AssignLookasideBuffer(sqlite_db());
189 }
190
191
5/16
✓ Branch 1 taken 3056 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 3056 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 3056 times.
✗ Branch 8 not taken.
✓ Branch 10 taken 3056 times.
✗ Branch 11 not taken.
✓ Branch 13 taken 3056 times.
✗ Branch 14 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 22 not taken.
✗ Branch 23 not taken.
 6112 return Sql(sqlite_db(), "PRAGMA temp_store=2;").Execute()
192
11/29
✓ Branch 2 taken 3056 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 3056 times.
✗ Branch 5 not taken.
✓ Branch 8 taken 3056 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 3056 times.
✗ Branch 12 not taken.
✓ Branch 14 taken 3056 times.
✗ Branch 15 not taken.
✓ Branch 17 taken 3056 times.
✗ Branch 18 not taken.
✓ Branch 19 taken 3056 times.
✗ Branch 20 not taken.
✓ Branch 21 taken 3056 times.
✗ Branch 22 not taken.
✓ Branch 24 taken 3056 times.
✗ Branch 25 not taken.
✓ Branch 27 taken 3056 times.
✗ Branch 28 not taken.
✓ Branch 30 taken 3056 times.
✗ Branch 31 not taken.
✗ Branch 32 not taken.
✗ Branch 33 not taken.
✗ Branch 35 not taken.
✗ Branch 36 not taken.
✗ Branch 38 not taken.
✗ Branch 39 not taken.
 6112 && Sql(sqlite_db(), "PRAGMA locking_mode=EXCLUSIVE;").Execute();
193 }
194 4344 return true;
195 }
196
197
198 template<class DerivedT>
199 7400 bool Database<DerivedT>::FileReadAhead() {
200 // Read-ahead into file system buffers
201 // TODO(jblomer): mmap, re-readahead
202
1/2
✗ Branch 2 not taken.
✓ Branch 3 taken 7400 times.
 7400 assert(filename().length() > 1);
203 int fd_readahead;
204
2/2
✓ Branch 2 taken 6181 times.
✓ Branch 3 taken 1219 times.
 7400 if (filename()[0] != '@') {
205 6181 fd_readahead = open(filename().c_str(), O_RDONLY);
206
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 6181 times.
 6181 if (fd_readahead < 0) {
207 ✗ LogCvmfs(kLogSql, kLogDebug, "failed to open %s for read-ahead (%d)",
208 ✗ filename().c_str(), errno);
209 ✗ return false;
210 }
211 6181 const ssize_t retval = platform_readahead(fd_readahead);
212 6181 close(fd_readahead);
213
214 // Read-ahead is known to fail on tmpfs with EINVAL
215 // EINVAL = "readahead() cannot be applied to that a file type"
216 // It can also fail with ENOSYS on kernel interfaces that do not implement
217 // readahead(), such as LX-Brand zones on illumos.
218 // Don't consider either a fatal error.
219
2/6
✓ Branch 0 taken 6181 times.
✗ Branch 1 not taken.
✗ Branch 2 not taken.
✓ Branch 3 taken 6181 times.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
 6181 if (retval != 0 && errno != EINVAL && errno != ENOSYS) {
220 ✗ LogCvmfs(kLogSql, kLogDebug | kLogSyslogWarn,
221 "failed to read-ahead %s: invalid file descrp. or not open for "
222 "reading (%d)",
223 ✗ filename().c_str(), errno);
224 ✗ return false;
225 }
226 }
227
228 7400 return true;
229 }
230
231
232 template<class DerivedT>
233 15680 bool Database<DerivedT>::PrepareCommonQueries() {
234 15680 sqlite3 *db = sqlite_db();
235
4/8
✓ Branch 2 taken 15680 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 15680 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 15680 times.
✗ Branch 9 not taken.
✓ Branch 11 taken 15680 times.
✗ Branch 12 not taken.
 15680 begin_transaction_ = new Sql(db, "BEGIN;");
236
4/8
✓ Branch 2 taken 15680 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 15680 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 15680 times.
✗ Branch 9 not taken.
✓ Branch 11 taken 15680 times.
✗ Branch 12 not taken.
 15680 commit_transaction_ = new Sql(db, "COMMIT;");
237
4/8
✓ Branch 2 taken 15680 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 15680 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 15680 times.
✗ Branch 9 not taken.
✓ Branch 11 taken 15680 times.
✗ Branch 12 not taken.
 15680 has_property_ = new Sql(db, "SELECT count(*) FROM properties "
238 "WHERE key = :key;");
239
4/8
✓ Branch 2 taken 15680 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 15680 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 15680 times.
✗ Branch 9 not taken.
✓ Branch 11 taken 15680 times.
✗ Branch 12 not taken.
 15680 get_property_ = new Sql(db, "SELECT value FROM properties "
240 "WHERE key = :key;");
241
4/8
✓ Branch 2 taken 15680 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 15680 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 15680 times.
✗ Branch 9 not taken.
✓ Branch 11 taken 15680 times.
✗ Branch 12 not taken.
 15680 set_property_ = new Sql(db, "INSERT OR REPLACE INTO properties "
242 "(key, value) VALUES (:key, :value);");
243
1/2
✓ Branch 2 taken 15680 times.
✗ Branch 3 not taken.
 31360 return (begin_transaction_.IsValid() && commit_transaction_.IsValid()
244
2/4
✓ Branch 1 taken 15680 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 15680 times.
✗ Branch 5 not taken.
 15680 && has_property_.IsValid() && get_property_.IsValid()
245
2/4
✓ Branch 0 taken 15680 times.
✗ Branch 1 not taken.
✓ Branch 3 taken 15680 times.
✗ Branch 4 not taken.
 31360 && set_property_.IsValid());
246 }
247
248
249 template<class DerivedT>
250 7400 void Database<DerivedT>::ReadSchemaRevision() {
251
2/4
✓ Branch 2 taken 7400 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 7400 times.
✗ Branch 6 not taken.
 14800 schema_version_ = (this->HasProperty(kSchemaVersionKey))
252
5/15
✓ Branch 0 taken 7400 times.
✗ Branch 1 not taken.
✓ Branch 4 taken 7400 times.
✗ Branch 5 not taken.
✗ Branch 6 not taken.
✓ Branch 7 taken 7400 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 7400 times.
✗ Branch 10 not taken.
✓ Branch 12 taken 7400 times.
✗ Branch 13 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
 7400 ? this->GetProperty<double>(kSchemaVersionKey)
253 : 1.0;
254
2/4
✓ Branch 2 taken 7400 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 7400 times.
✗ Branch 6 not taken.
 14800 schema_revision_ = (this->HasProperty(kSchemaRevisionKey))
255
8/15
✓ Branch 0 taken 7223 times.
✓ Branch 1 taken 177 times.
✓ Branch 4 taken 7223 times.
✗ Branch 5 not taken.
✗ Branch 6 not taken.
✓ Branch 7 taken 7223 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 7223 times.
✓ Branch 10 taken 177 times.
✓ Branch 12 taken 7223 times.
✓ Branch 13 taken 177 times.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
 7400 ? this->GetProperty<int>(kSchemaRevisionKey)
256 : 0;
257 7400 }
258
259
260 template<class DerivedT>
261 8907 bool Database<DerivedT>::StoreSchemaRevision() {
262
2/9
✓ Branch 1 taken 8907 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 8907 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
 17814 return this->SetProperty(kSchemaVersionKey, schema_version_)
263
8/22
✓ Branch 2 taken 8907 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 8907 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 8907 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 8907 times.
✗ Branch 12 not taken.
✓ Branch 13 taken 8907 times.
✗ Branch 14 not taken.
✓ Branch 15 taken 8907 times.
✗ Branch 16 not taken.
✓ Branch 18 taken 8907 times.
✗ Branch 19 not taken.
✓ Branch 21 taken 8907 times.
✗ Branch 22 not taken.
✗ Branch 23 not taken.
✗ Branch 24 not taken.
✗ Branch 26 not taken.
✗ Branch 27 not taken.
 26721 && this->SetProperty(kSchemaRevisionKey, schema_revision_);
264 }
265
266
267 template<class DerivedT>
268 7424 bool Database<DerivedT>::BeginTransaction() const {
269
3/4
✓ Branch 2 taken 7304 times.
✓ Branch 3 taken 120 times.
✓ Branch 6 taken 7304 times.
✗ Branch 7 not taken.
 7424 return begin_transaction_->Execute() && begin_transaction_->Reset();
270 }
271
272
273 template<class DerivedT>
274 7026 bool Database<DerivedT>::CommitTransaction() const {
275
2/4
✓ Branch 2 taken 7026 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 7026 times.
✗ Branch 7 not taken.
 7026 return commit_transaction_->Execute() && commit_transaction_->Reset();
276 }
277
278
279 template<class DerivedT>
280 8280 bool Database<DerivedT>::CreatePropertiesTable() {
281
3/6
✓ Branch 2 taken 8280 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 8280 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 8280 times.
✗ Branch 9 not taken.
 16560 return Sql(sqlite_db(),
282 "CREATE TABLE properties (key TEXT, value TEXT, "
283 "CONSTRAINT pk_properties PRIMARY KEY (key));")
284
1/2
✓ Branch 1 taken 8280 times.
✗ Branch 2 not taken.
 16560 .Execute();
285 }
286
287
288 template<class DerivedT>
289 36103 bool Database<DerivedT>::HasProperty(const std::string &key) const {
290
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 36103 times.
 36103 assert(has_property_.IsValid());
291 36103 const bool retval = has_property_->BindText(1, key)
292
2/4
✓ Branch 0 taken 36103 times.
✗ Branch 1 not taken.
✓ Branch 4 taken 36103 times.
✗ Branch 5 not taken.
 36103 && has_property_->FetchRow();
293
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 36103 times.
 36103 assert(retval);
294 36103 const bool result = has_property_->RetrieveInt64(0) > 0;
295 36103 has_property_->Reset();
296 36103 return result;
297 }
298
299 template<class DerivedT>
300 template<typename T>
301 52038 T Database<DerivedT>::GetProperty(const std::string &key) const {
302
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 26019 times.
 52038 assert(get_property_.IsValid());
303 52038 const bool retval = get_property_->BindText(1, key)
304
2/4
✓ Branch 0 taken 26019 times.
✗ Branch 1 not taken.
✓ Branch 4 taken 26019 times.
✗ Branch 5 not taken.
 52038 && get_property_->FetchRow();
305
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 26019 times.
 52038 assert(retval);
306 52038 const T result = get_property_->Retrieve<T>(0);
307
1/2
✓ Branch 2 taken 4510 times.
✗ Branch 3 not taken.
 52038 get_property_->Reset();
308 52038 return result;
309 }
310
311 template<class DerivedT>
312 template<typename T>
313 20818 T Database<DerivedT>::GetPropertyDefault(const std::string &key,
314 const T default_value) const {
315
2/2
✓ Branch 1 taken 4616 times.
✓ Branch 2 taken 5793 times.
 20818 return (HasProperty(key)) ? GetProperty<T>(key) : default_value;
316 }
317
318 template<class DerivedT>
319 template<typename T>
320 81510 bool Database<DerivedT>::SetProperty(const std::string &key, const T value) {
321
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 41287 times.
 81510 assert(set_property_.IsValid());
322
1/2
✓ Branch 4 taken 41287 times.
✗ Branch 5 not taken.
 163020 return set_property_->BindText(1, key) && set_property_->Bind(2, value)
323
3/6
✓ Branch 0 taken 41287 times.
✗ Branch 1 not taken.
✓ Branch 4 taken 41287 times.
✗ Branch 5 not taken.
✓ Branch 8 taken 41287 times.
✗ Branch 9 not taken.
 163020 && set_property_->Execute() && set_property_->Reset();
324 }
325
326 template<class DerivedT>
327 ✗ std::string Database<DerivedT>::GetLastErrorMsg() const {
328 ✗ std::string msg = sqlite3_errmsg(sqlite_db());
329 ✗ return msg;
330 }
331
332
333 template<class DerivedT>
334 3513 void Database<DerivedT>::TakeFileOwnership() {
335 3513 database_.TakeFileOwnership();
336 3513 LogCvmfs(kLogSql, kLogDebug, "Database object took ownership of '%s'",
337 3513 database_.filename().c_str());
338 3513 }
339
340
341 template<class DerivedT>
342 140 void Database<DerivedT>::DropFileOwnership() {
343 140 database_.DropFileOwnership();
344 140 LogCvmfs(kLogSql, kLogDebug, "Database object dropped ownership of '%s'",
345 140 database_.filename().c_str());
346 140 }
347
348
349 template<class DerivedT>
350 374 unsigned Database<DerivedT>::GetModifiedRowCount() const {
351 374 const int modified_rows = sqlite3_total_changes(sqlite_db());
352
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 374 times.
 374 assert(modified_rows >= 0);
353 374 return static_cast<unsigned>(modified_rows);
354 }
355
356 /**
357 * Ask SQlite for per-connection memory statistics
358 */
359 template<class DerivedT>
360 38 void Database<DerivedT>::GetMemStatistics(MemStatistics *stats) const {
361 38 const int reset = 0;
362 int current;
363 int highwater;
364 38 int retval = SQLITE_OK;
365
2/4
✓ Branch 1 taken 38 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 38 times.
✗ Branch 5 not taken.
 38 retval |= sqlite3_db_status(sqlite_db(), SQLITE_DBSTATUS_LOOKASIDE_USED,
366 &current, &highwater, reset);
367 38 stats->lookaside_slots_used = current;
368 38 stats->lookaside_slots_max = highwater;
369
2/4
✓ Branch 1 taken 38 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 38 times.
✗ Branch 5 not taken.
 38 retval |= sqlite3_db_status(sqlite_db(), SQLITE_DBSTATUS_LOOKASIDE_HIT,
370 &current, &highwater, reset);
371 38 stats->lookaside_hit = highwater;
372
2/4
✓ Branch 1 taken 38 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 38 times.
✗ Branch 5 not taken.
 38 retval |= sqlite3_db_status(sqlite_db(), SQLITE_DBSTATUS_LOOKASIDE_MISS_SIZE,
373 &current, &highwater, reset);
374 38 stats->lookaside_miss_size = highwater;
375
2/4
✓ Branch 1 taken 38 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 38 times.
✗ Branch 5 not taken.
 38 retval |= sqlite3_db_status(sqlite_db(), SQLITE_DBSTATUS_LOOKASIDE_MISS_FULL,
376 &current, &highwater, reset);
377 38 stats->lookaside_miss_full = highwater;
378
2/4
✓ Branch 1 taken 38 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 38 times.
✗ Branch 5 not taken.
 38 retval |= sqlite3_db_status(sqlite_db(), SQLITE_DBSTATUS_CACHE_USED, &current,
379 &highwater, reset);
380 38 stats->page_cache_used = current;
381
2/4
✓ Branch 1 taken 38 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 38 times.
✗ Branch 5 not taken.
 38 retval |= sqlite3_db_status(sqlite_db(), SQLITE_DBSTATUS_CACHE_HIT, &current,
382 &highwater, reset);
383 38 stats->page_cache_hit = current;
384
2/4
✓ Branch 1 taken 38 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 38 times.
✗ Branch 5 not taken.
 38 retval |= sqlite3_db_status(sqlite_db(), SQLITE_DBSTATUS_CACHE_MISS, &current,
385 &highwater, reset);
386 38 stats->page_cache_miss = current;
387
2/4
✓ Branch 1 taken 38 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 38 times.
✗ Branch 5 not taken.
 38 retval |= sqlite3_db_status(sqlite_db(), SQLITE_DBSTATUS_SCHEMA_USED,
388 &current, &highwater, reset);
389 38 stats->schema_used = current;
390
2/4
✓ Branch 1 taken 38 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 38 times.
✗ Branch 5 not taken.
 38 retval |= sqlite3_db_status(sqlite_db(), SQLITE_DBSTATUS_STMT_USED, &current,
391 &highwater, reset);
392 38 stats->stmt_used = current;
393
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 38 times.
 38 assert(retval == SQLITE_OK);
394 38 }
395
396
397 template<class DerivedT>
398 1975 double Database<DerivedT>::GetFreePageRatio() const {
399
3/6
✓ Branch 2 taken 1975 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 1975 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 1975 times.
✗ Branch 9 not taken.
 3950 Sql free_page_count_query(this->sqlite_db(), "PRAGMA freelist_count;");
400
3/6
✓ Branch 2 taken 1975 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 1975 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 1975 times.
✗ Branch 9 not taken.
 3950 Sql page_count_query(this->sqlite_db(), "PRAGMA page_count;");
401
402
1/2
✓ Branch 1 taken 1975 times.
✗ Branch 2 not taken.
 1975 const bool retval = page_count_query.FetchRow()
403
3/6
✓ Branch 0 taken 1975 times.
✗ Branch 1 not taken.
✓ Branch 3 taken 1975 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 1975 times.
✗ Branch 6 not taken.
 1975 && free_page_count_query.FetchRow();
404
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1975 times.
 1975 assert(retval);
405
406
1/2
✓ Branch 1 taken 1975 times.
✗ Branch 2 not taken.
 1975 const int64_t pages = page_count_query.RetrieveInt64(0);
407
1/2
✓ Branch 1 taken 1975 times.
✗ Branch 2 not taken.
 1975 const int64_t free_pages = free_page_count_query.RetrieveInt64(0);
408
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1975 times.
 1975 assert(pages > 0);
409
410 1975 return (static_cast<double>(free_pages) / static_cast<double>(pages));
411 1975 }
412
413
414 template<class DerivedT>
415 621 bool Database<DerivedT>::Vacuum() const {
416
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 621 times.
 621 assert(read_write_);
417 1038 return static_cast<const DerivedT *>(this)->CompactDatabase()
418
20/36
✓ Branch 1 taken 587 times.
✓ Branch 2 taken 34 times.
✓ Branch 3 taken 417 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 170 times.
✗ Branch 6 not taken.
✓ Branch 7 taken 417 times.
✓ Branch 8 taken 170 times.
✗ Branch 9 not taken.
✓ Branch 10 taken 417 times.
✓ Branch 11 taken 170 times.
✗ Branch 12 not taken.
✓ Branch 13 taken 417 times.
✓ Branch 14 taken 170 times.
✗ Branch 15 not taken.
✓ Branch 16 taken 587 times.
✗ Branch 17 not taken.
✓ Branch 18 taken 587 times.
✓ Branch 19 taken 34 times.
✓ Branch 20 taken 417 times.
✓ Branch 21 taken 170 times.
✓ Branch 22 taken 34 times.
✓ Branch 23 taken 417 times.
✓ Branch 24 taken 170 times.
✓ Branch 25 taken 34 times.
✓ Branch 26 taken 417 times.
✗ Branch 27 not taken.
✗ Branch 28 not taken.
✗ Branch 29 not taken.
✗ Branch 30 not taken.
✗ Branch 31 not taken.
✗ Branch 32 not taken.
✗ Branch 33 not taken.
✗ Branch 34 not taken.
✗ Branch 35 not taken.
✗ Branch 36 not taken.
 621 && Sql(this->sqlite_db(), "VACUUM;").Execute();
419 }
420
421
422 template<class DerivedT>
423 ✗ void Database<DerivedT>::PrintSqlError(const std::string &error_msg) {
424 ✗ LogCvmfs(kLogSql, kLogStderr, "%s\nSQLite said: '%s'", error_msg.c_str(),
425 this->GetLastErrorMsg().c_str());
426 }
427
428 template<class DerivedT>
429 const float Database<DerivedT>::kSchemaEpsilon = 0.0005;
430 template<class DerivedT>
431 const char *Database<DerivedT>::kSchemaVersionKey = "schema";
432 template<class DerivedT>
433 const char *Database<DerivedT>::kSchemaRevisionKey = "schema_revision";
434
435
436 //
437 // # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # #
438 //
439
440
441 template<>
442 3606 inline bool Sql::Bind(const int index, const int &value) {
443 3606 return this->BindInt64(index, value);
444 }
445
446 template<>
447 9627 inline bool Sql::Bind(const int index, const unsigned int &value) {
448 9627 return this->BindInt64(index, static_cast<int>(value));
449 }
450
451 template<>
452 10202 inline bool Sql::Bind(const int index, const uint64_t &value) {
453 10202 return this->BindInt64(index, static_cast<int64_t>(value));
454 }
455
456 template<>
457 inline bool Sql::Bind(const int index, const sqlite3_int64 &value) {
458 return this->BindInt64(index, value);
459 }
460
461 template<>
462 8809 inline bool Sql::Bind(const int index, const std::string &value) {
463 8809 return this->BindTextTransient(index, value);
464 }
465
466 template<>
467 8907 inline bool Sql::Bind(const int index, const float &value) {
468 8907 return this->BindDouble(index, value);
469 }
470
471 template<>
472 136 inline bool Sql::Bind(const int index, const double &value) {
473 136 return this->BindDouble(index, value);
474 }
475
476
477 template<>
478 9497 inline int Sql::Retrieve(const int index) {
479 9497 return static_cast<int>(this->RetrieveInt64(index));
480 }
481
482 template<>
483 ✗ inline bool Sql::Retrieve(const int index) {
484 ✗ return static_cast<bool>(this->RetrieveInt(index));
485 }
486
487 template<>
488 inline sqlite3_int64 Sql::Retrieve(const int index) {
489 return this->RetrieveInt64(index);
490 }
491
492 template<>
493 4374 inline uint64_t Sql::Retrieve(const int index) {
494 4374 return static_cast<uint64_t>(this->RetrieveInt64(index));
495 }
496
497 template<>
498 5530 inline std::string Sql::Retrieve(const int index) {
499 5530 return RetrieveString(index);
500 }
501
502 template<>
503 136 inline float Sql::Retrieve(const int index) {
504 136 return static_cast<float>(this->RetrieveDouble(index));
505 }
506
507 template<>
508 7536 inline double Sql::Retrieve(const int index) {
509 7536 return this->RetrieveDouble(index);
510 }
511
512 } // namespace sqlite
513
514 #endif // CVMFS_SQL_IMPL_H_
515